Skip to main content

TemporalServiceClient

temporalio_client

Struct TemporalServiceClient 

Source 
pub struct TemporalServiceClient { /* private fields */ }
Expand description

Aggregates various services exposed by the Temporal server

Implementations§

Source§

impl TemporalServiceClient

Source

pub fn from_services( workflow: Box<dyn WorkflowService>, operator: Box<dyn OperatorService>, cloud: Box<dyn CloudService>, test: Box<dyn TestService>, health: Box<dyn HealthService>, ) -> Self

Create a service client from implementations of the individual underlying services. Useful for mocking out service implementations.

Source

pub fn workflow_service(&self) -> Box<dyn WorkflowService>

Get the underlying workflow service client

Source

pub fn operator_service(&self) -> Box<dyn OperatorService>

Get the underlying operator service client

Source

pub fn cloud_service(&self) -> Box<dyn CloudService>

Get the underlying cloud service client

Source

pub fn test_service(&self) -> Box<dyn TestService>

Get the underlying test service client

Source

pub fn health_service(&self) -> Box<dyn HealthService>

Get the underlying health service client

Trait Implementations§

Source§

impl Clone for TemporalServiceClient

Source§

fn clone(&self) -> TemporalServiceClient

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

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> CloudService for RC
where RC: RawGrpcCaller + RawClientProducer + Clone + Unpin,

Source§

