messages

package
v1.1.1921 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 29, 2025 License: MIT Imports: 1 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// StateExecutionComplete is the execution complete state
	StateExecutionComplete = ".State.Execution.Complete"
	// StateProcessExecute is the process execute state
	StateProcessExecute = ".State.Process.Execute"
	// StateProcessAbort is the process abort state
	StateProcessAbort = ".State.Process.Abort"
	// StateProcessComplete is the process complete state
	StateProcessComplete = ".State.Process.Complete"
	// StateProcessTerminated is the process terminated state
	StateProcessTerminated = ".State.Process.Terminated"
	//StateTraversalExecute  is the traversal execute state
	StateTraversalExecute = ".State.Traversal.Execute"
	// StateTraversalComplete is the traversal complete state
	StateTraversalComplete = ".State.Traversal.Complete"
	// StateActivityExecute is the activity execute state
	StateActivityExecute = ".State.Activity.Execute"
	// StateActivityComplete is the activity complete state
	StateActivityComplete = ".State.Activity.Complete"
	// StateActivityAbort is the activity abort state
	StateActivityAbort = ".State.Activity.Abort"
	// StateExecutionExecute is the execution execute state
	StateExecutionExecute = ".State.Execution.Execute"
	// StateExecutionAbort is the execute abort state
	StateExecutionAbort = ".State.Execution.Abort"
	//StateJobExecute is the job execute state
	StateJobExecute = ".State.Job.Execute."
	// StateJobExecuteServiceTask is the execute service task state
	StateJobExecuteServiceTask = ".State.Job.Execute.ServiceTask"
	// StateJobAbortServiceTask is the abort service task state
	StateJobAbortServiceTask = ".State.Job.Abort.ServiceTask"
	// StateJobCompleteServiceTask is the complete service task state
	StateJobCompleteServiceTask = ".State.Job.Complete.ServiceTask"
	// StateJobAbortGateway is the abort gateway state
	StateJobAbortGateway = ".State.Job.Abort.Gateway"
	// StateJobAwaitGateway is the await gateway state
	StateJobAwaitGateway = ".State.Job.Await.Gateway"
	// StateJobComplete is the complete job state
	StateJobComplete = ".State.Job.Complete."
	// StateJobExecuteUserTask is the execute user task state
	StateJobExecuteUserTask = ".State.Job.Execute.UserTask"
	// StateJobCompleteUserTask is the complete user task state
	StateJobCompleteUserTask = ".State.Job.Complete.UserTask"
	// StateJobExecuteManualTask is the execute manual task state
	StateJobExecuteManualTask = ".State.Job.Execute.ManualTask"
	// StateJobCompleteManualTask is the complete manual task state
	StateJobCompleteManualTask = ".State.Job.Complete.ManualTask"
	// StateJobExecuteSendMessage is the execute send message state
	StateJobExecuteSendMessage = ".State.Job.Execute.SendMessage"
	// StateJobCompleteSendMessage is the complete send message state
	StateJobCompleteSendMessage = ".State.Job.Complete.SendMessage"
	// StateLog is the log
	StateLog = ".State.Log."
)
View Source 
const (
	// WorkFlowJobAbortAll is the wildcard state message subject for all job abort messages.
	WorkFlowJobAbortAll = "WORKFLOW.%s.State.Job.Abort.*"
	// WorkFlowJobCompleteAll is the wildcard state message subject for all job completion messages.
	WorkFlowJobCompleteAll = "WORKFLOW.%s" + StateJobComplete + "*"
	// WorkflowActivityAbort is the state message subject for aborting an activity.
	WorkflowActivityAbort = "WORKFLOW.%s" + StateActivityAbort
	// WorkflowActivityAll is the wildcard state message subject for all activity messages.
	WorkflowActivityAll = "WORKFLOW.%s.State.Activity.>"
	// WorkflowActivityComplete is the state message subject for completing an activity.
	WorkflowActivityComplete = "WORKFLOW.%s" + StateActivityComplete
	// WorkflowActivityExecute is the state message subject for executing an activity.
	WorkflowActivityExecute = "WORKFLOW.%s" + StateActivityExecute
	// WorkflowCommands is the wildcard state message subject for all workflow commands.
	WorkflowCommands = "WORKFLOW.%s.Command.>"
	// WorkflowElementTimedExecute is the state message subject for a timed element execute operation.
	WorkflowElementTimedExecute = "WORKFLOW.%s.Timers.ElementExecute"
	// WorkflowGeneralAbortAll is the wildcard state message subject for all abort messages/.
	WorkflowGeneralAbortAll = "WORKFLOW.%s.State.*.Abort"
	// WorkflowExecutionAbort is the state message subject for an execution instace being aborted.
	WorkflowExecutionAbort = "WORKFLOW.%s" + StateExecutionAbort
	// WorkflowExecutionAll is the wildcard state message subject for all execution state messages.
	WorkflowExecutionAll = "WORKFLOW.%s.State.Execution.>"
	// WorkflowExecutionComplete is the state message subject for completing an execution instance.
	WorkflowExecutionComplete = "WORKFLOW.%s" + StateExecutionComplete
	// WorkflowExecutionExecute is the state message subject for executing an execution instance.
	WorkflowExecutionExecute = "WORKFLOW.%s" + StateExecutionExecute
	// WorkflowExecutionTerminated is the state message subject for an execution instance terminating.
	WorkflowExecutionTerminated = "WORKFLOW.%s.State.Execution.Terminated"
	// WorkflowJobAwaitMessageExecute is the state message subject for awaiting a message.
	WorkflowJobAwaitMessageExecute = "WORKFLOW.%s" + StateJobExecute + "AwaitMessage"
	// WorkflowJobAwaitMessageComplete is the state message subject for completing awaiting a message.
	WorkflowJobAwaitMessageComplete = "WORKFLOW.%s.State.Job.Complete.AwaitMessage"
	// WorkflowJobAwaitMessageAbort is the state message subject for aborting awaiting a message.
	WorkflowJobAwaitMessageAbort = "WORKFLOW.%s.State.Job.Abort.AwaitMessage"
	// WorkflowJobLaunchComplete is the state message subject for completing a launch subworkflow task.
	WorkflowJobLaunchComplete = "WORKFLOW.%s.State.Job.Complete.Launch"
	// WorkflowJobLaunchExecute is the state message subject for executing a launch subworkflow task.
	WorkflowJobLaunchExecute = "WORKFLOW.%s" + StateJobExecute + "Launch"
	// WorkflowJobManualTaskAbort is the state message subject for sborting a manual task.
	WorkflowJobManualTaskAbort = "WORKFLOW.%s.State.Job.Abort.ManualTask"
	// WorkflowJobManualTaskComplete is the state message subject for completing a manual task.
	WorkflowJobManualTaskComplete = "WORKFLOW.%s" + StateJobCompleteManualTask
	// WorkflowJobManualTaskExecute is the state message subject for executing a manual task.
	WorkflowJobManualTaskExecute = "WORKFLOW.%s" + StateJobExecute + "ManualTask"
	// WorkflowJobSendMessageComplete is the state message subject for completing a send message task.
	WorkflowJobSendMessageComplete = "WORKFLOW.%s" + StateJobCompleteSendMessage
	// WorkflowJobSendMessageExecute is the state message subject for executing a send workfloe message task.
	WorkflowJobSendMessageExecute = "WORKFLOW.%s" + StateJobExecute + "SendMessage"
	// WorkflowJobSendMessageExecuteWild is the wildcard state message subject for executing a send workfloe message task.
	WorkflowJobSendMessageExecuteWild = "WORKFLOW.%s" + StateJobExecute + "SendMessage.>"
	// WorkflowJobServiceTaskAbort is the state message subject for aborting an in progress service task.
	WorkflowJobServiceTaskAbort = "WORKFLOW.%s" + StateJobAbortServiceTask
	// WorkflowJobServiceTaskComplete is the state message subject for a completed service task,
	WorkflowJobServiceTaskComplete = "WORKFLOW.%s" + StateJobCompleteServiceTask
	// WorkflowJobServiceTaskExecute is the raw state message subject for executing a service task.  An identifier is added to the end to route messages to the clients.
	WorkflowJobServiceTaskExecute = "WORKFLOW.%s" + StateJobExecute + "ServiceTask"
	// WorkflowJobServiceTaskExecuteWild is the wildcard state message subject for all execute service task messages.
	WorkflowJobServiceTaskExecuteWild = "WORKFLOW.%s" + StateJobExecute + "ServiceTask.>"
	// WorkflowJobServiceTaskSetExecuteWild is the state message subject for service tasks that are a part of a service task set
	WorkflowJobServiceTaskSetExecuteWild = "WORKFLOW.%s" + StateJobExecute + "Set.%s.ServiceTask.%s"
	// WorkflowJobTimerTaskComplete is the state message subject for completing a timed task.
	WorkflowJobTimerTaskComplete = "WORKFLOW.%s.State.Job.Complete.Timer"
	// WorkflowJobTimerTaskExecute is the state message subject for executing a timed task.
	WorkflowJobTimerTaskExecute = "WORKFLOW.%s" + StateJobExecute + "Timer"
	// WorkflowJobUserTaskAbort is the state message subject for aborting a user task.
	WorkflowJobUserTaskAbort = "WORKFLOW.%s.State.Job.Abort.UserTask"
	// WorkflowJobUserTaskComplete is the state message subject for completing a user task.
	WorkflowJobUserTaskComplete = "WORKFLOW.%s" + StateJobCompleteUserTask
	// WorkflowJobUserTaskExecute is the state message subject for executing a user task.
	WorkflowJobUserTaskExecute = "WORKFLOW.%s" + StateJobExecute + "UserTask"
	// WorkflowJobGatewayTaskComplete is the state message subject for completing a gateway task.
	WorkflowJobGatewayTaskComplete = "WORKFLOW.%s.State.Job.Complete.Gateway"
	// WorkflowJobGatewayTaskExecute is the state message subject for executing a gateway task.
	WorkflowJobGatewayTaskExecute = "WORKFLOW.%s" + StateJobExecute + "Gateway"
	// WorkflowJobGatewayTaskActivate is the state message subject for activating a gateway task for creation or re-entry.
	WorkflowJobGatewayTaskActivate = "WORKFLOW.%s.State.Job.Activate.Gateway"
	// WorkflowJobGatewayTaskReEnter is the state message subject for re entering an existing gateway task.
	WorkflowJobGatewayTaskReEnter = "WORKFLOW.%s.State.Job.ReEnter.Gateway"
	// WorkflowJobGatewayTaskAbort is the state message subject for aborting a gateway task.
	WorkflowJobGatewayTaskAbort = "WORKFLOW.%s" + StateJobAbortGateway
	// WorkflowJobGatewayTaskAwait is the state message subject for waiting for all branches of a convergent gateway task.
	WorkflowJobGatewayTaskAwait = "WORKFLOW.%s" + StateJobAwaitGateway
	//WorkflowActivityRetry is the state message to attempt retry of a prior failed activity (initially a servicetask/job)
	WorkflowActivityRetry = "WORKFLOW.%s.State.Activity.Retry"
	// WorkflowLog is the state message subject for logging messages to a workflow activity.
	WorkflowLog = "WORKFLOW.%s" + StateLog
	// WorkflowLogAll is the wildcard state message subject for all logging messages.
	WorkflowLogAll = "WORKFLOW.%s" + StateLog + ".*"
	// WorkflowMessage is the state message subject for all workflow messages.
	WorkflowMessage = "WORKFLOW.%s.Message"
	// WorkflowProcessComplete is the state message subject for completing a workfloe process.
	WorkflowProcessComplete = "WORKFLOW.%s" + StateProcessComplete
	// WorkflowProcessExecute is the state message subject for executing a workflow process.
	WorkflowProcessExecute = "WORKFLOW.%s" + StateProcessExecute
	// WorkflowProcessAbort is the state message subject for aborting a workflow process.
	WorkflowProcessAbort = "WORKFLOW.%s" + StateProcessAbort
	// WorkflowProcessTerminated is the state message subject for a workflow process terminating.
	WorkflowProcessTerminated = "WORKFLOW.%s" + StateProcessTerminated
	// WorkflowProcessCompensate is the state message subject for a workflow compensation event.
	WorkflowProcessCompensate = "WORKFLOW.%s.State.Process.Compensate"
	// WorkflowStateAll is the wildcard subject for catching all state messages.
	WorkflowStateAll = "WORKFLOW.%s.State.>"
	// WorkflowTimedExecute is the state message subject for timed workflow execute operation.
	WorkflowTimedExecute = "WORKFLOW.%s.Timers.WorkflowExecute"
	// WorkflowTraversalComplete is the state message subject for completing a traversal.
	WorkflowTraversalComplete = "WORKFLOW.%s" + StateTraversalComplete
	// WorkflowTraversalExecute is the state message subject for executing a new traversal.
	WorkflowTraversalExecute = "WORKFLOW.%s" + StateTraversalExecute

	// WorkflowSystemTaskCreate is the task created broadcast message.
	WorkflowSystemTaskCreate = "WORKFLOW.%s.System.Task.Create"
	// WorkflowSystemTaskUpdate is the task updated broadcast message.
	WorkflowSystemTaskUpdate = "WORKFLOW.%s.System.Task.Update"
	// WorkflowSystemTaskPause is the task paused broadcast message.
	WorkflowSystemTaskPause = "WORKFLOW.%s.System.Task.Pause"
	// WorkflowSystemTaskResume is the task resumed broadcast message.
	WorkflowSystemTaskResume = "WORKFLOW.%s.System.Task.Resume"
	// WorkflowSystemProcessCreate is the process Create broadcast message.
	WorkflowSystemProcessCreate = "WORKFLOW.%s.System.ProcessInstance.Create"
	// WorkflowSystemProcessPause is the process paused broadcast message.
	WorkflowSystemProcessPause = "WORKFLOW.%s.System.Process.Pause"
	// WorkflowSystemProcessError is the process error broadcast message.
	WorkflowSystemProcessError = "WORKFLOW.%s.System.Process.Error"
	// WorkflowSystemWorkflowDisableLaunchAttempted is the disabled Workflow launch attempted broadcast message.
	WorkflowSystemWorkflowDisableLaunchAttempted = "WORKFLOW.%s.System.Workflow.DisableLaunchAttempted"
	// WorkflowSystemHistoryArchive is the archive message for history items.
	WorkflowSystemHistoryArchive = "WORKFLOW.%s.System.History.Archive"
	// WorkflowSystemProcessFatalError is the process fatal error broadcast message.
	WorkflowSystemProcessFatalError = "WORKFLOW.%s.System.Process.FatalError"
)
View Source 
const (
	// WorkflowTelemetryClientCount is the message subject for workflow client count telemetry.
	WorkflowTelemetryClientCount = "WORKFLOW_TELEMETRY.Client.Count"
	// WorkflowTelemetryLog is the message subject for telemetry logging.
	WorkflowTelemetryLog = "WORKFLOW_TELEMETRY.Log"
)
View Source 
const (
	// APIAll is all API message subjects.
	APIAll = "WORKFLOW.Api.*"
	// APIStoreWorkflow is the store Workflow API subject.
	APIStoreWorkflow = "WORKFLOW.Api.StoreWorkflow"
	// APILaunchProcess is the launch process API subject.
	APILaunchProcess = "WORKFLOW.Api.LaunchProcess"
	// APIListWorkflows is the list workflows API subject.
	APIListWorkflows = "WORKFLOW.Api.ListWorkflows"
	// APIListExecution is the list workflow instances API subject.
	APIListExecution = "WORKFLOW.Api.ListExecution"
	// APIListExecutionProcesses is the get processes of a running workflow instance API subject.
	APIListExecutionProcesses = "WORKFLOW.Api.ListExecutionProcesses"
	// APICancelExecution is the cancel an execution API subject.
	APICancelExecution = "WORKFLOW.Api.CancelExecution"
	// APISendMessage is the send workflow message API subject.
	APISendMessage = "WORKFLOW.Api.SendMessage"
	// APICancelProcessInstance is the cancel process instance API message subject.
	APICancelProcessInstance = "WORKFLOW.API.CancelProcessInstance"
	// APICompleteManualTask is the complete manual task API subject.
	APICompleteManualTask = "WORKFLOW.Api.CompleteManualTask"
	// APICompleteServiceTask is the complete service task API subject.
	APICompleteServiceTask = "WORKFLOW.Api.CompleteServiceTask"
	// APICompleteUserTask is the complete user task API subject.
	APICompleteUserTask = "WORKFLOW.Api.CompleteUserTask"
	// APICompleteSendMessageTask is the complete send message task API subject.
	APICompleteSendMessageTask = "WORKFLOW.Api.CompleteSendMessageTask"
	// APIDeprecateServiceTask is the deprecate service task API subject.
	APIDeprecateServiceTask = "WORKFLOW.Api.DeprecateServiceTask"
	// APIListExecutableProcess is the list executable process API subject.
	APIListExecutableProcess = "WORKFLOW.Api.APIListExecutableProcess"
	// APIListUserTasks is the list user tasks API subject.
	APIListUserTasks = "WORKFLOW.Api.ListUserTasks"
	// APIOpenUserTask is the endpoint for locking a user task and retrieving its specification and state.
	APIOpenUserTask = "WORKFLOW.Api.OpenUserTask"
	// APIGetUserTask is the get user task API subject.
	APIGetUserTask = "WORKFLOW.Api.GetUserTask"
	// APIGetTaskSpecVersions is the get task versions API subject.
	APIGetTaskSpecVersions = "WORKFLOW.Api.GetTaskSpecVersions"
	// APIHandleWorkflowError is the handle workflow error API subject.
	APIHandleWorkflowError = "WORKFLOW.Api.HandleWorkflowError"
	// APIHandleWorkflowFatalError is the handle workflow fatal error API subject.
	APIHandleWorkflowFatalError = "WORKFLOW.Api.HandleWorkflowFatalError"
	// APIRegisterTask registers a task with SHAR and returns the id.  If the task already exists then the ID is returned of the existing task.
	APIRegisterTask = "Workflow.Api.RegisterTask"
	// APIGetProcessInstanceStatus is the get process instance status API subject.
	APIGetProcessInstanceStatus = "WORKFLOW.Api.GetProcessInstanceStatus"
	// APIGetTaskSpec is the get task spec API message subject.
	APIGetTaskSpec = "WORKFLOW.Api.GetTaskSpec"
	// APIGetWorkflowVersions is the get workflow versions API message subject.
	APIGetWorkflowVersions = "WORKFLOW.Api.StreamWorkflowVersions"
	// APIGetWorkflow is the get workflow API message subject.
	APIGetWorkflow = "WORKFLOW.Api.GetWorkflow"
	// APIGetProcessHistory is the get process history API message subject.
	APIGetProcessHistory = "WORKFLOW.Api.GetProcessHistory"
	// APIGetProcessInstanceHeaders is the get process instance headers API message subject.
	APIGetProcessInstanceHeaders = "WORKFLOW.Api.GetProcessInstanceHeaders"
	// APIDisableWorkflow is the disable workflow API message subject.
	APIDisableWorkflow = "WORKFLOW.Api.APIDisableWorkflow"
	// APIEnableWorkflow is the enable workflow API message subject.
	APIEnableWorkflow = "WORKFLOW.Api.APIEnableWorkflow"
	// APIPauseServiceTask is the pause service task API message subject.
	APIPauseServiceTask = "WORKFLOW.Api.APIPauseServiceTask"
	// APIResumeServiceTask is the resume service task API message subject.
	APIResumeServiceTask = "WORKFLOW.Api.APIResumeServiceTask"
	// APIGetVersionInfo is the get server version information API message subject.
	APIGetVersionInfo = "WORKFLOW.API.GetVersionInfo"
	// APIGetTaskSpecUsage is the get task spec usage API message subject.
	APIGetTaskSpecUsage = "WORKFLOW.Api.GetTaskSpecUsage"
	// APIListTaskSpecUIDs is the list task spec UIDs API message subject.
	APIListTaskSpecUIDs = "WORKFLOW.Api.ListTaskSpecUIDs"
	//APIGetFatalErrors gets fatal errors given a key prefix to search against
	APIGetFatalErrors = "WORKFLOW.Api.GetFatalErrors"
	// APIHeartbeat // is the heartbeat API message subject.
	APIHeartbeat = "WORKFLOW.Api.Heartbeat"
	// APILog // is the client logging message subject.
	APILog = "WORKFLOW.Api.Log"
	// APIGetJob is the get job API subject.
	APIGetJob = "WORKFLOW.Api.GetJob"
	// APIResolveWorkflow is the resolve workflow API subject.
	APIResolveWorkflow = "WORKFLOW.Api.ResolveWorkflow"
	// APIGetCompensationInputVariables is the get compensation input variables message subject.
	APIGetCompensationInputVariables = "WORKFLOW.Api.GetCompensationInputVariables"
	// APIGetCompensationOutputVariables is the get compensation output variables message subject.
	APIGetCompensationOutputVariables = "WORKFLOW.Api.GetCompensationOutputVariables"
	// APIRetry attempts to execute a previously failed activity again
	APIRetry = "WORKFLOW.Api.Retry"
	// ApiSaveUserTask represents the constant for saving user task state.
	ApiSaveUserTask = "WORKFLOW.Api.SaveUserTask"
)
View Source 
const (
	// WorkflowTelemetryTimer is the message subject for triggering telemetry messages from the server.
	WorkflowTelemetryTimer = "WORKFLOW.Message.Telemetry"
)

