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 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_table_fragment_states( &mut self, request: impl IntoRequest<ListTableFragmentStatesRequest>, ) -> Result<Response<ListTableFragmentStatesResponse>, Status>

pub async fn list_fragment_distribution( &mut self, request: impl IntoRequest<ListFragmentDistributionRequest>, ) -> Result<Response<ListFragmentDistributionResponse>, 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>

Trait Implementations

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

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

Returns a copy 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.