out_tcp: register config_map (#1971)

Signed-off-by: Atibhi Agrawal <[email protected]>

Author: asquare14

plugins/out_tcp/tcp.c

@@ -25,6 +25,7 @@
 #include <fluent-bit/flb_utils.h>
 #include <fluent-bit/flb_pack.h>
 #include <fluent-bit/flb_sds.h>
+#include <fluent-bit/flb_config_map.h>
 #include <msgpack.h>
 
 #include <stdio.h>
@@ -109,12 +110,34 @@ static int cb_tcp_exit(void *data, struct flb_config *config)
     return 0;
 }
 
+/* Configuration properties map */	
+static struct flb_config_map config_map[] = {	
+    {	
+     FLB_CONFIG_MAP_STR, "format", NULL,	
+     0, FLB_FALSE, 0,	
+     NULL	
+    },	
+    {	
+     FLB_CONFIG_MAP_STR, "json_date_format", NULL,	
+     0, FLB_FALSE, 0,	
+     NULL	
+    },	
+    {	
+     FLB_CONFIG_MAP_STR, "json_date_key", "date",	
+     0, FLB_TRUE, offsetof(struct flb_out_tcp, json_date_key),	
+     NULL	
+    },	
+    /* EOF */	
+    {0}	
+};
+
 /* Plugin reference */
 struct flb_output_plugin out_tcp_plugin = {
     .name           = "tcp",
     .description    = "TCP Output",
     .cb_init        = cb_tcp_init,
     .cb_flush       = cb_tcp_flush,
     .cb_exit        = cb_tcp_exit,
+    .config_map     = config_map,
     .flags          = FLB_OUTPUT_NET | FLB_IO_OPT_TLS,
 };

plugins/out_tcp/tcp_conf.c

@@ -42,6 +42,11 @@ struct flb_out_tcp *flb_tcp_conf_create(struct flb_output_instance *ins,
         return NULL;
     }
     ctx->ins = ins;
+    
+    ret = flb_output_config_map_set(ins, (void *) ctx);	
+    if (ret == -1) {	
+        return -1;	
+    }	
 
     /* Set default network configuration if not set */
     flb_output_net_default("127.0.0.1", 5170, ins);
@@ -101,14 +106,6 @@ struct flb_out_tcp *flb_tcp_conf_create(struct flb_output_instance *ins,
         }
     }
 
-    /* Date key for JSON output */
-    tmp = flb_output_get_property("json_date_key", ins);
-    if (tmp) {
-        ctx->json_date_key = flb_sds_create(tmp);
-    }
-    else {
-        ctx->json_date_key = flb_sds_create("date");
-    }
     ctx->u = upstream;
     ctx->host = ins->host.name;
     ctx->port = ins->host.port;
@@ -126,9 +123,6 @@ void flb_tcp_conf_destroy(struct flb_out_tcp *ctx)
         flb_upstream_destroy(ctx->u);
     }
 
-    if (ctx->json_date_key) {
-        flb_sds_destroy(ctx->json_date_key);
-    }
     flb_free(ctx);
     ctx = NULL;
 }