http_server: hs: separate message queues
@@ -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);
