File Coverage

blib/lib/Net/Statsd/Client/Timer.pm

Criterion	Covered	Total	%
statement	27	30	90.0
branch	4	6	66.6
condition	1	3	33.3
subroutine	7	8	87.5
pod	2	5	40.0
total	41	52	78.8

package Net::Statsd::Client::Timer;
use Moo;
use Sub::Quote;

# ABSTRACT: Measure event timings and send them to StatsD
our $VERSION = '0.33'; # VERSION
our $AUTHORITY = 'cpan:ARODLAND'; # AUTHORITY

use Time::HiRes qw(gettimeofday tv_interval);

has 'statsd' => (
  is => 'ro',
  required => 1,
);

has '_pending' => (
  is => 'rw',
  default => quote_sub q{1},
);

has ['metric', 'start', '_file', '_line', 'warning_callback'] => (
  is => 'rw',
);

sub BUILD {
  my ($self) = @_;
  my (undef, $file, $line) = caller(1);

  $self->start([gettimeofday]);
  $self->_file($file);
  $self->_line($line);
}

sub finish {
  my ($self) = @_;
  my $duration = tv_interval($self->{start}) * 1000;
  $self->{statsd}->timing_ms(
    $self->{metric},
    $duration,
    $self->{sample_rate},
  );
  delete $self->{_pending};
  return $duration;
}

sub cancel {
  my ($self) = @_;
  delete $self->{_pending};
}

sub emit_warning {
  my $self = shift;
  if (defined $self->warning_callback) {
    $self->warning_callback->(@_);
  } else {
    warn(@_);
  }
}

sub DEMOLISH {
  my ($self) = @_;
  if ($self->{_pending}) {
    my $metric = $self->{metric};
    $metric = $self->{statsd}{prefix} . $metric if $self->{statsd} && $self->{statsd}{prefix};
    $self->emit_warning("Unfinished timer for stat $metric (created at $self->{_file} line $self->{_line})");
  }
}

1;

__END__