fn get_users( &mut self, request: Request<GetUsersRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetUsersResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_users

Source§

fn get_user( &mut self, request: Request<GetUserRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetUserResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_user

Source§

fn create_user( &mut self, request: Request<CreateUserRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateUserResponse>, Status>> + Send + '_>>

See CloudServiceClient::create_user

Source§

fn update_user( &mut self, request: Request<UpdateUserRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateUserResponse>, Status>> + Send + '_>>

See CloudServiceClient::update_user

Source§

fn delete_user( &mut self, request: Request<DeleteUserRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteUserResponse>, Status>> + Send + '_>>

See CloudServiceClient::delete_user

Source§

fn set_user_namespace_access( &mut self, request: Request<SetUserNamespaceAccessRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SetUserNamespaceAccessResponse>, Status>> + Send + '_>>

See CloudServiceClient::set_user_namespace_access

Source§

fn get_async_operation( &mut self, request: Request<GetAsyncOperationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetAsyncOperationResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_async_operation

Source§

fn create_namespace( &mut self, request: Request<CreateNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateNamespaceResponse>, Status>> + Send + '_>>

See CloudServiceClient::create_namespace

Source§

fn get_namespaces( &mut self, request: Request<GetNamespacesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNamespacesResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_namespaces

Source§

fn get_namespace( &mut self, request: Request<GetNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNamespaceResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_namespace

Source§

fn update_namespace( &mut self, request: Request<UpdateNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNamespaceResponse>, Status>> + Send + '_>>

See CloudServiceClient::update_namespace

Source§

fn rename_custom_search_attribute( &mut self, request: Request<RenameCustomSearchAttributeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RenameCustomSearchAttributeResponse>, Status>> + Send + '_>>

See CloudServiceClient::rename_custom_search_attribute

Source§

fn delete_namespace( &mut self, request: Request<DeleteNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNamespaceResponse>, Status>> + Send + '_>>

See CloudServiceClient::delete_namespace

Source§

fn failover_namespace_region( &mut self, request: Request<FailoverNamespaceRegionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<FailoverNamespaceRegionResponse>, Status>> + Send + '_>>

See CloudServiceClient::failover_namespace_region

Source§

fn add_namespace_region( &mut self, request: Request<AddNamespaceRegionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AddNamespaceRegionResponse>, Status>> + Send + '_>>

See CloudServiceClient::add_namespace_region

Source§

fn delete_namespace_region( &mut self, request: Request<DeleteNamespaceRegionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNamespaceRegionResponse>, Status>> + Send + '_>>

See CloudServiceClient::delete_namespace_region

Source§

fn get_regions( &mut self, request: Request<GetRegionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetRegionsResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_regions

Source§

fn get_region( &mut self, request: Request<GetRegionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetRegionResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_region

Source§

fn get_api_keys( &mut self, request: Request<GetApiKeysRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetApiKeysResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_api_keys

Source§

fn get_api_key( &mut self, request: Request<GetApiKeyRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetApiKeyResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_api_key

Source§

fn create_api_key( &mut self, request: Request<CreateApiKeyRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateApiKeyResponse>, Status>> + Send + '_>>

See CloudServiceClient::create_api_key

Source§

fn update_api_key( &mut self, request: Request<UpdateApiKeyRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateApiKeyResponse>, Status>> + Send + '_>>

See CloudServiceClient::update_api_key

Source§

fn delete_api_key( &mut self, request: Request<DeleteApiKeyRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteApiKeyResponse>, Status>> + Send + '_>>

See CloudServiceClient::delete_api_key

Source§

fn get_nexus_endpoints( &mut self, request: Request<GetNexusEndpointsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNexusEndpointsResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_nexus_endpoints

Source§

fn get_nexus_endpoint( &mut self, request: Request<GetNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNexusEndpointResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_nexus_endpoint

Source§

fn create_nexus_endpoint( &mut self, request: Request<CreateNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateNexusEndpointResponse>, Status>> + Send + '_>>

See CloudServiceClient::create_nexus_endpoint

Source§

fn update_nexus_endpoint( &mut self, request: Request<UpdateNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNexusEndpointResponse>, Status>> + Send + '_>>

See CloudServiceClient::update_nexus_endpoint

Source§

fn delete_nexus_endpoint( &mut self, request: Request<DeleteNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNexusEndpointResponse>, Status>> + Send + '_>>

See CloudServiceClient::delete_nexus_endpoint

Source§

fn get_user_groups( &mut self, request: Request<GetUserGroupsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetUserGroupsResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_user_groups

Source§

fn get_user_group( &mut self, request: Request<GetUserGroupRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetUserGroupResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_user_group

Source§

fn create_user_group( &mut self, request: Request<CreateUserGroupRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateUserGroupResponse>, Status>> + Send + '_>>

See CloudServiceClient::create_user_group

Source§

fn update_user_group( &mut self, request: Request<UpdateUserGroupRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateUserGroupResponse>, Status>> + Send + '_>>

See CloudServiceClient::update_user_group

Source§

fn delete_user_group( &mut self, request: Request<DeleteUserGroupRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteUserGroupResponse>, Status>> + Send + '_>>

See CloudServiceClient::delete_user_group

Source§

fn add_user_group_member( &mut self, request: Request<AddUserGroupMemberRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AddUserGroupMemberResponse>, Status>> + Send + '_>>

See CloudServiceClient::add_user_group_member

Source§

fn remove_user_group_member( &mut self, request: Request<RemoveUserGroupMemberRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RemoveUserGroupMemberResponse>, Status>> + Send + '_>>

See CloudServiceClient::remove_user_group_member

Source§

fn get_user_group_members( &mut self, request: Request<GetUserGroupMembersRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetUserGroupMembersResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_user_group_members

Source§

fn set_user_group_namespace_access( &mut self, request: Request<SetUserGroupNamespaceAccessRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SetUserGroupNamespaceAccessResponse>, Status>> + Send + '_>>

See CloudServiceClient::set_user_group_namespace_access

Source§

fn create_service_account( &mut self, request: Request<CreateServiceAccountRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateServiceAccountResponse>, Status>> + Send + '_>>

See CloudServiceClient::create_service_account

Source§

fn get_service_account( &mut self, request: Request<GetServiceAccountRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetServiceAccountResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_service_account

Source§

fn get_service_accounts( &mut self, request: Request<GetServiceAccountsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetServiceAccountsResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_service_accounts

Source§

fn update_service_account( &mut self, request: Request<UpdateServiceAccountRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateServiceAccountResponse>, Status>> + Send + '_>>

See CloudServiceClient::update_service_account

Source§

fn delete_service_account( &mut self, request: Request<DeleteServiceAccountRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteServiceAccountResponse>, Status>> + Send + '_>>

See CloudServiceClient::delete_service_account

Source§

fn get_usage( &mut self, request: Request<GetUsageRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetUsageResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_usage

Source§

fn get_account( &mut self, request: Request<GetAccountRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetAccountResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_account

Source§

fn update_account( &mut self, request: Request<UpdateAccountRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateAccountResponse>, Status>> + Send + '_>>

See CloudServiceClient::update_account

Source§

fn create_namespace_export_sink( &mut self, request: Request<CreateNamespaceExportSinkRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateNamespaceExportSinkResponse>, Status>> + Send + '_>>

See CloudServiceClient::create_namespace_export_sink

Source§

fn get_namespace_export_sink( &mut self, request: Request<GetNamespaceExportSinkRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNamespaceExportSinkResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_namespace_export_sink

Source§

fn get_namespace_export_sinks( &mut self, request: Request<GetNamespaceExportSinksRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNamespaceExportSinksResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_namespace_export_sinks

Source§

fn update_namespace_export_sink( &mut self, request: Request<UpdateNamespaceExportSinkRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNamespaceExportSinkResponse>, Status>> + Send + '_>>

See CloudServiceClient::update_namespace_export_sink

Source§

fn delete_namespace_export_sink( &mut self, request: Request<DeleteNamespaceExportSinkRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNamespaceExportSinkResponse>, Status>> + Send + '_>>

See CloudServiceClient::delete_namespace_export_sink

Source§

fn validate_namespace_export_sink( &mut self, request: Request<ValidateNamespaceExportSinkRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ValidateNamespaceExportSinkResponse>, Status>> + Send + '_>>

See CloudServiceClient::validate_namespace_export_sink

Source§

fn update_namespace_tags( &mut self, request: Request<UpdateNamespaceTagsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNamespaceTagsResponse>, Status>> + Send + '_>>

See CloudServiceClient::update_namespace_tags

Source§

fn create_connectivity_rule( &mut self, request: Request<CreateConnectivityRuleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateConnectivityRuleResponse>, Status>> + Send + '_>>

See CloudServiceClient::create_connectivity_rule

Source§

fn get_connectivity_rule( &mut self, request: Request<GetConnectivityRuleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetConnectivityRuleResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_connectivity_rule

Source§

fn get_connectivity_rules( &mut self, request: Request<GetConnectivityRulesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetConnectivityRulesResponse>, Status>> + Send + '_>>

See CloudServiceClient::get_connectivity_rules

Source§

fn delete_connectivity_rule( &mut self, request: Request<DeleteConnectivityRuleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteConnectivityRuleResponse>, Status>> + Send + '_>>

See CloudServiceClient::delete_connectivity_rule

Source§

fn set_service_account_namespace_access( &mut self, request: Request<SetServiceAccountNamespaceAccessRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SetServiceAccountNamespaceAccessResponse>, Status>> + Send + '_>>

See CloudServiceClient::set_service_account_namespace_access

Source§

fn validate_account_audit_log_sink( &mut self, request: Request<ValidateAccountAuditLogSinkRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ValidateAccountAuditLogSinkResponse>, Status>> + Send + '_>>

See CloudServiceClient::validate_account_audit_log_sink

Source§

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

Source§

fn __clone_box(&self, _: Private) -> *mut ()

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> HealthService for RC
where RC: RawGrpcCaller + RawClientProducer + Clone + Unpin,

Source§

fn check( &mut self, request: Request<HealthCheckRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<HealthCheckResponse>, Status>> + Send + '_>>

See HealthClient::check

Source§

fn watch( &mut self, request: Request<HealthCheckRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Streaming<HealthCheckResponse>>, Status>> + Send + '_>>

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> OperatorService for RC
where RC: RawGrpcCaller + RawClientProducer + Clone + Unpin,

Source§

fn add_search_attributes( &mut self, request: Request<AddSearchAttributesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AddSearchAttributesResponse>, Status>> + Send + '_>>

See OperatorServiceClient::add_search_attributes

Source§

fn remove_search_attributes( &mut self, request: Request<RemoveSearchAttributesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RemoveSearchAttributesResponse>, Status>> + Send + '_>>

See OperatorServiceClient::remove_search_attributes

Source§

fn list_search_attributes( &mut self, request: Request<ListSearchAttributesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListSearchAttributesResponse>, Status>> + Send + '_>>

See OperatorServiceClient::list_search_attributes

Source§

fn delete_namespace( &mut self, request: Request<DeleteNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNamespaceResponse>, Status>> + Send + '_>>

See OperatorServiceClient::delete_namespace

Source§

fn add_or_update_remote_cluster( &mut self, request: Request<AddOrUpdateRemoteClusterRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AddOrUpdateRemoteClusterResponse>, Status>> + Send + '_>>

See OperatorServiceClient::add_or_update_remote_cluster

Source§

fn remove_remote_cluster( &mut self, request: Request<RemoveRemoteClusterRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RemoveRemoteClusterResponse>, Status>> + Send + '_>>

See OperatorServiceClient::remove_remote_cluster

Source§

fn list_clusters( &mut self, request: Request<ListClustersRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListClustersResponse>, Status>> + Send + '_>>

See OperatorServiceClient::list_clusters

Source§

fn get_nexus_endpoint( &mut self, request: Request<GetNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNexusEndpointResponse>, Status>> + Send + '_>>

See OperatorServiceClient::get_nexus_endpoint

Source§

fn create_nexus_endpoint( &mut self, request: Request<CreateNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateNexusEndpointResponse>, Status>> + Send + '_>>

See OperatorServiceClient::create_nexus_endpoint

Source§

fn update_nexus_endpoint( &mut self, request: Request<UpdateNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNexusEndpointResponse>, Status>> + Send + '_>>

See OperatorServiceClient::update_nexus_endpoint

Source§

fn delete_nexus_endpoint( &mut self, request: Request<DeleteNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNexusEndpointResponse>, Status>> + Send + '_>>

See OperatorServiceClient::delete_nexus_endpoint

Source§

fn list_nexus_endpoints( &mut self, request: Request<ListNexusEndpointsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListNexusEndpointsResponse>, Status>> + Send + '_>>

See OperatorServiceClient::list_nexus_endpoints

Source§

impl<RC> TestService for RC
where RC: RawGrpcCaller + RawClientProducer + Clone + Unpin,

Source§

fn lock_time_skipping( &mut self, request: Request<LockTimeSkippingRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<LockTimeSkippingResponse>, Status>> + Send + '_>>

See TestServiceClient::lock_time_skipping

Source§

fn unlock_time_skipping( &mut self, request: Request<UnlockTimeSkippingRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UnlockTimeSkippingResponse>, Status>> + Send + '_>>

See TestServiceClient::unlock_time_skipping

Source§

fn sleep( &mut self, request: Request<SleepRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SleepResponse>, Status>> + Send + '_>>

See TestServiceClient::sleep

Source§

fn sleep_until( &mut self, request: Request<SleepUntilRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SleepResponse>, Status>> + Send + '_>>

See TestServiceClient::sleep_until

Source§

fn unlock_time_skipping_with_sleep( &mut self, request: Request<SleepRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SleepResponse>, Status>> + Send + '_>>

See TestServiceClient::unlock_time_skipping_with_sleep

Source§

fn get_current_time( &mut self, request: Request<()>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetCurrentTimeResponse>, Status>> + Send + '_>>

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> WorkflowService for RC
where RC: RawGrpcCaller + RawClientProducer + Clone + Unpin,

Source§

fn register_namespace( &mut self, request: Request<RegisterNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RegisterNamespaceResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::register_namespace

Source§

fn describe_namespace( &mut self, request: Request<DescribeNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeNamespaceResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::describe_namespace

Source§

fn list_namespaces( &mut self, request: Request<ListNamespacesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListNamespacesResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_namespaces

Source§

fn update_namespace( &mut self, request: Request<UpdateNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNamespaceResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::update_namespace

Source§

fn deprecate_namespace( &mut self, request: Request<DeprecateNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeprecateNamespaceResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::deprecate_namespace

Source§

fn start_workflow_execution( &mut self, request: Request<StartWorkflowExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<StartWorkflowExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::start_workflow_execution

Source§

fn get_workflow_execution_history( &mut self, request: Request<GetWorkflowExecutionHistoryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetWorkflowExecutionHistoryResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::get_workflow_execution_history

Source§

fn get_workflow_execution_history_reverse( &mut self, request: Request<GetWorkflowExecutionHistoryReverseRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetWorkflowExecutionHistoryReverseResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::get_workflow_execution_history_reverse

Source§

fn poll_workflow_task_queue( &mut self, request: Request<PollWorkflowTaskQueueRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PollWorkflowTaskQueueResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::poll_workflow_task_queue

Source§

fn respond_workflow_task_completed( &mut self, request: Request<RespondWorkflowTaskCompletedRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RespondWorkflowTaskCompletedResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::respond_workflow_task_completed

Source§

fn respond_workflow_task_failed( &mut self, request: Request<RespondWorkflowTaskFailedRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RespondWorkflowTaskFailedResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::respond_workflow_task_failed

Source§

fn poll_activity_task_queue( &mut self, request: Request<PollActivityTaskQueueRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PollActivityTaskQueueResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::poll_activity_task_queue

Source§

fn record_activity_task_heartbeat( &mut self, request: Request<RecordActivityTaskHeartbeatRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RecordActivityTaskHeartbeatResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::record_activity_task_heartbeat

Source§

fn record_activity_task_heartbeat_by_id( &mut self, request: Request<RecordActivityTaskHeartbeatByIdRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RecordActivityTaskHeartbeatByIdResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::record_activity_task_heartbeat_by_id

Source§

fn respond_activity_task_completed( &mut self, request: Request<RespondActivityTaskCompletedRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RespondActivityTaskCompletedResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::respond_activity_task_completed

Source§

fn respond_activity_task_completed_by_id( &mut self, request: Request<RespondActivityTaskCompletedByIdRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RespondActivityTaskCompletedByIdResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::respond_activity_task_completed_by_id

Source§

fn respond_activity_task_failed( &mut self, request: Request<RespondActivityTaskFailedRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RespondActivityTaskFailedResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::respond_activity_task_failed

Source§

fn respond_activity_task_failed_by_id( &mut self, request: Request<RespondActivityTaskFailedByIdRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RespondActivityTaskFailedByIdResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::respond_activity_task_failed_by_id

Source§

fn respond_activity_task_canceled( &mut self, request: Request<RespondActivityTaskCanceledRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RespondActivityTaskCanceledResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::respond_activity_task_canceled

Source§

fn respond_activity_task_canceled_by_id( &mut self, request: Request<RespondActivityTaskCanceledByIdRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RespondActivityTaskCanceledByIdResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::respond_activity_task_canceled_by_id

Source§

fn request_cancel_workflow_execution( &mut self, request: Request<RequestCancelWorkflowExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RequestCancelWorkflowExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::request_cancel_workflow_execution

Source§

fn signal_workflow_execution( &mut self, request: Request<SignalWorkflowExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SignalWorkflowExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::signal_workflow_execution

Source§

fn signal_with_start_workflow_execution( &mut self, request: Request<SignalWithStartWorkflowExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SignalWithStartWorkflowExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::signal_with_start_workflow_execution

Source§

fn reset_workflow_execution( &mut self, request: Request<ResetWorkflowExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ResetWorkflowExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::reset_workflow_execution

Source§

fn terminate_workflow_execution( &mut self, request: Request<TerminateWorkflowExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TerminateWorkflowExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::terminate_workflow_execution

Source§

fn delete_workflow_execution( &mut self, request: Request<DeleteWorkflowExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteWorkflowExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::delete_workflow_execution

Source§

fn list_open_workflow_executions( &mut self, request: Request<ListOpenWorkflowExecutionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListOpenWorkflowExecutionsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_open_workflow_executions

Source§

fn list_closed_workflow_executions( &mut self, request: Request<ListClosedWorkflowExecutionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListClosedWorkflowExecutionsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_closed_workflow_executions

Source§

fn list_workflow_executions( &mut self, request: Request<ListWorkflowExecutionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListWorkflowExecutionsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_workflow_executions

Source§

fn list_archived_workflow_executions( &mut self, request: Request<ListArchivedWorkflowExecutionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListArchivedWorkflowExecutionsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_archived_workflow_executions

Source§

fn scan_workflow_executions( &mut self, request: Request<ScanWorkflowExecutionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ScanWorkflowExecutionsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::scan_workflow_executions

Source§

fn count_workflow_executions( &mut self, request: Request<CountWorkflowExecutionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CountWorkflowExecutionsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::count_workflow_executions

Source§

fn create_workflow_rule( &mut self, request: Request<CreateWorkflowRuleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateWorkflowRuleResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::create_workflow_rule

Source§

fn describe_workflow_rule( &mut self, request: Request<DescribeWorkflowRuleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeWorkflowRuleResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::describe_workflow_rule

Source§

fn delete_workflow_rule( &mut self, request: Request<DeleteWorkflowRuleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteWorkflowRuleResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::delete_workflow_rule

Source§

fn list_workflow_rules( &mut self, request: Request<ListWorkflowRulesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListWorkflowRulesResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_workflow_rules

Source§

fn trigger_workflow_rule( &mut self, request: Request<TriggerWorkflowRuleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TriggerWorkflowRuleResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::trigger_workflow_rule

Source§

fn get_search_attributes( &mut self, request: Request<GetSearchAttributesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetSearchAttributesResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::get_search_attributes

Source§

fn respond_query_task_completed( &mut self, request: Request<RespondQueryTaskCompletedRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RespondQueryTaskCompletedResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::respond_query_task_completed

Source§

fn reset_sticky_task_queue( &mut self, request: Request<ResetStickyTaskQueueRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ResetStickyTaskQueueResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::reset_sticky_task_queue

Source§

fn query_workflow( &mut self, request: Request<QueryWorkflowRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<QueryWorkflowResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::query_workflow

Source§

fn describe_workflow_execution( &mut self, request: Request<DescribeWorkflowExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeWorkflowExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::describe_workflow_execution

Source§

fn describe_task_queue( &mut self, request: Request<DescribeTaskQueueRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeTaskQueueResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::describe_task_queue

Source§

fn get_cluster_info( &mut self, request: Request<GetClusterInfoRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetClusterInfoResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::get_cluster_info

Source§

fn get_system_info( &mut self, request: Request<GetSystemInfoRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetSystemInfoResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::get_system_info

Source§

fn list_task_queue_partitions( &mut self, request: Request<ListTaskQueuePartitionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListTaskQueuePartitionsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_task_queue_partitions

Source§

fn create_schedule( &mut self, request: Request<CreateScheduleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateScheduleResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::create_schedule

Source§

fn describe_schedule( &mut self, request: Request<DescribeScheduleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeScheduleResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::describe_schedule

Source§

fn update_schedule( &mut self, request: Request<UpdateScheduleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateScheduleResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::update_schedule

Source§

fn patch_schedule( &mut self, request: Request<PatchScheduleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PatchScheduleResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::patch_schedule

Source§

fn list_schedule_matching_times( &mut self, request: Request<ListScheduleMatchingTimesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListScheduleMatchingTimesResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_schedule_matching_times

Source§

fn delete_schedule( &mut self, request: Request<DeleteScheduleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteScheduleResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::delete_schedule

Source§

fn list_schedules( &mut self, request: Request<ListSchedulesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListSchedulesResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_schedules

Source§

fn count_schedules( &mut self, request: Request<CountSchedulesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CountSchedulesResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::count_schedules

Source§

fn update_worker_build_id_compatibility( &mut self, request: Request<UpdateWorkerBuildIdCompatibilityRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateWorkerBuildIdCompatibilityResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::update_worker_build_id_compatibility

Source§

fn get_worker_build_id_compatibility( &mut self, request: Request<GetWorkerBuildIdCompatibilityRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetWorkerBuildIdCompatibilityResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::get_worker_build_id_compatibility

Source§

fn get_worker_task_reachability( &mut self, request: Request<GetWorkerTaskReachabilityRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetWorkerTaskReachabilityResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::get_worker_task_reachability

Source§

fn update_workflow_execution( &mut self, request: Request<UpdateWorkflowExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateWorkflowExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::update_workflow_execution

Source§

fn poll_workflow_execution_update( &mut self, request: Request<PollWorkflowExecutionUpdateRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PollWorkflowExecutionUpdateResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::poll_workflow_execution_update

Source§

fn start_batch_operation( &mut self, request: Request<StartBatchOperationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<StartBatchOperationResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::start_batch_operation

Source§

fn stop_batch_operation( &mut self, request: Request<StopBatchOperationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<StopBatchOperationResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::stop_batch_operation

Source§

fn describe_batch_operation( &mut self, request: Request<DescribeBatchOperationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeBatchOperationResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::describe_batch_operation

Source§

fn describe_deployment( &mut self, request: Request<DescribeDeploymentRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeDeploymentResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::describe_deployment

Source§

fn list_batch_operations( &mut self, request: Request<ListBatchOperationsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListBatchOperationsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_batch_operations

Source§

fn list_deployments( &mut self, request: Request<ListDeploymentsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListDeploymentsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_deployments

Source§

fn execute_multi_operation( &mut self, request: Request<ExecuteMultiOperationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ExecuteMultiOperationResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::execute_multi_operation

Source§

fn get_current_deployment( &mut self, request: Request<GetCurrentDeploymentRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetCurrentDeploymentResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::get_current_deployment

Source§

fn get_deployment_reachability( &mut self, request: Request<GetDeploymentReachabilityRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetDeploymentReachabilityResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::get_deployment_reachability

Source§

fn get_worker_versioning_rules( &mut self, request: Request<GetWorkerVersioningRulesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetWorkerVersioningRulesResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::get_worker_versioning_rules

Source§

fn update_worker_versioning_rules( &mut self, request: Request<UpdateWorkerVersioningRulesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateWorkerVersioningRulesResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::update_worker_versioning_rules

Source§

fn poll_nexus_task_queue( &mut self, request: Request<PollNexusTaskQueueRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PollNexusTaskQueueResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::poll_nexus_task_queue

Source§

fn respond_nexus_task_completed( &mut self, request: Request<RespondNexusTaskCompletedRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RespondNexusTaskCompletedResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::respond_nexus_task_completed

Source§

fn respond_nexus_task_failed( &mut self, request: Request<RespondNexusTaskFailedRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RespondNexusTaskFailedResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::respond_nexus_task_failed

Source§

fn set_current_deployment( &mut self, request: Request<SetCurrentDeploymentRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SetCurrentDeploymentResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::set_current_deployment

Source§

fn shutdown_worker( &mut self, request: Request<ShutdownWorkerRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ShutdownWorkerResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::shutdown_worker

Source§

fn update_activity_options( &mut self, request: Request<UpdateActivityOptionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateActivityOptionsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::update_activity_options

Source§

fn pause_activity( &mut self, request: Request<PauseActivityRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PauseActivityResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::pause_activity

Source§

fn unpause_activity( &mut self, request: Request<UnpauseActivityRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UnpauseActivityResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::unpause_activity

Source§

fn update_workflow_execution_options( &mut self, request: Request<UpdateWorkflowExecutionOptionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateWorkflowExecutionOptionsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::update_workflow_execution_options

Source§

fn reset_activity( &mut self, request: Request<ResetActivityRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ResetActivityResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::reset_activity

Source§

fn delete_worker_deployment( &mut self, request: Request<DeleteWorkerDeploymentRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteWorkerDeploymentResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::delete_worker_deployment

Source§

fn delete_worker_deployment_version( &mut self, request: Request<DeleteWorkerDeploymentVersionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteWorkerDeploymentVersionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::delete_worker_deployment_version

Source§

fn describe_worker_deployment( &mut self, request: Request<DescribeWorkerDeploymentRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeWorkerDeploymentResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::describe_worker_deployment

Source§

fn describe_worker_deployment_version( &mut self, request: Request<DescribeWorkerDeploymentVersionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeWorkerDeploymentVersionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::describe_worker_deployment_version

Source§

fn list_worker_deployments( &mut self, request: Request<ListWorkerDeploymentsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListWorkerDeploymentsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_worker_deployments

Source§

fn set_worker_deployment_current_version( &mut self, request: Request<SetWorkerDeploymentCurrentVersionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SetWorkerDeploymentCurrentVersionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::set_worker_deployment_current_version

Source§

fn set_worker_deployment_ramping_version( &mut self, request: Request<SetWorkerDeploymentRampingVersionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SetWorkerDeploymentRampingVersionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::set_worker_deployment_ramping_version

Source§

fn update_worker_deployment_version_metadata( &mut self, request: Request<UpdateWorkerDeploymentVersionMetadataRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateWorkerDeploymentVersionMetadataResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::update_worker_deployment_version_metadata

Source§

fn list_workers( &mut self, request: Request<ListWorkersRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListWorkersResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_workers

Source§

fn record_worker_heartbeat( &mut self, request: Request<RecordWorkerHeartbeatRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RecordWorkerHeartbeatResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::record_worker_heartbeat

Source§

fn update_task_queue_config( &mut self, request: Request<UpdateTaskQueueConfigRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateTaskQueueConfigResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::update_task_queue_config

Source§

fn fetch_worker_config( &mut self, request: Request<FetchWorkerConfigRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<FetchWorkerConfigResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::fetch_worker_config

Source§

fn update_worker_config( &mut self, request: Request<UpdateWorkerConfigRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateWorkerConfigResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::update_worker_config

Source§

fn describe_worker( &mut self, request: Request<DescribeWorkerRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeWorkerResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::describe_worker

Source§

fn set_worker_deployment_manager( &mut self, request: Request<SetWorkerDeploymentManagerRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SetWorkerDeploymentManagerResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::set_worker_deployment_manager

Source§

fn pause_workflow_execution( &mut self, request: Request<PauseWorkflowExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PauseWorkflowExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::pause_workflow_execution

Source§

fn unpause_workflow_execution( &mut self, request: Request<UnpauseWorkflowExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UnpauseWorkflowExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::unpause_workflow_execution

Source§

fn start_activity_execution( &mut self, request: Request<StartActivityExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<StartActivityExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::start_activity_execution

Source§

fn describe_activity_execution( &mut self, request: Request<DescribeActivityExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeActivityExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::describe_activity_execution

Source§

fn poll_activity_execution( &mut self, request: Request<PollActivityExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PollActivityExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::poll_activity_execution

Source§

fn list_activity_executions( &mut self, request: Request<ListActivityExecutionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListActivityExecutionsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::list_activity_executions

Source§

fn count_activity_executions( &mut self, request: Request<CountActivityExecutionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CountActivityExecutionsResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::count_activity_executions

Source§

fn request_cancel_activity_execution( &mut self, request: Request<RequestCancelActivityExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RequestCancelActivityExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::request_cancel_activity_execution

Source§

fn terminate_activity_execution( &mut self, request: Request<TerminateActivityExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TerminateActivityExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::terminate_activity_execution

Source§

fn delete_activity_execution( &mut self, request: Request<DeleteActivityExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteActivityExecutionResponse>, Status>> + Send + '_>>

See WorkflowServiceClient::delete_activity_execution

Source§

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