Trait servers::interceptor::LogIngestInterceptor
source · pub trait LogIngestInterceptor {
type Error: ErrorExt;
// Provided methods
fn pre_pipeline(
&self,
values: Vec<Value>,
_query_ctx: QueryContextRef,
) -> Result<Vec<Value>, Self::Error> { ... }
fn pre_ingest(
&self,
request: RowInsertRequests,
_query_ctx: QueryContextRef,
) -> Result<RowInsertRequests, Self::Error> { ... }
}
Expand description
LogIngestInterceptor can track life cycle of a log ingestion request and customize or abort its execution at given point.
Required Associated Types§
Provided Methods§
sourcefn pre_pipeline(
&self,
values: Vec<Value>,
_query_ctx: QueryContextRef,
) -> Result<Vec<Value>, Self::Error>
fn pre_pipeline( &self, values: Vec<Value>, _query_ctx: QueryContextRef, ) -> Result<Vec<Value>, Self::Error>
Called before pipeline execution.
sourcefn pre_ingest(
&self,
request: RowInsertRequests,
_query_ctx: QueryContextRef,
) -> Result<RowInsertRequests, Self::Error>
fn pre_ingest( &self, request: RowInsertRequests, _query_ctx: QueryContextRef, ) -> Result<RowInsertRequests, Self::Error>
Called before insertion.