http_server: add function to ingest health metrics

Signed-off-by: Takahiro Yamashita <[email protected]>

Author: nokute78

include/fluent-bit/http_server/flb_hs.h

@@ -54,6 +54,7 @@ struct flb_hs {
 
 struct flb_hs *flb_hs_create(const char *listen, const char *tcp_port,
                              struct flb_config *config);
+int flb_hs_push_health_metrics(struct flb_hs *hs, void *data, size_t size);
 int flb_hs_push_pipeline_metrics(struct flb_hs *hs, void *data, size_t size);
 int flb_hs_push_storage_metrics(struct flb_hs *hs, void *data, size_t size);
 

src/http_server/flb_hs.c

@@ -37,10 +37,15 @@ static void cb_root(mk_request_t *request, void *data)
     mk_http_done(request);
 }
 
+/* Ingest health metrics into the web service context */
+int flb_hs_push_health_metrics(struct flb_hs *hs, void *data, size_t size)
+{
+    return mk_mq_send(hs->ctx, hs->qid_health, data, size);
+}
+
 /* Ingest pipeline metrics into the web service context */
 int flb_hs_push_pipeline_metrics(struct flb_hs *hs, void *data, size_t size)
 {
-    mk_mq_send(hs->ctx, hs->qid_health, data, size);
     return mk_mq_send(hs->ctx, hs->qid_metrics, data, size);
 }