1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
package Search::Elasticsearch::Client::2_0::Role::Scroll;
$Search::Elasticsearch::Client::2_0::Role::Scroll::VERSION = '6.81';
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<Search::Elasticsearch::Client::2_0::Scroll> and L<Search::Elasticsearch::Client::2_0::Async::Scroll>
__END__
=pod
=encoding UTF-8
=head1 NAME
Search::Elasticsearch::Client::2_0::Role::Scroll - Provides common functionality to L<Search::Elasticsearch::Client::2_0::Scroll> and L<Search::Elasticsearch::Client::2_0::Async::Scroll>
=head1 VERSION
version 6.81
=head1 AUTHOR
Enrico Zimuel <enrico.zimuel@elastic.co>
=head1 COPYRIGHT AND LICENSE
This software is Copyright (c) 2020 by Elasticsearch BV.
This is free software, licensed under:
The Apache License, Version 2.0, January 2004
=cut
|
