Help us shape the future of Go! Take the 2026 Go Developer Survey

core

package
v1.1.7 Latest Latest
Warning

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

Go to latest
Published: Apr 6, 2025 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source
const (
	QueueDefault = Queue("default")
	QueueSystem  = Queue("_system_")
)

Variables

This section is empty.

Functions

func ValidQueue

func ValidQueue(q Queue) error

ValidQueue ensures that the queue name is valid.

Types

type Queue

type Queue string

func (*Queue) Scan

func (q *Queue) Scan(value interface{}) error

func (Queue) Value

func (q Queue) Value() (string, error)

type WorkflowInstance

type WorkflowInstance struct {
	// InstanceID is the ID of the workflow instance.
	InstanceID string `json:"instance_id,omitempty"`

	// ExecutionID is the ID of the current execution of the workflow instance.
	ExecutionID string `json:"execution_id,omitempty"`

	// Parent refers to the parent workflow instance if this instance is a sub-workflow.
	Parent *WorkflowInstance `json:"parent,omitempty"`

	// ParentEventID is the ID of the event in the parent workflow that started this sub-workflow.
	ParentEventID int64 `json:"parent_event_id,omitempty"`
}

func NewSubWorkflowInstance

func NewSubWorkflowInstance(instanceID, executionID string, parentInstance *WorkflowInstance, parentEventID int64) *WorkflowInstance

func NewWorkflowInstance

func NewWorkflowInstance(instanceID, executionID string) *WorkflowInstance

func (*WorkflowInstance) SubWorkflow

func (wi *WorkflowInstance) SubWorkflow() bool

type WorkflowInstanceState

type WorkflowInstanceState int
const (
	WorkflowInstanceStateActive WorkflowInstanceState = iota
	WorkflowInstanceStateContinuedAsNew
	WorkflowInstanceStateFinished
)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL