health: use input coroutine flag to correctly use async network i/o.
@@ -129,7 +129,7 @@ static int in_health_collect(struct flb_input_instance *ins,
flb_input_chunk_append_raw(ins, NULL, 0, mp_sbuf.data, mp_sbuf.size);
msgpack_sbuffer_destroy(&mp_sbuf);
- return 0;
+ FLB_INPUT_RETURN(0);
}
static int in_health_init(struct flb_input_instance *in,
@@ -254,5 +254,5 @@ struct flb_input_plugin in_health_plugin = {
.cb_collect = in_health_collect,
.cb_flush_buf = NULL,
.cb_exit = in_health_exit,
- .flags = FLB_INPUT_NET
+ .flags = FLB_INPUT_NET|FLB_INPUT_CORO
};
