Rename ingest helper method

quickwit-oss · Aug 23, 2024 · 51122c4 · 51122c4
1 parent e548422
commit 51122c4
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git 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
@@ -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
@@ -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,