Struct StreamManagerServiceClient 

pub struct StreamManagerServiceClient<T> {
    inner: Grpc<T>,
}

Fields

inner: Grpc<T>

Implementations

impl StreamManagerServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>

where D: TryInto<Endpoint>, D::Error: Into<StdError>,

Attempt to create a new client by connecting to a given endpoint.

impl<T> StreamManagerServiceClient<T>

where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> StreamManagerServiceClient<InterceptedService<T, F>>

where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

pub async fn flush( &mut self, request: impl IntoRequest<FlushRequest>, ) -> Result<Response<FlushResponse>, Status>

pub async fn pause( &mut self, request: impl IntoRequest<PauseRequest>, ) -> Result<Response<PauseResponse>, Status>

pub async fn resume( &mut self, request: impl IntoRequest<ResumeRequest>, ) -> Result<Response<ResumeResponse>, Status>

pub async fn refresh( &mut self, request: impl IntoRequest<RefreshRequest>, ) -> Result<Response<RefreshResponse>, Status>

pub async fn cancel_creating_jobs( &mut self, request: impl IntoRequest<CancelCreatingJobsRequest>, ) -> Result<Response<CancelCreatingJobsResponse>, Status>

pub async fn list_table_fragments( &mut self, request: impl IntoRequest<ListTableFragmentsRequest>, ) -> Result<Response<ListTableFragmentsResponse>, Status>

pub async fn list_streaming_job_states( &mut self, request: impl IntoRequest<ListStreamingJobStatesRequest>, ) -> Result<Response<ListStreamingJobStatesResponse>, Status>

pub async fn list_fragment_distribution( &mut self, request: impl IntoRequest<ListFragmentDistributionRequest>, ) -> Result<Response<ListFragmentDistributionResponse>, Status>

pub async fn list_creating_fragment_distribution( &mut self, request: impl IntoRequest<ListCreatingFragmentDistributionRequest>, ) -> Result<Response<ListCreatingFragmentDistributionResponse>, Status>

pub async fn list_actor_states( &mut self, request: impl IntoRequest<ListActorStatesRequest>, ) -> Result<Response<ListActorStatesResponse>, Status>

pub async fn list_actor_splits( &mut self, request: impl IntoRequest<ListActorSplitsRequest>, ) -> Result<Response<ListActorSplitsResponse>, Status>

pub async fn list_object_dependencies( &mut self, request: impl IntoRequest<ListObjectDependenciesRequest>, ) -> Result<Response<ListObjectDependenciesResponse>, Status>

pub async fn apply_throttle( &mut self, request: impl IntoRequest<ApplyThrottleRequest>, ) -> Result<Response<ApplyThrottleResponse>, Status>

pub async fn recover( &mut self, request: impl IntoRequest<RecoverRequest>, ) -> Result<Response<RecoverResponse>, Status>

pub async fn list_rate_limits( &mut self, request: impl IntoRequest<ListRateLimitsRequest>, ) -> Result<Response<ListRateLimitsResponse>, Status>

pub async fn alter_connector_props( &mut self, request: impl IntoRequest<AlterConnectorPropsRequest>, ) -> Result<Response<AlterConnectorPropsResponse>, Status>

pub async fn get_fragment_by_id( &mut self, request: impl IntoRequest<GetFragmentByIdRequest>, ) -> Result<Response<GetFragmentByIdResponse>, Status>

pub async fn get_fragment_vnodes( &mut self, request: impl IntoRequest<GetFragmentVnodesRequest>, ) -> Result<Response<GetFragmentVnodesResponse>, Status>

pub async fn get_actor_vnodes( &mut self, request: impl IntoRequest<GetActorVnodesRequest>, ) -> Result<Response<GetActorVnodesResponse>, Status>

pub async fn set_sync_log_store_aligned( &mut self, request: impl IntoRequest<SetSyncLogStoreAlignedRequest>, ) -> Result<Response<SetSyncLogStoreAlignedResponse>, Status>

pub async fn list_cdc_progress( &mut self, request: impl IntoRequest<ListCdcProgressRequest>, ) -> Result<Response<ListCdcProgressResponse>, Status>

pub async fn list_unmigrated_tables( &mut self, request: impl IntoRequest<ListUnmigratedTablesRequest>, ) -> Result<Response<ListUnmigratedTablesResponse>, Status>

pub async fn list_refresh_table_states( &mut self, request: impl IntoRequest<ListRefreshTableStatesRequest>, ) -> Result<Response<ListRefreshTableStatesResponse>, Status>

Trait Implementations

impl<T: Clone> Clone for StreamManagerServiceClient<T>

fn clone(&self) -> StreamManagerServiceClient<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for StreamManagerServiceClient<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.