Added support for setting fresh_interval for elasticsearch template

BenB196 · Sep 24, 2019 · ce2cdcf · ce2cdcf
1 parent 2526b30
commit ce2cdcf
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 1 deletion.
diff --git a/README.md b/README.md
@@ -121,7 +121,8 @@ Currently, only JSON formatted configuration files are accepted, in the future Y
       "indexTimeGen": "onOrBefore",                                                                                         #How to determine what time to use for the time stamp. Supports timeNow, onOrBefore, eventTimestamp, or insertionTimestamp.
       "elasticUrl": "http://elasticsearch:9200",                                                                            #The elasticsearch URL
       "sniffing": false,                                                                                                    #This determines whether the application will automatically try update its elasticsearch node list
-      "bestCompression": false,                                                                                            #This allows for indexes to be created with best_compression codec enabled
+      "bestCompression": false,                                                                                             #This allows for indexes to be created with best_compression codec enabled
+      "refreshInterval": 30,                                                                                                #This allows you to set the refresh interval (in seconds) of the index template. If empty it disables refresh interval
       "basicAuth": {                                                                                                        #If you are using basic auth with elasticsearch
         "user": "",
         "password": ""

diff --git a/config/configReader.go b/config/configReader.go
@@ -54,6 +54,7 @@ type Elasticsearch struct {
 	BasicAuth			BasicAuth	`json:"basicAuth,omitempty"`
 	Sniffing			bool		`json:"sniffing,omitempty"`
 	BestCompression		bool		`json:"bestCompression,omitempty"`
+	RefreshInterval		int			`json:"refreshInterval,omitempty"`
 	Aliases				[]string	`json:"aliases,omitempty"`
 }
 

diff --git a/elasticsearch/elasticsearch.go b/elasticsearch/elasticsearch.go
@@ -60,9 +60,17 @@ func BuildIndexPattern(elasticConfig config.Elasticsearch) string {
 		codec = ""
 	}
 
+	var refreshInterval string
+	if elasticConfig.RefreshInterval == 0 {
+		refreshInterval = "-1"
+	} else {
+		refreshInterval = strconv.Itoa(elasticConfig.RefreshInterval) + "s"
+	}
+
 	index := "{" +
 		"  \"settings\": {" +
 		codec +
+		"    \"refresh_interval\": \"" + refreshInterval + "\"," +
 		"    \"number_of_shards\": " + strconv.Itoa(elasticConfig.NumberOfShards) + "," +
 		"    \"number_of_replicas\": " + strconv.Itoa(elasticConfig.NumberOfReplicas) + "" +
 		"  }," +