filter_ecs: new filter for AWS ECS Metadata (fluent#5899)

Signed-off-by: Wesley Pettit <[email protected]> Signed-off-by: Manal Geries <[email protected]>
mgeriesa · Oct 25, 2022 · d6d87f9 · d6d87f9
1 parent fcc0823
commit d6d87f9
Show file tree

Hide file tree

Showing 8 changed files with 2,129 additions and 1 deletion.
diff --git a/CMakeLists.txt b/CMakeLists.txt
@@ -222,6 +222,7 @@ option(FLB_OUT_S3                      "Enable AWS S3 output plugin"
 option(FLB_OUT_WEBSOCKET               "Enable Websocket output plugin"               Yes)
 option(FLB_FILTER_ALTER_SIZE           "Enable alter_size filter"                     Yes)
 option(FLB_FILTER_AWS                  "Enable aws filter"                            Yes)
+option(FLB_FILTER_ECS                  "Enable AWS ECS filter"                        Yes)
 option(FLB_FILTER_CHECKLIST            "Enable checklist filter"                      Yes)
 option(FLB_FILTER_EXPECT               "Enable expect filter"                         Yes)
 option(FLB_FILTER_GREP                 "Enable grep filter"                           Yes)
@@ -243,6 +244,7 @@ option(FLB_FILTER_GEOIP2               "Enable geoip2 filter"
 option(FLB_FILTER_NIGHTFALL            "Enable Nightfall filter"                      Yes)
 option(FLB_FILTER_WASM                 "Enable WASM filter"                           Yes)
 
+
 if(DEFINED FLB_NIGHTLY_BUILD AND NOT "${FLB_NIGHTLY_BUILD}" STREQUAL "")
   FLB_DEFINITION_VAL(FLB_NIGHTLY_BUILD ${FLB_NIGHTLY_BUILD})
 endif()

diff --git a/plugins/CMakeLists.txt b/plugins/CMakeLists.txt
@@ -286,6 +286,7 @@ REGISTER_OUT_PLUGIN("out_s3")
 REGISTER_FILTER_PLUGIN("filter_alter_size")
 REGISTER_FILTER_PLUGIN("filter_aws")
 REGISTER_FILTER_PLUGIN("filter_checklist")
+REGISTER_FILTER_PLUGIN("filter_ecs")
 REGISTER_FILTER_PLUGIN("filter_record_modifier")
 REGISTER_FILTER_PLUGIN("filter_throttle")
 REGISTER_FILTER_PLUGIN("filter_throttle_size")

diff --git a/plugins/filter_aws/aws.c b/plugins/filter_aws/aws.c
@@ -162,7 +162,6 @@ static int cb_aws_init(struct flb_filter_instance *f_ins,
         return -1;
     }
 
-    /* Remove async flag from upstream */
     flb_stream_disable_async_mode(&ctx->ec2_upstream->base);
 
     /* Retrieve metadata */

diff --git a/plugins/filter_ecs/CMakeLists.txt b/plugins/filter_ecs/CMakeLists.txt
@@ -0,0 +1,5 @@
+set(src
+  ecs.c
+  )
+
+FLB_PLUGIN(filter_ecs "${src}" "")