pipeline: outputs: es: tests for upstream node configuration properties

mabrarov · mabrarov · commit 4abc828674bc · 2025-05-23T23:26:31.000+03:00
Signed-off-by: Marat Abrarov &lt;abrarov@gmail.com&gt;
diff --git a/plugins/out_es/es.c b/plugins/out_es/es.c
@@ -642,7 +642,7 @@ static int cb_es_init(struct flb_output_instance *ins,
     return 0;
 }
 
-static struct flb_elasticsearch_config *flb_elasticsearch_target(
+struct flb_elasticsearch_config *flb_elasticsearch_target(
         struct flb_elasticsearch *ctx, struct flb_upstream_node **node)
 {
     struct flb_elasticsearch_config *ec;
diff --git a/plugins/out_es/es.h b/plugins/out_es/es.h
@@ -22,6 +22,7 @@
 
 #include <monkey/mk_core/mk_list.h>
 #include <fluent-bit/flb_sds.h>
+#include <fluent-bit/flb_upstream_node.h>
 
 #define FLB_ES_DEFAULT_HOST       "127.0.0.1"
 #define FLB_ES_DEFAULT_PORT       9200
@@ -173,4 +174,7 @@ struct flb_elasticsearch {
     struct flb_output_instance *ins;
 };
 
+struct flb_elasticsearch_config *flb_elasticsearch_target(
+        struct flb_elasticsearch *ctx, struct flb_upstream_node **node);
+
 #endif
diff --git a/tests/runtime/out_elasticsearch.c b/tests/runtime/out_elasticsearch.c

Original file line number	Diff line number	Diff line change
`@@ -642,7 +642,7 @@ static int cb_es_init(struct flb_output_instance *ins,`
`642`	`642`	`return 0;`
`643`	`643`	`}`
`644`	`644`
`645`		`-static struct flb_elasticsearch_config *flb_elasticsearch_target(`
	`645`	`+struct flb_elasticsearch_config *flb_elasticsearch_target(`
`646`	`646`	`struct flb_elasticsearch ctx, struct flb_upstream_node *node)`
`647`	`647`	`{`
`648`	`648`	`struct flb_elasticsearch_config *ec;`