File Coverage

lib/Measure/Everything/Adapter/InfluxDB/TCP.pm

Criterion	Covered	Total	%
statement	18	38	47.3
branch	0	8	0.0
condition	0	4	0.0
subroutine	6	9	66.6
pod	0	2	0.0
total	24	61	39.3

package Measure::Everything::Adapter::InfluxDB::TCP;
use strict;
use warnings;

our $VERSION = '1.003';

# ABSTRACT: Send stats to Influx via TCP using Telegraf

use base qw(Measure::Everything::Adapter::Base);
use InfluxDB::LineProtocol qw();
use IO::Socket::INET;
use Log::Any qw($log);

sub init {
    my $self = shift;

    my $host = $self->{host} || 'localhost';
    my $port = $self->{port} || 8094;
    my $precision = $self->{precision} ? 'precision='.$self->{precision} : '';
    InfluxDB::LineProtocol->import('data2line', $precision);

    my $socket = IO::Socket::INET->new(
        PeerAddr => $host,
        PeerPort => $port,
        Proto    => 'tcp',
    );
    if ($socket) {
        $self->{socket} = $socket;
    }
    else {
        $log->errorf(
            "Cannot set up TCP socket on %s:%s, no stats will be recorded!",
            $host, $port );
    }
}

sub write {
    my $self = shift;
    my $line = data2line(@_);

    if ($self->{socket} ) {
        local $SIG{'PIPE'} = sub { die "SIGPIPE" };
        eval {
            $self->{socket}->send($line."\n");
        };
        return unless $@;
        $log->errorf("write error %s", $@);
    }
    undef $self->{socket};
    $self->init;
}

1;

__END__