| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/filter_aws/ |
| H A D | aws.c | 490 msgpack_packer tmp_pck; in cb_aws_filter() local
532 msgpack_pack_array(&tmp_pck, 2); in cb_aws_filter()
550 msgpack_pack_str_body(&tmp_pck, in cb_aws_filter()
554 msgpack_pack_str_body(&tmp_pck, in cb_aws_filter()
561 msgpack_pack_str_body(&tmp_pck, in cb_aws_filter()
565 msgpack_pack_str_body(&tmp_pck, in cb_aws_filter()
571 msgpack_pack_str_body(&tmp_pck, in cb_aws_filter()
575 msgpack_pack_str_body(&tmp_pck, in cb_aws_filter()
581 msgpack_pack_str_body(&tmp_pck, in cb_aws_filter()
585 msgpack_pack_str_body(&tmp_pck, in cb_aws_filter()
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/src/ |
| H A D | flb_parser_logfmt.c | 66 msgpack_packer *tmp_pck, in logfmt_parser() argument
174 tmp_pck, in logfmt_parser()
179 msgpack_pack_str(tmp_pck, key_len); in logfmt_parser()
183 msgpack_pack_str(tmp_pck, 0); in logfmt_parser()
186 msgpack_pack_nil(tmp_pck); in logfmt_parser()
205 msgpack_pack_str(tmp_pck, out_len); in logfmt_parser()
206 msgpack_pack_str_body(tmp_pck, in logfmt_parser()
214 msgpack_pack_str_body(tmp_pck, in logfmt_parser()
261 msgpack_packer tmp_pck; in flb_parser_logfmt_do() local
290 msgpack_pack_map(&tmp_pck, map_size); in flb_parser_logfmt_do()
[all …]
|
| H A D | flb_parser_ltsv.c | 85 msgpack_packer *tmp_pck, in ltsv_parser() argument
153 tmp_pck, in ltsv_parser()
158 msgpack_pack_str(tmp_pck, label_len); in ltsv_parser()
159 msgpack_pack_str_body(tmp_pck, (const char *)label, label_len); in ltsv_parser()
160 msgpack_pack_str(tmp_pck, field_len); in ltsv_parser()
161 msgpack_pack_str_body(tmp_pck, (const char *)field, field_len); in ltsv_parser()
210 msgpack_packer tmp_pck; in flb_parser_ltsv_do() local
238 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write); in flb_parser_ltsv_do()
239 msgpack_pack_map(&tmp_pck, map_size); in flb_parser_ltsv_do()
241 last_byte = ltsv_parser(parser, in_buf, in_size, &tmp_pck, in flb_parser_ltsv_do()
|
| H A D | flb_parser_regex.c | 131 msgpack_packer tmp_pck; in flb_parser_regex_do() local
140 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write); in flb_parser_regex_do()
144 msgpack_pack_map(&tmp_pck, arr_size); in flb_parser_regex_do()
147 pcb.pck = &tmp_pck; in flb_parser_regex_do()
|
| H A D | flb_pack.c | 799 msgpack_packer tmp_pck; in flb_pack_msgpack_to_json_format() local
824 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write); in flb_pack_msgpack_to_json_format()
837 msgpack_pack_array(&tmp_pck, records); in flb_pack_msgpack_to_json_format()
862 msgpack_pack_map(&tmp_pck, map_size + 1); in flb_pack_msgpack_to_json_format()
865 msgpack_pack_map(&tmp_pck, map_size); in flb_pack_msgpack_to_json_format()
870 msgpack_pack_str(&tmp_pck, flb_sds_len(date_key)); in flb_pack_msgpack_to_json_format()
876 msgpack_pack_double(&tmp_pck, flb_time_to_double(&tms)); in flb_pack_msgpack_to_json_format()
889 msgpack_pack_str(&tmp_pck, s); in flb_pack_msgpack_to_json_format()
890 msgpack_pack_str_body(&tmp_pck, time_formatted, s); in flb_pack_msgpack_to_json_format()
902 msgpack_pack_object(&tmp_pck, *k); in flb_pack_msgpack_to_json_format()
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/filter_tensorflow/ |
| H A D | tensorflow.c | 249 msgpack_packer tmp_pck; in cb_tf_filter() local
266 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write); in cb_tf_filter()
376 msgpack_pack_array(&tmp_pck, 2); in cb_tf_filter()
377 flb_time_append_to_msgpack(&tm, &tmp_pck, 0); in cb_tf_filter()
380 msgpack_pack_map(&tmp_pck, map_size + 2); in cb_tf_filter()
383 msgpack_pack_map(&tmp_pck, 2); in cb_tf_filter()
393 msgpack_pack_str(&tmp_pck, strlen("inference_time")); in cb_tf_filter()
395 msgpack_pack_float(&tmp_pck, elapsed_time); in cb_tf_filter()
397 msgpack_pack_str(&tmp_pck, strlen("tf_out")); in cb_tf_filter()
398 msgpack_pack_str_body(&tmp_pck, "tf_out", strlen("tf_out")); in cb_tf_filter()
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_es/ |
| H A D | es.c | 138 msgpack_pack_str(tmp_pck, key_size); in es_pack_map_content()
153 es_pack_map_content(tmp_pck, *v, ctx); in es_pack_map_content()
161 es_pack_array_content(tmp_pck, *v, ctx); in es_pack_map_content()
164 msgpack_pack_object(tmp_pck, *v); in es_pack_map_content()
186 es_pack_map_content(tmp_pck, *e, ctx); in es_pack_array_content()
191 es_pack_array_content(tmp_pck, *e, ctx); in es_pack_array_content()
195 msgpack_pack_object(tmp_pck, *e); in es_pack_array_content()
273 msgpack_packer tmp_pck; in elasticsearch_format() local
405 msgpack_pack_map(&tmp_pck, map_size + 1); in elasticsearch_format()
425 msgpack_pack_str(&tmp_pck, s); in elasticsearch_format()
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/filter_record_modifier/ |
| H A D | filter_modifier.c | 272 msgpack_packer tmp_pck; in cb_modifier_filter() local
281 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write); in cb_modifier_filter()
329 msgpack_pack_array(&tmp_pck, 2); in cb_modifier_filter()
330 flb_time_append_to_msgpack(&tm, &tmp_pck, 0); in cb_modifier_filter()
332 msgpack_pack_map(&tmp_pck, removed_map_num); in cb_modifier_filter()
336 msgpack_pack_object(&tmp_pck, (kv+i)->key); in cb_modifier_filter()
337 msgpack_pack_object(&tmp_pck, (kv+i)->val); in cb_modifier_filter()
348 msgpack_pack_str(&tmp_pck, mod_rec->key_len); in cb_modifier_filter()
349 msgpack_pack_str_body(&tmp_pck, in cb_modifier_filter()
351 msgpack_pack_str(&tmp_pck, mod_rec->val_len); in cb_modifier_filter()
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/filter_parser/ |
| H A D | filter_parser.c | 210 msgpack_packer tmp_pck; in cb_parser_filter() local
220 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write); in cb_parser_filter()
306 msgpack_pack_array(&tmp_pck, 2); in cb_parser_filter()
307 flb_time_append_to_msgpack(&tm, &tmp_pck, 0); in cb_parser_filter()
332 msgpack_pack_object(&tmp_pck, result.data); in cb_parser_filter()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_azure/ |
| H A D | azure.c | 66 msgpack_packer tmp_pck; in azure_format() local
88 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write); in azure_format()
107 msgpack_pack_object(&tmp_pck, k); in azure_format()
108 msgpack_pack_object(&tmp_pck, v); in azure_format()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/filter_throttle/ |
| H A D | throttle.c | 233 msgpack_packer tmp_pck; in cb_throttle_filter() local
237 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write); in cb_throttle_filter()
252 msgpack_pack_object(&tmp_pck, root); in cb_throttle_filter()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/filter_grep/ |
| H A D | grep.c | 222 msgpack_packer tmp_pck;
226 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write);
243 msgpack_pack_object(&tmp_pck, root);
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/filter_lua/ |
| H A D | lua.c | 505 msgpack_packer tmp_pck; in cb_lua_filter() local
515 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write); in cb_lua_filter()
599 msgpack_pack_object(&tmp_pck, root); in cb_lua_filter()
611 ret = pack_result(&t, &tmp_pck, &tmp_sbuf, in cb_lua_filter()
625 msgpack_pack_object(&tmp_pck, root); in cb_lua_filter()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/ |
| H A D | DEVELOPER_GUIDE.md | 221 msgpack_packer tmp_pck;
228 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write);
252 msgpack_pack_array(&tmp_pck, 2);
253 flb_time_append_to_msgpack(&tm, &tmp_pck, 0);
257 msgpack_pack_map(&tmp_pck, total_records);
262 msgpack_pack_object(&tmp_pck, (kv+i)->key);
263 msgpack_pack_object(&tmp_pck, (kv+i)->val);
267 msgpack_pack_str(&tmp_pck, A_NEW_KEY_LEN);
268 msgpack_pack_str_body(&tmp_pck, A_NEW_KEY, A_NEW_KEY_LEN);
269 msgpack_pack_str(&tmp_pck, A_NEW_VALUE_LEN);
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/filter_kubernetes/ |
| H A D | kubernetes.c | 453 msgpack_packer tmp_pck; in cb_kube_filter() local
482 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write); in cb_kube_filter()
566 msgpack_pack_array(&tmp_pck, 2); in cb_kube_filter()
569 ret = pack_map_content(&tmp_pck, &tmp_sbuf, in cb_kube_filter()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/filter_throttle_size/ |
| H A D | throttle_size.c | 674 msgpack_packer tmp_pck;
678 msgpack_packer_init(&tmp_pck, &tmp_sbuf, msgpack_sbuffer_write);
706 msgpack_pack_object(&tmp_pck, root);
|