SharedReplaceableClient

Struct SharedReplaceableClient 

Source
pub struct SharedReplaceableClient<C>
where C: Clone + Send + Sync,
{ /* private fields */ }
Expand description

A client wrapper that allows replacing the underlying client at a later point in time. Clones of this struct have a shared reference to the underlying client, and each clone also has its own cached clone of the underlying client. Before every service call, a check is made whether the shared client was replaced, and the cached clone is updated accordingly.

This struct is fully thread-safe, and it works in a lock-free manner except when the client is being replaced. A read-write lock is used then, with minimal locking time.

Implementations§

Source§

impl<C> SharedReplaceableClient<C>
where C: Clone + Send + Sync,

Source

pub fn new(client: C) -> Self

Creates the initial instance of replaceable client with the provided underlying client. Use clone() method to create more instances that share the same underlying client.

Source

pub fn replace_client(&self, new_client: C)

Replaces the client for all instances that share this instance’s underlying client.

Source

pub fn inner_clone(&self) -> C

Returns a clone of the underlying client.

Source

pub fn inner_cow(&self) -> Cow<'_, C>

Returns an immutable reference to this instance’s cached clone of the underlying client if it’s up to date, or a fresh clone of the shared client otherwise. Because it’s an immutable method, it will not update this instance’s cached clone. For this reason, prefer to use inner_mut_refreshed() when possible.

Source

pub fn inner_mut_refreshed(&mut self) -> &mut C

Returns a mutable reference to this instance’s cached clone of the underlying client. If the cached clone is not up to date, it’s refreshed before the reference is returned. This method is called automatically by most other mutable methods, in particular by all service calls, so most of the time it doesn’t need to be called directly.

While this method allows mutable access to the underlying client, any configuration changes will not be shared with other instances, and will be lost if the client gets replaced from anywhere. To make configuration changes, use replace_client() instead.

Trait Implementations§

Source§

impl<C> Clone for SharedReplaceableClient<C>
where C: Clone + Send + Sync,

Source§

fn clone(&self) -> Self

Creates a new instance of replaceable client that shares the underlying client with this instance. Replacing a client in either instance will replace it for both instances, and all other clones too.

1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl<C> Debug for SharedReplaceableClient<C>
where C: Clone + Send + Sync + Debug,

Source§

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

Formats the value using the given formatter. Read more
Source§

impl<C> NamespacedClient for SharedReplaceableClient<C>

Source§

fn namespace(&self) -> String

Returns the namespace this client is bound to
Source§

fn identity(&self) -> String

Returns the client identity

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

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

Source§

fn get_users( &mut self, request: impl IntoRequest<GetUsersRequest>, ) -> BoxFuture<'_, Result<Response<GetUsersResponse>, Status>>

Source§

fn get_user( &mut self, request: impl IntoRequest<GetUserRequest>, ) -> BoxFuture<'_, Result<Response<GetUserResponse>, Status>>

Source§

fn create_user( &mut self, request: impl IntoRequest<CreateUserRequest>, ) -> BoxFuture<'_, Result<Response<CreateUserResponse>, Status>>

Source§

fn update_user( &mut self, request: impl IntoRequest<UpdateUserRequest>, ) -> BoxFuture<'_, Result<Response<UpdateUserResponse>, Status>>

Source§

fn delete_user( &mut self, request: impl IntoRequest<DeleteUserRequest>, ) -> BoxFuture<'_, Result<Response<DeleteUserResponse>, Status>>

Source§

fn set_user_namespace_access( &mut self, request: impl IntoRequest<SetUserNamespaceAccessRequest>, ) -> BoxFuture<'_, Result<Response<SetUserNamespaceAccessResponse>, Status>>

Source§

fn get_async_operation( &mut self, request: impl IntoRequest<GetAsyncOperationRequest>, ) -> BoxFuture<'_, Result<Response<GetAsyncOperationResponse>, Status>>

Source§

fn create_namespace( &mut self, request: impl IntoRequest<CreateNamespaceRequest>, ) -> BoxFuture<'_, Result<Response<CreateNamespaceResponse>, Status>>

Source§

fn get_namespaces( &mut self, request: impl IntoRequest<GetNamespacesRequest>, ) -> BoxFuture<'_, Result<Response<GetNamespacesResponse>, Status>>

Source§

