From 51122c43f72d80bde41a9a2faa7e1a495d1a4e4c Mon Sep 17 00:00:00 2001
From: Remi Dettai <rdettai@gmail.com>
Date: Fri, 23 Aug 2024 09:56:14 +0200
Subject: [PATCH] Rename ingest helper method

---
 quickwit/quickwit-opentelemetry/src/otlp/logs.rs   | 6 +++---
 quickwit/quickwit-opentelemetry/src/otlp/mod.rs    | 2 +-
 quickwit/quickwit-opentelemetry/src/otlp/traces.rs | 6 +++---
 3 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/quickwit/quickwit-opentelemetry/src/otlp/logs.rs b/quickwit/quickwit-opentelemetry/src/otlp/logs.rs
index a88deee6e5b..a78f49fceea 100644
--- a/quickwit/quickwit-opentelemetry/src/otlp/logs.rs
+++ b/quickwit/quickwit-opentelemetry/src/otlp/logs.rs
@@ -41,8 +41,8 @@ use tracing::field::Empty;
 use tracing::{error, instrument, warn, Span as RuntimeSpan};
 
 use super::{
-    extract_otel_index_id_from_metadata, is_zero, parse_log_record_body, store_helper, OtelSignal,
-    SpanId, TraceId, TryFromSpanIdError, TryFromTraceIdError,
+    extract_otel_index_id_from_metadata, ingest_doc_batch_v2, is_zero, parse_log_record_body,
+    OtelSignal, SpanId, TraceId, TryFromSpanIdError, TryFromTraceIdError,
 };
 use crate::otlp::extract_attributes;
 use crate::otlp::metrics::OTLP_SERVICE_METRICS;
@@ -337,7 +337,7 @@ impl OtlpGrpcLogsService {
         index_id: String,
         doc_batch: DocBatchV2,
     ) -> Result<(), tonic::Status> {
-        store_helper(
+        ingest_doc_batch_v2(
             self.ingest_router.clone(),
             index_id,
             doc_batch,
diff --git a/quickwit/quickwit-opentelemetry/src/otlp/mod.rs b/quickwit/quickwit-opentelemetry/src/otlp/mod.rs
index 3ae2a153a16..d985c712f07 100644
--- a/quickwit/quickwit-opentelemetry/src/otlp/mod.rs
+++ b/quickwit/quickwit-opentelemetry/src/otlp/mod.rs
@@ -225,7 +225,7 @@ pub(crate) fn extract_otel_index_id_from_metadata(
     Ok(index_id.to_string())
 }
 
-async fn store_helper(
+async fn ingest_doc_batch_v2(
     ingest_router: IngestRouterServiceClient,
     index_id: String,
     doc_batch: DocBatchV2,
diff --git a/quickwit/quickwit-opentelemetry/src/otlp/traces.rs b/quickwit/quickwit-opentelemetry/src/otlp/traces.rs
index c978be23ab5..daa3cc46a1f 100644
--- a/quickwit/quickwit-opentelemetry/src/otlp/traces.rs
+++ b/quickwit/quickwit-opentelemetry/src/otlp/traces.rs
@@ -46,8 +46,8 @@ use tracing::field::Empty;
 use tracing::{error, instrument, warn, Span as RuntimeSpan};
 
 use super::{
-    extract_otel_index_id_from_metadata, is_zero, store_helper, OtelSignal, TryFromSpanIdError,
-    TryFromTraceIdError,
+    extract_otel_index_id_from_metadata, ingest_doc_batch_v2, is_zero, OtelSignal,
+    TryFromSpanIdError, TryFromTraceIdError,
 };
 use crate::otlp::metrics::OTLP_SERVICE_METRICS;
 use crate::otlp::{extract_attributes, SpanId, TraceId};
@@ -793,7 +793,7 @@ impl OtlpGrpcTracesService {
         index_id: String,
         doc_batch: DocBatchV2,
     ) -> Result<(), tonic::Status> {
-        store_helper(
+        ingest_doc_batch_v2(
             self.ingest_router.clone(),
             index_id,
             doc_batch,