use the common batcher

src/sinks/gcp/stackdriver/logs/sink.rs

@@ -1,6 +1,9 @@
 //! Implementation of the `gcp_stackdriver_logs` sink.
 
-use crate::sinks::{prelude::*, util::http::HttpRequest};
+use crate::sinks::{
+    prelude::*,
+    util::http::{HttpJsonBatchSizer, HttpRequest},
+};
 
 use super::request_builder::StackdriverLogsRequestBuilder;
 
@@ -33,8 +36,11 @@ where
     async fn run_inner(self: Box<Self>, input: BoxStream<'_, Event>) -> Result<(), ()> {
         let service = ServiceBuilder::new().service(self.service);
         input
-            // Batch the input stream with byte size calculation
-            .batched(self.batch_settings.into_byte_size_config())
+            // Batch the input stream with size calculation based on the estimated encoded json size
+            .batched(
+                self.batch_settings
+                    .into_item_size_config(HttpJsonBatchSizer),
+            )
             // Build requests with no concurrency limit.
             .request_builder(None, self.request_builder)
             // Filter out any errors that occurred in the request building.

src/sinks/util/http.rs

@@ -690,7 +690,7 @@ pub fn http_response_retry_logic() -> HttpStatusRetryLogic<
 
 /// Uses the estimated json encoded size to determine batch sizing.
 #[derive(Default)]
-pub(super) struct HttpJsonBatchSizer;
+pub struct HttpJsonBatchSizer;
 
 impl ItemBatchSize<Event> for HttpJsonBatchSizer {
     fn size(&self, item: &Event) -> usize {