fix: logs mappings (#125)

* fix: add mappings for logs

* fix: mappings for rollover indices

* Update utils.go

Co-authored-by: Siddharth Kothari <sids.aquarius@gmail.com>

Author: lakhansamani

plugins/logs/dao.go

@@ -42,7 +42,13 @@ func initPlugin(alias, config string) (*elasticsearch, error) {
 	}
 
 	replicas := util.GetReplicas()
-	settings := fmt.Sprintf(config, alias, util.HiddenIndexSettings(), replicas)
+
+	settings := fmt.Sprintf(config, alias, util.HiddenIndexSettings(), replicas, LogsMappings)
+
+	if util.GetVersion() == 6 {
+		mappings := fmt.Sprintf(`{"_doc": %s}`, LogsMappings)
+		settings = fmt.Sprintf(config, alias, util.HiddenIndexSettings(), replicas, mappings)
+	}
 	// Meta index doesn't exist, create one
 	indexName := alias + `-000001`
 	// this works for ES6 client as well
@@ -111,10 +117,19 @@ func (es *elasticsearch) rolloverIndexJob(alias string) {
 	settingsString := fmt.Sprintf(`{%s "index.number_of_shards": 1, "index.number_of_replicas": %d}`, util.HiddenIndexSettings(), util.GetReplicas())
 	settings := make(map[string]interface{})
 	json.Unmarshal([]byte(settingsString), &settings)
+
+	mappingString := LogsMappings
+	if util.GetVersion() == 6 {
+		mappingString = fmt.Sprintf(`{"_doc": %s}`, LogsMappings)
+	}
+
+	mappings := make(map[string]interface{})
+	json.Unmarshal([]byte(mappingString), &mappings)
 	rolloverService, err := es7.NewIndicesRolloverService(util.GetClient7()).
 		Alias(alias).
 		Conditions(rolloverConditions).
 		Settings(settings).
+		Mappings(mappings).
 		Do(ctx)
 	if err != nil {
 		log.Printf(logTag, "error while creating a rollover service %s %v", alias, err)

plugins/logs/logs.go

@@ -29,7 +29,8 @@ const (
 		%s
 	    "index.number_of_shards": 1,
 	    "index.number_of_replicas": %d
-	  }
+	  },
+	  "mappings": %s
 	}`
 	rolloverConfig = `{
 		"max_age":  "%s",