Trait kvproto::import_sstpb_grpc::ImportSst[−][src]

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

    fn upload(
        &mut self, 
        ctx: RpcContext<'_>, 
        stream: RequestStream<UploadRequest>, 
        sink: ClientStreamingSink<UploadResponse>
    );

    fn ingest(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: IngestRequest, 
        sink: UnarySink<IngestResponse>
    );

    fn compact(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: CompactRequest, 
        sink: UnarySink<CompactResponse>
    );

    fn set_download_speed_limit(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: SetDownloadSpeedLimitRequest, 
        sink: UnarySink<SetDownloadSpeedLimitResponse>
    );

    fn download(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: DownloadRequest, 
        sink: UnarySink<DownloadResponse>
    );

    fn write(
        &mut self, 
        ctx: RpcContext<'_>, 
        stream: RequestStream<WriteRequest>, 
        sink: ClientStreamingSink<WriteResponse>
    );

    fn multi_ingest(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: MultiIngestRequest, 
        sink: UnarySink<IngestResponse>
    );
}

Required methods

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

fn upload(
    &mut self,
    ctx: RpcContext<'_>,
    stream: RequestStream<UploadRequest>,
    sink: ClientStreamingSink<UploadResponse>
)[src]

fn ingest(
    &mut self,
    ctx: RpcContext<'_>,
    req: IngestRequest,
    sink: UnarySink<IngestResponse>
)[src]

fn compact(
    &mut self,
    ctx: RpcContext<'_>,
    req: CompactRequest,
    sink: UnarySink<CompactResponse>
)[src]

fn set_download_speed_limit(
    &mut self,
    ctx: RpcContext<'_>,
    req: SetDownloadSpeedLimitRequest,
    sink: UnarySink<SetDownloadSpeedLimitResponse>
)[src]

fn download(
    &mut self,
    ctx: RpcContext<'_>,
    req: DownloadRequest,
    sink: UnarySink<DownloadResponse>
)[src]

fn write(
    &mut self,
    ctx: RpcContext<'_>,
    stream: RequestStream<WriteRequest>,
    sink: ClientStreamingSink<WriteResponse>
)[src]

fn multi_ingest(
    &mut self,
    ctx: RpcContext<'_>,
    req: MultiIngestRequest,
    sink: UnarySink<IngestResponse>
)[src]

Loading content...

Implementors

Loading content...