File Coverage

blib/lib/Mojolicious/Plugin/Statsd/Adapter/Statsd.pm

Criterion	Covered	Total	%
statement	22	22	100.0
branch			n/a
condition	3	4	75.0
subroutine	7	7	100.0
pod	4	4	100.0
total	36	37	97.3

package Mojolicious::Plugin::Statsd::Adapter::Statsd;

use Mojo::Base -base;

use Mojo::Loader qw(load_class);

our $VERSION = '0.06';

use IO::Socket::INET ();

has client =>  sub {
    my $self = shift;
    my ($host, $port) = split ':', $self->addr;
    load_class "Net::Statsd::Tiny";
    return Net::Statsd::Tiny->new(
        socket => $self->socket,
    );
};

has socket => sub {
    my $self = shift;
    IO::Socket::INET->new(
        Proto    => 'udp',
        PeerAddr => $self->addr,
        Blocking => 0,
    ) or die "Can't open write socket for stats: $@";
};

has addr => sub {
  $ENV{STATSD_ADDR} // '127.0.0.1:8125';
};

sub counter {
    my ( $self, $names, $value, $rate ) = @_;
    $self->client->counter($_, $value, $rate // 1) for @$names;
    return -1;
}

sub timing {
    my ( $self, $names, $value, $rate ) = @_;
    $self->client->timing($_, $value, $rate // 1) for @$names;
    return -1;
}

sub gauge {
    my ( $self, $names, $value ) = @_;
    $self->client->gauge($_, $value) for @$names;
    return -1;
}

sub set_add {
    my ( $self, $names, @values ) = @_;
    for my $value (@values) {
        $self->client->set_add($_, $value) for @$names;
    }
    return -1;
}

1;

# ABSTRACT: Statsd UDP recording

__END__