Struct kvproto::import_sstpb::ImportSstClient

pub struct ImportSstClient { /* fields omitted */ }

Implementations

impl ImportSstClient

pub fn new(channel: Channel) -> Self

pub fn switch_mode_opt(
    &self,
    req: &SwitchModeRequest,
    opt: CallOption
) -> Result<SwitchModeResponse>

pub fn switch_mode(&self, req: &SwitchModeRequest) -> Result<SwitchModeResponse>

pub fn switch_mode_async_opt(
    &self,
    req: &SwitchModeRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<SwitchModeResponse>>

pub fn switch_mode_async(
    &self,
    req: &SwitchModeRequest
) -> Result<ClientUnaryReceiver<SwitchModeResponse>>

pub fn upload_opt(
    &self,
    opt: CallOption
) -> Result<(ClientCStreamSender<UploadRequest>, ClientCStreamReceiver<UploadResponse>)>

pub fn upload(
    &self
) -> Result<(ClientCStreamSender<UploadRequest>, ClientCStreamReceiver<UploadResponse>)>

pub fn ingest_opt(
    &self,
    req: &IngestRequest,
    opt: CallOption
) -> Result<IngestResponse>

pub fn ingest(&self, req: &IngestRequest) -> Result<IngestResponse>

pub fn ingest_async_opt(
    &self,
    req: &IngestRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<IngestResponse>>

pub fn ingest_async(
    &self,
    req: &IngestRequest
) -> Result<ClientUnaryReceiver<IngestResponse>>

pub fn compact_opt(
    &self,
    req: &CompactRequest,
    opt: CallOption
) -> Result<CompactResponse>

pub fn compact(&self, req: &CompactRequest) -> Result<CompactResponse>

pub fn compact_async_opt(
    &self,
    req: &CompactRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<CompactResponse>>

pub fn compact_async(
    &self,
    req: &CompactRequest
) -> Result<ClientUnaryReceiver<CompactResponse>>

pub fn set_download_speed_limit_opt(
    &self,
    req: &SetDownloadSpeedLimitRequest,
    opt: CallOption
) -> Result<SetDownloadSpeedLimitResponse>

pub fn set_download_speed_limit(
    &self,
    req: &SetDownloadSpeedLimitRequest
) -> Result<SetDownloadSpeedLimitResponse>

pub fn set_download_speed_limit_async_opt(
    &self,
    req: &SetDownloadSpeedLimitRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<SetDownloadSpeedLimitResponse>>

pub fn set_download_speed_limit_async(
    &self,
    req: &SetDownloadSpeedLimitRequest
) -> Result<ClientUnaryReceiver<SetDownloadSpeedLimitResponse>>

pub fn download_opt(
    &self,
    req: &DownloadRequest,
    opt: CallOption
) -> Result<DownloadResponse>

pub fn download(&self, req: &DownloadRequest) -> Result<DownloadResponse>

pub fn download_async_opt(
    &self,
    req: &DownloadRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<DownloadResponse>>

pub fn download_async(
    &self,
    req: &DownloadRequest
) -> Result<ClientUnaryReceiver<DownloadResponse>>

pub fn write_opt(
    &self,
    opt: CallOption
) -> Result<(ClientCStreamSender<WriteRequest>, ClientCStreamReceiver<WriteResponse>)>

pub fn write(
    &self
) -> Result<(ClientCStreamSender<WriteRequest>, ClientCStreamReceiver<WriteResponse>)>

pub fn multi_ingest_opt(
    &self,
    req: &MultiIngestRequest,
    opt: CallOption
) -> Result<IngestResponse>

pub fn multi_ingest(&self, req: &MultiIngestRequest) -> Result<IngestResponse>

pub fn multi_ingest_async_opt(
    &self,
    req: &MultiIngestRequest,
    opt: CallOption
) -> Result<ClientUnaryReceiver<IngestResponse>>

pub fn multi_ingest_async(
    &self,
    req: &MultiIngestRequest
) -> Result<ClientUnaryReceiver<IngestResponse>>

pub fn spawn<F>(&self, f: F) where
    F: Future<Output = ()> + Send + 'static, 

Trait Implementations

impl Clone for ImportSstClient

fn clone(&self) -> ImportSstClient

Returns a copy of the value.

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

Performs copy-assignment from source.