Metric pusher
The library supports pushing to the following interfaces:
- InfluxDb via HTTP API
- InfluxDb via UDP plugin
Installation
Using Composer:
composer require calltouch/metric-pusher
Usage
InfluxDb via HTTP API
use Calltouch\MetricPusher\MetricData\{Metric, Tag, TagCollection, Data, DataCollection};
use Calltouch\MetricPusher\Pusher\InfluxDbHttpApiPusher;
use Calltouch\MetricPusher\Collector;
$url = 'http://127.0.0.1:8086';
$db = 'database1';
// optional params
$params = [
'user' => 'user1', // influx user
'password' => 'password', // influx password
'timeout' => 100, // request max timeout in milliseconds
];
$pusher = new InfluxDbHttpApiPusher($url, $db, $params);
$collector = new Collector($pusher);
$tags = new TagCollection;
$tags->add(new Tag('host', gethostname()));
$data = new DataCollection;
$data->add(new Data('value', rand(0, 100)));
$metric = new Metric('metric_name1', $data, $tags);
$collector->sendMetrics([$metric]);
InfluxDb via UDP plugin
use Calltouch\MetricPusher\MetricData\{Metric, Tag, TagCollection, Data, DataCollection};
use Calltouch\MetricPusher\Pusher\InfluxDbUdpPusher;
use Calltouch\MetricPusher\Collector;
$host = '127.0.0.1';
$port = '8089';
$pusher = new InfluxDbUdpPusher($host, $port);
$collector = new Collector($pusher);
$tags = new TagCollection;
$tags->add(new Tag('host', gethostname()));
$data = new DataCollection;
$data->add(new Data('value', rand(0, 100)));
$metric = new Metric('metric_name2', $data, $tags);
$collector->sendMetrics([$metric]);