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

Signed-off-by: Marat Abrarov <[email protected]>
fluent · Sep 30, 2023 · f6431c2 · f6431c2
1 parent 63ad8e5
commit f6431c2
Show file tree

Hide file tree

Showing 3 changed files with 393 additions and 3 deletions.
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
@@ -164,4 +165,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