custom_calyptia: pass the fleet_id parameter and label to out_calyptia.

Signed-off-by: Phillip Whelan <[email protected]>
fluent · Sep 4, 2023 · f94c4ad · f94c4ad
1 parent f7731f3
commit f94c4ad
Showing 1 changed file with 15 additions and 1 deletion.
diff --git a/plugins/custom_calyptia/calyptia.c b/plugins/custom_calyptia/calyptia.c
@@ -264,7 +264,7 @@ static struct flb_output_instance *setup_cloud_output(struct flb_config *config,
 
             label = flb_sds_create_size(strlen(key->str) + strlen(val->str) + 1);
 
-            if(!label) {
+            if (!label) {
                 flb_free(ctx);
                 return NULL;
             }
@@ -309,6 +309,20 @@ static struct flb_output_instance *setup_cloud_output(struct flb_config *config,
         flb_output_set_property(cloud, "tls.verify", "false");
     }
 
+    if (ctx->fleet_id) {
+        flb_output_set_property(cloud, "fleet_id", ctx->fleet_id);
+        label = flb_sds_create_size(strlen("fleet_id") + strlen(ctx->fleet_id) + 1);
+
+        if (!label) {
+            flb_free(ctx);
+            return NULL;
+        }
+
+        flb_sds_printf(&label, "fleet_id %s", ctx->fleet_id);
+        flb_output_set_property(cloud, "add_label", label);
+        flb_sds_destroy(label);
+    }
+
 #ifdef FLB_HAVE_CHUNK_TRACE
     flb_output_set_property(cloud, "pipeline_id", ctx->pipeline_id);
 #endif /* FLB_HAVE_CHUNK_TRACE */