temporal_sdk_service (temporal_sdk v0.2.1)
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
Types
-type get_workflow_history_opts() :: [{namespace, unicode:chardata()} | {maximum_page_size, pos_integer()} | {next_page_token, binary()} | {wait_new_event, boolean()} | {history_event_filter_type, temporal_sdk_proto_service_workflow_binaries:'temporal.api.enums.v1.HistoryEventFilterType'()} | {grpc_opts, temporal_sdk_client:grpc_opts()} | {raw_request, temporal_sdk_proto_service_workflow_binaries:'temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryReverseRequest'()} | {response_type, temporal_sdk:response_type()}].
-type get_workflow_history_reverse_opts() :: [{namespace, unicode:chardata()} | {maximum_page_size, pos_integer()} | {next_page_token, binary()} | {grpc_opts, temporal_sdk_client:grpc_opts()} | {raw_request, temporal_sdk_proto_service_workflow_binaries:'temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryReverseRequest'()} | {response_type, temporal_sdk:response_type()}].
-type list_archived_workflows_opts() :: [{namespace, unicode:chardata()} | {page_size, pos_integer()} | {next_page_token, binary()} | {query, unicode:chardata()} | {grpc_opts, temporal_sdk_client:grpc_opts()} | {raw_request, temporal_sdk_proto_service_workflow_binaries:'temporal.api.workflowservice.v1.ListArchivedWorkflowExecutionsRequest'()} | {response_type, temporal_sdk:response_type()}].
-type list_closed_workflows_opts() :: [{namespace, unicode:chardata()} | {maximum_page_size, pos_integer()} | {next_page_token, binary()} | {start_time_filter, temporal_sdk_proto_service_workflow_binaries:'temporal.api.filter.v1.StartTimeFilter'()} | {filters, {execution_filter, temporal_sdk_proto_service_workflow_binaries:'temporal.api.filter.v1.WorkflowExecutionFilter'()} | {type_filter, temporal_sdk_proto_service_workflow_binaries:'temporal.api.filter.v1.WorkflowTypeFilter'()} | {status_filter, temporal_sdk_proto_service_workflow_binaries:'temporal.api.filter.v1.StatusFilter'()}} | {grpc_opts, temporal_sdk_client:grpc_opts()} | {raw_request, temporal_sdk_proto_service_workflow_binaries:'temporal.api.workflowservice.v1.ListClosedWorkflowExecutionsRequest'()} | {response_type, temporal_sdk:response_type()}].
-type list_open_workflows_opts() :: [{namespace, unicode:chardata()} | {maximum_page_size, pos_integer()} | {next_page_token, binary()} | {start_time_filter, temporal_sdk_proto_service_workflow_binaries:'temporal.api.filter.v1.StartTimeFilter'()} | {filters, {execution_filter, temporal_sdk_proto_service_workflow_binaries:'temporal.api.filter.v1.WorkflowExecutionFilter'()} | {type_filter, temporal_sdk_proto_service_workflow_binaries:'temporal.api.filter.v1.WorkflowTypeFilter'()}} | {grpc_opts, temporal_sdk_client:grpc_opts()} | {raw_request, temporal_sdk_proto_service_workflow_binaries:'temporal.api.workflowservice.v1.ListOpenWorkflowExecutionsRequest'()} | {response_type, temporal_sdk:response_type()}].
-type list_workflows_opts() :: [{namespace, unicode:chardata()} | {page_size, pos_integer()} | {next_page_token, binary()} | {query, unicode:chardata()} | {grpc_opts, temporal_sdk_client:grpc_opts()} | {raw_request, temporal_sdk_proto_service_workflow_binaries:'temporal.api.workflowservice.v1.ListWorkflowExecutionsRequest'()} | {response_type, temporal_sdk:response_type()}].
Functions
-spec get_workflow_history(Cluster :: temporal_sdk_cluster:cluster_name(), WorkflowExecutionOrId :: 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(), WorkflowExecutionOrId :: temporal_sdk:workflow_execution_or_id(), Opts :: 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(), WorkflowExecutionOrId :: 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(), WorkflowExecutionOrId :: temporal_sdk:workflow_execution_or_id(), Opts :: 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 :: 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 :: 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 :: 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 :: list_workflows_opts()) -> {ok, temporal_sdk_proto_service_workflow_binaries:'temporal.api.workflowservice.v1.ListWorkflowExecutionsResponse'()} | temporal_sdk:response().