squads_temporal_client

Struct ConfiguredClient

Source 
pub struct ConfiguredClient<C> { /* private fields */ }
Expand description

A client with ClientOptions attached, which can be passed to initialize workers, or can be used directly. Is cheap to clone.

Implementations§

Source§

impl<C> ConfiguredClient<C>

Source

pub fn set_headers(&self, headers: HashMap<String, String>)

Set HTTP request headers overwriting previous headers

Source

pub fn set_api_key(&self, api_key: Option<String>)

Set API key, overwriting previous

Source

pub fn options(&self) -> &ClientOptions

Returns the options the client is configured with

Source

pub fn capabilities(&self) -> Option<&Capabilities>

Returns the server capabilities we (may have) learned about when establishing an initial connection

Source

pub fn workers(&self) -> Arc<SlotManager>

Returns a cloned reference to a registry with workers using this client instance

Trait Implementations§

Source§

impl<C: Clone> Clone for ConfiguredClient<C>

Source§

fn clone(&self) -> ConfiguredClient<C>

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl<C: Debug> Debug for ConfiguredClient<C>

Source§

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

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

impl<C> Deref for ConfiguredClient<C>

Source§

type Target = C

The resulting type after dereferencing.
Source§

fn deref(&self) -> &Self::Target

Dereferences the value.
Source§

impl<C> DerefMut for ConfiguredClient<C>

Source§

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

Auto Trait Implementations§

§

impl<C> Freeze for ConfiguredClient<C>
where C: Freeze,

§

impl<C> !RefUnwindSafe for ConfiguredClient<C>

§

impl<C> Send for ConfiguredClient<C>
where C: Send,

§

impl<C> Sync for ConfiguredClient<C>
where C: Sync,

§

impl<C> Unpin for ConfiguredClient<C>
where C: Unpin,

§

impl<C> !UnwindSafe for ConfiguredClient<C>

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>>

See CloudServiceClient::get_users
Source§

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

See CloudServiceClient::get_user
Source§

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

See CloudServiceClient::create_user
Source§

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

See CloudServiceClient::update_user
Source§

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

See CloudServiceClient::delete_user
Source§

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

See CloudServiceClient::set_user_namespace_access
Source§

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

See CloudServiceClient::get_async_operation
Source§

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

See CloudServiceClient::create_namespace
Source§

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

See CloudServiceClient::get_namespaces
Source§

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

See CloudServiceClient::get_namespace
Source§

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

See CloudServiceClient::update_namespace
Source§

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

See CloudServiceClient::rename_custom_search_attribute
Source§

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

See CloudServiceClient::delete_namespace
Source§

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

See CloudServiceClient::failover_namespace_region
Source§

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

See CloudServiceClient::add_namespace_region
Source§

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

See CloudServiceClient::delete_namespace_region
Source§

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

See CloudServiceClient::get_regions
Source§

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

See CloudServiceClient::get_region
Source§

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

See CloudServiceClient::get_api_keys
Source§

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

See CloudServiceClient::get_api_key
Source§

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

See CloudServiceClient::create_api_key
Source§

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

See CloudServiceClient::update_api_key
Source§

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

See CloudServiceClient::delete_api_key
Source§

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

See CloudServiceClient::get_nexus_endpoints
Source§

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

See CloudServiceClient::get_nexus_endpoint
Source§

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

See CloudServiceClient::create_nexus_endpoint
Source§

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

See CloudServiceClient::update_nexus_endpoint
Source§

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

See CloudServiceClient::delete_nexus_endpoint
Source§

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

See CloudServiceClient::get_user_groups
Source§

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

See CloudServiceClient::get_user_group
Source§

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

See CloudServiceClient::create_user_group
Source§

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

See CloudServiceClient::update_user_group
Source§

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

See CloudServiceClient::delete_user_group
Source§

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

See CloudServiceClient::add_user_group_member
Source§

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

See CloudServiceClient::remove_user_group_member
Source§

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

See CloudServiceClient::get_user_group_members
Source§

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

See CloudServiceClient::set_user_group_namespace_access
Source§

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

See CloudServiceClient::create_service_account
Source§

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

See CloudServiceClient::get_service_account
Source§

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

See CloudServiceClient::get_service_accounts
Source§

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

See CloudServiceClient::update_service_account
Source§

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

