From f37d4cced869c5d08a072ef23b192a5d8c54d2f5 Mon Sep 17 00:00:00 2001
From: Eduardo Silva <eduardo@chronosphere.io>
Date: Fri, 17 Jan 2025 17:46:36 -0600
Subject: [PATCH] out_opentelemetry: set grpc flag when paylaod is compressed

Signed-off-by: Eduardo Silva <eduardo@chronosphere.io>
---
 plugins/out_opentelemetry/opentelemetry.c | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/plugins/out_opentelemetry/opentelemetry.c b/plugins/out_opentelemetry/opentelemetry.c
index 9d913122732..3d963a38d2f 100644
--- a/plugins/out_opentelemetry/opentelemetry.c
+++ b/plugins/out_opentelemetry/opentelemetry.c
@@ -20,6 +20,8 @@
 #include <fluent-bit/flb_output_plugin.h>
 #include <fluent-bit/flb_input_event.h>
 #include <fluent-bit/flb_snappy.h>
+#include <fluent-bit/flb_gzip.h>
+#include <fluent-bit/flb_zstd.h>
 #include <fluent-bit/flb_metrics.h>
 #include <fluent-bit/flb_time.h>
 #include <fluent-bit/flb_kv.h>
@@ -305,6 +307,10 @@ int opentelemetry_post(struct opentelemetry_context *ctx,
 
         grpc_body = sds_result;
 
+        if(compression_algorithm != NULL) {
+            ((uint8_t *) grpc_body)[0] = 0x01;
+        }
+
         ((uint8_t *) grpc_body)[1] = (wire_message_length & 0xFF000000) >> 24;
         ((uint8_t *) grpc_body)[2] = (wire_message_length & 0x00FF0000) >> 16;
         ((uint8_t *) grpc_body)[3] = (wire_message_length & 0x0000FF00) >> 8;