router: do not check for event_type
@@ -181,27 +181,6 @@ int flb_router_io_set(struct flb_config *config)
out_count++;
}
- /* Just 1 input and 1 output */
- if (in_count == 1 && out_count == 1) {
- i_ins = mk_list_entry_first(&config->inputs,
- struct flb_input_instance, _head);
- o_ins = mk_list_entry_first(&config->outputs,
- struct flb_output_instance, _head);
-
- if (flb_router_match_type(i_ins->event_type, o_ins) &&
- !o_ins->match
-#ifdef FLB_HAVE_REGEX
- && !o_ins->match_regex
-#endif
- ) {
- flb_debug("[router] default match rule %s:%s",
- i_ins->name, o_ins->name);
- o_ins->match = flb_sds_create_len("*", 1);
- flb_router_connect(i_ins, o_ins);
- return 0;
- }
- }
-
/* N:M case, iterate all input instances */
mk_list_foreach(i_head, &config->inputs) {
i_ins = mk_list_entry(i_head, struct flb_input_instance, _head);
@@ -239,25 +218,6 @@ int flb_router_io_set(struct flb_config *config)
#endif
)) {
- if (!flb_router_match_type(i_ins->event_type, o_ins)) {
- if (i_ins->event_type == FLB_INPUT_LOGS) {
- flb_debug("[router] data generated by %s input are logs, "
- "but matching destination plugin %s don't handle "
- "logs. Skipping destination.",
- flb_input_name(i_ins),
- flb_output_name(o_ins));
- }
- else if (i_ins->event_type == FLB_INPUT_METRICS) {
- flb_debug("[router] data generated by %s input are metrics, "
- "but matching destination plugin %s don't handle "
- "metrics.Skipping destination.",
- flb_input_name(i_ins),
- flb_output_name(o_ins));
- }
- continue;
- }
-
-
flb_debug("[router] match rule %s:%s",
i_ins->name, o_ins->name);
flb_router_connect(i_ins, o_ins);