fn get_namespace( &mut self, request: impl IntoRequest<GetNamespaceRequest>, ) -> BoxFuture<'_, Result<Response<GetNamespaceResponse>, Status>>

Source§

fn update_namespace( &mut self, request: impl IntoRequest<UpdateNamespaceRequest>, ) -> BoxFuture<'_, Result<Response<UpdateNamespaceResponse>, Status>>

Source§

fn rename_custom_search_attribute( &mut self, request: impl IntoRequest<RenameCustomSearchAttributeRequest>, ) -> BoxFuture<'_, Result<Response<RenameCustomSearchAttributeResponse>, Status>>

Source§

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

Source§

fn failover_namespace_region( &mut self, request: impl IntoRequest<FailoverNamespaceRegionRequest>, ) -> BoxFuture<'_, Result<Response<FailoverNamespaceRegionResponse>, Status>>

Source§

fn add_namespace_region( &mut self, request: impl IntoRequest<AddNamespaceRegionRequest>, ) -> BoxFuture<'_, Result<Response<AddNamespaceRegionResponse>, Status>>

Source§

fn delete_namespace_region( &mut self, request: impl IntoRequest<DeleteNamespaceRegionRequest>, ) -> BoxFuture<'_, Result<Response<DeleteNamespaceRegionResponse>, Status>>

Source§

fn get_regions( &mut self, request: impl IntoRequest<GetRegionsRequest>, ) -> BoxFuture<'_, Result<Response<GetRegionsResponse>, Status>>

Source§

fn get_region( &mut self, request: impl IntoRequest<GetRegionRequest>, ) -> BoxFuture<'_, Result<Response<GetRegionResponse>, Status>>

Source§

fn get_api_keys( &mut self, request: impl IntoRequest<GetApiKeysRequest>, ) -> BoxFuture<'_, Result<Response<GetApiKeysResponse>, Status>>

Source§

fn get_api_key( &mut self, request: impl IntoRequest<GetApiKeyRequest>, ) -> BoxFuture<'_, Result<Response<GetApiKeyResponse>, Status>>

Source§

fn create_api_key( &mut self, request: impl IntoRequest<CreateApiKeyRequest>, ) -> BoxFuture<'_, Result<Response<CreateApiKeyResponse>, Status>>

Source§

fn update_api_key( &mut self, request: impl IntoRequest<UpdateApiKeyRequest>, ) -> BoxFuture<'_, Result<Response<UpdateApiKeyResponse>, Status>>

Source§

fn delete_api_key( &mut self, request: impl IntoRequest<DeleteApiKeyRequest>, ) -> BoxFuture<'_, Result<Response<DeleteApiKeyResponse>, Status>>

Source§

fn get_nexus_endpoints( &mut self, request: impl IntoRequest<GetNexusEndpointsRequest>, ) -> BoxFuture<'_, Result<Response<GetNexusEndpointsResponse>, Status>>

Source§

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

Source§

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

Source§

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

Source§

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

Source§

fn get_user_groups( &mut self, request: impl IntoRequest<GetUserGroupsRequest>, ) -> BoxFuture<'_, Result<Response<GetUserGroupsResponse>, Status>>

Source§

fn get_user_group( &mut self, request: impl IntoRequest<GetUserGroupRequest>, ) -> BoxFuture<'_, Result<Response<GetUserGroupResponse>, Status>>

Source§

fn create_user_group( &mut self, request: impl IntoRequest<CreateUserGroupRequest>, ) -> BoxFuture<'_, Result<Response<CreateUserGroupResponse>, Status>>

Source§

fn update_user_group( &mut self, request: impl IntoRequest<UpdateUserGroupRequest>, ) -> BoxFuture<'_, Result<Response<UpdateUserGroupResponse>, Status>>

Source§

fn delete_user_group( &mut self, request: impl IntoRequest<DeleteUserGroupRequest>, ) -> BoxFuture<'_, Result<Response<DeleteUserGroupResponse>, Status>>

Source§

fn add_user_group_member( &mut self, request: impl IntoRequest<AddUserGroupMemberRequest>, ) -> BoxFuture<'_, Result<Response<AddUserGroupMemberResponse>, Status>>

Source§

fn remove_user_group_member( &mut self, request: impl IntoRequest<RemoveUserGroupMemberRequest>, ) -> BoxFuture<'_, Result<Response<RemoveUserGroupMemberResponse>, Status>>

Source§

