temporal_sdk_proto (temporal_sdk v0.1.15)

View Source

Temporal gRPC services module.

Summary

Types

service()

-type service() ::
          'RegisterNamespace' | 'DescribeNamespace' | 'ListNamespaces' | 'UpdateNamespace' |
          'DeprecateNamespace' | 'StartWorkflowExecution' | 'ExecuteMultiOperation' |
          'GetWorkflowExecutionHistory' | 'GetWorkflowExecutionHistoryReverse' |
          'PollWorkflowTaskQueue' | 'RespondWorkflowTaskCompleted' | 'RespondWorkflowTaskFailed' |
          'PollActivityTaskQueue' | 'RecordActivityTaskHeartbeat' | 'RecordActivityTaskHeartbeatById' |
          'RespondActivityTaskCompleted' | 'RespondActivityTaskCompletedById' |
          'RespondActivityTaskFailed' | 'RespondActivityTaskFailedById' |
          'RespondActivityTaskCanceled' | 'RespondActivityTaskCanceledById' |
          'RequestCancelWorkflowExecution' | 'SignalWorkflowExecution' |
          'SignalWithStartWorkflowExecution' | 'ResetWorkflowExecution' | 'TerminateWorkflowExecution' |
          'DeleteWorkflowExecution' | 'ListOpenWorkflowExecutions' | 'ListClosedWorkflowExecutions' |
          'ListWorkflowExecutions' | 'ListArchivedWorkflowExecutions' | 'ScanWorkflowExecutions' |
          'CountWorkflowExecutions' | 'GetSearchAttributes' | 'RespondQueryTaskCompleted' |
          'ResetStickyTaskQueue' | 'ShutdownWorker' | 'QueryWorkflow' | 'DescribeWorkflowExecution' |
          'DescribeTaskQueue' | 'GetClusterInfo' | 'GetSystemInfo' | 'ListTaskQueuePartitions' |
          'CreateSchedule' | 'DescribeSchedule' | 'UpdateSchedule' | 'PatchSchedule' |
          'ListScheduleMatchingTimes' | 'DeleteSchedule' | 'ListSchedules' |
          'UpdateWorkerBuildIdCompatibility' | 'GetWorkerBuildIdCompatibility' |
          'UpdateWorkerVersioningRules' | 'GetWorkerVersioningRules' | 'GetWorkerTaskReachability' |
          'DescribeDeployment' | 'DescribeWorkerDeploymentVersion' | 'ListDeployments' |
          'GetDeploymentReachability' | 'GetCurrentDeployment' | 'SetCurrentDeployment' |
          'SetWorkerDeploymentCurrentVersion' | 'DescribeWorkerDeployment' | 'DeleteWorkerDeployment' |
          'DeleteWorkerDeploymentVersion' | 'SetWorkerDeploymentRampingVersion' |
          'ListWorkerDeployments' | 'UpdateWorkerDeploymentVersionMetadata' |
          'SetWorkerDeploymentManager' | 'UpdateWorkflowExecution' | 'PollWorkflowExecutionUpdate' |
          'StartBatchOperation' | 'StopBatchOperation' | 'DescribeBatchOperation' |
          'ListBatchOperations' | 'PollNexusTaskQueue' | 'RespondNexusTaskCompleted' |
          'RespondNexusTaskFailed' | 'UpdateActivityOptions' | 'UpdateWorkflowExecutionOptions' |
          'PauseActivity' | 'UnpauseActivity' | 'ResetActivity' | 'CreateWorkflowRule' |
          'DescribeWorkflowRule' | 'DeleteWorkflowRule' | 'ListWorkflowRules' | 'TriggerWorkflowRule' |
          'RecordWorkerHeartbeat' | 'ListWorkers' | 'UpdateTaskQueueConfig' | 'FetchWorkerConfig' |
          'UpdateWorkerConfig' | 'DescribeWorker' | 'AddSearchAttributes' | 'RemoveSearchAttributes' |
          'ListSearchAttributes' | 'DeleteNamespace' | 'AddOrUpdateRemoteCluster' |
          'RemoveRemoteCluster' | 'ListClusters' | 'GetNexusEndpoint' | 'CreateNexusEndpoint' |
          'UpdateNexusEndpoint' | 'DeleteNexusEndpoint' | 'ListNexusEndpoints'.

service_info()

-type service_info() ::
          #{content_type := binary(),
            input :=
                temporal_sdk_proto_service_workflow_binaries:'$msg_name'() |
                temporal_sdk_proto_service_operator_binaries:'$msg_name'(),
            input_stream := boolean(),
            output :=
                temporal_sdk_proto_service_workflow_binaries:'$msg_name'() |
                temporal_sdk_proto_service_operator_binaries:'$msg_name'(),
            output_stream := boolean(),
            msg_type := binary(),
            name := atom(),
            opts := list(),
            service_fqname :=
                'temporal.api.workflowservice.v1.WorkflowService' |
                'temporal.api.operatorservice.v1.OperatorService'}.

Functions

info(Service)

-spec info(Service :: service()) -> service_info().