Trait kvproto::import_kvpb_grpc::ImportKv [−][src]
Required methods
fn switch_mode(
&mut self,
ctx: RpcContext<'_>,
req: SwitchModeRequest,
sink: UnarySink<SwitchModeResponse>
)
[src]
&mut self,
ctx: RpcContext<'_>,
req: SwitchModeRequest,
sink: UnarySink<SwitchModeResponse>
)
fn open_engine(
&mut self,
ctx: RpcContext<'_>,
req: OpenEngineRequest,
sink: UnarySink<OpenEngineResponse>
)
[src]
&mut self,
ctx: RpcContext<'_>,
req: OpenEngineRequest,
sink: UnarySink<OpenEngineResponse>
)
fn write_engine(
&mut self,
ctx: RpcContext<'_>,
stream: RequestStream<WriteEngineRequest>,
sink: ClientStreamingSink<WriteEngineResponse>
)
[src]
&mut self,
ctx: RpcContext<'_>,
stream: RequestStream<WriteEngineRequest>,
sink: ClientStreamingSink<WriteEngineResponse>
)
fn write_engine_v3(
&mut self,
ctx: RpcContext<'_>,
req: WriteEngineV3Request,
sink: UnarySink<WriteEngineResponse>
)
[src]
&mut self,
ctx: RpcContext<'_>,
req: WriteEngineV3Request,
sink: UnarySink<WriteEngineResponse>
)
fn close_engine(
&mut self,
ctx: RpcContext<'_>,
req: CloseEngineRequest,
sink: UnarySink<CloseEngineResponse>
)
[src]
&mut self,
ctx: RpcContext<'_>,
req: CloseEngineRequest,
sink: UnarySink<CloseEngineResponse>
)
fn import_engine(
&mut self,
ctx: RpcContext<'_>,
req: ImportEngineRequest,
sink: UnarySink<ImportEngineResponse>
)
[src]
&mut self,
ctx: RpcContext<'_>,
req: ImportEngineRequest,
sink: UnarySink<ImportEngineResponse>
)
fn cleanup_engine(
&mut self,
ctx: RpcContext<'_>,
req: CleanupEngineRequest,
sink: UnarySink<CleanupEngineResponse>
)
[src]
&mut self,
ctx: RpcContext<'_>,
req: CleanupEngineRequest,
sink: UnarySink<CleanupEngineResponse>
)
fn compact_cluster(
&mut self,
ctx: RpcContext<'_>,
req: CompactClusterRequest,
sink: UnarySink<CompactClusterResponse>
)
[src]
&mut self,
ctx: RpcContext<'_>,
req: CompactClusterRequest,
sink: UnarySink<CompactClusterResponse>
)
fn get_version(
&mut self,
ctx: RpcContext<'_>,
req: GetVersionRequest,
sink: UnarySink<GetVersionResponse>
)
[src]
&mut self,
ctx: RpcContext<'_>,
req: GetVersionRequest,
sink: UnarySink<GetVersionResponse>
)
fn get_metrics(
&mut self,
ctx: RpcContext<'_>,
req: GetMetricsRequest,
sink: UnarySink<GetMetricsResponse>
)
[src]
&mut self,
ctx: RpcContext<'_>,
req: GetMetricsRequest,
sink: UnarySink<GetMetricsResponse>
)