fn get_user_group_members( &mut self, request: impl IntoRequest<GetUserGroupMembersRequest>, ) -> BoxFuture<'_, Result<Response<GetUserGroupMembersResponse>, Status>>

Source§

fn set_user_group_namespace_access( &mut self, request: impl IntoRequest<SetUserGroupNamespaceAccessRequest>, ) -> BoxFuture<'_, Result<Response<SetUserGroupNamespaceAccessResponse>, Status>>

Source§

fn create_service_account( &mut self, request: impl IntoRequest<CreateServiceAccountRequest>, ) -> BoxFuture<'_, Result<Response<CreateServiceAccountResponse>, Status>>

Source§

fn get_service_account( &mut self, request: impl IntoRequest<GetServiceAccountRequest>, ) -> BoxFuture<'_, Result<Response<GetServiceAccountResponse>, Status>>

Source§

fn get_service_accounts( &mut self, request: impl IntoRequest<GetServiceAccountsRequest>, ) -> BoxFuture<'_, Result<Response<GetServiceAccountsResponse>, Status>>

Source§

fn update_service_account( &mut self, request: impl IntoRequest<UpdateServiceAccountRequest>, ) -> BoxFuture<'_, Result<Response<UpdateServiceAccountResponse>, Status>>

Source§

fn delete_service_account( &mut self, request: impl IntoRequest<DeleteServiceAccountRequest>, ) -> BoxFuture<'_, Result<Response<DeleteServiceAccountResponse>, Status>>

Source§

fn get_usage( &mut self, request: impl IntoRequest<GetUsageRequest>, ) -> BoxFuture<'_, Result<Response<GetUsageResponse>, Status>>

Source§

fn get_account( &mut self, request: impl IntoRequest<GetAccountRequest>, ) -> BoxFuture<'_, Result<Response<GetAccountResponse>, Status>>

Source§

fn update_account( &mut self, request: impl IntoRequest<UpdateAccountRequest>, ) -> BoxFuture<'_, Result<Response<UpdateAccountResponse>, Status>>

Source§

fn create_namespace_export_sink( &mut self, request: impl IntoRequest<CreateNamespaceExportSinkRequest>, ) -> BoxFuture<'_, Result<Response<CreateNamespaceExportSinkResponse>, Status>>

Source§

fn get_namespace_export_sink( &mut self, request: impl IntoRequest<GetNamespaceExportSinkRequest>, ) -> BoxFuture<'_, Result<Response<GetNamespaceExportSinkResponse>, Status>>

Source§

fn get_namespace_export_sinks( &mut self, request: impl IntoRequest<GetNamespaceExportSinksRequest>, ) -> BoxFuture<'_, Result<Response<GetNamespaceExportSinksResponse>, Status>>

Source§

fn update_namespace_export_sink( &mut self, request: impl IntoRequest<UpdateNamespaceExportSinkRequest>, ) -> BoxFuture<'_, Result<Response<UpdateNamespaceExportSinkResponse>, Status>>

Source§

fn delete_namespace_export_sink( &mut self, request: impl IntoRequest<DeleteNamespaceExportSinkRequest>, ) -> BoxFuture<'_, Result<Response<DeleteNamespaceExportSinkResponse>, Status>>

Source§

fn validate_namespace_export_sink( &mut self, request: impl IntoRequest<ValidateNamespaceExportSinkRequest>, ) -> BoxFuture<'_, Result<Response<ValidateNamespaceExportSinkResponse>, Status>>

Source§

fn update_namespace_tags( &mut self, request: impl IntoRequest<UpdateNamespaceTagsRequest>, ) -> BoxFuture<'_, Result<Response<UpdateNamespaceTagsResponse>, Status>>

Source§

fn create_connectivity_rule( &mut self, request: impl IntoRequest<CreateConnectivityRuleRequest>, ) -> BoxFuture<'_, Result<Response<CreateConnectivityRuleResponse>, Status>>

Source§

fn get_connectivity_rule( &mut self, request: impl IntoRequest<GetConnectivityRuleRequest>, ) -> BoxFuture<'_, Result<Response<GetConnectivityRuleResponse>, Status>>

Source§

fn get_connectivity_rules( &mut self, request: impl IntoRequest<GetConnectivityRulesRequest>, ) -> BoxFuture<'_, Result<Response<GetConnectivityRulesResponse>, Status>>

Source§

