Trait WorkflowService

Source

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