File Coverage

blib/lib/Linux/GetPidstat/Writer.pm

Criterion	Covered	Total	%
statement	32	32	100.0
branch	6	8	75.0
condition			n/a
subroutine	8	8	100.0
pod	0	2	0.0
total	46	50	92.0

package Linux::GetPidstat::Writer;
use 5.008001;
use strict;
use warnings;

use Time::Piece;
use Linux::GetPidstat::Writer::File;
use Linux::GetPidstat::Writer::Mackerel;

sub new {
    my ( $class, %opt ) = @_;
    bless \%opt, $class;
}

sub output {
    my ($self, $ret_pidstats) = @_;

    my $file;
    if (length $self->{res_file}) {
        $file = Linux::GetPidstat::Writer::File->new(
            res_file => $self->{res_file},
            now      => $self->{now},
            dry_run  => $self->{dry_run},
        );
    }

    my $mackerel;
    if (length $self->{mackerel_metric_type}) {
        $mackerel = Linux::GetPidstat::Writer::Mackerel->new(
            mackerel_metric_type       => $self->{mackerel_metric_type},
            mackerel_api_key           => $self->{mackerel_api_key},
            mackerel_service_name      => $self->{mackerel_service_name},
            mackerel_metric_key_prefix => $self->{mackerel_metric_key_prefix},
            mackerel_host_id           => $self->{mackerel_host_id},
            now                        => $self->{now},
            dry_run                    => $self->{dry_run},
        );
    }

    # ex. backup_mysql => { cpu => 21.0 }
    while (my ($program_name, $s) = each %$ret_pidstats) {
        while (my ($metric_name, $metric) = each %$s) {
            if ($file) {
                $file->output($program_name, $metric_name, $metric);
            }
        }
    }
    if ($mackerel) {
        $mackerel->bulk_output($ret_pidstats);
    }
}

1;
__END__