fn delete_connectivity_rule( &mut self, request: impl IntoRequest<DeleteConnectivityRuleRequest>, ) -> BoxFuture<'_, Result<Response<DeleteConnectivityRuleResponse>, Status>>

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FromRef<T> for T
where T: Clone,

Source§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
Source§

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

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<L> LayerExt<L> for L

Source§

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

Applies the layer to a service and wraps it in Layered.
Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WfClientExt for T
where T: WfHandleClient + Clone,

Source§

fn get_untyped_workflow_handle( &self, workflow_id: impl Into<String>, run_id: impl Into<String>, ) -> WorkflowHandle<Self, Vec<Payload>>

Create an untyped handle for a workflow execution, which can be used to do things like wait for that workflow’s result. run_id may be left blank to target the latest run.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

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

Source§

fn register_namespace( &mut self, request: impl IntoRequest<RegisterNamespaceRequest>, ) -> BoxFuture<'_, Result<Response<RegisterNamespaceResponse>, Status>>

Source§

fn describe_namespace( &mut self, request: impl IntoRequest<DescribeNamespaceRequest>, ) -> BoxFuture<'_, Result<Response<DescribeNamespaceResponse>, Status>>

Source§

fn list_namespaces( &mut self, request: impl IntoRequest<ListNamespacesRequest>, ) -> BoxFuture<'_, Result<Response<ListNamespacesResponse>, Status>>

Source§

fn update_namespace( &mut self, request: impl IntoRequest<UpdateNamespaceRequest>, ) -> BoxFuture<'_, Result<Response<UpdateNamespaceResponse>, Status>>

Source§

fn deprecate_namespace( &mut self, request: impl IntoRequest<DeprecateNamespaceRequest>, ) -> BoxFuture<'_, Result<Response<DeprecateNamespaceResponse>, Status>>

Source§

fn start_workflow_execution( &mut self, request: impl IntoRequest<StartWorkflowExecutionRequest>, ) -> BoxFuture<'_, Result<Response<StartWorkflowExecutionResponse>, Status>>

Source§

fn get_workflow_execution_history( &mut self, request: impl IntoRequest<GetWorkflowExecutionHistoryRequest>, ) -> BoxFuture<'_, Result<Response<GetWorkflowExecutionHistoryResponse>, Status>>

Source§

fn get_workflow_execution_history_reverse( &mut self, request: impl IntoRequest<GetWorkflowExecutionHistoryReverseRequest>, ) -> BoxFuture<'_, Result<Response<GetWorkflowExecutionHistoryReverseResponse>, Status>>

Source§

fn poll_workflow_task_queue( &mut self, request: impl IntoRequest<PollWorkflowTaskQueueRequest>, ) -> BoxFuture<'_, Result<Response<PollWorkflowTaskQueueResponse>, Status>>

Source§

fn respond_workflow_task_completed( &mut self, request: impl IntoRequest<RespondWorkflowTaskCompletedRequest>, ) -> BoxFuture<'_, Result<Response<RespondWorkflowTaskCompletedResponse>, Status>>

Source§

fn respond_workflow_task_failed( &mut self, request: impl IntoRequest<RespondWorkflowTaskFailedRequest>, ) -> BoxFuture<'_, Result<Response<RespondWorkflowTaskFailedResponse>, Status>>

Source§

fn poll_activity_task_queue( &mut self, request: impl IntoRequest<PollActivityTaskQueueRequest>, ) -> BoxFuture<'_, Result<Response<PollActivityTaskQueueResponse>, Status>>

Source§

fn record_activity_task_heartbeat( &mut self, request: impl IntoRequest<RecordActivityTaskHeartbeatRequest>, ) -> BoxFuture<'_, Result<Response<RecordActivityTaskHeartbeatResponse>, Status>>

Source§

fn record_activity_task_heartbeat_by_id( &mut self, request: impl IntoRequest<RecordActivityTaskHeartbeatByIdRequest>, ) -> BoxFuture<'_, Result<Response<RecordActivityTaskHeartbeatByIdResponse>, Status>>

Source§

fn respond_activity_task_completed( &mut self, request: impl IntoRequest<RespondActivityTaskCompletedRequest>, ) -> BoxFuture<'_, Result<Response<RespondActivityTaskCompletedResponse>, Status>>

Source§

fn respond_activity_task_completed_by_id( &mut self, request: impl IntoRequest<RespondActivityTaskCompletedByIdRequest>, ) -> BoxFuture<'_, Result<Response<RespondActivityTaskCompletedByIdResponse>, Status>>

Source§

fn respond_activity_task_failed( &mut self, request: impl IntoRequest<RespondActivityTaskFailedRequest>, ) -> BoxFuture<'_, Result<Response<RespondActivityTaskFailedResponse>, Status>>

Source§

fn respond_activity_task_failed_by_id( &mut self, request: impl IntoRequest<RespondActivityTaskFailedByIdRequest>, ) -> BoxFuture<'_, Result<Response<RespondActivityTaskFailedByIdResponse>, Status>>

Source§

fn respond_activity_task_canceled( &mut self, request: impl IntoRequest<RespondActivityTaskCanceledRequest>, ) -> BoxFuture<'_, Result<Response<RespondActivityTaskCanceledResponse>, Status>>

Source§

fn respond_activity_task_canceled_by_id( &mut self, request: impl IntoRequest<RespondActivityTaskCanceledByIdRequest>, ) -> BoxFuture<'_, Result<Response<RespondActivityTaskCanceledByIdResponse>, Status>>

Source§

fn request_cancel_workflow_execution( &mut self, request: impl IntoRequest<RequestCancelWorkflowExecutionRequest>, ) -> BoxFuture<'_, Result<Response<RequestCancelWorkflowExecutionResponse>, Status>>

Source§

fn signal_workflow_execution( &mut self, request: impl IntoRequest<SignalWorkflowExecutionRequest>, ) -> BoxFuture<'_, Result<Response<SignalWorkflowExecutionResponse>, Status>>

Source§

fn signal_with_start_workflow_execution( &mut self, request: impl IntoRequest<SignalWithStartWorkflowExecutionRequest>, ) -> BoxFuture<'_, Result<Response<SignalWithStartWorkflowExecutionResponse>, Status>>

Source§

fn reset_workflow_execution( &mut self, request: impl IntoRequest<ResetWorkflowExecutionRequest>, ) -> BoxFuture<'_, Result<Response<ResetWorkflowExecutionResponse>, Status>>

Source§

fn terminate_workflow_execution( &mut self, request: impl IntoRequest<TerminateWorkflowExecutionRequest>, ) -> BoxFuture<'_, Result<Response<TerminateWorkflowExecutionResponse>, Status>>

Source§

fn delete_workflow_execution( &mut self, request: impl IntoRequest<DeleteWorkflowExecutionRequest>, ) -> BoxFuture<'_, Result<Response<DeleteWorkflowExecutionResponse>, Status>>

Source§

fn list_open_workflow_executions( &mut self, request: impl IntoRequest<ListOpenWorkflowExecutionsRequest>, ) -> BoxFuture<'_, Result<Response<ListOpenWorkflowExecutionsResponse>, Status>>

Source§

fn list_closed_workflow_executions( &mut self, request: impl IntoRequest<ListClosedWorkflowExecutionsRequest>, ) -> BoxFuture<'_, Result<Response<ListClosedWorkflowExecutionsResponse>, Status>>

Source§

fn list_workflow_executions( &mut self, request: impl IntoRequest<ListWorkflowExecutionsRequest>, ) -> BoxFuture<'_, Result<Response<ListWorkflowExecutionsResponse>, Status>>

Source§

fn list_archived_workflow_executions( &mut self, request: impl IntoRequest<ListArchivedWorkflowExecutionsRequest>, ) -> BoxFuture<'_, Result<Response<ListArchivedWorkflowExecutionsResponse>, Status>>

Source§

fn scan_workflow_executions( &mut self, request: impl IntoRequest<ScanWorkflowExecutionsRequest>, ) -> BoxFuture<'_, Result<Response<ScanWorkflowExecutionsResponse>, Status>>

Source§

fn count_workflow_executions( &mut self, request: impl IntoRequest<CountWorkflowExecutionsRequest>, ) -> BoxFuture<'_, Result<Response<CountWorkflowExecutionsResponse>, Status>>

Source§

fn create_workflow_rule( &mut self, request: impl IntoRequest<CreateWorkflowRuleRequest>, ) -> BoxFuture<'_, Result<Response<CreateWorkflowRuleResponse>, Status>>

Source§

fn describe_workflow_rule( &mut self, request: impl IntoRequest<DescribeWorkflowRuleRequest>, ) -> BoxFuture<'_, Result<Response<DescribeWorkflowRuleResponse>, Status>>

