TemporalSdk.Service (temporal_sdk v0.2.1)

View Source

Temporal 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

get_workflow_history(cluster, workflow_execution_or_id)

@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()

get_workflow_history(cluster, workflow_execution_or_id, opts)

@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()

get_workflow_history_reverse(cluster, workflow_execution_or_id)

@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()

get_workflow_history_reverse(cluster, workflow_execution_or_id, opts)

@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()

list_archived_workflows(cluster)

@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()

list_archived_workflows(cluster, opts)

@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()

list_closed_workflows(cluster)

@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()

list_closed_workflows(cluster, opts)

@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()

list_open_workflows(cluster)

@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()

list_open_workflows(cluster, opts)

@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()

list_workflows(cluster)

@spec list_workflows(cluster :: :temporal_sdk_cluster.cluster_name()) ::
  {:ok,
   :temporal_sdk_proto_service_workflow_binaries."temporal.api.workflowservice.v1.ListWorkflowExecutionsResponse"()}
  | :temporal_sdk.response()

list_workflows(cluster, opts)

@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()