| line |
true |
false |
branch |
|
210
|
0 |
0 |
if ($Search::Elasticsearch::VERSION < 5) |
|
224
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $nodes) |
|
225
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $cxn_pool) |
|
226
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("open", $nodes, "ARRAY") |
|
227
|
0 |
0 |
unless $self->brik_help_run_empty_array_arg("open", $nodes) |
|
230
|
0 |
0 |
unless ($node =~ m[https?://]) |
|
261
|
0 |
0 |
if ($self->disable_deprecation_logging) |
|
266
|
0 |
0 |
unless (defined $es) |
|
285
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
286
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_bulk_mode", $index) |
|
287
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_bulk_mode", $type) |
|
301
|
0 |
0 |
if ($self->use_type) |
|
305
|
0 |
0 |
if ($self->use_bulk_autoflush) { } |
|
332
|
0 |
0 |
if ($@) |
|
346
|
0 |
0 |
unless my $version = $self->version |
|
347
|
0 |
0 |
if ($version ge "5.0.0") |
|
355
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
356
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_scroll_scan_mode", $index) |
|
357
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_scroll_scan_mode", $size) |
|
367
|
0 |
0 |
if ($@) |
|
384
|
0 |
0 |
unless my $version = $self->version |
|
385
|
0 |
0 |
if ($version lt "5.0.0") |
|
395
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
396
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_scroll", $index) |
|
397
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_scroll", $size) |
|
410
|
0 |
0 |
if ($self->use_type) |
|
411
|
0 |
0 |
if ($type ne "*") |
|
423
|
0 |
0 |
if ($@) |
|
442
|
0 |
0 |
unless (defined $scroll) |
|
456
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_scroll", $scroll) |
|
462
|
0 |
0 |
if ($@) |
|
477
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_scroll", $scroll) |
|
481
|
0 |
0 |
if ($count > 1) { } |
|
483
|
0 |
0 |
if (@docs > 0) |
|
491
|
0 |
0 |
if ($@) |
|
509
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
510
|
0 |
0 |
unless $self->brik_help_run_undef_arg("index_document", $doc) |
|
511
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("index_document", $doc, "HASH") |
|
512
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
513
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
519
|
0 |
0 |
if (defined $id) |
|
523
|
0 |
0 |
if ($self->use_type) |
|
527
|
0 |
0 |
if (defined $hash) |
|
528
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("index_document", $hash, "HASH") |
|
531
|
0 |
0 |
if (defined $hash->{'routing'} and defined $$doc{$hash->{'routing'}}) |
|
541
|
0 |
0 |
if ($@) |
|
558
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
559
|
0 |
0 |
unless $self->brik_help_run_undef_arg("reindex", $index) |
|
560
|
0 |
0 |
unless $self->brik_help_run_undef_arg("reindex", $new) |
|
572
|
0 |
0 |
if ($self->use_type) |
|
573
|
0 |
0 |
if (defined $type) |
|
582
|
0 |
0 |
if ($@) |
|
607
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
613
|
0 |
0 |
unless (defined $nodes) |
|
623
|
0 |
0 |
if ($action eq "indices:data/write/reindex" and not exists $tasks{$task}) |
|
638
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
639
|
0 |
0 |
unless $self->brik_help_run_undef_arg("cancel_reindex_task", $id) |
|
651
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
652
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_taskid", $id) |
|
663
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
665
|
0 |
0 |
unless my $tasks = $self->get_reindex_tasks |
|
666
|
0 |
0 |
unless (keys %$tasks) |
|
672
|
0 |
0 |
unless my $task = $self->get_taskid($id) |
|
696
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
699
|
0 |
0 |
unless $self->show_reindex_progress |
|
711
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
712
|
0 |
0 |
unless $self->brik_help_run_undef_arg("reindex_with_mapping_from_json_file", $index) |
|
714
|
0 |
0 |
unless $self->brik_help_run_undef_arg("reindex_with_mapping_from_json_file", $new) |
|
715
|
0 |
0 |
unless $self->brik_help_run_undef_arg("reindex_with_mapping_from_json_file", $file) |
|
716
|
0 |
0 |
unless $self->brik_help_run_file_not_found("reindex_with_mapping_from_json_file", $file) |
|
719
|
0 |
0 |
unless my $fj = "Metabrik::File::Json"->new_from_brik_init($self) |
|
720
|
0 |
0 |
unless my $json = $fj->read($file) |
|
739
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
740
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_document", $doc) |
|
741
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("update_document", $doc, "HASH") |
|
742
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_document", $id) |
|
743
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
744
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
752
|
0 |
0 |
if ($self->use_type) |
|
756
|
0 |
0 |
if (defined $hash) |
|
757
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("update_document", $hash, "HASH") |
|
766
|
0 |
0 |
if ($@) |
|
784
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_bulk_mode", $bulk) |
|
785
|
0 |
0 |
unless $self->brik_help_run_undef_arg("index_bulk", $doc) |
|
786
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
787
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
792
|
0 |
0 |
if (defined $id) |
|
796
|
0 |
0 |
if (defined $hash) |
|
797
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("index_bulk", $hash, "HASH") |
|
799
|
0 |
0 |
if (defined $hash->{'routing'} and defined $$doc{$hash->{'routing'}}) |
|
809
|
0 |
0 |
if ($@) |
|
812
|
0 |
0 |
if (defined $p and exists $p->{'class'}) { } |
|
838
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_bulk_mode", $bulk) |
|
839
|
0 |
0 |
unless $self->brik_help_run_undef_arg("index_bulk_from_list", $list) |
|
840
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("index_bulk_from_list", $list, "ARRAY") |
|
842
|
0 |
0 |
unless $self->brik_help_run_empty_array_arg("index_bulk_from_list", $list) |
|
844
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
845
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
847
|
0 |
0 |
if (defined $hash) |
|
848
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("index_bulk_from_list", $hash, "HASH") |
|
857
|
0 |
0 |
if (defined $hash) |
|
859
|
0 |
0 |
if (defined $hash->{'routing'} and defined $$doc{$hash->{'routing'}}) |
|
871
|
0 |
0 |
if ($@) |
|
874
|
0 |
0 |
if (defined $p and exists $p->{'class'}) { } |
|
896
|
0 |
0 |
unless $self->brik_help_run_undef_arg("clean_deleted_from_index", $index) |
|
899
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
910
|
0 |
0 |
if ($@) |
|
913
|
0 |
0 |
if (defined $p and exists $p->{'class'}) { } |
|
941
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_bulk_mode", $bulk) |
|
942
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_document_bulk", $doc) |
|
943
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
944
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
951
|
0 |
0 |
if ($self->use_type) |
|
955
|
0 |
0 |
if (defined $id) |
|
959
|
0 |
0 |
if (defined $hash) |
|
960
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("update_document_bulk", $hash, "HASH") |
|
969
|
0 |
0 |
if ($@) |
|
972
|
0 |
0 |
if (defined $p and exists $p->{'class'}) { } |
|
997
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_bulk_mode", $bulk) |
|
1007
|
0 |
0 |
if ($@) |
|
1009
|
0 |
0 |
if (--$try == 0) |
|
1011
|
0 |
0 |
if (defined $p and exists $p->{'class'}) { } |
|
1028
|
0 |
0 |
if (defined $index) |
|
1046
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1049
|
0 |
0 |
if (defined $index and $index ne "*") |
|
1052
|
0 |
0 |
if ($self->use_type) |
|
1053
|
0 |
0 |
if (defined $type and $type ne "*") |
|
1065
|
0 |
0 |
unless my $version = $self->version |
|
1066
|
0 |
0 |
if ($version ge '5.0.0') { } |
|
1076
|
0 |
0 |
if ($@) |
|
1081
|
0 |
0 |
if ($version ge '5.0.0') { } |
|
|
0 |
0 |
elsif (exists $r->{'hits'} and exists $r->{'hits'}{'total'}) { } |
|
1082
|
0 |
0 |
if (exists $r->{'count'}) |
|
1110
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1111
|
0 |
0 |
unless $self->brik_help_run_undef_arg("query", $query) |
|
1112
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
1113
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
1114
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("query", $query, "HASH") |
|
1124
|
0 |
0 |
if ($es_version == 7) |
|
1128
|
0 |
0 |
if (defined $hash) |
|
1129
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("query", $hash, "HASH") |
|
1133
|
0 |
0 |
if ($self->use_type) |
|
1134
|
0 |
0 |
if ($type ne "*") |
|
1143
|
0 |
0 |
if ($@) |
|
1158
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1159
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_from_id", $id) |
|
1160
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
1161
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
1169
|
0 |
0 |
if ($self->use_type) |
|
1174
|
0 |
0 |
if ($@) |
|
1191
|
0 |
0 |
unless $self->brik_help_run_undef_arg("www_search", $query) |
|
1192
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
1193
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
1198
|
0 |
0 |
unless my $sj = "Metabrik::String::Json"->new_from_brik_init($self) |
|
1204
|
0 |
0 |
if ($self->use_type) |
|
1205
|
0 |
0 |
if ($type ne "*") |
|
1211
|
0 |
0 |
unless my $get = $self->SUPER::get($url) |
|
1214
|
0 |
0 |
unless my $decoded = $sj->decode($body) |
|
1230
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1231
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_index", $index) |
|
1232
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("delete_index", $index, "ARRAY", "SCALAR") |
|
1242
|
0 |
0 |
if ($@) |
|
1262
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1263
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_document", $index) |
|
1264
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_document", $id) |
|
1271
|
0 |
0 |
if ($self->use_type) |
|
1275
|
0 |
0 |
if (defined $hash) |
|
1276
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("delete_document", $hash, "HASH") |
|
1285
|
0 |
0 |
if ($@) |
|
1303
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1304
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_by_query", $query) |
|
1305
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_by_query", $index) |
|
1306
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_by_query", $type) |
|
1307
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("delete_by_query", $query, "HASH") |
|
1316
|
0 |
0 |
if ($self->use_type) |
|
1320
|
0 |
0 |
if (defined $proceed and $proceed) |
|
1328
|
0 |
0 |
if ($@) |
|
1349
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1355
|
0 |
0 |
if ($@) |
|
1362
|
0 |
0 |
if (@lines == 0) |
|
1367
|
0 |
0 |
if (defined $string) |
|
1369
|
0 |
0 |
if (/$string/) |
|
1386
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1392
|
0 |
0 |
if ($@) |
|
1399
|
0 |
0 |
if (@lines == 0) |
|
1413
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1419
|
0 |
0 |
if ($@) |
|
1426
|
0 |
0 |
if (@lines == 0) |
|
1440
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1446
|
0 |
0 |
if ($@) |
|
1453
|
0 |
0 |
if (@lines == 0) |
|
1467
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1473
|
0 |
0 |
if ($@) |
|
1480
|
0 |
0 |
if (@lines == 0) |
|
1491
|
0 |
0 |
unless my $get = $self->get_indices |
|
1495
|
0 |
0 |
if (defined $regex) { } |
|
1496
|
0 |
0 |
if ($_->{'index'} =~ /$regex/) |
|
1512
|
0 |
0 |
unless my $lines = $self->show_indices($string) |
|
1513
|
0 |
0 |
if (@$lines == 0) |
|
1527
|
0 |
0 |
if (@t == 10) { } |
|
|
0 |
0 |
elsif (@t == 9) { } |
|
|
0 |
0 |
elsif (@t == 8) { } |
|
1575
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1576
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index", $index) |
|
1577
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_index", $index, "ARRAY", "SCALAR") |
|
1587
|
0 |
0 |
if ($@) |
|
1600
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1601
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index", $index) |
|
1611
|
0 |
0 |
if ($@) |
|
1625
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1626
|
0 |
0 |
unless $self->brik_help_run_undef_arg("list_index_types", $index) |
|
1627
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("list_index_types", $index, "SCALAR") |
|
1629
|
0 |
0 |
unless my $r = $self->get_mappings($index) |
|
1630
|
0 |
0 |
if (keys %$r > 1) |
|
1655
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1656
|
0 |
0 |
unless $self->brik_help_run_undef_arg("list_index_fields", $index) |
|
1657
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("list_index_fields", $index, "SCALAR") |
|
1660
|
0 |
0 |
if (defined $type) { } |
|
1661
|
0 |
0 |
unless $r = $self->get_mappings($index, $type) |
|
1662
|
0 |
0 |
if (keys %$r > 1) |
|
1667
|
0 |
0 |
if ($self->is_mapping_exists($index, "_default_")) |
|
1677
|
0 |
0 |
unless $r = $self->get_mappings($index) |
|
1678
|
0 |
0 |
if (keys %$r > 1) |
|
1703
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1704
|
0 |
0 |
unless $self->brik_help_run_undef_arg("list_indices_version", $index) |
|
1705
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("list_indices_version", $index, "ARRAY", "SCALAR") |
|
1708
|
0 |
0 |
unless my $r = $self->get_index($index) |
|
1728
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1729
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_index", $index) |
|
1730
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("open_index", $index, "ARRAY", "SCALAR") |
|
1738
|
0 |
0 |
if ($@) |
|
1751
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1752
|
0 |
0 |
unless $self->brik_help_run_undef_arg("close_index", $index) |
|
1753
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("close_index", $index, "ARRAY", "SCALAR") |
|
1761
|
0 |
0 |
if ($@) |
|
1778
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1797
|
0 |
0 |
if ($@) |
|
1818
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1819
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_alias", $index) |
|
1820
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_alias", $alias) |
|
1831
|
0 |
0 |
if ($@) |
|
1847
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1848
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_alias", $index) |
|
1849
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_alias", $alias) |
|
1860
|
0 |
0 |
if ($@) |
|
1873
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1874
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_alias", $new_index) |
|
1875
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_alias", $alias) |
|
1879
|
0 |
0 |
unless my $aliases = $self->get_aliases |
|
1882
|
0 |
0 |
if ($this eq $alias) |
|
1887
|
0 |
0 |
if $prev_index |
|
1891
|
0 |
0 |
if (defined $prev_index) |
|
1892
|
0 |
0 |
unless $self->delete_alias($prev_index, $alias) |
|
1902
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_mapping_exists", $index) |
|
1903
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_mapping_exists", $mapping) |
|
1905
|
0 |
0 |
unless ($self->is_index_exists($index)) |
|
1909
|
0 |
0 |
unless my $all = $self->get_mappings($index) |
|
1913
|
0 |
0 |
if ($this_mapping eq $mapping) |
|
1930
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1931
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_mappings", $index) |
|
1932
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_mappings", $index, "ARRAY", "SCALAR") |
|
1939
|
0 |
0 |
if ($self->use_type) |
|
1947
|
0 |
0 |
if ($@) |
|
1964
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1965
|
0 |
0 |
unless $self->brik_help_run_undef_arg("create_index", $index) |
|
1971
|
0 |
0 |
if (defined $shards) |
|
1979
|
0 |
0 |
if ($@) |
|
1996
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1997
|
0 |
0 |
unless $self->brik_help_run_undef_arg("create_index_with_mappings", $index) |
|
1998
|
0 |
0 |
unless $self->brik_help_run_undef_arg("create_index_with_mappings", $mappings) |
|
1999
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("create_index_with_mappings", $mappings, "HASH") |
|
2011
|
0 |
0 |
if ($@) |
|
2026
|
0 |
0 |
unless $self->brik_help_run_undef_arg("info", $nodes) |
|
2027
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("info", $nodes, "ARRAY") |
|
2028
|
0 |
0 |
unless $self->brik_help_run_empty_array_arg("info", $nodes) |
|
2032
|
0 |
0 |
unless $self->get($first) |
|
2042
|
0 |
0 |
unless $self->brik_help_run_undef_arg("version", $nodes) |
|
2043
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("version", $nodes, "ARRAY") |
|
2044
|
0 |
0 |
unless $self->brik_help_run_empty_array_arg("version", $nodes) |
|
2048
|
0 |
0 |
unless $self->get($first) |
|
2049
|
0 |
0 |
unless my $content = $self->content |
|
2061
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2067
|
0 |
0 |
if ($@) |
|
2078
|
0 |
0 |
unless my $content = $self->get_templates |
|
2091
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2092
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_template", $template) |
|
2100
|
0 |
0 |
if ($@) |
|
2113
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2114
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_mapping", $index) |
|
2115
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_mapping", $type) |
|
2116
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_mapping", $mapping) |
|
2117
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("put_mapping", $mapping, "HASH") |
|
2126
|
0 |
0 |
if ($self->use_type) |
|
2131
|
0 |
0 |
if ($@) |
|
2148
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2149
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_template", $name) |
|
2150
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_template", $template) |
|
2151
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("put_template", $template, "HASH") |
|
2161
|
0 |
0 |
if ($@) |
|
2175
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2176
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_mapping_from_json_file", $index) |
|
2178
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_mapping_from_json_file", $type) |
|
2180
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_mapping_from_json_file", $json_file) |
|
2182
|
0 |
0 |
unless $self->brik_help_run_file_not_found("put_mapping_from_json_file", $json_file) |
|
2185
|
0 |
0 |
unless my $fj = "Metabrik::File::Json"->new_from_brik_init($self) |
|
2186
|
0 |
0 |
unless my $data = $fj->read($json_file) |
|
2188
|
0 |
0 |
unless (exists $data->{'mappings'}) |
|
2201
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2202
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_mapping_from_json_file", $json_file) |
|
2204
|
0 |
0 |
unless $self->brik_help_run_file_not_found("update_mapping_from_json_file", $json_file) |
|
2206
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_mapping_from_json_file", $type) |
|
2208
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_mapping_from_json_file", $index) |
|
2211
|
0 |
0 |
unless my $fj = "Metabrik::File::Json"->new_from_brik_init($self) |
|
2212
|
0 |
0 |
unless my $data = $fj->read($json_file) |
|
2214
|
0 |
0 |
unless (exists $data->{'mappings'}) |
|
2229
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2230
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_template_from_json_file", $json_file) |
|
2232
|
0 |
0 |
unless $self->brik_help_run_file_not_found("put_template_from_json_file", $json_file) |
|
2235
|
0 |
0 |
unless my $fj = "Metabrik::File::Json"->new_from_brik_init($self) |
|
2236
|
0 |
0 |
unless my $data = $fj->read($json_file) |
|
2238
|
0 |
0 |
unless (defined $name) |
|
2242
|
0 |
0 |
unless (defined $name) |
|
2255
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2256
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_template_from_json_file", $json_file) |
|
2258
|
0 |
0 |
unless $self->brik_help_run_file_not_found("update_template_from_json_file", $json_file) |
|
2261
|
0 |
0 |
unless my $fj = "Metabrik::File::Json"->new_from_brik_init($self) |
|
2262
|
0 |
0 |
unless my $data = $fj->read($json_file) |
|
2264
|
0 |
0 |
unless (defined $name) |
|
2268
|
0 |
0 |
unless (defined $name) |
|
2288
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2291
|
0 |
0 |
if (defined $indices) |
|
2292
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_settings", $indices) |
|
2293
|
0 |
0 |
unless my $ref = $self->brik_help_run_invalid_arg("get_settings", $indices, "ARRAY", "SCALAR") |
|
2297
|
0 |
0 |
if (defined $names) |
|
2298
|
0 |
0 |
unless $self->brik_help_run_file_not_found("get_settings", $names) |
|
2299
|
0 |
0 |
unless my $ref = $self->brik_help_run_invalid_arg("get_settings", $names, "ARRAY", "SCALAR") |
|
2308
|
0 |
0 |
if ($@) |
|
2331
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2332
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_settings", $settings) |
|
2333
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("put_settings", $settings, "HASH") |
|
2338
|
0 |
0 |
if (defined $indices) |
|
2339
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_settings", $indices) |
|
2340
|
0 |
0 |
unless my $ref = $self->brik_help_run_invalid_arg("put_settings", $indices, "ARRAY", "SCALAR") |
|
2349
|
0 |
0 |
if ($@) |
|
2362
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2363
|
0 |
0 |
unless $self->brik_help_run_undef_arg("set_index_readonly", $indices) |
|
2364
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("set_index_readonly", $indices, "ARRAY", "SCALAR") |
|
2367
|
0 |
0 |
if (not defined $bool) { } |
|
2371
|
0 |
0 |
$bool ? : |
|
2416
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2417
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("reset_index_readonly", $indices, "ARRAY", "SCALAR") |
|
2437
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2439
|
0 |
0 |
unless my $list = $self->list_indices |
|
2443
|
0 |
0 |
unless my $ro = $self->get_index_readonly($this) |
|
2444
|
0 |
0 |
if (defined $ro->{'index'}{'provided_name'}) |
|
2457
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2458
|
0 |
0 |
unless $self->brik_help_run_undef_arg("set_index_number_of_replicas", $indices) |
|
2459
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("set_index_number_of_replicas", $indices, "ARRAY", "SCALAR") |
|
2472
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2473
|
0 |
0 |
unless $self->brik_help_run_undef_arg("set_index_refresh_interval", $indices) |
|
2474
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("set_index_refresh_interval", $indices, "ARRAY", "SCALAR") |
|
2479
|
0 |
0 |
if ($number =~ /^\d+$/ and $number > 0) |
|
2493
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2494
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index_settings", $indices) |
|
2495
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_index_settings", $indices, "ARRAY", "SCALAR") |
|
2513
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2514
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index_readonly", $indices) |
|
2515
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_index_readonly", $indices, "ARRAY", "SCALAR") |
|
2534
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2535
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index_number_of_replicas", $indices) |
|
2536
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_index_number_of_replicas", $indices, "ARRAY", "SCALAR") |
|
2554
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2555
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index_refresh_interval", $indices) |
|
2556
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_index_refresh_interval", $indices, "ARRAY", "SCALAR") |
|
2574
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2575
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index_number_of_shards", $indices) |
|
2576
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_index_number_of_shards", $indices, "ARRAY", "SCALAR") |
|
2597
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2598
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_template", $name) |
|
2606
|
0 |
0 |
if ($@) |
|
2622
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2623
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_index_exists", $index) |
|
2631
|
0 |
0 |
if ($@) |
|
2636
|
0 |
0 |
$r ? : |
|
2647
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2648
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_type_exists", $index) |
|
2649
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_type_exists", $type) |
|
2656
|
0 |
0 |
if ($self->use_type) |
|
2661
|
0 |
0 |
if ($@) |
|
2667
|
0 |
0 |
$r ? : |
|
2678
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2679
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_document_exists", $index) |
|
2680
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_document_exists", $type) |
|
2681
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_document_exists", $document) |
|
2682
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("is_document_exists", $document, "HASH") |
|
2690
|
0 |
0 |
if ($self->use_type) |
|
2695
|
0 |
0 |
if ($@) |
|
2701
|
0 |
0 |
$r ? : |
|
2708
|
0 |
0 |
unless $self->brik_help_run_undef_arg("parse_error_string", $string) |
|
2715
|
0 |
0 |
if (defined $dump and length $dump) |
|
2716
|
0 |
0 |
unless my $sd = "Metabrik::String::Dump"->new_from_brik_init($self) |
|
2721
|
0 |
0 |
if (defined $node and $node =~ /^http/ and $code =~ /^\d+$/ and defined $dump and ref $dump eq "HASH") |
|
2749
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2750
|
0 |
0 |
unless $self->brik_help_run_undef_arg("refresh_index", $index) |
|
2762
|
0 |
0 |
if ($@) |
|
2763
|
0 |
0 |
if (--$try == 0) |
|
2766
|
0 |
0 |
if (defined $p and exists $p->{'class'}) { } |
|
2791
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2792
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as", $format) |
|
2793
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as", $index) |
|
2794
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as", $size) |
|
2796
|
0 |
0 |
if ($format ne "csv" and $format ne "json") |
|
2807
|
0 |
0 |
unless my $version = $self->version |
|
2808
|
0 |
0 |
if ($version lt '5.0.0') { } |
|
2809
|
0 |
0 |
unless $scroll = $self->open_scroll_scan_mode($index, $size) |
|
2812
|
0 |
0 |
unless $scroll = $self->open_scroll($index, $size) |
|
2817
|
0 |
0 |
unless my $fd = "Metabrik::File::Dump"->new_from_brik_init($self) |
|
2821
|
0 |
0 |
if ($format eq 'csv') { } |
|
|
0 |
0 |
elsif ($format eq 'json') { } |
|
2822
|
0 |
0 |
unless $out = "Metabrik::File::Csv"->new_from_brik_init($self) |
|
2830
|
0 |
0 |
if (defined $self->csv_header) |
|
2834
|
0 |
0 |
if (defined $self->csv_encoded_fields) |
|
2837
|
0 |
0 |
if (defined $self->csv_object_fields) |
|
2844
|
0 |
0 |
unless $out = "Metabrik::File::Json"->new_from_brik_init($self) |
|
2863
|
0 |
0 |
if (defined $cb) |
|
2865
|
0 |
0 |
unless (defined $this) |
|
2877
|
0 |
0 |
unless (exists $types{$type}) |
|
2878
|
0 |
0 |
if ($format eq 'csv') { } |
|
|
0 |
0 |
elsif ($format eq 'json') { } |
|
2880
|
0 |
0 |
if (not defined $csv_header) { } |
|
2881
|
0 |
0 |
unless my $fields = $self->list_index_fields($index, $type) |
|
2896
|
0 |
0 |
if (-f $done) |
|
2912
|
0 |
0 |
if ($format eq "csv") |
|
2917
|
0 |
0 |
if (@{$chunk{$type};} > 999) |
|
2919
|
0 |
0 |
unless (defined $r) |
|
2929
|
0 |
0 |
unless (++$exported % 100000) |
|
2939
|
0 |
0 |
if ($max > 0 and $exported >= $max) |
|
2950
|
0 |
0 |
if (@{$chunk{$type};} > 0) |
|
2961
|
0 |
0 |
if ($duration > 0) |
|
2973
|
0 |
0 |
$exported == $total ? : |
|
2977
|
0 |
0 |
unless $fd->write($result, $done) |
|
2990
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2991
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as_csv", $index) |
|
2992
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as_csv", $size) |
|
3003
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3004
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as_json", $index) |
|
3005
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as_json", $size) |
|
3019
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3020
|
0 |
0 |
unless $self->brik_help_run_undef_arg("import_from", $format) |
|
3021
|
0 |
0 |
unless $self->brik_help_run_undef_arg("import_from", $input) |
|
3022
|
0 |
0 |
unless $self->brik_help_run_file_not_found("import_from", $input) |
|
3024
|
0 |
0 |
if ($format ne "csv" and $format ne "json") |
|
3031
|
0 |
0 |
unless (defined $index and defined $type) |
|
3033
|
0 |
0 |
if ($input =~ /^(.+):(.+)\.(?:csv|json)(?:.*)?$/) |
|
3043
|
0 |
0 |
if (-f $done) |
|
3052
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
3053
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
3055
|
0 |
0 |
if ($index eq "*") |
|
3059
|
0 |
0 |
if ($self->use_type) |
|
3060
|
0 |
0 |
if ($type eq "*") |
|
3071
|
0 |
0 |
if ($self->is_index_exists($index)) |
|
3073
|
0 |
0 |
unless (defined $count_before) |
|
3082
|
0 |
0 |
unless $self->open_bulk_mode($index, $type) |
|
3087
|
0 |
0 |
unless my $fd = "Metabrik::File::Dump"->new_from_brik_init($self) |
|
3090
|
0 |
0 |
if ($format eq 'csv') { } |
|
|
0 |
0 |
elsif ($format eq 'json') { } |
|
3091
|
0 |
0 |
unless $out = "Metabrik::File::Csv"->new_from_brik_init($self) |
|
3100
|
0 |
0 |
unless $out = "Metabrik::File::Json"->new_from_brik_init($self) |
|
3117
|
0 |
0 |
$self->use_ignore_id ? : |
|
3123
|
0 |
0 |
if (defined $value and length $value) |
|
3128
|
0 |
0 |
if (defined $cb) |
|
3130
|
0 |
0 |
unless (defined $h) |
|
3140
|
0 |
0 |
if (defined $hash and defined $hash->{'routing'} and defined $$h{$hash->{'routing'}}) |
|
3153
|
0 |
0 |
if ($@) |
|
3157
|
0 |
0 |
unless (defined $r) |
|
3167
|
0 |
0 |
if ($first and $self->is_index_exists($index)) |
|
3174
|
0 |
0 |
if ($self->use_indexing_optimizations) |
|
3182
|
0 |
0 |
unless (++$imported % 100000) |
|
3190
|
0 |
0 |
if ($max > 0 and $imported >= $max) |
|
3205
|
0 |
0 |
unless my $count_current = $self->count($index, $type) |
|
3210
|
0 |
0 |
$count_current - $count_before == $read ? : |
|
3211
|
0 |
0 |
if ($complete) { } |
|
3230
|
0 |
0 |
unless $fd->write($result, $done) |
|
3233
|
0 |
0 |
if (defined $refresh_interval) |
|
3236
|
0 |
0 |
if (defined $number_of_replicas and $self->use_indexing_optimizations) |
|
3248
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3249
|
0 |
0 |
unless $self->brik_help_run_undef_arg("import_from_csv", $input) |
|
3250
|
0 |
0 |
unless $self->brik_help_run_file_not_found("import_from_csv", $input) |
|
3261
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3262
|
0 |
0 |
unless $self->brik_help_run_undef_arg("import_from_json", $input) |
|
3263
|
0 |
0 |
unless $self->brik_help_run_file_not_found("import_from_json", $input) |
|
3277
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3278
|
0 |
0 |
unless $self->brik_help_run_undef_arg("import_from_csv_worker", $input_csv) |
|
3280
|
0 |
0 |
unless $self->brik_help_run_file_not_found("import_from_csv_worker", $input_csv) |
|
3284
|
0 |
0 |
unless (defined $index and defined $type) |
|
3286
|
0 |
0 |
if ($input_csv =~ /^(.+):(.+)\.csv(?:.*)?$/) |
|
3295
|
0 |
0 |
if (-f $done) |
|
3304
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
3305
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
3307
|
0 |
0 |
if ($index eq "*") |
|
3311
|
0 |
0 |
if ($self->use_type) |
|
3312
|
0 |
0 |
if ($type eq "*") |
|
3323
|
0 |
0 |
if ($self->is_index_exists($index)) |
|
3325
|
0 |
0 |
unless (defined $count_before) |
|
3334
|
0 |
0 |
unless $self->open_bulk_mode($index, $type) |
|
3342
|
0 |
0 |
unless my $fd = "Metabrik::File::Dump"->new_from_brik_init($self) |
|
3344
|
0 |
0 |
unless my $fc = "Metabrik::File::Csv"->new_from_brik_init($self) |
|
3351
|
0 |
0 |
unless my $wp = "Metabrik::Worker::Parallel"->new_from_brik_init($self) |
|
3354
|
0 |
0 |
unless $wp->create_manager |
|
3379
|
0 |
0 |
if (defined $value and length $value) |
|
3384
|
0 |
0 |
if (defined $cb) |
|
3386
|
0 |
0 |
unless (defined $h) |
|
3401
|
0 |
0 |
if ($@) |
|
3405
|
0 |
0 |
unless (defined $r) |
|
3413
|
0 |
0 |
unless ($imported % 10000) |
|
3428
|
0 |
0 |
if ($first and $self->is_index_exists($index)) |
|
3435
|
0 |
0 |
if ($self->use_indexing_optimizations) |
|
3454
|
0 |
0 |
if ($max > 0 and $imported >= $max) |
|
3460
|
0 |
0 |
if @$list < $batch |
|
3475
|
0 |
0 |
unless my $count_current = $self->count($index, $type) |
|
3480
|
0 |
0 |
$count_current - $count_before == $read ? : |
|
3481
|
0 |
0 |
if ($complete) { } |
|
3500
|
0 |
0 |
unless $fd->write($result, $done) |
|
3503
|
0 |
0 |
if (defined $refresh_interval) |
|
3506
|
0 |
0 |
if (defined $number_of_replicas and $self->use_indexing_optimizations) |
|
3522
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3530
|
0 |
0 |
if ($@) |
|
3547
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3555
|
0 |
0 |
if ($@) |
|
3570
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3576
|
0 |
0 |
if ($@) |
|
3591
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3597
|
0 |
0 |
if ($@) |
|
3612
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3618
|
0 |
0 |
if ($@) |
|
3634
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3635
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_cluster_settings", $settings) |
|
3636
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("put_cluster_settings", $settings, "HASH") |
|
3646
|
0 |
0 |
if ($@) |
|
3657
|
0 |
0 |
unless my $get = $self->show_indices |
|
3661
|
0 |
0 |
if (/^\s*green\s+/) |
|
3672
|
0 |
0 |
unless my $get = $self->show_indices |
|
3676
|
0 |
0 |
if (/^\s*yellow\s+/) |
|
3687
|
0 |
0 |
unless my $get = $self->show_indices |
|
3691
|
0 |
0 |
if (/^\s*red\s+/) |
|
3702
|
0 |
0 |
unless my $get = $self->show_indices |
|
3710
|
0 |
0 |
unless my $get = $self->show_indices |
|
3716
|
0 |
0 |
if (/^\s*red\s+/) { } |
|
|
0 |
0 |
elsif (/^\s*yellow\s+/) { } |
|
|
0 |
0 |
elsif (/^\s*green\s+/) { } |
|
3737
|
0 |
0 |
unless my $indices = $self->get_indices |
|
3751
|
0 |
0 |
unless my $indices = $self->get_indices($string) |
|
3753
|
0 |
0 |
unless my $fn = "Metabrik::Format::Number"->new_from_brik_init($self) |
|
3774
|
0 |
0 |
unless my $indices = $self->get_indices($string) |
|
3776
|
0 |
0 |
unless my $fn = "Metabrik::Format::Number"->new_from_brik_init($self) |
|
3796
|
0 |
0 |
unless my $indices = $self->get_indices |
|
3798
|
0 |
0 |
unless my $fn = "Metabrik::Format::Number"->new_from_brik_init($self) |
|
3814
|
0 |
0 |
unless my $get = $self->get_indices |
|
3818
|
0 |
0 |
if ($_->{'color'} eq "green") |
|
3829
|
0 |
0 |
unless my $get = $self->get_indices |
|
3833
|
0 |
0 |
if ($_->{'color'} eq "yellow") |
|
3844
|
0 |
0 |
unless my $get = $self->get_indices |
|
3848
|
0 |
0 |
if ($_->{'color'} eq "red") |
|
3874
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_hits_total", $run) |
|
3876
|
0 |
0 |
if (ref $run eq "HASH") |
|
3877
|
0 |
0 |
if (exists $run->{'hits'} and exists $run->{'hits'}{'total'}) |
|
3880
|
0 |
0 |
if (ref $run->{'hits'}{'total'} eq "HASH") |
|
3918
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3924
|
0 |
0 |
if ($@) |
|
3948
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3949
|
0 |
0 |
unless $self->brik_help_run_undef_arg("create_snapshot_repository", $body) |
|
3962
|
0 |
0 |
if ($@) |
|
3975
|
0 |
0 |
unless $self->brik_help_run_undef_arg("create_shared_fs_snapshot_repository", $location) |
|
3977
|
0 |
0 |
unless ($location =~ m[^/]) |
|
4000
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4006
|
0 |
0 |
if ($@) |
|
4021
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4027
|
0 |
0 |
if ($@) |
|
4043
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4052
|
0 |
0 |
if (defined $body) |
|
4060
|
0 |
0 |
if ($@) |
|
4072
|
0 |
0 |
unless $self->brik_help_run_undef_arg("create_snapshot_for_indices", $indices) |
|
4087
|
0 |
0 |
unless my $status = $self->get_snapshot_status |
|
4089
|
0 |
0 |
if (@{$status->{'snapshots'};} == 0) |
|
4099
|
0 |
0 |
if ($self->is_snapshot_finished) |
|
4103
|
0 |
0 |
unless my $status = $self->get_snapshot_status |
|
4113
|
0 |
0 |
if ($done) { } |
|
4133
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4134
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_snapshot_repository", $repository_name) |
|
4142
|
0 |
0 |
if ($@) |
|
4155
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4167
|
0 |
0 |
if ($@) |
|
4183
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4184
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_snapshot", $snapshot_name) |
|
4185
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_snapshot", $repository_name) |
|
4197
|
0 |
0 |
if ($@) |
|
4215
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4216
|
0 |
0 |
unless $self->brik_help_run_undef_arg("restore_snapshot", $snapshot_name) |
|
4217
|
0 |
0 |
unless $self->brik_help_run_undef_arg("restore_snapshot", $repository_name) |
|
4223
|
0 |
0 |
if (defined $body) |
|
4231
|
0 |
0 |
if ($@) |
|
4245
|
0 |
0 |
unless $self->brik_help_run_undef_arg("restore_snapshot_for_indices", $indices) |
|
4246
|
0 |
0 |
unless $self->brik_help_run_undef_arg("restore_snapshot_for_indices", $snapshot_name) |
|
4247
|
0 |
0 |
unless $self->brik_help_run_undef_arg("restore_snapshot_for_indices", $repository_name) |