package Search::Elasticsearch::Client::1_0::Role::Scroll; $Search::Elasticsearch::Client::1_0::Role::Scroll::VERSION = '5.00'; use Moo::Role; requires 'finish'; use Search::Elasticsearch::Util qw(parse_params throw); use Devel::GlobalDestruction; use namespace::clean; has 'es' => ( is => 'ro', required => 1 ); has 'scroll' => ( is => 'ro' ); has 'scroll_in_qs' => ( is => 'ro' ); has 'total' => ( is => 'rwp' ); has 'max_score' => ( is => 'rwp' ); has 'facets' => ( is => 'rwp' ); has 'aggregations' => ( is => 'rwp' ); has 'suggest' => ( is => 'rwp' ); has 'took' => ( is => 'rwp' ); has 'total_took' => ( is => 'rwp' ); has 'search_params' => ( is => 'ro' ); has 'is_finished' => ( is => 'rwp', default => '' ); has '_pid' => ( is => 'ro', default => sub {$$} ); has '_scroll_id' => ( is => 'rwp', clearer => 1, predicate => 1 ); #=================================== sub scroll_request { #=================================== my $self = shift; throw( 'Illegal', 'Scroll requests are not fork safe and may only be ' . 'refilled by the same process that created the instance.' ) if $self->_pid != $$; my %args = ( scroll => $self->scroll ); if ( $self->scroll_in_qs ) { $args{scroll_id} = $self->_scroll_id; } else { $args{body} = $self->_scroll_id; } $self->es->scroll(%args); } #=================================== sub DEMOLISH { #=================================== my $self = shift or return; return if in_global_destruction; $self->finish; } 1; # ABSTRACT: Provides common functionality to L and L __END__ =pod =encoding UTF-8 =head1 NAME Search::Elasticsearch::Client::1_0::Role::Scroll - Provides common functionality to L and L =head1 VERSION version 5.00 =head1 AUTHOR Clinton Gormley =head1 COPYRIGHT AND LICENSE This software is Copyright (c) 2016 by Elasticsearch BV. This is free software, licensed under: The Apache License, Version 2.0, January 2004 =cut