WorkflowService

squads_temporal_client

Trait WorkflowService 

Source 
pub trait WorkflowService: RawClientLike
where
    <Self as RawClientLike>::SvcType: GrpcService<Body> + Send + Clone + 'static,
    <<Self as RawClientLike>::SvcType as GrpcService<Body>>::ResponseBody: Body<Data = Bytes> + Send + 'static,
    <<Self as RawClientLike>::SvcType as GrpcService<Body>>::Error: Into<StdError>,
    <<Self as RawClientLike>::SvcType as GrpcService<Body>>::Future: Send,
    <<<Self as RawClientLike>::SvcType as GrpcService<Body>>::ResponseBody as Body>::Error: Into<StdError> + Send,
{

Show 92 methods    // Provided methods
    fn register_namespace(
        &mut self,
        request: impl IntoRequest<RegisterNamespaceRequest>,
    ) -> BoxFuture<'_, Result<Response<RegisterNamespaceResponse>, Status>> { ... }
    fn describe_namespace(
        &mut self,
        request: impl IntoRequest<DescribeNamespaceRequest>,
    ) -> BoxFuture<'_, Result<Response<DescribeNamespaceResponse>, Status>> { ... }
    fn list_namespaces(
        &mut self,
        request: impl IntoRequest<ListNamespacesRequest>,
    ) -> BoxFuture<'_, Result<Response<ListNamespacesResponse>, Status>> { ... }
    fn update_namespace(
        &mut self,
        request: impl IntoRequest<UpdateNamespaceRequest>,
    ) -> BoxFuture<'_, Result<Response<UpdateNamespaceResponse>, Status>> { ... }
    fn deprecate_namespace(
        &mut self,
        request: impl IntoRequest<DeprecateNamespaceRequest>,
    ) -> BoxFuture<'_, Result<Response<DeprecateNamespaceResponse>, Status>> { ... }
    fn start_workflow_execution(
        &mut self,
        request: impl IntoRequest<StartWorkflowExecutionRequest>,
    ) -> BoxFuture<'_, Result<Response<StartWorkflowExecutionResponse>, Status>> { ... }
    fn get_workflow_execution_history(
        &mut self,
        request: impl IntoRequest<GetWorkflowExecutionHistoryRequest>,
    ) -> BoxFuture<'_, Result<Response<GetWorkflowExecutionHistoryResponse>, Status>> { ... }
    fn get_workflow_execution_history_reverse(
        &mut self,
        request: impl IntoRequest<GetWorkflowExecutionHistoryReverseRequest>,
    ) -> BoxFuture<'_, Result<Response<GetWorkflowExecutionHistoryReverseResponse>, Status>> { ... }
    fn poll_workflow_task_queue(
        &mut self,
        request: impl IntoRequest<PollWorkflowTaskQueueRequest>,
    ) -> BoxFuture<'_, Result<Response<PollWorkflowTaskQueueResponse>, Status>> { ... }
    fn respond_workflow_task_completed(
        &mut self,
        request: impl IntoRequest<RespondWorkflowTaskCompletedRequest>,
    ) -> BoxFuture<'_, Result<Response<RespondWorkflowTaskCompletedResponse>, Status>> { ... }
    fn respond_workflow_task_failed(
        &mut self,
        request: impl IntoRequest<RespondWorkflowTaskFailedRequest>,
    ) -> BoxFuture<'_, Result<Response<RespondWorkflowTaskFailedResponse>, Status>> { ... }
    fn poll_activity_task_queue(
        &mut self,
        request: impl IntoRequest<PollActivityTaskQueueRequest>,
    ) -> BoxFuture<'_, Result<Response<PollActivityTaskQueueResponse>, Status>> { ... }
    fn record_activity_task_heartbeat(
        &mut self,
        request: impl IntoRequest<RecordActivityTaskHeartbeatRequest>,
    ) -> BoxFuture<'_, Result<Response<RecordActivityTaskHeartbeatResponse>, Status>> { ... }
    fn record_activity_task_heartbeat_by_id(
        &mut self,
        request: impl IntoRequest<RecordActivityTaskHeartbeatByIdRequest>,
    ) -> BoxFuture<'_, Result<Response<RecordActivityTaskHeartbeatByIdResponse>, Status>> { ... }
    fn respond_activity_task_completed(
        &mut self,
        request: impl IntoRequest<RespondActivityTaskCompletedRequest>,
    ) -> BoxFuture<'_, Result<Response<RespondActivityTaskCompletedResponse>, Status>> { ... }
    fn respond_activity_task_completed_by_id(
        &mut self,
        request: impl IntoRequest<RespondActivityTaskCompletedByIdRequest>,
    ) -> BoxFuture<'_, Result<Response<RespondActivityTaskCompletedByIdResponse>, Status>> { ... }
    fn respond_activity_task_failed(
        &mut self,
        request: impl IntoRequest<RespondActivityTaskFailedRequest>,
    ) -> BoxFuture<'_, Result<Response<RespondActivityTaskFailedResponse>, Status>> { ... }
    fn respond_activity_task_failed_by_id(
        &mut self,
        request: impl IntoRequest<RespondActivityTaskFailedByIdRequest>,
    ) -> BoxFuture<'_, Result<Response<RespondActivityTaskFailedByIdResponse>, Status>> { ... }
    fn respond_activity_task_canceled(
        &mut self,
        request: impl IntoRequest<RespondActivityTaskCanceledRequest>,
    ) -> BoxFuture<'_, Result<Response<RespondActivityTaskCanceledResponse>, Status>> { ... }
    fn respond_activity_task_canceled_by_id(
        &mut self,
        request: impl IntoRequest<RespondActivityTaskCanceledByIdRequest>,
    ) -> BoxFuture<'_, Result<Response<RespondActivityTaskCanceledByIdResponse>, Status>> { ... }
    fn request_cancel_workflow_execution(
        &mut self,
        request: impl IntoRequest<RequestCancelWorkflowExecutionRequest>,
    ) -> BoxFuture<'_, Result<Response<RequestCancelWorkflowExecutionResponse>, Status>> { ... }
    fn signal_workflow_execution(
        &mut self,
        request: impl IntoRequest<SignalWorkflowExecutionRequest>,
    ) -> BoxFuture<'_, Result<Response<SignalWorkflowExecutionResponse>, Status>> { ... }
    fn signal_with_start_workflow_execution(
        &mut self,
        request: impl IntoRequest<SignalWithStartWorkflowExecutionRequest>,
    ) -> BoxFuture<'_, Result<Response<SignalWithStartWorkflowExecutionResponse>, Status>> { ... }
    fn reset_workflow_execution(
        &mut self,
        request: impl IntoRequest<ResetWorkflowExecutionRequest>,
    ) -> BoxFuture<'_, Result<Response<ResetWorkflowExecutionResponse>, Status>> { ... }
    fn terminate_workflow_execution(
        &mut self,
        request: impl IntoRequest<TerminateWorkflowExecutionRequest>,
    ) -> BoxFuture<'_, Result<Response<TerminateWorkflowExecutionResponse>, Status>> { ... }
    fn delete_workflow_execution(
        &mut self,
        request: impl IntoRequest<DeleteWorkflowExecutionRequest>,
    ) -> BoxFuture<'_, Result<Response<DeleteWorkflowExecutionResponse>, Status>> { ... }
    fn list_open_workflow_executions(
        &mut self,
        request: impl IntoRequest<ListOpenWorkflowExecutionsRequest>,
    ) -> BoxFuture<'_, Result<Response<ListOpenWorkflowExecutionsResponse>, Status>> { ... }
    fn list_closed_workflow_executions(
        &mut self,
        request: impl IntoRequest<ListClosedWorkflowExecutionsRequest>,
    ) -> BoxFuture<'_, Result<Response<ListClosedWorkflowExecutionsResponse>, Status>> { ... }
    fn list_workflow_executions(
        &mut self,
        request: impl IntoRequest<ListWorkflowExecutionsRequest>,
    ) -> BoxFuture<'_, Result<Response<ListWorkflowExecutionsResponse>, Status>> { ... }
    fn list_archived_workflow_executions(
        &mut self,
        request: impl IntoRequest<ListArchivedWorkflowExecutionsRequest>,
    ) -> BoxFuture<'_, Result<Response<ListArchivedWorkflowExecutionsResponse>, Status>> { ... }
    fn scan_workflow_executions(
        &mut self,
        request: impl IntoRequest<ScanWorkflowExecutionsRequest>,
    ) -> BoxFuture<'_, Result<Response<ScanWorkflowExecutionsResponse>, Status>> { ... }
    fn count_workflow_executions(
        &mut self,
        request: impl IntoRequest<CountWorkflowExecutionsRequest>,
    ) -> BoxFuture<'_, Result<Response<CountWorkflowExecutionsResponse>, Status>> { ... }
    fn create_workflow_rule(
        &mut self,
        request: impl IntoRequest<CreateWorkflowRuleRequest>,
    ) -> BoxFuture<'_, Result<Response<CreateWorkflowRuleResponse>, Status>> { ... }
    fn describe_workflow_rule(
        &mut self,
        request: impl IntoRequest<DescribeWorkflowRuleRequest>,
    ) -> BoxFuture<'_, Result<Response<DescribeWorkflowRuleResponse>, Status>> { ... }
    fn delete_workflow_rule(
        &mut self,
        request: impl IntoRequest<DeleteWorkflowRuleRequest>,
    ) -> BoxFuture<'_, Result<Response<DeleteWorkflowRuleResponse>, Status>> { ... }
    fn list_workflow_rules(
        &mut self,
        request: impl IntoRequest<ListWorkflowRulesRequest>,
    ) -> BoxFuture<'_, Result<Response<ListWorkflowRulesResponse>, Status>> { ... }
    fn trigger_workflow_rule(
        &mut self,
        request: impl IntoRequest<TriggerWorkflowRuleRequest>,
    ) -> BoxFuture<'_, Result<Response<TriggerWorkflowRuleResponse>, Status>> { ... }
    fn get_search_attributes(
        &mut self,
        request: impl IntoRequest<GetSearchAttributesRequest>,
    ) -> BoxFuture<'_, Result<Response<GetSearchAttributesResponse>, Status>> { ... }
    fn respond_query_task_completed(
        &mut self,
        request: impl IntoRequest<RespondQueryTaskCompletedRequest>,
    ) -> BoxFuture<'_, Result<Response<RespondQueryTaskCompletedResponse>, Status>> { ... }
    fn reset_sticky_task_queue(
        &mut self,
        request: impl IntoRequest<ResetStickyTaskQueueRequest>,
    ) -> BoxFuture<'_, Result<Response<ResetStickyTaskQueueResponse>, Status>> { ... }
    fn query_workflow(
        &mut self,
        request: impl IntoRequest<QueryWorkflowRequest>,
    ) -> BoxFuture<'_, Result<Response<QueryWorkflowResponse>, Status>> { ... }
    fn describe_workflow_execution(
        &mut self,
        request: impl IntoRequest<DescribeWorkflowExecutionRequest>,
    ) -> BoxFuture<'_, Result<Response<DescribeWorkflowExecutionResponse>, Status>> { ... }
    fn describe_task_queue(
        &mut self,
        request: impl IntoRequest<DescribeTaskQueueRequest>,
    ) -> BoxFuture<'_, Result<Response<DescribeTaskQueueResponse>, Status>> { ... }
    fn get_cluster_info(
        &mut self,
        request: impl IntoRequest<GetClusterInfoRequest>,
    ) -> BoxFuture<'_, Result<Response<GetClusterInfoResponse>, Status>> { ... }
    fn get_system_info(
        &mut self,
        request: impl IntoRequest<GetSystemInfoRequest>,
    ) -> BoxFuture<'_, Result<Response<GetSystemInfoResponse>, Status>> { ... }
    fn list_task_queue_partitions(
        &mut self,
        request: impl IntoRequest<ListTaskQueuePartitionsRequest>,
    ) -> BoxFuture<'_, Result<Response<ListTaskQueuePartitionsResponse>, Status>> { ... }
    fn create_schedule(
        &mut self,
        request: impl IntoRequest<CreateScheduleRequest>,
    ) -> BoxFuture<'_, Result<Response<CreateScheduleResponse>, Status>> { ... }
    fn describe_schedule(
        &mut self,
        request: impl IntoRequest<DescribeScheduleRequest>,
    ) -> BoxFuture<'_, Result<Response<DescribeScheduleResponse>, Status>> { ... }
    fn update_schedule(
        &mut self,
        request: impl IntoRequest<UpdateScheduleRequest>,
    ) -> BoxFuture<'_, Result<Response<UpdateScheduleResponse>, Status>> { ... }
    fn patch_schedule(
        &mut self,
        request: impl IntoRequest<PatchScheduleRequest>,
    ) -> BoxFuture<'_, Result<Response<PatchScheduleResponse>, Status>> { ... }
    fn list_schedule_matching_times(
        &mut self,
        request: impl IntoRequest<ListScheduleMatchingTimesRequest>,
    ) -> BoxFuture<'_, Result<Response<ListScheduleMatchingTimesResponse>, Status>> { ... }
    fn delete_schedule(
        &mut self,
        request: impl IntoRequest<DeleteScheduleRequest>,
    ) -> BoxFuture<'_, Result<Response<DeleteScheduleResponse>, Status>> { ... }
    fn list_schedules(
        &mut self,
        request: impl IntoRequest<ListSchedulesRequest>,
    ) -> BoxFuture<'_, Result<Response<ListSchedulesResponse>, Status>> { ... }
    fn update_worker_build_id_compatibility(
        &mut self,
        request: impl IntoRequest<UpdateWorkerBuildIdCompatibilityRequest>,
    ) -> BoxFuture<'_, Result<Response<UpdateWorkerBuildIdCompatibilityResponse>, Status>> { ... }
    fn get_worker_build_id_compatibility(
        &mut self,
        request: impl IntoRequest<GetWorkerBuildIdCompatibilityRequest>,
    ) -> BoxFuture<'_, Result<Response<GetWorkerBuildIdCompatibilityResponse>, Status>> { ... }
    fn get_worker_task_reachability(
        &mut self,
        request: impl IntoRequest<GetWorkerTaskReachabilityRequest>,
    ) -> BoxFuture<'_, Result<Response<GetWorkerTaskReachabilityResponse>, Status>> { ... }
    fn update_workflow_execution(
        &mut self,
        request: impl IntoRequest<UpdateWorkflowExecutionRequest>,
    ) -> BoxFuture<'_, Result<Response<UpdateWorkflowExecutionResponse>, Status>> { ... }
    fn poll_workflow_execution_update(
        &mut self,
        request: impl IntoRequest<PollWorkflowExecutionUpdateRequest>,
    ) -> BoxFuture<'_, Result<Response<PollWorkflowExecutionUpdateResponse>, Status>> { ... }
    fn start_batch_operation(
        &mut self,
        request: impl IntoRequest<StartBatchOperationRequest>,
    ) -> BoxFuture<'_, Result<Response<StartBatchOperationResponse>, Status>> { ... }
    fn stop_batch_operation(
        &mut self,
        request: impl IntoRequest<StopBatchOperationRequest>,
    ) -> BoxFuture<'_, Result<Response<StopBatchOperationResponse>, Status>> { ... }
    fn describe_batch_operation(
        &mut self,
        request: impl IntoRequest<DescribeBatchOperationRequest>,
    ) -> BoxFuture<'_, Result<Response<DescribeBatchOperationResponse>, Status>> { ... }
    fn describe_deployment(
        &mut self,
        request: impl IntoRequest<DescribeDeploymentRequest>,
    ) -> BoxFuture<'_, Result<Response<DescribeDeploymentResponse>, Status>> { ... }
    fn list_batch_operations(
        &mut self,
        request: impl IntoRequest<ListBatchOperationsRequest>,
    ) -> BoxFuture<'_, Result<Response<ListBatchOperationsResponse>, Status>> { ... }
    fn list_deployments(
        &mut self,
        request: impl IntoRequest<ListDeploymentsRequest>,
    ) -> BoxFuture<'_, Result<Response<ListDeploymentsResponse>, Status>> { ... }
    fn execute_multi_operation(
        &mut self,
        request: impl IntoRequest<ExecuteMultiOperationRequest>,
    ) -> BoxFuture<'_, Result<Response<ExecuteMultiOperationResponse>, Status>> { ... }
    fn get_current_deployment(
        &mut self,
        request: impl IntoRequest<GetCurrentDeploymentRequest>,
    ) -> BoxFuture<'_, Result<Response<GetCurrentDeploymentResponse>, Status>> { ... }
    fn get_deployment_reachability(
        &mut self,
        request: impl IntoRequest<GetDeploymentReachabilityRequest>,
    ) -> BoxFuture<'_, Result<Response<GetDeploymentReachabilityResponse>, Status>> { ... }
    fn get_worker_versioning_rules(
        &mut self,
        request: impl IntoRequest<GetWorkerVersioningRulesRequest>,
    ) -> BoxFuture<'_, Result<Response<GetWorkerVersioningRulesResponse>, Status>> { ... }
    fn update_worker_versioning_rules(
        &mut self,
        request: impl IntoRequest<UpdateWorkerVersioningRulesRequest>,
    ) -> BoxFuture<'_, Result<Response<UpdateWorkerVersioningRulesResponse>, Status>> { ... }
    fn poll_nexus_task_queue(
        &mut self,
        request: impl IntoRequest<PollNexusTaskQueueRequest>,
    ) -> BoxFuture<'_, Result<Response<PollNexusTaskQueueResponse>, Status>> { ... }
    fn respond_nexus_task_completed(
        &mut self,
        request: impl IntoRequest<RespondNexusTaskCompletedRequest>,
    ) -> BoxFuture<'_, Result<Response<RespondNexusTaskCompletedResponse>, Status>> { ... }
    fn respond_nexus_task_failed(
        &mut self,
        request: impl IntoRequest<RespondNexusTaskFailedRequest>,
    ) -> BoxFuture<'_, Result<Response<RespondNexusTaskFailedResponse>, Status>> { ... }
    fn set_current_deployment(
        &mut self,
        request: impl IntoRequest<SetCurrentDeploymentRequest>,
    ) -> BoxFuture<'_, Result<Response<SetCurrentDeploymentResponse>, Status>> { ... }
    fn shutdown_worker(
        &mut self,
        request: impl IntoRequest<ShutdownWorkerRequest>,
    ) -> BoxFuture<'_, Result<Response<ShutdownWorkerResponse>, Status>> { ... }
    fn update_activity_options(
        &mut self,
        request: impl IntoRequest<UpdateActivityOptionsRequest>,
    ) -> BoxFuture<'_, Result<Response<UpdateActivityOptionsResponse>, Status>> { ... }
    fn pause_activity(
        &mut self,
        request: impl IntoRequest<PauseActivityRequest>,
    ) -> BoxFuture<'_, Result<Response<PauseActivityResponse>, Status>> { ... }
    fn unpause_activity(
        &mut self,
        request: impl IntoRequest<UnpauseActivityRequest>,
    ) -> BoxFuture<'_, Result<Response<UnpauseActivityResponse>, Status>> { ... }
    fn update_workflow_execution_options(
        &mut self,
        request: impl IntoRequest<UpdateWorkflowExecutionOptionsRequest>,
    ) -> BoxFuture<'_, Result<Response<UpdateWorkflowExecutionOptionsResponse>, Status>> { ... }
    fn reset_activity(
        &mut self,
        request: impl IntoRequest<ResetActivityRequest>,
    ) -> BoxFuture<'_, Result<Response<ResetActivityResponse>, Status>> { ... }
    fn delete_worker_deployment(
        &mut self,
        request: impl IntoRequest<DeleteWorkerDeploymentRequest>,
    ) -> BoxFuture<'_, Result<Response<DeleteWorkerDeploymentResponse>, Status>> { ... }
    fn delete_worker_deployment_version(
        &mut self,
        request: impl IntoRequest<DeleteWorkerDeploymentVersionRequest>,
    ) -> BoxFuture<'_, Result<Response<DeleteWorkerDeploymentVersionResponse>, Status>> { ... }
    fn describe_worker_deployment(
        &mut self,
        request: impl IntoRequest<DescribeWorkerDeploymentRequest>,
    ) -> BoxFuture<'_, Result<Response<DescribeWorkerDeploymentResponse>, Status>> { ... }
    fn describe_worker_deployment_version(
        &mut self,
        request: impl IntoRequest<DescribeWorkerDeploymentVersionRequest>,
    ) -> BoxFuture<'_, Result<Response<DescribeWorkerDeploymentVersionResponse>, Status>> { ... }
    fn list_worker_deployments(
        &mut self,
        request: impl IntoRequest<ListWorkerDeploymentsRequest>,
    ) -> BoxFuture<'_, Result<Response<ListWorkerDeploymentsResponse>, Status>> { ... }
    fn set_worker_deployment_current_version(
        &mut self,
        request: impl IntoRequest<SetWorkerDeploymentCurrentVersionRequest>,
    ) -> BoxFuture<'_, Result<Response<SetWorkerDeploymentCurrentVersionResponse>, Status>> { ... }
    fn set_worker_deployment_ramping_version(
        &mut self,
        request: impl IntoRequest<SetWorkerDeploymentRampingVersionRequest>,
    ) -> BoxFuture<'_, Result<Response<SetWorkerDeploymentRampingVersionResponse>, Status>> { ... }
    fn update_worker_deployment_version_metadata(
        &mut self,
        request: impl IntoRequest<UpdateWorkerDeploymentVersionMetadataRequest>,
    ) -> BoxFuture<'_, Result<Response<UpdateWorkerDeploymentVersionMetadataResponse>, Status>> { ... }
    fn list_workers(
        &mut self,
        request: impl IntoRequest<ListWorkersRequest>,
    ) -> BoxFuture<'_, Result<Response<ListWorkersResponse>, Status>> { ... }
    fn record_worker_heartbeat(
        &mut self,
        request: impl IntoRequest<RecordWorkerHeartbeatRequest>,
    ) -> BoxFuture<'_, Result<Response<RecordWorkerHeartbeatResponse>, Status>> { ... }
    fn update_task_queue_config(
        &mut self,
        request: impl IntoRequest<UpdateTaskQueueConfigRequest>,
    ) -> BoxFuture<'_, Result<Response<UpdateTaskQueueConfigResponse>, Status>> { ... }
    fn fetch_worker_config(
        &mut self,
        request: impl IntoRequest<FetchWorkerConfigRequest>,
    ) -> BoxFuture<'_, Result<Response<FetchWorkerConfigResponse>, Status>> { ... }
    fn update_worker_config(
        &mut self,
        request: impl IntoRequest<UpdateWorkerConfigRequest>,
    ) -> BoxFuture<'_, Result<Response<UpdateWorkerConfigResponse>, Status>> { ... }

}
Expand description

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

Provided Methods§

Source

fn 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

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

See WorkflowServiceClient::update_task_queue_config

Source

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

See WorkflowServiceClient::fetch_worker_config

Source

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

See WorkflowServiceClient::update_worker_config

Dyn Compatibility§

This trait is not dyn compatible.

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

Implementors§

Source§

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