router: new checker for routing types

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

Author: edsiper

include/fluent-bit/flb_router.h

@@ -22,13 +22,29 @@
 #define FLB_ROUTER_H
 
 #include <fluent-bit/flb_info.h>
+#include <fluent-bit/flb_input.h>
 #include <fluent-bit/flb_output.h>
 
 struct flb_router_path {
     struct flb_output_instance *ins;
     struct mk_list _head;
 };
 
+static inline int flb_router_match_type(int in_event_type,
+                                        struct flb_output_instance *ins)
+{
+    if (in_event_type == FLB_INPUT_LOGS &&
+        !(ins->event_type & FLB_OUTPUT_LOGS)) {
+        return FLB_FALSE;
+    }
+    else if (in_event_type == FLB_INPUT_METRICS &&
+             !(ins->event_type & FLB_OUTPUT_METRICS)) {
+        return FLB_FALSE;
+    }
+
+    return FLB_TRUE;
+}
+
 int flb_router_match(const char *tag, int tag_len,
                      const char *match, void *match_regex);
 int flb_router_io_set(struct flb_config *config);

src/flb_router.c

@@ -171,7 +171,9 @@ int flb_router_io_set(struct flb_config *config)
                                     struct flb_input_instance, _head);
         o_ins = mk_list_entry_first(&config->outputs,
                                     struct flb_output_instance, _head);
-        if (!o_ins->match
+
+        if (flb_router_match_type(i_ins->event_type, o_ins) &&
+            !o_ins->match
 #ifdef FLB_HAVE_REGEX
             && !o_ins->match_regex
 #endif
@@ -212,6 +214,10 @@ int flb_router_io_set(struct flb_config *config)
                 continue;
             }
 
+            if (!flb_router_match_type(i_ins->event_type, o_ins)) {
+                continue;
+            }
+
             if (flb_router_match(i_ins->tag, i_ins->tag_len, o_ins->match
 #ifdef FLB_HAVE_REGEX
                 , o_ins->match_regex
@@ -250,6 +256,3 @@ void flb_router_exit(struct flb_config *config)
         }
     }
 }
-
-
-