feat: add index to config

Author: d-perl

src/config.rs

@@ -26,6 +26,10 @@ fn default_blocktime_millis() -> usize {
 fn default_consumer() -> String {
     "log-ingestor".into()
 }
+/// Default value for the elastic index
+fn default_index() -> String {
+    "logstash-bec_test123".into()
+}
 
 #[derive(Clone, Debug, Deserialize)]
 pub struct RedisConfig {
@@ -46,6 +50,8 @@ pub struct ElasticConfig {
     pub api_key: String,
     #[serde(default = "default_chunk_size")]
     pub chunk_size: u16,
+    #[serde(default = "default_index")]
+    pub index: String,
 }
 
 #[derive(Clone, Debug, Deserialize)]

src/elastic_push.rs

@@ -53,7 +53,7 @@ pub async fn consumer_loop(rx: &mut mpsc::UnboundedReceiver<LogRecord>, config:
         }
         let body = make_json_body(&buffer).unwrap_or(vec![]);
         let response = elastic_client
-            .bulk(elasticsearch::BulkParts::Index("test-index"))
+            .bulk(elasticsearch::BulkParts::Index(&config.index))
             .body(body)
             .send()
             .await;

src/example_config.toml

@@ -11,6 +11,7 @@ port = 6379
 [elastic]
 api_key = "RjhrMWY1Z0J4ZjV0T0NJQmIzdjU6ZjVURGdmWmVCM3I3ckd2ZmFLUXl6UQ=="
 chunk_size = 100
+index = "logstash-bec_test123"
 
 [elastic.url]
 url = "http://localhost"