Source§

fn delete_workflow_rule( &mut self, request: impl IntoRequest<DeleteWorkflowRuleRequest>, ) -> BoxFuture<'_, Result<Response<DeleteWorkflowRuleResponse>, Status>>

Source§

fn list_workflow_rules( &mut self, request: impl IntoRequest<ListWorkflowRulesRequest>, ) -> BoxFuture<'_, Result<Response<ListWorkflowRulesResponse>, Status>>

Source§

fn trigger_workflow_rule( &mut self, request: impl IntoRequest<TriggerWorkflowRuleRequest>, ) -> BoxFuture<'_, Result<Response<TriggerWorkflowRuleResponse>, Status>>

Source§

fn get_search_attributes( &mut self, request: impl IntoRequest<GetSearchAttributesRequest>, ) -> BoxFuture<'_, Result<Response<GetSearchAttributesResponse>, Status>>

Source§

fn respond_query_task_completed( &mut self, request: impl IntoRequest<RespondQueryTaskCompletedRequest>, ) -> BoxFuture<'_, Result<Response<RespondQueryTaskCompletedResponse>, Status>>

Source§

fn reset_sticky_task_queue( &mut self, request: impl IntoRequest<ResetStickyTaskQueueRequest>, ) -> BoxFuture<'_, Result<Response<ResetStickyTaskQueueResponse>, Status>>

Source§

fn query_workflow( &mut self, request: impl IntoRequest<QueryWorkflowRequest>, ) -> BoxFuture<'_, Result<Response<QueryWorkflowResponse>, Status>>

Source§

fn describe_workflow_execution( &mut self, request: impl IntoRequest<DescribeWorkflowExecutionRequest>, ) -> BoxFuture<'_, Result<Response<DescribeWorkflowExecutionResponse>, Status>>

Source§

fn describe_task_queue( &mut self, request: impl IntoRequest<DescribeTaskQueueRequest>, ) -> BoxFuture<'_, Result<Response<DescribeTaskQueueResponse>, Status>>

Source§

fn get_cluster_info( &mut self, request: impl IntoRequest<GetClusterInfoRequest>, ) -> BoxFuture<'_, Result<Response<GetClusterInfoResponse>, Status>>

Source§

fn get_system_info( &mut self, request: impl IntoRequest<GetSystemInfoRequest>, ) -> BoxFuture<'_, Result<Response<GetSystemInfoResponse>, Status>>

Source§

fn list_task_queue_partitions( &mut self, request: impl IntoRequest<ListTaskQueuePartitionsRequest>, ) -> BoxFuture<'_, Result<Response<ListTaskQueuePartitionsResponse>, Status>>

Source§

fn create_schedule( &mut self, request: impl IntoRequest<CreateScheduleRequest>, ) -> BoxFuture<'_, Result<Response<CreateScheduleResponse>, Status>>

Source§

fn describe_schedule( &mut self, request: impl IntoRequest<DescribeScheduleRequest>, ) -> BoxFuture<'_, Result<Response<DescribeScheduleResponse>, Status>>

Source§

fn update_schedule( &mut self, request: impl IntoRequest<UpdateScheduleRequest>, ) -> BoxFuture<'_, Result<Response<UpdateScheduleResponse>, Status>>

Source§

fn patch_schedule( &mut self, request: impl IntoRequest<PatchScheduleRequest>, ) -> BoxFuture<'_, Result<Response<PatchScheduleResponse>, Status>>

Source§

fn list_schedule_matching_times( &mut self, request: impl IntoRequest<ListScheduleMatchingTimesRequest>, ) -> BoxFuture<'_, Result<Response<ListScheduleMatchingTimesResponse>, Status>>

Source§

fn delete_schedule( &mut self, request: impl IntoRequest<DeleteScheduleRequest>, ) -> BoxFuture<'_, Result<Response<DeleteScheduleResponse>, Status>>

Source§

fn list_schedules( &mut self, request: impl IntoRequest<ListSchedulesRequest>, ) -> BoxFuture<'_, Result<Response<ListSchedulesResponse>, Status>>

Source§

fn update_worker_build_id_compatibility( &mut self, request: impl IntoRequest<UpdateWorkerBuildIdCompatibilityRequest>, ) -> BoxFuture<'_, Result<Response<UpdateWorkerBuildIdCompatibilityResponse>, Status>>

