constants

Documentation

Index

• Constants
• type QueueType
• type TaskType

Constants

const (
	// QueueTypeInMemory in memory queue type
	QueueTypeInMemory = "in-memory"
	// QueueTypeEventMesh EventMesh queue
	QueueTypeEventMesh = "eventmesh"
)

const (
	TaskStartID   = "START"
	TaskEndID     = "END"
	NormalStatus  = 1
	InvalidStatus = -1
)

const (
	TaskInstanceSleepStatus   = 1
	TaskInstanceWaitStatus    = 2
	TaskInstanceProcessStatus = 3
	TaskInstanceSuccessStatus = 4
	TaskInstanceFailStatus    = 5
)

task instance status

const (
	WorkflowInstanceProcessStatus = 1
	WorkflowInstanceSuccessStatus = 2
)

workflow instance status

const (
	LogSchedule = "schedule"
	LogQueue    = "queue"
)

log name

const (
	TaskTypeOperation = "operation"
	TaskTypeEvent     = "event"
	TaskTypeSwitch    = "switch"
)

const (
	EventTypePublish                 = "publish"
	EventPropsWorkflowInstanceID     = "workflowinstanceid"
	EventPropsWorkflowTaskInstanceID = "workflowtaskinstanceid"
)

const (
	MetricsEventTask     = "event_task"
	MetricsOperationTask = "operation_task"
	MetricsSwitchTask    = "switch_task"
	MetricsScheduler     = "scheduler"
	MetricsEngine        = "engine"
	MetricsTaskQueue     = "task_queue"
)

Metrics Collector types

const (
	MetricsTotal        = "total"
	MetricsSwitchReject = "reject"
	MetricsSwitchPass   = "pass"

	MetricsStartRequest      = "start_request"
	MetricsTransitionRequest = "transition_request"

	MetricsDbLockAcquireTime = "db_lock_acquire_time"
	MetricsQueueSize         = "queue_size"
)

Metrics labels

const (
	// RetryAttempts fail retry max times
	RetryAttempts = 5
)

Types

type QueueType

type QueueType int

type TaskType

type TaskType int