pub trait PromStoreProtocolInterceptor {
    type Error: ErrorExt;

    // Provided methods
    fn pre_write(
        &self,
        _write_req: &RowInsertRequests,
        _ctx: QueryContextRef,
    ) -> Result<(), Self::Error> { ... }
    fn pre_read(
        &self,
        _read_req: &ReadRequest,
        _ctx: QueryContextRef,
    ) -> Result<(), Self::Error> { ... }
}
Expand description

PromStoreProtocolInterceptor can track life cycle of a prom store request and customize or abort its execution at given point.

Required Associated Types§

source

type Error: ErrorExt

Provided Methods§

source

fn pre_write( &self, _write_req: &RowInsertRequests, _ctx: QueryContextRef, ) -> Result<(), Self::Error>

source

fn pre_read( &self, _read_req: &ReadRequest, _ctx: QueryContextRef, ) -> Result<(), Self::Error>

Implementations on Foreign Types§

source§

impl<E: ErrorExt> PromStoreProtocolInterceptor for Option<PromStoreProtocolInterceptorRef<E>>

§

type Error = E

source§

fn pre_write( &self, write_req: &RowInsertRequests, ctx: QueryContextRef, ) -> Result<(), Self::Error>

source§

fn pre_read( &self, read_req: &ReadRequest, ctx: QueryContextRef, ) -> Result<(), Self::Error>

Implementors§