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
|
use Search::Elasticsearch;
use Test::More;
use strict;
use warnings;
my $trace
= !$ENV{TRACE} ? undef
: $ENV{TRACE} eq '1' ? 'Stderr'
: [ 'File', $ENV{TRACE} ];
unless ($ENV{CLIENT_VER}) {
plan skip_all => 'No $ENV{CLIENT_VER} specified';
exit;
}
unless ($ENV{ES}) {
plan skip_all => 'No Elasticsearch test node available';
exit;
}
my $api = "$ENV{CLIENT_VER}::Direct";
my $body = $ENV{ES_BODY} || 'GET';
my $cxn = $ENV{ES_CXN} || do "default_cxn.pl" || die( $@ || $! );
my $cxn_pool = $ENV{ES_CXN_POOL} || 'Static';
my $timeout = $ENV{ES_TIMEOUT} || 30;
my @plugins = split /,/, ( $ENV{ES_PLUGINS} || '' );
our %Auth;
my $es;
if ( $ENV{ES} ) {
eval {
$es = Search::Elasticsearch->new(
nodes => $ENV{ES},
trace_to => $trace,
cxn => $cxn,
cxn_pool => $cxn_pool,
client => $api,
send_get_body_as => $body,
request_timeout => $timeout,
plugins => \@plugins,
%Auth
);
$es->ping unless $ENV{ES_SKIP_PING};
1;
} || do {
diag $@;
undef $es;
};
}
unless ( $ENV{ES_SKIP_PING} ) {
my $version = $es->info->{version}{number};
my $api = $es->api_version;
unless ( $api eq '0_90' && $version =~ /^0\.9/
|| substr( $api, 0, 1 ) eq substr( $version, 0, 1 ) )
{
plan skip_all =>
"Tests are for API version $api but Elasticsearch is version $version\n";
exit;
}
}
return $es;
|
