chore: rename

GreptimeTeam · Sep 18, 2024 · f65f6f1 · f65f6f1
1 parent 3070128
commit f65f6f1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/servers/src/http/event.rs b/src/servers/src/http/event.rs
@@ -383,7 +383,7 @@ pub async fn log_ingester(
     log_state
         .ingest_interceptor
         .as_ref()
-        .pre_transform(&value, query_ctx.clone())?;
+        .pre_pipeline(&value, query_ctx.clone())?;
 
     ingest_logs_inner(
         handler,

diff --git a/src/servers/src/interceptor.rs b/src/servers/src/interceptor.rs
@@ -405,7 +405,7 @@ pub trait LogIngestInterceptor {
     type Error: ErrorExt;
 
     /// Called before pipeline execution.
-    fn pre_transform(
+    fn pre_pipeline(
         &self,
         _values: &[Value],
         _query_ctx: QueryContextRef,
@@ -432,13 +432,13 @@ where
 {
     type Error = E;
 
-    fn pre_transform(
+    fn pre_pipeline(
         &self,
         values: &[Value],
         query_ctx: QueryContextRef,
     ) -> Result<(), Self::Error> {
         if let Some(this) = self {
-            this.pre_transform(values, query_ctx)
+            this.pre_pipeline(values, query_ctx)
         } else {
             Ok(())
         }