| 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) |
|
485
|
0 |
0 |
if ($count > 1) { } |
|
487
|
0 |
0 |
if (@docs > 0) |
|
495
|
0 |
0 |
if ($@) |
|
497
|
0 |
0 |
if (--$try == 0) |
|
519
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
520
|
0 |
0 |
unless $self->brik_help_run_undef_arg("index_document", $doc) |
|
521
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("index_document", $doc, "HASH") |
|
522
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
523
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
529
|
0 |
0 |
if (defined $id) |
|
533
|
0 |
0 |
if ($self->use_type) |
|
537
|
0 |
0 |
if (defined $hash) |
|
538
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("index_document", $hash, "HASH") |
|
541
|
0 |
0 |
if (defined $hash->{'routing'} and defined $$doc{$hash->{'routing'}}) |
|
551
|
0 |
0 |
if ($@) |
|
568
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
569
|
0 |
0 |
unless $self->brik_help_run_undef_arg("reindex", $index) |
|
570
|
0 |
0 |
unless $self->brik_help_run_undef_arg("reindex", $new) |
|
582
|
0 |
0 |
if ($self->use_type) |
|
583
|
0 |
0 |
if (defined $type) |
|
592
|
0 |
0 |
if ($@) |
|
617
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
623
|
0 |
0 |
unless (defined $nodes) |
|
633
|
0 |
0 |
if ($action eq "indices:data/write/reindex" and not exists $tasks{$task}) |
|
648
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
649
|
0 |
0 |
unless $self->brik_help_run_undef_arg("cancel_reindex_task", $id) |
|
661
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
662
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_taskid", $id) |
|
673
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
675
|
0 |
0 |
unless my $tasks = $self->get_reindex_tasks |
|
676
|
0 |
0 |
unless (keys %$tasks) |
|
682
|
0 |
0 |
unless my $task = $self->get_taskid($id) |
|
706
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
709
|
0 |
0 |
unless $self->show_reindex_progress |
|
721
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
722
|
0 |
0 |
unless $self->brik_help_run_undef_arg("reindex_with_mapping_from_json_file", $index) |
|
724
|
0 |
0 |
unless $self->brik_help_run_undef_arg("reindex_with_mapping_from_json_file", $new) |
|
725
|
0 |
0 |
unless $self->brik_help_run_undef_arg("reindex_with_mapping_from_json_file", $file) |
|
726
|
0 |
0 |
unless $self->brik_help_run_file_not_found("reindex_with_mapping_from_json_file", $file) |
|
729
|
0 |
0 |
unless my $fj = "Metabrik::File::Json"->new_from_brik_init($self) |
|
730
|
0 |
0 |
unless my $json = $fj->read($file) |
|
749
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
750
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_document", $doc) |
|
751
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("update_document", $doc, "HASH") |
|
752
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_document", $id) |
|
753
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
754
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
762
|
0 |
0 |
if ($self->use_type) |
|
766
|
0 |
0 |
if (defined $hash) |
|
767
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("update_document", $hash, "HASH") |
|
776
|
0 |
0 |
if ($@) |
|
794
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_bulk_mode", $bulk) |
|
795
|
0 |
0 |
unless $self->brik_help_run_undef_arg("index_bulk", $doc) |
|
796
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
797
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
802
|
0 |
0 |
if (defined $id) |
|
806
|
0 |
0 |
if (defined $hash) |
|
807
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("index_bulk", $hash, "HASH") |
|
809
|
0 |
0 |
if (defined $hash->{'routing'} and defined $$doc{$hash->{'routing'}}) |
|
819
|
0 |
0 |
if ($@) |
|
822
|
0 |
0 |
if (defined $p and exists $p->{'class'}) { } |
|
848
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_bulk_mode", $bulk) |
|
849
|
0 |
0 |
unless $self->brik_help_run_undef_arg("index_bulk_from_list", $list) |
|
850
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("index_bulk_from_list", $list, "ARRAY") |
|
852
|
0 |
0 |
unless $self->brik_help_run_empty_array_arg("index_bulk_from_list", $list) |
|
854
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
855
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
857
|
0 |
0 |
if (defined $hash) |
|
858
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("index_bulk_from_list", $hash, "HASH") |
|
867
|
0 |
0 |
if (defined $hash) |
|
869
|
0 |
0 |
if (defined $hash->{'routing'} and defined $$doc{$hash->{'routing'}}) |
|
881
|
0 |
0 |
if ($@) |
|
884
|
0 |
0 |
if (defined $p and exists $p->{'class'}) { } |
|
906
|
0 |
0 |
unless $self->brik_help_run_undef_arg("clean_deleted_from_index", $index) |
|
909
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
920
|
0 |
0 |
if ($@) |
|
923
|
0 |
0 |
if (defined $p and exists $p->{'class'}) { } |
|
951
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_bulk_mode", $bulk) |
|
952
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_document_bulk", $doc) |
|
953
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
954
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
961
|
0 |
0 |
if ($self->use_type) |
|
965
|
0 |
0 |
if (defined $id) |
|
969
|
0 |
0 |
if (defined $hash) |
|
970
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("update_document_bulk", $hash, "HASH") |
|
979
|
0 |
0 |
if ($@) |
|
982
|
0 |
0 |
if (defined $p and exists $p->{'class'}) { } |
|
1007
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_bulk_mode", $bulk) |
|
1017
|
0 |
0 |
if ($@) |
|
1019
|
0 |
0 |
if (--$try == 0) |
|
1021
|
0 |
0 |
if (defined $p and exists $p->{'class'}) { } |
|
1038
|
0 |
0 |
if (defined $index) |
|
1056
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1059
|
0 |
0 |
if (defined $index and $index ne "*") |
|
1062
|
0 |
0 |
if ($self->use_type) |
|
1063
|
0 |
0 |
if (defined $type and $type ne "*") |
|
1075
|
0 |
0 |
unless my $version = $self->version |
|
1076
|
0 |
0 |
if ($version ge '5.0.0') { } |
|
1086
|
0 |
0 |
if ($@) |
|
1091
|
0 |
0 |
if ($version ge '5.0.0') { } |
|
|
0 |
0 |
elsif (exists $r->{'hits'} and exists $r->{'hits'}{'total'}) { } |
|
1092
|
0 |
0 |
if (exists $r->{'count'}) |
|
1120
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1121
|
0 |
0 |
unless $self->brik_help_run_undef_arg("query", $query) |
|
1122
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
1123
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
1124
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("query", $query, "HASH") |
|
1134
|
0 |
0 |
if ($es_version == 7) |
|
1138
|
0 |
0 |
if (defined $hash) |
|
1139
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("query", $hash, "HASH") |
|
1143
|
0 |
0 |
if ($self->use_type) |
|
1144
|
0 |
0 |
if ($type ne "*") |
|
1153
|
0 |
0 |
if ($@) |
|
1168
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1169
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_from_id", $id) |
|
1170
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
1171
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
1179
|
0 |
0 |
if ($self->use_type) |
|
1184
|
0 |
0 |
if ($@) |
|
1201
|
0 |
0 |
unless $self->brik_help_run_undef_arg("www_search", $query) |
|
1202
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
1203
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
1208
|
0 |
0 |
unless my $sj = "Metabrik::String::Json"->new_from_brik_init($self) |
|
1214
|
0 |
0 |
if ($self->use_type) |
|
1215
|
0 |
0 |
if ($type ne "*") |
|
1221
|
0 |
0 |
unless my $get = $self->SUPER::get($url) |
|
1224
|
0 |
0 |
unless my $decoded = $sj->decode($body) |
|
1240
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1241
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_index", $index) |
|
1242
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("delete_index", $index, "ARRAY", "SCALAR") |
|
1252
|
0 |
0 |
if ($@) |
|
1272
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1273
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_document", $index) |
|
1274
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_document", $id) |
|
1281
|
0 |
0 |
if ($self->use_type) |
|
1285
|
0 |
0 |
if (defined $hash) |
|
1286
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("delete_document", $hash, "HASH") |
|
1295
|
0 |
0 |
if ($@) |
|
1313
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1314
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_by_query", $query) |
|
1315
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_by_query", $index) |
|
1316
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_by_query", $type) |
|
1317
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("delete_by_query", $query, "HASH") |
|
1326
|
0 |
0 |
if ($self->use_type) |
|
1330
|
0 |
0 |
if (defined $proceed and $proceed) |
|
1338
|
0 |
0 |
if ($@) |
|
1359
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1365
|
0 |
0 |
if ($@) |
|
1372
|
0 |
0 |
if (@lines == 0) |
|
1377
|
0 |
0 |
if (defined $string) |
|
1379
|
0 |
0 |
if (/$string/) |
|
1396
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1402
|
0 |
0 |
if ($@) |
|
1409
|
0 |
0 |
if (@lines == 0) |
|
1423
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1429
|
0 |
0 |
if ($@) |
|
1436
|
0 |
0 |
if (@lines == 0) |
|
1450
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1456
|
0 |
0 |
if ($@) |
|
1463
|
0 |
0 |
if (@lines == 0) |
|
1477
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1483
|
0 |
0 |
if ($@) |
|
1490
|
0 |
0 |
if (@lines == 0) |
|
1501
|
0 |
0 |
unless my $get = $self->get_indices |
|
1505
|
0 |
0 |
if (defined $regex) { } |
|
1506
|
0 |
0 |
if ($_->{'index'} =~ /$regex/) |
|
1522
|
0 |
0 |
unless my $lines = $self->show_indices($string) |
|
1523
|
0 |
0 |
if (@$lines == 0) |
|
1537
|
0 |
0 |
if (@t == 10) { } |
|
|
0 |
0 |
elsif (@t == 9) { } |
|
|
0 |
0 |
elsif (@t == 8) { } |
|
1585
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1586
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index", $index) |
|
1587
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_index", $index, "ARRAY", "SCALAR") |
|
1597
|
0 |
0 |
if ($@) |
|
1610
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1611
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index", $index) |
|
1621
|
0 |
0 |
if ($@) |
|
1635
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1636
|
0 |
0 |
unless $self->brik_help_run_undef_arg("list_index_types", $index) |
|
1637
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("list_index_types", $index, "SCALAR") |
|
1639
|
0 |
0 |
unless my $r = $self->get_mappings($index) |
|
1640
|
0 |
0 |
if (keys %$r > 1) |
|
1665
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1666
|
0 |
0 |
unless $self->brik_help_run_undef_arg("list_index_fields", $index) |
|
1667
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("list_index_fields", $index, "SCALAR") |
|
1670
|
0 |
0 |
if (defined $type) { } |
|
1671
|
0 |
0 |
unless $r = $self->get_mappings($index, $type) |
|
1672
|
0 |
0 |
if (keys %$r > 1) |
|
1677
|
0 |
0 |
if ($self->is_mapping_exists($index, "_default_")) |
|
1687
|
0 |
0 |
unless $r = $self->get_mappings($index) |
|
1688
|
0 |
0 |
if (keys %$r > 1) |
|
1713
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1714
|
0 |
0 |
unless $self->brik_help_run_undef_arg("list_indices_version", $index) |
|
1715
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("list_indices_version", $index, "ARRAY", "SCALAR") |
|
1718
|
0 |
0 |
unless my $r = $self->get_index($index) |
|
1738
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1739
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open_index", $index) |
|
1740
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("open_index", $index, "ARRAY", "SCALAR") |
|
1748
|
0 |
0 |
if ($@) |
|
1761
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1762
|
0 |
0 |
unless $self->brik_help_run_undef_arg("close_index", $index) |
|
1763
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("close_index", $index, "ARRAY", "SCALAR") |
|
1771
|
0 |
0 |
if ($@) |
|
1788
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1807
|
0 |
0 |
if ($@) |
|
1828
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1829
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_alias", $index) |
|
1830
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_alias", $alias) |
|
1841
|
0 |
0 |
if ($@) |
|
1857
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1858
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_alias", $index) |
|
1859
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_alias", $alias) |
|
1870
|
0 |
0 |
if ($@) |
|
1883
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1884
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_alias", $new_index) |
|
1885
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_alias", $alias) |
|
1889
|
0 |
0 |
unless my $aliases = $self->get_aliases |
|
1892
|
0 |
0 |
if ($this eq $alias) |
|
1897
|
0 |
0 |
if $prev_index |
|
1901
|
0 |
0 |
if (defined $prev_index) |
|
1902
|
0 |
0 |
unless $self->delete_alias($prev_index, $alias) |
|
1912
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_mapping_exists", $index) |
|
1913
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_mapping_exists", $mapping) |
|
1915
|
0 |
0 |
unless ($self->is_index_exists($index)) |
|
1919
|
0 |
0 |
unless my $all = $self->get_mappings($index) |
|
1923
|
0 |
0 |
if ($this_mapping eq $mapping) |
|
1940
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1941
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_mappings", $index) |
|
1942
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_mappings", $index, "ARRAY", "SCALAR") |
|
1949
|
0 |
0 |
if ($self->use_type) |
|
1957
|
0 |
0 |
if ($@) |
|
1974
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
1975
|
0 |
0 |
unless $self->brik_help_run_undef_arg("create_index", $index) |
|
1981
|
0 |
0 |
if (defined $shards) |
|
1989
|
0 |
0 |
if ($@) |
|
2006
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2007
|
0 |
0 |
unless $self->brik_help_run_undef_arg("create_index_with_mappings", $index) |
|
2008
|
0 |
0 |
unless $self->brik_help_run_undef_arg("create_index_with_mappings", $mappings) |
|
2009
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("create_index_with_mappings", $mappings, "HASH") |
|
2021
|
0 |
0 |
if ($@) |
|
2036
|
0 |
0 |
unless $self->brik_help_run_undef_arg("info", $nodes) |
|
2037
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("info", $nodes, "ARRAY") |
|
2038
|
0 |
0 |
unless $self->brik_help_run_empty_array_arg("info", $nodes) |
|
2042
|
0 |
0 |
unless $self->get($first) |
|
2052
|
0 |
0 |
unless $self->brik_help_run_undef_arg("version", $nodes) |
|
2053
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("version", $nodes, "ARRAY") |
|
2054
|
0 |
0 |
unless $self->brik_help_run_empty_array_arg("version", $nodes) |
|
2058
|
0 |
0 |
unless $self->get($first) |
|
2059
|
0 |
0 |
unless my $content = $self->content |
|
2071
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2077
|
0 |
0 |
if ($@) |
|
2088
|
0 |
0 |
unless my $content = $self->get_templates |
|
2101
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2102
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_template", $template) |
|
2110
|
0 |
0 |
if ($@) |
|
2123
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2124
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_mapping", $index) |
|
2125
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_mapping", $type) |
|
2126
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_mapping", $mapping) |
|
2127
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("put_mapping", $mapping, "HASH") |
|
2136
|
0 |
0 |
if ($self->use_type) |
|
2141
|
0 |
0 |
if ($@) |
|
2158
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2159
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_template", $name) |
|
2160
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_template", $template) |
|
2161
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("put_template", $template, "HASH") |
|
2171
|
0 |
0 |
if ($@) |
|
2185
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2186
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_mapping_from_json_file", $index) |
|
2188
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_mapping_from_json_file", $type) |
|
2190
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_mapping_from_json_file", $json_file) |
|
2192
|
0 |
0 |
unless $self->brik_help_run_file_not_found("put_mapping_from_json_file", $json_file) |
|
2195
|
0 |
0 |
unless my $fj = "Metabrik::File::Json"->new_from_brik_init($self) |
|
2196
|
0 |
0 |
unless my $data = $fj->read($json_file) |
|
2198
|
0 |
0 |
unless (exists $data->{'mappings'}) |
|
2211
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2212
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_mapping_from_json_file", $json_file) |
|
2214
|
0 |
0 |
unless $self->brik_help_run_file_not_found("update_mapping_from_json_file", $json_file) |
|
2216
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_mapping_from_json_file", $type) |
|
2218
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_mapping_from_json_file", $index) |
|
2221
|
0 |
0 |
unless my $fj = "Metabrik::File::Json"->new_from_brik_init($self) |
|
2222
|
0 |
0 |
unless my $data = $fj->read($json_file) |
|
2224
|
0 |
0 |
unless (exists $data->{'mappings'}) |
|
2239
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2240
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_template_from_json_file", $json_file) |
|
2242
|
0 |
0 |
unless $self->brik_help_run_file_not_found("put_template_from_json_file", $json_file) |
|
2245
|
0 |
0 |
unless my $fj = "Metabrik::File::Json"->new_from_brik_init($self) |
|
2246
|
0 |
0 |
unless my $data = $fj->read($json_file) |
|
2248
|
0 |
0 |
unless (defined $name) |
|
2252
|
0 |
0 |
unless (defined $name) |
|
2265
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2266
|
0 |
0 |
unless $self->brik_help_run_undef_arg("update_template_from_json_file", $json_file) |
|
2268
|
0 |
0 |
unless $self->brik_help_run_file_not_found("update_template_from_json_file", $json_file) |
|
2271
|
0 |
0 |
unless my $fj = "Metabrik::File::Json"->new_from_brik_init($self) |
|
2272
|
0 |
0 |
unless my $data = $fj->read($json_file) |
|
2274
|
0 |
0 |
unless (defined $name) |
|
2278
|
0 |
0 |
unless (defined $name) |
|
2298
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2301
|
0 |
0 |
if (defined $indices) |
|
2302
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_settings", $indices) |
|
2303
|
0 |
0 |
unless my $ref = $self->brik_help_run_invalid_arg("get_settings", $indices, "ARRAY", "SCALAR") |
|
2307
|
0 |
0 |
if (defined $names) |
|
2308
|
0 |
0 |
unless $self->brik_help_run_file_not_found("get_settings", $names) |
|
2309
|
0 |
0 |
unless my $ref = $self->brik_help_run_invalid_arg("get_settings", $names, "ARRAY", "SCALAR") |
|
2318
|
0 |
0 |
if ($@) |
|
2341
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2342
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_settings", $settings) |
|
2343
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("put_settings", $settings, "HASH") |
|
2348
|
0 |
0 |
if (defined $indices) |
|
2349
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_settings", $indices) |
|
2350
|
0 |
0 |
unless my $ref = $self->brik_help_run_invalid_arg("put_settings", $indices, "ARRAY", "SCALAR") |
|
2359
|
0 |
0 |
if ($@) |
|
2372
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2373
|
0 |
0 |
unless $self->brik_help_run_undef_arg("set_index_readonly", $indices) |
|
2374
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("set_index_readonly", $indices, "ARRAY", "SCALAR") |
|
2377
|
0 |
0 |
if (not defined $bool) { } |
|
2381
|
0 |
0 |
$bool ? : |
|
2426
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2427
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("reset_index_readonly", $indices, "ARRAY", "SCALAR") |
|
2447
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2449
|
0 |
0 |
unless my $list = $self->list_indices |
|
2453
|
0 |
0 |
unless my $ro = $self->get_index_readonly($this) |
|
2454
|
0 |
0 |
if (defined $ro->{'index'}{'provided_name'}) |
|
2467
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2468
|
0 |
0 |
unless $self->brik_help_run_undef_arg("set_index_number_of_replicas", $indices) |
|
2469
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("set_index_number_of_replicas", $indices, "ARRAY", "SCALAR") |
|
2482
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2483
|
0 |
0 |
unless $self->brik_help_run_undef_arg("set_index_refresh_interval", $indices) |
|
2484
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("set_index_refresh_interval", $indices, "ARRAY", "SCALAR") |
|
2489
|
0 |
0 |
if ($number =~ /^\d+$/ and $number > 0) |
|
2503
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2504
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index_settings", $indices) |
|
2505
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_index_settings", $indices, "ARRAY", "SCALAR") |
|
2523
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2524
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index_readonly", $indices) |
|
2525
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_index_readonly", $indices, "ARRAY", "SCALAR") |
|
2544
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2545
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index_number_of_replicas", $indices) |
|
2546
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_index_number_of_replicas", $indices, "ARRAY", "SCALAR") |
|
2564
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2565
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index_refresh_interval", $indices) |
|
2566
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_index_refresh_interval", $indices, "ARRAY", "SCALAR") |
|
2584
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2585
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_index_number_of_shards", $indices) |
|
2586
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("get_index_number_of_shards", $indices, "ARRAY", "SCALAR") |
|
2607
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2608
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_template", $name) |
|
2616
|
0 |
0 |
if ($@) |
|
2632
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2633
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_index_exists", $index) |
|
2641
|
0 |
0 |
if ($@) |
|
2646
|
0 |
0 |
$r ? : |
|
2657
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2658
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_type_exists", $index) |
|
2659
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_type_exists", $type) |
|
2666
|
0 |
0 |
if ($self->use_type) |
|
2671
|
0 |
0 |
if ($@) |
|
2677
|
0 |
0 |
$r ? : |
|
2688
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2689
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_document_exists", $index) |
|
2690
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_document_exists", $type) |
|
2691
|
0 |
0 |
unless $self->brik_help_run_undef_arg("is_document_exists", $document) |
|
2692
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("is_document_exists", $document, "HASH") |
|
2700
|
0 |
0 |
if ($self->use_type) |
|
2705
|
0 |
0 |
if ($@) |
|
2711
|
0 |
0 |
$r ? : |
|
2718
|
0 |
0 |
unless $self->brik_help_run_undef_arg("parse_error_string", $string) |
|
2725
|
0 |
0 |
if (defined $dump and length $dump) |
|
2726
|
0 |
0 |
unless my $sd = "Metabrik::String::Dump"->new_from_brik_init($self) |
|
2731
|
0 |
0 |
if (defined $node and $node =~ /^http/ and $code =~ /^\d+$/ and defined $dump and ref $dump eq "HASH") |
|
2759
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2760
|
0 |
0 |
unless $self->brik_help_run_undef_arg("refresh_index", $index) |
|
2772
|
0 |
0 |
if ($@) |
|
2773
|
0 |
0 |
if (--$try == 0) |
|
2776
|
0 |
0 |
if (defined $p and exists $p->{'class'}) { } |
|
2801
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
2802
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as", $format) |
|
2803
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as", $index) |
|
2804
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as", $size) |
|
2806
|
0 |
0 |
if ($format ne "csv" and $format ne "json") |
|
2817
|
0 |
0 |
unless my $version = $self->version |
|
2818
|
0 |
0 |
if ($version lt '5.0.0') { } |
|
2819
|
0 |
0 |
unless $scroll = $self->open_scroll_scan_mode($index, $size) |
|
2822
|
0 |
0 |
unless $scroll = $self->open_scroll($index, $size) |
|
2827
|
0 |
0 |
unless my $fd = "Metabrik::File::Dump"->new_from_brik_init($self) |
|
2831
|
0 |
0 |
if ($format eq 'csv') { } |
|
|
0 |
0 |
elsif ($format eq 'json') { } |
|
2832
|
0 |
0 |
unless $out = "Metabrik::File::Csv"->new_from_brik_init($self) |
|
2840
|
0 |
0 |
if (defined $self->csv_header) |
|
2844
|
0 |
0 |
if (defined $self->csv_encoded_fields) |
|
2847
|
0 |
0 |
if (defined $self->csv_object_fields) |
|
2854
|
0 |
0 |
unless $out = "Metabrik::File::Json"->new_from_brik_init($self) |
|
2873
|
0 |
0 |
if (defined $cb) |
|
2875
|
0 |
0 |
unless (defined $this) |
|
2887
|
0 |
0 |
unless (exists $types{$type}) |
|
2888
|
0 |
0 |
if ($format eq 'csv') { } |
|
|
0 |
0 |
elsif ($format eq 'json') { } |
|
2890
|
0 |
0 |
if (not defined $csv_header) { } |
|
2891
|
0 |
0 |
unless my $fields = $self->list_index_fields($index, $type) |
|
2906
|
0 |
0 |
if (-f $done) |
|
2922
|
0 |
0 |
if ($format eq "csv") |
|
2927
|
0 |
0 |
if (@{$chunk{$type};} > 999) |
|
2929
|
0 |
0 |
unless (defined $r) |
|
2939
|
0 |
0 |
unless (++$exported % 100000) |
|
2949
|
0 |
0 |
if ($max > 0 and $exported >= $max) |
|
2960
|
0 |
0 |
if (@{$chunk{$type};} > 0) |
|
2971
|
0 |
0 |
if ($duration > 0) |
|
2983
|
0 |
0 |
$exported == $total ? : |
|
2987
|
0 |
0 |
unless $fd->write($result, $done) |
|
3000
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3001
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as_csv", $index) |
|
3002
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as_csv", $size) |
|
3013
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3014
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as_json", $index) |
|
3015
|
0 |
0 |
unless $self->brik_help_run_undef_arg("export_as_json", $size) |
|
3029
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3030
|
0 |
0 |
unless $self->brik_help_run_undef_arg("import_from", $format) |
|
3031
|
0 |
0 |
unless $self->brik_help_run_undef_arg("import_from", $input) |
|
3032
|
0 |
0 |
unless $self->brik_help_run_file_not_found("import_from", $input) |
|
3034
|
0 |
0 |
if ($format ne "csv" and $format ne "json") |
|
3041
|
0 |
0 |
unless (defined $index and defined $type) |
|
3043
|
0 |
0 |
if ($input =~ /^(.+):(.+)\.(?:csv|json)(?:.*)?$/) |
|
3053
|
0 |
0 |
if (-f $done) |
|
3062
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
3063
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
3065
|
0 |
0 |
if ($index eq "*") |
|
3069
|
0 |
0 |
if ($self->use_type) |
|
3070
|
0 |
0 |
if ($type eq "*") |
|
3081
|
0 |
0 |
if ($self->is_index_exists($index)) |
|
3083
|
0 |
0 |
unless (defined $count_before) |
|
3092
|
0 |
0 |
unless $self->open_bulk_mode($index, $type) |
|
3097
|
0 |
0 |
unless my $fd = "Metabrik::File::Dump"->new_from_brik_init($self) |
|
3100
|
0 |
0 |
if ($format eq 'csv') { } |
|
|
0 |
0 |
elsif ($format eq 'json') { } |
|
3101
|
0 |
0 |
unless $out = "Metabrik::File::Csv"->new_from_brik_init($self) |
|
3110
|
0 |
0 |
unless $out = "Metabrik::File::Json"->new_from_brik_init($self) |
|
3127
|
0 |
0 |
$self->use_ignore_id ? : |
|
3133
|
0 |
0 |
if (defined $value and length $value) |
|
3138
|
0 |
0 |
if (defined $cb) |
|
3140
|
0 |
0 |
unless (defined $h) |
|
3150
|
0 |
0 |
if (defined $hash and defined $hash->{'routing'} and defined $$h{$hash->{'routing'}}) |
|
3163
|
0 |
0 |
if ($@) |
|
3167
|
0 |
0 |
unless (defined $r) |
|
3177
|
0 |
0 |
if ($first and $self->is_index_exists($index)) |
|
3184
|
0 |
0 |
if ($self->use_indexing_optimizations) |
|
3192
|
0 |
0 |
unless (++$imported % 100000) |
|
3200
|
0 |
0 |
if ($max > 0 and $imported >= $max) |
|
3215
|
0 |
0 |
unless my $count_current = $self->count($index, $type) |
|
3220
|
0 |
0 |
$count_current - $count_before == $read ? : |
|
3221
|
0 |
0 |
if ($complete) { } |
|
3240
|
0 |
0 |
unless $fd->write($result, $done) |
|
3243
|
0 |
0 |
if (defined $refresh_interval) |
|
3246
|
0 |
0 |
if (defined $number_of_replicas and $self->use_indexing_optimizations) |
|
3258
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3259
|
0 |
0 |
unless $self->brik_help_run_undef_arg("import_from_csv", $input) |
|
3260
|
0 |
0 |
unless $self->brik_help_run_file_not_found("import_from_csv", $input) |
|
3271
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3272
|
0 |
0 |
unless $self->brik_help_run_undef_arg("import_from_json", $input) |
|
3273
|
0 |
0 |
unless $self->brik_help_run_file_not_found("import_from_json", $input) |
|
3287
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3288
|
0 |
0 |
unless $self->brik_help_run_undef_arg("import_from_csv_worker", $input_csv) |
|
3290
|
0 |
0 |
unless $self->brik_help_run_file_not_found("import_from_csv_worker", $input_csv) |
|
3294
|
0 |
0 |
unless (defined $index and defined $type) |
|
3296
|
0 |
0 |
if ($input_csv =~ /^(.+):(.+)\.csv(?:.*)?$/) |
|
3305
|
0 |
0 |
if (-f $done) |
|
3314
|
0 |
0 |
unless $self->brik_help_set_undef_arg("index", $index) |
|
3315
|
0 |
0 |
unless $self->brik_help_set_undef_arg("type", $type) |
|
3317
|
0 |
0 |
if ($index eq "*") |
|
3321
|
0 |
0 |
if ($self->use_type) |
|
3322
|
0 |
0 |
if ($type eq "*") |
|
3333
|
0 |
0 |
if ($self->is_index_exists($index)) |
|
3335
|
0 |
0 |
unless (defined $count_before) |
|
3344
|
0 |
0 |
unless $self->open_bulk_mode($index, $type) |
|
3352
|
0 |
0 |
unless my $fd = "Metabrik::File::Dump"->new_from_brik_init($self) |
|
3354
|
0 |
0 |
unless my $fc = "Metabrik::File::Csv"->new_from_brik_init($self) |
|
3361
|
0 |
0 |
unless my $wp = "Metabrik::Worker::Parallel"->new_from_brik_init($self) |
|
3364
|
0 |
0 |
unless $wp->create_manager |
|
3389
|
0 |
0 |
if (defined $value and length $value) |
|
3394
|
0 |
0 |
if (defined $cb) |
|
3396
|
0 |
0 |
unless (defined $h) |
|
3411
|
0 |
0 |
if ($@) |
|
3415
|
0 |
0 |
unless (defined $r) |
|
3423
|
0 |
0 |
unless ($imported % 10000) |
|
3438
|
0 |
0 |
if ($first and $self->is_index_exists($index)) |
|
3445
|
0 |
0 |
if ($self->use_indexing_optimizations) |
|
3464
|
0 |
0 |
if ($max > 0 and $imported >= $max) |
|
3470
|
0 |
0 |
if @$list < $batch |
|
3485
|
0 |
0 |
unless my $count_current = $self->count($index, $type) |
|
3490
|
0 |
0 |
$count_current - $count_before == $read ? : |
|
3491
|
0 |
0 |
if ($complete) { } |
|
3510
|
0 |
0 |
unless $fd->write($result, $done) |
|
3513
|
0 |
0 |
if (defined $refresh_interval) |
|
3516
|
0 |
0 |
if (defined $number_of_replicas and $self->use_indexing_optimizations) |
|
3532
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3540
|
0 |
0 |
if ($@) |
|
3557
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3565
|
0 |
0 |
if ($@) |
|
3580
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3586
|
0 |
0 |
if ($@) |
|
3601
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3607
|
0 |
0 |
if ($@) |
|
3622
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3628
|
0 |
0 |
if ($@) |
|
3644
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3645
|
0 |
0 |
unless $self->brik_help_run_undef_arg("put_cluster_settings", $settings) |
|
3646
|
0 |
0 |
unless $self->brik_help_run_invalid_arg("put_cluster_settings", $settings, "HASH") |
|
3656
|
0 |
0 |
if ($@) |
|
3667
|
0 |
0 |
unless my $get = $self->show_indices |
|
3671
|
0 |
0 |
if (/^\s*green\s+/) |
|
3682
|
0 |
0 |
unless my $get = $self->show_indices |
|
3686
|
0 |
0 |
if (/^\s*yellow\s+/) |
|
3697
|
0 |
0 |
unless my $get = $self->show_indices |
|
3701
|
0 |
0 |
if (/^\s*red\s+/) |
|
3712
|
0 |
0 |
unless my $get = $self->show_indices |
|
3720
|
0 |
0 |
unless my $get = $self->show_indices |
|
3726
|
0 |
0 |
if (/^\s*red\s+/) { } |
|
|
0 |
0 |
elsif (/^\s*yellow\s+/) { } |
|
|
0 |
0 |
elsif (/^\s*green\s+/) { } |
|
3747
|
0 |
0 |
unless my $indices = $self->get_indices |
|
3761
|
0 |
0 |
unless my $indices = $self->get_indices($string) |
|
3763
|
0 |
0 |
unless my $fn = "Metabrik::Format::Number"->new_from_brik_init($self) |
|
3784
|
0 |
0 |
unless my $indices = $self->get_indices($string) |
|
3786
|
0 |
0 |
unless my $fn = "Metabrik::Format::Number"->new_from_brik_init($self) |
|
3806
|
0 |
0 |
unless my $indices = $self->get_indices |
|
3808
|
0 |
0 |
unless my $fn = "Metabrik::Format::Number"->new_from_brik_init($self) |
|
3824
|
0 |
0 |
unless my $get = $self->get_indices |
|
3828
|
0 |
0 |
if ($_->{'color'} eq "green") |
|
3839
|
0 |
0 |
unless my $get = $self->get_indices |
|
3843
|
0 |
0 |
if ($_->{'color'} eq "yellow") |
|
3854
|
0 |
0 |
unless my $get = $self->get_indices |
|
3858
|
0 |
0 |
if ($_->{'color'} eq "red") |
|
3884
|
0 |
0 |
unless $self->brik_help_run_undef_arg("get_hits_total", $run) |
|
3886
|
0 |
0 |
if (ref $run eq "HASH") |
|
3887
|
0 |
0 |
if (exists $run->{'hits'} and exists $run->{'hits'}{'total'}) |
|
3890
|
0 |
0 |
if (ref $run->{'hits'}{'total'} eq "HASH") |
|
3928
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3934
|
0 |
0 |
if ($@) |
|
3958
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
3959
|
0 |
0 |
unless $self->brik_help_run_undef_arg("create_snapshot_repository", $body) |
|
3972
|
0 |
0 |
if ($@) |
|
3985
|
0 |
0 |
unless $self->brik_help_run_undef_arg("create_shared_fs_snapshot_repository", $location) |
|
3987
|
0 |
0 |
unless ($location =~ m[^/]) |
|
4010
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4016
|
0 |
0 |
if ($@) |
|
4031
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4037
|
0 |
0 |
if ($@) |
|
4053
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4062
|
0 |
0 |
if (defined $body) |
|
4070
|
0 |
0 |
if ($@) |
|
4082
|
0 |
0 |
unless $self->brik_help_run_undef_arg("create_snapshot_for_indices", $indices) |
|
4097
|
0 |
0 |
unless my $status = $self->get_snapshot_status |
|
4099
|
0 |
0 |
if (@{$status->{'snapshots'};} == 0) |
|
4109
|
0 |
0 |
if ($self->is_snapshot_finished) |
|
4113
|
0 |
0 |
unless my $status = $self->get_snapshot_status |
|
4123
|
0 |
0 |
if ($done) { } |
|
4143
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4144
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_snapshot_repository", $repository_name) |
|
4152
|
0 |
0 |
if ($@) |
|
4165
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4177
|
0 |
0 |
if ($@) |
|
4193
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4194
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_snapshot", $snapshot_name) |
|
4195
|
0 |
0 |
unless $self->brik_help_run_undef_arg("delete_snapshot", $repository_name) |
|
4207
|
0 |
0 |
if ($@) |
|
4225
|
0 |
0 |
unless $self->brik_help_run_undef_arg("open", $es) |
|
4226
|
0 |
0 |
unless $self->brik_help_run_undef_arg("restore_snapshot", $snapshot_name) |
|
4227
|
0 |
0 |
unless $self->brik_help_run_undef_arg("restore_snapshot", $repository_name) |
|
4233
|
0 |
0 |
if (defined $body) |
|
4241
|
0 |
0 |
if ($@) |
|
4255
|
0 |
0 |
unless $self->brik_help_run_undef_arg("restore_snapshot_for_indices", $indices) |
|
4256
|
0 |
0 |
unless $self->brik_help_run_undef_arg("restore_snapshot_for_indices", $snapshot_name) |
|
4257
|
0 |
0 |
unless $self->brik_help_run_undef_arg("restore_snapshot_for_indices", $repository_name) |