calltouch/metric-pusher

The library provides unified way to push metrics to different storages

Metric pusher

, _(*1)

The library supports pushing to the following interfaces: - InfluxDb via HTTP API - InfluxDb via UDP plugin, _(*2)

Installation

Using Composer:, _(*3)

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]);