See CloudServiceClient::delete_service_account
Source§

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

See CloudServiceClient::get_usage
Source§

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

See CloudServiceClient::get_account
Source§

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

See CloudServiceClient::update_account
Source§

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

See CloudServiceClient::create_namespace_export_sink
Source§

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

See CloudServiceClient::get_namespace_export_sink
Source§

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

See CloudServiceClient::get_namespace_export_sinks
Source§

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

See CloudServiceClient::update_namespace_export_sink
Source§

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

See CloudServiceClient::delete_namespace_export_sink
Source§

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

See CloudServiceClient::validate_namespace_export_sink
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§

fn check( &mut self, request: impl IntoRequest<HealthCheckRequest>, ) -> BoxFuture<'_, Result<Response<HealthCheckResponse>, Status>>

See HealthClient::check
Source§

fn watch( &mut self, request: impl IntoRequest<HealthCheckRequest>, ) -> BoxFuture<'_, Result<Response<Streaming<HealthCheckResponse>>, Status>>

See HealthClient::watch
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>>

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
Source§

impl<P, T> Receiver for P
where P: Deref<Target = T> + ?Sized, T: ?Sized,

Source§

type Target = T

🔬This is a nightly-only experimental API. (arbitrary_self_types)
The target type on which the method may be called.
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§

fn lock_time_skipping( &mut self, request: impl IntoRequest<LockTimeSkippingRequest>, ) -> BoxFuture<'_, Result<Response<LockTimeSkippingResponse>, Status>>

See TestServiceClient::lock_time_skipping
Source§

fn unlock_time_skipping( &mut self, request: impl IntoRequest<UnlockTimeSkippingRequest>, ) -> BoxFuture<'_, Result<Response<UnlockTimeSkippingResponse>, Status>>

See TestServiceClient::unlock_time_skipping
Source§

fn sleep( &mut self, request: impl IntoRequest<SleepRequest>, ) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>>

See TestServiceClient::sleep
Source§

fn sleep_until( &mut self, request: impl IntoRequest<SleepUntilRequest>, ) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>>

See TestServiceClient::sleep_until
Source§

fn unlock_time_skipping_with_sleep( &mut self, request: impl IntoRequest<SleepRequest>, ) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>>

See TestServiceClient::unlock_time_skipping_with_sleep
Source§

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

See TestServiceClient::get_current_time
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> 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>>

See WorkflowServiceClient::register_namespace
Source§

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

See WorkflowServiceClient::describe_namespace
Source§

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

See WorkflowServiceClient::list_namespaces
Source§

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

See WorkflowServiceClient::update_namespace
Source§

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

See WorkflowServiceClient::deprecate_namespace
Source§

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

See WorkflowServiceClient::start_workflow_execution
Source§

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

See WorkflowServiceClient::get_workflow_execution_history
Source§

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

See WorkflowServiceClient::get_workflow_execution_history_reverse
Source§

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

See WorkflowServiceClient::poll_workflow_task_queue
Source§

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

See WorkflowServiceClient::respond_workflow_task_completed
Source§

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

See WorkflowServiceClient::respond_workflow_task_failed
Source§

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

See WorkflowServiceClient::poll_activity_task_queue
Source§

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

See WorkflowServiceClient::record_activity_task_heartbeat
Source§

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

See WorkflowServiceClient::record_activity_task_heartbeat_by_id
Source§

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

See WorkflowServiceClient::respond_activity_task_completed
Source§

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

See WorkflowServiceClient::respond_activity_task_completed_by_id
Source§

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

See WorkflowServiceClient::respond_activity_task_failed
Source§

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

See WorkflowServiceClient::respond_activity_task_failed_by_id
Source§

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

See WorkflowServiceClient::respond_activity_task_canceled
Source§

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

See WorkflowServiceClient::respond_activity_task_canceled_by_id
Source§

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

See WorkflowServiceClient::request_cancel_workflow_execution
Source§

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

See WorkflowServiceClient::signal_workflow_execution
Source§

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

See WorkflowServiceClient::signal_with_start_workflow_execution
Source§

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

See WorkflowServiceClient::reset_workflow_execution
Source§

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

See WorkflowServiceClient::terminate_workflow_execution
Source§

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

See WorkflowServiceClient::delete_workflow_execution
Source§

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

See WorkflowServiceClient::list_open_workflow_executions
Source§

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

