wip chunked stream input

fluent · Dec 19, 2023 · 9cf86df · 9cf86df
1 parent 047ca27
commit 9cf86df
Show file tree

Hide file tree

Showing 3 changed files with 341 additions and 94 deletions.
diff --git a/include/fluent-bit/flb_http_client.h b/include/fluent-bit/flb_http_client.h
@@ -100,6 +100,8 @@ struct flb_http_debug {
     int (*cb_debug_request_payload);
 };
 
+struct flb_http_chunk_complete_callback;
+
 /* Set a request type */
 struct flb_http_client {
     /* Upstream connection */
@@ -135,6 +137,13 @@ struct flb_http_client {
 
     /* Reference to Callback context */
     void *cb_ctx;
+    struct flb_http_chunk_complete_callback* cb_chunk_complete;
+};
+
+struct flb_http_chunk_complete_callback {
+    int (*cb)(struct flb_http_client *c, int* bytes_consumed, void* p1, void* p2);
+    void* p1;
+    void* p2;
 };
 
 void flb_http_client_debug(struct flb_http_client *c,
@@ -172,5 +181,10 @@ int flb_http_buffer_increase(struct flb_http_client *c, size_t size,
 int flb_http_strip_port_from_host(struct flb_http_client *c);
 int flb_http_allow_duplicated_headers(struct flb_http_client *c, int allow);
 int flb_http_client_debug_property_is_valid(char *key, char *val);
+int flb_http_client_set_chunk_complete_callback(struct flb_http_client *c,
+                int (*cb)(struct flb_http_client *c, int *bytes_consumed,
+                        void* p1, void* p2),
+                void* p1,
+                void* p2);
 
 #endif