Struct QueryConnect 

pub struct QueryConnect { /* private fields */ }

Implementations

impl QueryConnect

pub fn new(state: AppState) -> Self

Trait Implementations

impl Clone for QueryConnect

fn clone(&self) -> QueryConnect

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Service for QueryConnect

async fn get( &self, ctx: Context, request: OwnedView<GetRequestView<'static>>, ) -> Result<(GetResponse, Context), ConnectError>

Point lookup of a single key.

async fn get_many( &self, ctx: Context, request: OwnedView<GetManyRequestView<'static>>, ) -> Result<(Pin<Box<dyn Stream<Item = Result<GetManyFrame, ConnectError>> + Send>>, Context), ConnectError>

Batch point lookup of multiple keys, streamed back in frames.

async fn range( &self, ctx: Context, request: OwnedView<RangeRequestView<'static>>, ) -> Result<(Pin<Box<dyn Stream<Item = Result<RangeFrame, ConnectError>> + Send>>, Context), ConnectError>

Lexicographic range scan, streamed back in batched frames.

async fn reduce( &self, ctx: Context, request: OwnedView<ReduceRequestView<'static>>, ) -> Result<(ReduceResponse, Context), ConnectError>

Server-side aggregation over a key range with optional grouping and filtering.