NAME

            

              
              
Data::AnyXfer::Elastic::Import::Utils::Buffer - Buffer class
            
          

DESCRIPTION

            

              
              
This module provides methods for buffer action
            
          

SYNOPSIS

            

              
              
use Data::AnyXfer::Elastic::Import::Utils::Buffer;
my $buffer = Data::AnyXfer::Elastic::Import::Utils::Buffer->new(
    callback => $sub );
# push data into buffer
$buffer->push(@data);
# called automatically when more than c<max_size> items have
# been added to the buffer using c<push>
$buffer->flush();
            
          

ATTRIBUTES

max_size

            

              
              
size of the buffer, default is 200
            
          

callback

            

              
              
   # Callback must follow the call signature
   $callback->(@data_entries);
callback function which will process the data once the buffer
has been filled
            
          

push

            

              
              
$buffer->push(@data);
pushes data to buffer
            
          

flush

            

              
              
$buffer->flush();
passes data to callback and clears buffer
            
          

COPYRIGHT

This software is copyright (c) 2019, Anthony Lucas.

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