InfluxDB\Adapter\Udp\Writer

Complexity

Total Complexity

4

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getOptions()	0	4	1
A	send()	0	6	1
A	write()	0	15	1

<?php
namespace InfluxDB\Adapter\Udp;

use InfluxDB\Adapter\WriterTrait;
use InfluxDB\Adapter\Udp\Options;
use InfluxDB\Adapter\WritableInterface;

class Writer implements WritableInterface
{
    use WriterTrait;

    private $options;

    public function __construct(Options $options)
    {
        $this->options = $options;
    }

    public function getOptions()
    {
        return $this->options;
    }
    public function send(array $message)
    {
        $message = $this->messageToLineProtocol($message, $this->getOptions()->getTags());

        $this->write($message);
    }

    public function write($message)
    {
        // Create a handler in order to handle the 'Host is down' message
        set_error_handler(function() {
            // Suppress the error, this is the UDP adapter and if we can't send
            // it then we shouldn't inturrupt their application.
        });

        $socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
        socket_sendto($socket, $message, strlen($message), 0, $this->getOptions()->getHost(), $this->getOptions()->getPort());
        socket_close($socket);

        // Remove our error handler.
        restore_error_handler();
    }
}