input: support flb_input_collector_delete

   To delete a registered collector event from input plugin instance.

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

Author: nokute78

include/fluent-bit/flb_input.h

@@ -508,6 +508,7 @@ int flb_input_collector_start(int coll_id, struct flb_input_instance *ins);
 int flb_input_collectors_start(struct flb_config *config);
 int flb_input_collector_pause(int coll_id, struct flb_input_instance *ins);
 int flb_input_collector_resume(int coll_id, struct flb_input_instance *ins);
+int flb_input_collector_delete(int coll_id, struct flb_input_instance *ins);
 int flb_input_collector_fd(flb_pipefd_t fd, struct flb_config *config);
 int flb_input_set_collector_time(struct flb_input_instance *ins,
                                  int (*cb_collect) (struct flb_input_instance *,

src/flb_input.c

@@ -876,6 +876,24 @@ int flb_input_collector_pause(int coll_id, struct flb_input_instance *in)
     return 0;
 }
 
+int flb_input_collector_delete(int coll_id, struct flb_input_instance *in)
+{
+    struct flb_input_collector *coll;
+
+    coll = get_collector(coll_id, in);
+    if (!coll) {
+        return -1;
+    }
+    if (flb_input_collector_pause(coll_id, in) < 0) {
+        return -1;
+    }
+
+    mk_list_del(&coll->_head);
+    mk_list_del(&coll->_head_ins);
+    flb_free(coll);
+    return 0;
+}
+
 int flb_input_collector_resume(int coll_id, struct flb_input_instance *in)
 {
     int fd;