TemporalSdk.Service (temporal_sdk v0.2.0)
View SourceTemporal general services module.
TODO:
scan_workflow_executions
count_workflow_executions
describe_task_queue
get_cluster_info
get_system_info
list_task_queue_partitions
'UpdateActivityOptions'
'UpdateWorkflowExecutionOptions'
'PauseActivity'
'UnpauseActivity'
'ResetActivity'
'ExecuteMultiOperation'
'CreateWorkflowRule'
'DescribeWorkflowRule'
'DeleteWorkflowRule'
'ListWorkflowRules'
'TriggerWorkflowRule'
Summary
Functions
@spec get_workflow_history( cluster :: :temporal_sdk_cluster.cluster_name(), workflow_execution_or_id :: :temporal_sdk.workflow_execution_or_id() ) :: {:ok, :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryResponse"()} | :temporal_sdk.response()
@spec get_workflow_history( cluster :: :temporal_sdk_cluster.cluster_name(), workflow_execution_or_id :: :temporal_sdk.workflow_execution_or_id(), opts :: :temporal_sdk_service.get_workflow_history_opts() ) :: {:ok, :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryResponse"()} | :temporal_sdk.response()
@spec get_workflow_history_reverse( cluster :: :temporal_sdk_cluster.cluster_name(), workflow_execution_or_id :: :temporal_sdk.workflow_execution_or_id() ) :: {:ok, :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryReverseResponse"()} | :temporal_sdk.response()
@spec get_workflow_history_reverse( cluster :: :temporal_sdk_cluster.cluster_name(), workflow_execution_or_id :: :temporal_sdk.workflow_execution_or_id(), opts :: :temporal_sdk_service.get_workflow_history_reverse_opts() ) :: {:ok, :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryReverseResponse"()} | :temporal_sdk.response()
@spec list_archived_workflows(cluster :: :temporal_sdk_cluster.cluster_name()) :: {:ok, :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.ListArchivedWorkflowExecutionsResponse"()} | :temporal_sdk.response()
@spec list_archived_workflows( cluster :: :temporal_sdk_cluster.cluster_name(), opts :: :temporal_sdk_service.list_archived_workflows_opts() ) :: {:ok, :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.ListArchivedWorkflowExecutionsResponse"()} | :temporal_sdk.response()
@spec list_closed_workflows(cluster :: :temporal_sdk_cluster.cluster_name()) :: {:ok, :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.ListClosedWorkflowExecutionsResponse"()} | :temporal_sdk.response()
@spec list_closed_workflows( cluster :: :temporal_sdk_cluster.cluster_name(), opts :: :temporal_sdk_service.list_closed_workflows_opts() ) :: {:ok, :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.ListClosedWorkflowExecutionsResponse"()} | :temporal_sdk.response()
@spec list_open_workflows(cluster :: :temporal_sdk_cluster.cluster_name()) :: {:ok, :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.ListOpenWorkflowExecutionsResponse"()} | :temporal_sdk.response()
@spec list_open_workflows( cluster :: :temporal_sdk_cluster.cluster_name(), opts :: :temporal_sdk_service.list_open_workflows_opts() ) :: {:ok, :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.ListOpenWorkflowExecutionsResponse"()} | :temporal_sdk.response()
@spec list_workflows(cluster :: :temporal_sdk_cluster.cluster_name()) :: {:ok, :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.ListWorkflowExecutionsResponse"()} | :temporal_sdk.response()
@spec list_workflows( cluster :: :temporal_sdk_cluster.cluster_name(), opts :: :temporal_sdk_service.list_workflows_opts() ) :: {:ok, :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.ListWorkflowExecutionsResponse"()} | :temporal_sdk.response()