File tree Expand file tree Collapse file tree 1 file changed +24
-2
lines changed Expand file tree Collapse file tree 1 file changed +24
-2
lines changed Original file line number Diff line number Diff line change @@ -35,8 +35,30 @@ sub index_exists ($self, $index) {
35
35
$self -> {es }-> indices-> exists ( index => $index );
36
36
}
37
37
38
- sub index_create ($self , $index ) {
39
- $self -> {es }-> indices-> create( index => $index );
38
+ sub index_create ($self , %args ) {
39
+ my $index = $args {index };
40
+ $index or die " Need an index name to create an index\n " ;
41
+
42
+ my $add_mapping = $args {add_mapping };
43
+ my $delete_first = $args {delete_first };
44
+
45
+ $self -> index_delete($index , 1) if ($delete_first );
46
+
47
+ my @body ;
48
+ if ($add_mapping ) {
49
+ my $home = home();
50
+ my $mapping_file = $home -> child(' conf/es/' . $index . ' /mapping.json' );
51
+ my $mapping = decode_json $mapping_file -> slurp();
52
+ my $settings_file = $home -> child(' conf/es/' . $index . ' /settings.json' );
53
+ my $settings = decode_json $settings_file -> slurp();
54
+
55
+ @body = ( body => {
56
+ settings => $settings ,
57
+ mappings => { $index => $mapping },
58
+ });
59
+ }
60
+
61
+ $self -> {es }-> indices-> create( index => $index , @body );
40
62
}
41
63
42
64
sub index_delete ($self , $index , $skip_exists ) {
You can’t perform that action at this time.
0 commit comments