Trait kvproto::import_kvpb_grpc::ImportKv[−][src]

pub trait ImportKv {
    fn switch_mode(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: SwitchModeRequest, 
        sink: UnarySink<SwitchModeResponse>
    );

    fn open_engine(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: OpenEngineRequest, 
        sink: UnarySink<OpenEngineResponse>
    );

    fn write_engine(
        &mut self, 
        ctx: RpcContext<'_>, 
        stream: RequestStream<WriteEngineRequest>, 
        sink: ClientStreamingSink<WriteEngineResponse>
    );

    fn write_engine_v3(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: WriteEngineV3Request, 
        sink: UnarySink<WriteEngineResponse>
    );

    fn close_engine(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: CloseEngineRequest, 
        sink: UnarySink<CloseEngineResponse>
    );

    fn import_engine(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: ImportEngineRequest, 
        sink: UnarySink<ImportEngineResponse>
    );

    fn cleanup_engine(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: CleanupEngineRequest, 
        sink: UnarySink<CleanupEngineResponse>
    );

    fn compact_cluster(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: CompactClusterRequest, 
        sink: UnarySink<CompactClusterResponse>
    );

    fn get_version(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: GetVersionRequest, 
        sink: UnarySink<GetVersionResponse>
    );

    fn get_metrics(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: GetMetricsRequest, 
        sink: UnarySink<GetMetricsResponse>
    );
}

Required methods

fn switch_mode(
    &mut self,
    ctx: RpcContext<'_>,
    req: SwitchModeRequest,
    sink: UnarySink<SwitchModeResponse>
)[src]

fn open_engine(
    &mut self,
    ctx: RpcContext<'_>,
    req: OpenEngineRequest,
    sink: UnarySink<OpenEngineResponse>
)[src]

fn write_engine(
    &mut self,
    ctx: RpcContext<'_>,
    stream: RequestStream<WriteEngineRequest>,
    sink: ClientStreamingSink<WriteEngineResponse>
)[src]

fn write_engine_v3(
    &mut self,
    ctx: RpcContext<'_>,
    req: WriteEngineV3Request,
    sink: UnarySink<WriteEngineResponse>
)[src]

fn close_engine(
    &mut self,
    ctx: RpcContext<'_>,
    req: CloseEngineRequest,
    sink: UnarySink<CloseEngineResponse>
)[src]

fn import_engine(
    &mut self,
    ctx: RpcContext<'_>,
    req: ImportEngineRequest,
    sink: UnarySink<ImportEngineResponse>
)[src]

fn cleanup_engine(
    &mut self,
    ctx: RpcContext<'_>,
    req: CleanupEngineRequest,
    sink: UnarySink<CleanupEngineResponse>
)[src]

fn compact_cluster(
    &mut self,
    ctx: RpcContext<'_>,
    req: CompactClusterRequest,
    sink: UnarySink<CompactClusterResponse>
)[src]

fn get_version(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetVersionRequest,
    sink: UnarySink<GetVersionResponse>
)[src]

fn get_metrics(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetMetricsRequest,
    sink: UnarySink<GetMetricsResponse>
)[src]

Loading content...

Implementors

Loading content...