Trait LogIngestInterceptor

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> { ... }
}

LogIngestInterceptor can track life cycle of a log ingestion request and customize or abort its execution at given point.

Required Associated Types

type Error: ErrorExt

Provided Methods

fn pre_pipeline( &self, values: Vec<Value>, _query_ctx: QueryContextRef, ) -> Result<Vec<Value>, Self::Error>

Called before pipeline execution.

fn pre_ingest( &self, request: RowInsertRequests, _query_ctx: QueryContextRef, ) -> Result<RowInsertRequests, Self::Error>

Called before insertion.

Implementations on Foreign Types

impl<E> LogIngestInterceptor for Option<&LogIngestInterceptorRef<E>>

where E: ErrorExt,

type Error = E

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>

Implementors