File Coverage

lib/Flux/Log/In.pm

Criterion	Covered	Total	%
statement	10	12	83.3
branch			n/a
condition			n/a
subroutine	4	4	100.0
pod			n/a
total	14	16	87.5

package Flux::Log::In;
{
  $Flux::Log::In::VERSION = '1.00';
}

# ABSTRACT: input stream for Flux::Log storage.


use Moo;
with
    'Flux::In::Role::Easy',
    'Flux::In::Role::Lag',
    'Flux::Role::Description';

use Type::Params qw(validate);
use Types::Standard qw( Int Str HashRef Object Optional );

use Log::Unrotate;

has '_unrotate_params' => (
    is => 'ro',
    isa => HashRef,
    init_arg => 'unrotate',
    required => 1,
);

has 'log' => (
    is => 'ro',
    isa => Str,
    required => 1,
);

has '_unrotate' => (
    is => 'lazy',
    isa => Object,
    default => sub {
        my $self = shift;
        return Log::Unrotate->new({
            log => $self->log,
            %{ $self->_unrotate_params }
        });
    },
);

sub description {
    my $self = shift;

    my $current_log = $self->_unrotate->_log_file; # FIXME - incapsulation violation!
    return
        "pos: ".$self->_unrotate_params->{pos}."\n"
        ."log: $current_log";
}

sub clone {
    my $self = shift;
    return __PACKAGE__->new({ unrotate => $self->_unrotate_params });
}

sub read {
    my $self = shift;
    validate(\@_);

    return $self->_unrotate->read;
}

sub position {
    my $self = shift;
    validate(\@_);
    return $self->_unrotate->position;
}

sub lag {
    my $self = shift;
    validate(\@_);

    return $self->_unrotate->lag;
}

sub commit {
    my $self = shift;
    my ($position) = validate(\@_, Optional[Int]);

    $self->_unrotate->commit($position ? $position : ());
}


1;

__END__