http_server: hs: separate message queues

Signed-off-by: Eduardo Silva <[email protected]>

Author: edsiper

include/fluent-bit/http_server/flb_hs.h

@@ -41,7 +41,8 @@ struct flb_hs_buf {
 struct flb_hs {
     mk_ctx_t *ctx;             /* Monkey HTTP Context */
     int vid;                   /* Virtual Host ID     */
-    int qid;                   /* Message Queue ID    */
+    int qid_metrics;           /* Metrics Message Queue ID    */
+    int qid_storage;           /* Storage Message Queue ID    */
 
     pthread_t tid;             /* Server Thread */
     struct flb_config *config; /* Fluent Bit context */
@@ -53,7 +54,9 @@ struct flb_hs {
 
 struct flb_hs *flb_hs_create(const char *listen, const char *tcp_port,
                              struct flb_config *config);
-int flb_hs_push_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);
+
 int flb_hs_destroy(struct flb_hs *ctx);
 int flb_hs_start(struct flb_hs *hs);