Source§

fn get_worker_build_id_compatibility( &mut self, request: impl IntoRequest<GetWorkerBuildIdCompatibilityRequest>, ) -> BoxFuture<'_, Result<Response<GetWorkerBuildIdCompatibilityResponse>, Status>>

Source§

fn get_worker_task_reachability( &mut self, request: impl IntoRequest<GetWorkerTaskReachabilityRequest>, ) -> BoxFuture<'_, Result<Response<GetWorkerTaskReachabilityResponse>, Status>>

Source§

fn update_workflow_execution( &mut self, request: impl IntoRequest<UpdateWorkflowExecutionRequest>, ) -> BoxFuture<'_, Result<Response<UpdateWorkflowExecutionResponse>, Status>>

Source§

fn poll_workflow_execution_update( &mut self, request: impl IntoRequest<PollWorkflowExecutionUpdateRequest>, ) -> BoxFuture<'_, Result<Response<PollWorkflowExecutionUpdateResponse>, Status>>

Source§

fn start_batch_operation( &mut self, request: impl IntoRequest<StartBatchOperationRequest>, ) -> BoxFuture<'_, Result<Response<StartBatchOperationResponse>, Status>>

Source§

fn stop_batch_operation( &mut self, request: impl IntoRequest<StopBatchOperationRequest>, ) -> BoxFuture<'_, Result<Response<StopBatchOperationResponse>, Status>>

Source§

fn describe_batch_operation( &mut self, request: impl IntoRequest<DescribeBatchOperationRequest>, ) -> BoxFuture<'_, Result<Response<DescribeBatchOperationResponse>, Status>>

Source§

fn describe_deployment( &mut self, request: impl IntoRequest<DescribeDeploymentRequest>, ) -> BoxFuture<'_, Result<Response<DescribeDeploymentResponse>, Status>>

Source§

fn list_batch_operations( &mut self, request: impl IntoRequest<ListBatchOperationsRequest>, ) -> BoxFuture<'_, Result<Response<ListBatchOperationsResponse>, Status>>

Source§

fn list_deployments( &mut self, request: impl IntoRequest<ListDeploymentsRequest>, ) -> BoxFuture<'_, Result<Response<ListDeploymentsResponse>, Status>>

Source§

fn execute_multi_operation( &mut self, request: impl IntoRequest<ExecuteMultiOperationRequest>, ) -> BoxFuture<'_, Result<Response<ExecuteMultiOperationResponse>, Status>>

Source§

fn get_current_deployment( &mut self, request: impl IntoRequest<GetCurrentDeploymentRequest>, ) -> BoxFuture<'_, Result<Response<GetCurrentDeploymentResponse>, Status>>

Source§

fn get_deployment_reachability( &mut self, request: impl IntoRequest<GetDeploymentReachabilityRequest>, ) -> BoxFuture<'_, Result<Response<GetDeploymentReachabilityResponse>, Status>>

Source§

fn get_worker_versioning_rules( &mut self, request: impl IntoRequest<GetWorkerVersioningRulesRequest>, ) -> BoxFuture<'_, Result<Response<GetWorkerVersioningRulesResponse>, Status>>

Source§

fn update_worker_versioning_rules( &mut self, request: impl IntoRequest<UpdateWorkerVersioningRulesRequest>, ) -> BoxFuture<'_, Result<Response<UpdateWorkerVersioningRulesResponse>, Status>>

Source§

fn poll_nexus_task_queue( &mut self, request: impl IntoRequest<PollNexusTaskQueueRequest>, ) -> BoxFuture<'_, Result<Response<PollNexusTaskQueueResponse>, Status>>

Source§

fn respond_nexus_task_completed( &mut self, request: impl IntoRequest<RespondNexusTaskCompletedRequest>, ) -> BoxFuture<'_, Result<Response<RespondNexusTaskCompletedResponse>, Status>>

Source§

fn respond_nexus_task_failed( &mut self, request: impl IntoRequest<RespondNexusTaskFailedRequest>, ) -> BoxFuture<'_, Result<Response<RespondNexusTaskFailedResponse>, Status>>

Source§

fn set_current_deployment( &mut self, request: impl IntoRequest<SetCurrentDeploymentRequest>, ) -> BoxFuture<'_, Result<Response<SetCurrentDeploymentResponse>, Status>>

Source§

