File Coverage

lib/Beekeeper/Service/LogTail.pm

Criterion	Covered	Total	%
statement	15	26	57.6
branch	0	2	0.0
condition			n/a
subroutine	4	6	66.6
pod	2	2	100.0
total	21	36	58.3

package Beekeeper::Service::LogTail;

use strict;
use warnings;

our $VERSION = '0.09';

use Beekeeper::Client;

# Show errors from perspective of caller
$Carp::Internal{(__PACKAGE__)}++;


sub tail {
    my ($class, %args) = @_;

    my $client = Beekeeper::Client->instance;
    my $guard = $client->__use_authorization_token('BKPR_ADMIN');
    my $timeout = delete $args{'timeout'};

    my $resp = $client->call_remote(
        method  => '_bkpr.logtail.tail',
        params  => \%args,
        timeout => $timeout,
    );

    return $resp->result;
}

sub tail_async {
    my ($class, %args) = @_;

    my $on_success = delete $args{'on_success'};
    my $on_error   = delete $args{'on_error'};

    unless ($on_error) {
        my ($file, $line) = (caller)[1,2];
        $on_error = sub { die $_[0]->message . " at $file line $line\n"; };
    }

    my $client = Beekeeper::Client->instance;
    my $guard = $client->__use_authorization_token('BKPR_ADMIN');
    my $timeout = delete $args{'timeout'};

    $client->call_remote_async(
        method     => '_bkpr.logtail.tail',
        params     => \%args,
        timeout    => $timeout,
        on_success => $on_success,
        on_error   => $on_error,
    );
}

1;

__END__