File Coverage

blib/lib/Measure/Everything/Adapter/InfluxDB/UDP.pm

Criterion	Covered	Total	%
statement	23	23	100.0
branch			n/a
condition	1	4	25.0
subroutine	7	7	100.0
pod	0	2	0.0
total	31	36	86.1

use strict;
use warnings;

package Measure::Everything::Adapter::InfluxDB::UDP;
# ABSTRACT: A Measure::Everything adapter to feed InfluxDB through UDP.
$Measure::Everything::Adapter::InfluxDB::UDP::VERSION = '0.01';

use IO::Socket::INET;

use base qw(Measure::Everything::Adapter::Base);
use InfluxDB::LineProtocol qw(data2line);

sub init {
    my $self = shift;
    my %config = @_;
    my $socket = IO::Socket::INET->new(
        PeerAddr  => $config{host} || $config{addr} || 'localhost',
        PeerPort  => $config{port} || 8089,
        Proto     => 'udp',
        ReuseAddr => 1,
    );
    $self->{socket} = $socket;
    return $self;
}

sub write {
    my $self = shift;
    my $line = data2line(@_);
    return $self->{socket}->send( $line );
}

1;

__END__