File Coverage

blib/lib/Log/Log4perl/Appender/Elasticsearch/Bulk.pm

Criterion	Covered	Total	%
statement	30	40	75.0
branch	1	4	25.0
condition	1	2	50.0
subroutine	8	9	88.8
pod	1	2	50.0
total	41	57	71.9

package Log::Log4perl::Appender::Elasticsearch::Bulk;

use 5.006;
use strict;
use warnings;

use constant _INTERNAL_DEBUG => 0;

use base 'Log::Log4perl::Appender::Elasticsearch';

=head1 NAME

Log::Log4perl::Appender::Elasticsearch::Bulk

=head1 DESCRIPTION

This appender is based on L. It buffers the log entries and flush by certain buffer size or on destroy.

=head1 OPTIONS

=over 4

=item

buffer_size

the number of log entries in a bulk load.

default 50

=back

For further options see L

=cut

sub new {
    my ($class, %p) = @_;
    my $fc = delete($p{buffer_size});

    my $self = $class->SUPER::new(%p);

    $self->{_buffer} = [];
    $self->{_buffer_size} = $fc || 50;

    return $self;
} ## end sub new

sub _flush {
    my ($self) = @_;
    my $data   = "";
    my $buff   = delete $self->{_buffer};
    $self->{_buffer} = [];

    scalar(@{$buff}) || return;

    foreach (@{$buff}) {
        $data .= join $/, '{"create":{}}', $self->_to_json($_), '';
    }

    if (_INTERNAL_DEBUG) {
        require Data::Dumper;
        print Data::Dumper::Dumper($buff);
        print $data;
    }

    $self->_send_request($data, '_bulk');
} ## end sub _flush

sub log {
    my ($self, %p) = @_;
    push @{ $self->{_buffer} }, $self->_prepare_body(%p);
    (scalar(@{ $self->{_buffer} }) == $self->{_buffer_size}) && $self->_flush();
}

sub DESTROY {
    my ($self) = @_;
    _INTERNAL_DEBUG && print "_flush on destroy\n";
    $self->_flush();
}

=head1 AUTHOR

Alexei Pastuchov

=head1 REPOSITORY

L

=head1 LICENSE AND COPYRIGHT

Copyright 2015 by Alexei Pastuchov Epalik at cpan.orgE.

This library is free software; you can redistribute it and/or modify
it under the same terms as Perl itself.

=cut

1;    # End of Log::Log4perl::Appender::Elasticsearch::Bulk