fn shutdown_worker( &mut self, request: impl IntoRequest<ShutdownWorkerRequest>, ) -> BoxFuture<'_, Result<Response<ShutdownWorkerResponse>, Status>>

Source§

fn update_activity_options( &mut self, request: impl IntoRequest<UpdateActivityOptionsRequest>, ) -> BoxFuture<'_, Result<Response<UpdateActivityOptionsResponse>, Status>>

Source§

fn pause_activity( &mut self, request: impl IntoRequest<PauseActivityRequest>, ) -> BoxFuture<'_, Result<Response<PauseActivityResponse>, Status>>

Source§

fn unpause_activity( &mut self, request: impl IntoRequest<UnpauseActivityRequest>, ) -> BoxFuture<'_, Result<Response<UnpauseActivityResponse>, Status>>

Source§

fn update_workflow_execution_options( &mut self, request: impl IntoRequest<UpdateWorkflowExecutionOptionsRequest>, ) -> BoxFuture<'_, Result<Response<UpdateWorkflowExecutionOptionsResponse>, Status>>

Source§

fn reset_activity( &mut self, request: impl IntoRequest<ResetActivityRequest>, ) -> BoxFuture<'_, Result<Response<ResetActivityResponse>, Status>>

Source§

fn delete_worker_deployment( &mut self, request: impl IntoRequest<DeleteWorkerDeploymentRequest>, ) -> BoxFuture<'_, Result<Response<DeleteWorkerDeploymentResponse>, Status>>

Source§

fn delete_worker_deployment_version( &mut self, request: impl IntoRequest<DeleteWorkerDeploymentVersionRequest>, ) -> BoxFuture<'_, Result<Response<DeleteWorkerDeploymentVersionResponse>, Status>>

Source§

fn describe_worker_deployment( &mut self, request: impl IntoRequest<DescribeWorkerDeploymentRequest>, ) -> BoxFuture<'_, Result<Response<DescribeWorkerDeploymentResponse>, Status>>

Source§

fn describe_worker_deployment_version( &mut self, request: impl IntoRequest<DescribeWorkerDeploymentVersionRequest>, ) -> BoxFuture<'_, Result<Response<DescribeWorkerDeploymentVersionResponse>, Status>>

Source§

fn list_worker_deployments( &mut self, request: impl IntoRequest<ListWorkerDeploymentsRequest>, ) -> BoxFuture<'_, Result<Response<ListWorkerDeploymentsResponse>, Status>>

Source§

fn set_worker_deployment_current_version( &mut self, request: impl IntoRequest<SetWorkerDeploymentCurrentVersionRequest>, ) -> BoxFuture<'_, Result<Response<SetWorkerDeploymentCurrentVersionResponse>, Status>>

Source§

fn set_worker_deployment_ramping_version( &mut self, request: impl IntoRequest<SetWorkerDeploymentRampingVersionRequest>, ) -> BoxFuture<'_, Result<Response<SetWorkerDeploymentRampingVersionResponse>, Status>>

Source§

fn update_worker_deployment_version_metadata( &mut self, request: impl IntoRequest<UpdateWorkerDeploymentVersionMetadataRequest>, ) -> BoxFuture<'_, Result<Response<UpdateWorkerDeploymentVersionMetadataResponse>, Status>>

Source§

fn list_workers( &mut self, request: impl IntoRequest<ListWorkersRequest>, ) -> BoxFuture<'_, Result<Response<ListWorkersResponse>, Status>>

Source§

fn record_worker_heartbeat( &mut self, request: impl IntoRequest<RecordWorkerHeartbeatRequest>, ) -> BoxFuture<'_, Result<Response<RecordWorkerHeartbeatResponse>, Status>>

Source§

fn update_task_queue_config( &mut self, request: impl IntoRequest<UpdateTaskQueueConfigRequest>, ) -> BoxFuture<'_, Result<Response<UpdateTaskQueueConfigResponse>, Status>>

Source§

fn fetch_worker_config( &mut self, request: impl IntoRequest<FetchWorkerConfigRequest>, ) -> BoxFuture<'_, Result<Response<FetchWorkerConfigResponse>, Status>>

Source§

fn update_worker_config( &mut self, request: impl IntoRequest<UpdateWorkerConfigRequest>, ) -> BoxFuture<'_, Result<Response<UpdateWorkerConfigResponse>, Status>>

Source§

impl<T> ErasedDestructor for T
where T: 'static,