Trait kvproto::enginepb::Engine

pub trait Engine {
    fn apply_command_batch(
        &mut self, 
        ctx: RpcContext<'_>, 
        stream: RequestStream<CommandRequestBatch>, 
        sink: DuplexSink<CommandResponseBatch>
    );
    fn apply_snapshot(
        &mut self, 
        ctx: RpcContext<'_>, 
        stream: RequestStream<SnapshotRequest>, 
        sink: ClientStreamingSink<SnapshotDone>
    );
}

Required methods

fn apply_command_batch(
    &mut self,
    ctx: RpcContext<'_>,
    stream: RequestStream<CommandRequestBatch>,
    sink: DuplexSink<CommandResponseBatch>
)

fn apply_snapshot(
    &mut self,
    ctx: RpcContext<'_>,
    stream: RequestStream<SnapshotRequest>,
    sink: ClientStreamingSink<SnapshotDone>
)

Loading content...

Implementors

Loading content...