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

Signed-off-by: Marat Abrarov <[email protected]>

Author: mabrarov

plugins/out_es/es.c

@@ -645,7 +645,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;

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
@@ -174,4 +175,20 @@ struct flb_elasticsearch {
     struct flb_output_instance *ins;
 };
 
+/**
+ *  Get plugin configuration.
+ *  In HA mode, the selected upstream node is also output.
+ *  In HA mode, the returned plugin configuration matches the output upstream node.
+ *
+ *  @param ctx  Non-NULL plugin context.
+ *  @param node Non-NULL output parameter for selected upstream node.
+ *              `*node` is set to NULL if not in HA mode or
+ *              there is no upstream node.
+ *
+ *  @return Configuration of plugin or NULL if error happened or
+ *          there is no upstream node (in HA mode).
+ */
+struct flb_elasticsearch_config *flb_elasticsearch_target(
+        struct flb_elasticsearch *ctx, struct flb_upstream_node **node);
+
 #endif