OperatorService

squads_temporal_client

Trait OperatorService 

Source 
pub trait OperatorService: RawClientLike
where
    <Self as RawClientLike>::SvcType: GrpcService<Body> + Send + Clone + 'static,
    <<Self as RawClientLike>::SvcType as GrpcService<Body>>::ResponseBody: Body<Data = Bytes> + Send + 'static,
    <<Self as RawClientLike>::SvcType as GrpcService<Body>>::Error: Into<StdError>,
    <<Self as RawClientLike>::SvcType as GrpcService<Body>>::Future: Send,
    <<<Self as RawClientLike>::SvcType as GrpcService<Body>>::ResponseBody as Body>::Error: Into<StdError> + Send,
{
    // Provided methods
    fn add_search_attributes(
        &mut self,
        request: impl IntoRequest<AddSearchAttributesRequest>,
    ) -> BoxFuture<'_, Result<Response<AddSearchAttributesResponse>, Status>> { ... }
    fn remove_search_attributes(
        &mut self,
        request: impl IntoRequest<RemoveSearchAttributesRequest>,
    ) -> BoxFuture<'_, Result<Response<RemoveSearchAttributesResponse>, Status>> { ... }
    fn list_search_attributes(
        &mut self,
        request: impl IntoRequest<ListSearchAttributesRequest>,
    ) -> BoxFuture<'_, Result<Response<ListSearchAttributesResponse>, Status>> { ... }
    fn delete_namespace(
        &mut self,
        request: impl IntoRequest<DeleteNamespaceRequest>,
    ) -> BoxFuture<'_, Result<Response<DeleteNamespaceResponse>, Status>> { ... }
    fn add_or_update_remote_cluster(
        &mut self,
        request: impl IntoRequest<AddOrUpdateRemoteClusterRequest>,
    ) -> BoxFuture<'_, Result<Response<AddOrUpdateRemoteClusterResponse>, Status>> { ... }
    fn remove_remote_cluster(
        &mut self,
        request: impl IntoRequest<RemoveRemoteClusterRequest>,
    ) -> BoxFuture<'_, Result<Response<RemoveRemoteClusterResponse>, Status>> { ... }
    fn list_clusters(
        &mut self,
        request: impl IntoRequest<ListClustersRequest>,
    ) -> BoxFuture<'_, Result<Response<ListClustersResponse>, Status>> { ... }
    fn get_nexus_endpoint(
        &mut self,
        request: impl IntoRequest<GetNexusEndpointRequest>,
    ) -> BoxFuture<'_, Result<Response<GetNexusEndpointResponse>, Status>> { ... }
    fn create_nexus_endpoint(
        &mut self,
        request: impl IntoRequest<CreateNexusEndpointRequest>,
    ) -> BoxFuture<'_, Result<Response<CreateNexusEndpointResponse>, Status>> { ... }
    fn update_nexus_endpoint(
        &mut self,
        request: impl IntoRequest<UpdateNexusEndpointRequest>,
    ) -> BoxFuture<'_, Result<Response<UpdateNexusEndpointResponse>, Status>> { ... }
    fn delete_nexus_endpoint(
        &mut self,
        request: impl IntoRequest<DeleteNexusEndpointRequest>,
    ) -> BoxFuture<'_, Result<Response<DeleteNexusEndpointResponse>, Status>> { ... }
    fn list_nexus_endpoints(
        &mut self,
        request: impl IntoRequest<ListNexusEndpointsRequest>,
    ) -> BoxFuture<'_, Result<Response<ListNexusEndpointsResponse>, Status>> { ... }
}
Expand description

Trait version of the generated client with modifications to attach appropriate metric labels or whatever else to requests

Provided Methods§

Source

fn add_search_attributes( &mut self, request: impl IntoRequest<AddSearchAttributesRequest>, ) -> BoxFuture<'_, Result<Response<AddSearchAttributesResponse>, Status>>

See OperatorServiceClient::add_search_attributes

Source

fn remove_search_attributes( &mut self, request: impl IntoRequest<RemoveSearchAttributesRequest>, ) -> BoxFuture<'_, Result<Response<RemoveSearchAttributesResponse>, Status>>

See OperatorServiceClient::remove_search_attributes

Source

fn list_search_attributes( &mut self, request: impl IntoRequest<ListSearchAttributesRequest>, ) -> BoxFuture<'_, Result<Response<ListSearchAttributesResponse>, Status>>

See OperatorServiceClient::list_search_attributes

Source

fn delete_namespace( &mut self, request: impl IntoRequest<DeleteNamespaceRequest>, ) -> BoxFuture<'_, Result<Response<DeleteNamespaceResponse>, Status>>

See OperatorServiceClient::delete_namespace

Source

fn add_or_update_remote_cluster( &mut self, request: impl IntoRequest<AddOrUpdateRemoteClusterRequest>, ) -> BoxFuture<'_, Result<Response<AddOrUpdateRemoteClusterResponse>, Status>>

See OperatorServiceClient::add_or_update_remote_cluster

Source

fn remove_remote_cluster( &mut self, request: impl IntoRequest<RemoveRemoteClusterRequest>, ) -> BoxFuture<'_, Result<Response<RemoveRemoteClusterResponse>, Status>>

See OperatorServiceClient::remove_remote_cluster

Source

fn list_clusters( &mut self, request: impl IntoRequest<ListClustersRequest>, ) -> BoxFuture<'_, Result<Response<ListClustersResponse>, Status>>

See OperatorServiceClient::list_clusters

Source

fn get_nexus_endpoint( &mut self, request: impl IntoRequest<GetNexusEndpointRequest>, ) -> BoxFuture<'_, Result<Response<GetNexusEndpointResponse>, Status>>

See OperatorServiceClient::get_nexus_endpoint

Source

fn create_nexus_endpoint( &mut self, request: impl IntoRequest<CreateNexusEndpointRequest>, ) -> BoxFuture<'_, Result<Response<CreateNexusEndpointResponse>, Status>>

See OperatorServiceClient::create_nexus_endpoint

Source

fn update_nexus_endpoint( &mut self, request: impl IntoRequest<UpdateNexusEndpointRequest>, ) -> BoxFuture<'_, Result<Response<UpdateNexusEndpointResponse>, Status>>

See OperatorServiceClient::update_nexus_endpoint

Source

fn delete_nexus_endpoint( &mut self, request: impl IntoRequest<DeleteNexusEndpointRequest>, ) -> BoxFuture<'_, Result<Response<DeleteNexusEndpointResponse>, Status>>

See OperatorServiceClient::delete_nexus_endpoint

Source

fn list_nexus_endpoints( &mut self, request: impl IntoRequest<ListNexusEndpointsRequest>, ) -> BoxFuture<'_, Result<Response<ListNexusEndpointsResponse>, Status>>

See OperatorServiceClient::list_nexus_endpoints

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§

Source§

impl<RC, T> OperatorService for RC
where RC: RawClientLike<SvcType = T>, T: GrpcService<Body> + Send + Clone + 'static, T::ResponseBody: Body<Data = Bytes> + Send + 'static, T::Error: Into<StdError>, T::Future: Send, <T::ResponseBody as Body>::Error: Into<StdError> + Send,