plugin_proxy: api: Expose CMetrics context to Golang plugins

Signed-off-by: Hiroshi Hatake <[email protected]>

include/fluent-bit/flb_api.h

@@ -26,6 +26,9 @@
 struct flb_api {
     const char *(*output_get_property) (const char *, struct flb_output_instance *);
     const char *(*input_get_property) (const char *, struct flb_input_instance *);
+
+    void *(*output_get_cmt_instance) (struct flb_output_instance *);
+    void *(*input_get_cmt_instance) (struct flb_input_instance *);
 };
 
 #ifdef FLB_CORE

include/fluent-bit/flb_input.h

@@ -509,6 +509,9 @@ int flb_input_set_property(struct flb_input_instance *ins,
                            const char *k, const char *v);
 const char *flb_input_get_property(const char *key,
                                    struct flb_input_instance *ins);
+#ifdef FLB_HAVE_METRICS
+void *flb_input_get_cmt_instance(struct flb_input_instance *ins);
+#endif
 
 int flb_input_check(struct flb_config *config);
 void flb_input_set_context(struct flb_input_instance *ins, void *context);

include/fluent-bit/flb_output.h

@@ -728,6 +728,9 @@ const char *flb_output_name(struct flb_output_instance *in);
 int flb_output_set_property(struct flb_output_instance *out,
                             const char *k, const char *v);
 const char *flb_output_get_property(const char *key, struct flb_output_instance *ins);
+#ifdef FLB_HAVE_METRICS
+void *flb_output_get_cmt_instance(struct flb_output_instance *ins);
+#endif
 void flb_output_net_default(const char *host, int port,
                             struct flb_output_instance *ins);
 const char *flb_output_name(struct flb_output_instance *ins);

src/flb_api.c

@@ -21,6 +21,7 @@
 #include <fluent-bit/flb_api.h>
 #include <fluent-bit/flb_mem.h>
 
+#include <fluent-bit/flb_input.h>
 #include <fluent-bit/flb_output.h>
 
 struct flb_api *flb_api_create()
@@ -35,6 +36,12 @@ struct flb_api *flb_api_create()
 
     api->output_get_property = flb_output_get_property;
     api->input_get_property = flb_input_get_property;
+
+#ifdef FLB_HAVE_METRICS
+    api->output_get_cmt_instance = flb_output_get_cmt_instance;
+    api->input_get_cmt_instance = flb_input_get_cmt_instance;
+#endif
+
     return api;
 }
 

src/flb_input.c

@@ -475,6 +475,13 @@ const char *flb_input_get_property(const char *key,
     return flb_config_prop_get(key, &ins->properties);
 }
 
+#ifdef FLB_HAVE_METRICS
+void *flb_input_get_cmt_instance(struct flb_input_instance *ins)
+{
+    return (void *)ins->cmt;
+}
+#endif
+
 /* Return an instance name or alias */
 const char *flb_input_name(struct flb_input_instance *ins)
 {

src/flb_output.c

@@ -807,6 +807,13 @@ const char *flb_output_get_property(const char *key, struct flb_output_instance
     return flb_config_prop_get(key, &ins->properties);
 }
 
+#ifdef FLB_HAVE_METRICS
+void *flb_output_get_cmt_instance(struct flb_output_instance *ins)
+{
+    return (void *)ins->cmt;
+}
+#endif
+
 /* Trigger the output plugins setup callbacks to prepare them. */
 int flb_output_init_all(struct flb_config *config)
 {