Skip to content

Commit

Permalink
tests: runtime: processor_metrics_selector: check if works as an outp…
Browse files Browse the repository at this point in the history
…ut processor

Signed-off-by: Thiago Padilha <[email protected]>
Signed-off-by: Markus Bergholz <[email protected]>
  • Loading branch information
tchrono authored and markuman committed May 29, 2024
1 parent 4c45c01 commit 222bc1d
Showing 1 changed file with 65 additions and 0 deletions.
65 changes: 65 additions & 0 deletions tests/runtime/processor_metrics_selector.c
Original file line number Diff line number Diff line change
Expand Up @@ -549,6 +549,70 @@ void flb_test_selector_substring_exclude(void)
flb_destroy(ctx);
}

void flb_test_selector_can_modify_output(void)
{
int ret;
flb_ctx_t *ctx;
int in_ffd;
int out_ffd;
struct flb_processor *proc;
struct flb_processor_unit *pu;
struct cfl_variant var = {
.type = CFL_VARIANT_STRING,
.data.as_string = "/kubernetes/",
};
struct cfl_variant action = {
.type = CFL_VARIANT_STRING,
.data.as_string = "include",
};

ctx = flb_create();
flb_service_set(ctx,
"Flush", "0.200000000",
"Grace", "2",
NULL);

proc = flb_processor_create(ctx->config, "unit_test", NULL, 0);
TEST_CHECK(proc != NULL);

pu = flb_processor_unit_create(proc, FLB_PROCESSOR_METRICS, "metrics_selector");
TEST_CHECK(pu != NULL);
ret = flb_processor_unit_set_property(pu, "metric_name", &var);
TEST_CHECK(ret == 0);
ret = flb_processor_unit_set_property(pu, "action", &action);
TEST_CHECK(ret == 0);

/* Input */
in_ffd = flb_input(ctx, (char *) "event_type", NULL);
TEST_CHECK(in_ffd >= 0);
ret = flb_input_set(ctx, in_ffd, "tag", "test", NULL);
TEST_CHECK(ret == 0);
ret = flb_input_set(ctx, in_ffd, "type", "metrics", NULL);
TEST_CHECK(ret == 0);
ret = flb_input_set(ctx, in_ffd, "interval_sec", "1", NULL);
TEST_CHECK(ret == 0);

out_ffd = flb_output(ctx, (char *) "stdout", NULL);
TEST_CHECK(out_ffd >= 0);
ret = flb_output_set(ctx, out_ffd, "match", "test", NULL);
TEST_CHECK(ret == 0);
ret = flb_output_set(ctx, out_ffd, "format", "msgpack", NULL);
TEST_CHECK(ret == 0);

/* set up processor */
ret = flb_output_set_processor(ctx, out_ffd, proc);
TEST_CHECK(ret == 0);

clear_output_num();

ret = flb_start(ctx);
TEST_CHECK(ret == 0);

flb_time_msleep(1500); /* waiting flush */

flb_stop(ctx);
flb_destroy(ctx);
}
#endif

/* Test list */
Expand All @@ -560,6 +624,7 @@ TEST_LIST = {
{"prefix_exclude", flb_test_selector_prefix_exclude},
{"substring_include", flb_test_selector_substring_include},
{"substring_exclude", flb_test_selector_substring_exclude},
{"can_modify_output", flb_test_selector_can_modify_output},
#endif
{NULL, NULL}
};

0 comments on commit 222bc1d

Please sign in to comment.