See WorkflowServiceClient::list_closed_workflow_executions
Source§

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

See WorkflowServiceClient::list_workflow_executions
Source§

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

See WorkflowServiceClient::list_archived_workflow_executions
Source§

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

See WorkflowServiceClient::scan_workflow_executions
Source§

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

See WorkflowServiceClient::count_workflow_executions
Source§

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

See WorkflowServiceClient::create_workflow_rule
Source§

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

See WorkflowServiceClient::describe_workflow_rule
Source§

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

See WorkflowServiceClient::delete_workflow_rule
Source§

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

See WorkflowServiceClient::list_workflow_rules
Source§

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

See WorkflowServiceClient::trigger_workflow_rule
Source§

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

See WorkflowServiceClient::get_search_attributes
Source§

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

See WorkflowServiceClient::respond_query_task_completed
Source§

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

See WorkflowServiceClient::reset_sticky_task_queue
Source§

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

See WorkflowServiceClient::query_workflow
Source§

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

See WorkflowServiceClient::describe_workflow_execution
Source§

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

See WorkflowServiceClient::describe_task_queue
Source§

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

See WorkflowServiceClient::get_cluster_info
Source§

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

See WorkflowServiceClient::get_system_info
Source§

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

See WorkflowServiceClient::list_task_queue_partitions
Source§

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

See WorkflowServiceClient::create_schedule
Source§

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

See WorkflowServiceClient::describe_schedule
Source§

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

See WorkflowServiceClient::update_schedule
Source§

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

See WorkflowServiceClient::patch_schedule
Source§

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

See WorkflowServiceClient::list_schedule_matching_times
Source§

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

See WorkflowServiceClient::delete_schedule
Source§

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

See WorkflowServiceClient::list_schedules
Source§

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

See WorkflowServiceClient::update_worker_build_id_compatibility
Source§

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

See WorkflowServiceClient::get_worker_build_id_compatibility
Source§

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

See WorkflowServiceClient::get_worker_task_reachability
Source§

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

See WorkflowServiceClient::update_workflow_execution
Source§

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

See WorkflowServiceClient::poll_workflow_execution_update
Source§

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

See WorkflowServiceClient::start_batch_operation
Source§

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

See WorkflowServiceClient::stop_batch_operation
Source§

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

See WorkflowServiceClient::describe_batch_operation
Source§

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

See WorkflowServiceClient::describe_deployment
Source§

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

See WorkflowServiceClient::list_batch_operations
Source§

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

See WorkflowServiceClient::list_deployments
Source§

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

See WorkflowServiceClient::execute_multi_operation
Source§

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

See WorkflowServiceClient::get_current_deployment
Source§

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

See WorkflowServiceClient::get_deployment_reachability
Source§

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

See WorkflowServiceClient::get_worker_versioning_rules
Source§

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

See WorkflowServiceClient::update_worker_versioning_rules
Source§

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

See WorkflowServiceClient::poll_nexus_task_queue
Source§

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

See WorkflowServiceClient::respond_nexus_task_completed
Source§

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

See WorkflowServiceClient::respond_nexus_task_failed
Source§

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

See WorkflowServiceClient::set_current_deployment
Source§

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

See WorkflowServiceClient::shutdown_worker
Source§

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

See WorkflowServiceClient::update_activity_options
Source§

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

See WorkflowServiceClient::pause_activity
Source§

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

See WorkflowServiceClient::unpause_activity
Source§

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

See WorkflowServiceClient::update_workflow_execution_options
Source§

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

See WorkflowServiceClient::reset_activity
Source§

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

See WorkflowServiceClient::delete_worker_deployment
Source§

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

See WorkflowServiceClient::delete_worker_deployment_version
Source§

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

See WorkflowServiceClient::describe_worker_deployment
Source§

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

See WorkflowServiceClient::describe_worker_deployment_version
Source§

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

See WorkflowServiceClient::list_worker_deployments
Source§

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

See WorkflowServiceClient::set_worker_deployment_current_version
Source§

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

See WorkflowServiceClient::set_worker_deployment_ramping_version
Source§

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

See WorkflowServiceClient::update_worker_deployment_version_metadata
Source§

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

See WorkflowServiceClient::list_workers
Source§

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

See WorkflowServiceClient::record_worker_heartbeat
Source§

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