Skip to content

Commit 975b7a7

Browse files
pwhelanedsiper
authored andcommitted
input: add networking options for server and client inputs to help output.
Signed-off-by: Phillip Whelan <[email protected]>
1 parent 61e5afd commit 975b7a7

File tree

2 files changed

+49
-0
lines changed

2 files changed

+49
-0
lines changed

include/fluent-bit/flb_input.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,8 @@
2525
#include <fluent-bit/flb_coro.h>
2626
#include <fluent-bit/flb_config.h>
2727
#include <fluent-bit/flb_network.h>
28+
#include <fluent-bit/flb_downstream.h>
29+
#include <fluent-bit/flb_upstream.h>
2830
#include <fluent-bit/flb_mem.h>
2931
#include <fluent-bit/flb_str.h>
3032
#include <fluent-bit/flb_bits.h>

src/flb_help.c

Lines changed: 47 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -278,6 +278,53 @@ int flb_help_input(struct flb_input_instance *ins, void **out_buf, size_t *out_s
278278
flb_config_map_destroy(config_map);
279279
}
280280

281+
if (ins->p->flags & FLB_INPUT_NET_SERVER) {
282+
flb_mp_map_header_append(&mh);
283+
pack_str(&mp_pck, "networking");
284+
285+
config_map = flb_downstream_get_config_map(ins->config);
286+
msgpack_pack_array(&mp_pck, mk_list_size(config_map));
287+
mk_list_foreach(head, config_map) {
288+
m = mk_list_entry(head, struct flb_config_map, _head);
289+
pack_config_map_entry(&mp_pck, m);
290+
}
291+
flb_config_map_destroy(config_map);
292+
}
293+
else if (ins->p->flags & FLB_INPUT_NET) {
294+
flb_mp_map_header_append(&mh);
295+
pack_str(&mp_pck, "networking");
296+
297+
config_map = flb_upstream_get_config_map(ins->config);
298+
msgpack_pack_array(&mp_pck, mk_list_size(config_map));
299+
mk_list_foreach(head, config_map) {
300+
m = mk_list_entry(head, struct flb_config_map, _head);
301+
pack_config_map_entry(&mp_pck, m);
302+
}
303+
flb_config_map_destroy(config_map);
304+
}
305+
306+
if (ins->p->flags & (FLB_IO_TLS | FLB_IO_OPT_TLS)) {
307+
flb_mp_map_header_append(&mh);
308+
pack_str(&mp_pck, "network_tls");
309+
310+
config_map = flb_tls_get_config_map(ins->config);
311+
msgpack_pack_array(&mp_pck, mk_list_size(config_map));
312+
313+
/* Adjust 'tls' default value based on plugin type" */
314+
m = mk_list_entry_first(config_map, struct flb_config_map, _head);
315+
if (ins->p->flags & FLB_IO_TLS) {
316+
m->value.val.boolean = FLB_TRUE;
317+
}
318+
else if (ins->p->flags & FLB_IO_OPT_TLS) {
319+
m->value.val.boolean = FLB_FALSE;
320+
}
321+
mk_list_foreach(head, config_map) {
322+
m = mk_list_entry(head, struct flb_config_map, _head);
323+
pack_config_map_entry(&mp_pck, m);
324+
}
325+
flb_config_map_destroy(config_map);
326+
}
327+
281328
flb_mp_map_header_end(&mh);
282329

283330
*out_buf = mp_sbuf.data;

0 commit comments

Comments
 (0)