Variables

View Source 
var (
	// KvJob is the name of the key value store that holds workflow jobs.
	KvJob = "WORKFLOW_JOB"
	// KvVersion is the name of the key value store that holds an ordered list of workflow version IDs for a given workflow
	KvVersion = "WORKFLOW_VERSION"
	// KvDefinition is the name of the key value store that holds the state machine definition for workflows
	KvDefinition = "WORKFLOW_DEF"
	// KvTelemetry is the name of the key value store that holds open workflow telemetry spans until they are completed.
	KvTelemetry = "WORKFLOW_TELEM"
	// KvInstance is the name of the key value store that holds workflow instance information.
	KvInstance = "WORKFLOW_INSTANCE"
	// KvExecution is the name of the key value store that holds execution information.
	KvExecution = "WORKFLOW_EXECUTION"
	// KvUserTask is the name of the key value store that holds active user tasks.
	KvUserTask = "WORKFLOW_USERTASK"
	// KvOwnerName is the name of the key value store that holds owner names for owner IDs
	KvOwnerName = "WORKFLOW_OWNERNAME"
	// KvOwnerID is the name of the key value store that holds owner IDs for owner names.
	KvOwnerID = "WORKFLOW_OWNERID"
	// KvClientTaskID is the name of the key value store that holds the unique ID used by clients to subscribe to service task messages.
	KvClientTaskID = "WORKFLOW_CLIENTTASK"
	// KvProcessInstance is the name of the key value store holding process instances.
	KvProcessInstance = "WORKFLOW_PROCESS"
	// KvGateway is the name of the key value store holding gateway instances.
	KvGateway = "WORKFLOW_GATEWAY"
	// KvLock is the name of the key value store holding locks.
	KvLock = "WORKFLOW_GENLCK"
	// KvMessageTypes is the name of the key value store containing known message types.
	KvMessageTypes = "WORKFLOW_MSGTYPES"
	// KvTaskSpecVersions is the name of the key value store holding task specification versions.
	KvTaskSpecVersions = "WORKFLOW_TSPECVER"
	// KvTaskSpec is the name of the key value store holding task specification.
	KvTaskSpec = "WORKFLOW_TSKSPEC"
	// KvProcess is the name of the key value store mapping process names to workflow names.
	KvProcess = "WORKFLOW_PROCESS_MAPPING"
	// KvMessages is the name of the key value store containing messages.
	KvMessages = "WORKFLOW_MESSAGES"
	// KvClients is the name of the key value store containing connected clients.
	KvClients = "WORKFLOW_CLIENTS"
	// KvFatalError is the name of the key value store containing fatal errs.
	KvFatalError = "WORKFLOW_FATAL_ERROR"
	// KvUserTaskState represents the state of a user task within a workflow.
	KvUserTaskState = "WORKFLOW_TASK_STATE"
	// KvWorkflowHistory is the key value containing history
	KvWorkflowHistory = "WORKFLOW_HISTORY"
)
View Source 
var AllMessages = []string{

	subj.NS(WorkflowSystemTaskCreate, "*"),
	subj.NS(WorkflowSystemTaskUpdate, "*"),
	subj.NS(WorkflowSystemProcessPause, "*"),
	subj.NS(WorkflowSystemProcessError, "*"),

	subj.NS(WorkFlowJobAbortAll, "*"),
	subj.NS(WorkFlowJobCompleteAll, "*"),
	subj.NS(WorkflowActivityAbort, "*"),
	subj.NS(WorkflowActivityComplete, "*"),
	subj.NS(WorkflowActivityExecute, "*"),
	subj.NS(WorkflowCommands, "*"),
	subj.NS(WorkflowElementTimedExecute, "*"),
	subj.NS(WorkflowExecutionAll, "*"),
	subj.NS(WorkflowJobAwaitMessageExecute, "*"),
	subj.NS(WorkflowJobLaunchExecute, "*"),
	subj.NS(WorkflowJobManualTaskExecute, "*"),
	subj.NS(WorkflowJobSendMessageExecuteWild, "*"),
	subj.NS(WorkflowJobServiceTaskExecuteWild, "*"),
	subj.NS(WorkflowJobGatewayTaskExecute, "*"),
	subj.NS(WorkflowJobTimerTaskExecute, "*"),
	subj.NS(WorkflowJobUserTaskExecute, "*"),
	subj.NS(WorkflowLogAll, "*"),
	subj.NS(WorkflowMessage, "*"),
	subj.NS(WorkflowProcessComplete, "*"),
	subj.NS(WorkflowProcessAbort, "*"),
	subj.NS(WorkflowProcessExecute, "*"),
	subj.NS(WorkflowProcessTerminated, "*"),
	subj.NS(WorkflowProcessCompensate, "*"),
	subj.NS(WorkflowTimedExecute, "*"),
	subj.NS(WorkflowTraversalComplete, "*"),
	subj.NS(WorkflowTraversalExecute, "*"),
	subj.NS(WorkflowJobGatewayTaskActivate, "*"),
	subj.NS(WorkflowJobGatewayTaskReEnter, "*"),
	WorkflowTelemetryTimer,
	"WORKFLOW.*.Compensate.*",
	"$JS.EVENT.ADVISORY.CONSUMER.MAX_DELIVERIES.WORKFLOW.>",
}

AllMessages provides the list of subscriptions for the WORKFLOW stream.

View Source 
var LogLevels = []WorkflowLogLevel{
	LogFatal,
	LogError,
	LogWarn,
	LogInfo,
	LogDebug,
}

LogLevels provides a way of using an index to select a log level.

View Source 
var WorkflowMessageFormat = "WORKFLOW.%s.Message.%s"

WorkflowMessageFormat provides the template for sending workflow messages.

Functions

This section is empty.

Types

type WorkflowLogLevel added in v1.0.271 

type WorkflowLogLevel string

WorkflowLogLevel represents a subject suffix for logging levels 

const (
	// LogFatal is the suffix for a fatal error.
	LogFatal WorkflowLogLevel = ".Fatal"
	// LogError is the suffix for an error.
	LogError WorkflowLogLevel = ".Error"
	// LogWarn is the suffix for a warning.
	LogWarn WorkflowLogLevel = ".Warning"
	// LogInfo is the suffix for an information message.
	LogInfo WorkflowLogLevel = ".Info"
	// LogDebug is the suffix for a debug message.
	LogDebug WorkflowLogLevel = ".Debug"
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.