workflow

type GetCurrentRunNumberFunc func() uint32

type GetEnvIdFunc func() uid.ID

type GetStringMapFunc func() gera.StringMap

type LoadSubworkflowFunc func(workflowPathExpr string, parent Updatable) (root *aggregatorRole, workflowRepo repos.IRepo, err error)

type ParentAdapter struct {
	SendEvents SendEvents
	// contains filtered or unexported fields
}

type PublicUpdatable interface {
	UpdateStatus(s task.Status)
	UpdateState(s task.State)
}

type Role interface {
	VarNode
	GetParent() Updatable
	GetParentRole() Role
	GetRootRole() Role
	GetRoles() []Role
	GetPath() string
	GetName() string
	GetStatus() task.Status
	GetState() task.State
	GetTasks() task.Tasks
	GetTaskClasses() []string
	GenerateTaskDescriptors() task.Descriptors

	ProcessTemplates(workflowRepo repos.IRepo, loadSubworkflow LoadSubworkflowFunc) error
	GlobFilter(g glob.Glob) []Role
	SetRuntimeVar(key string, value string)
	SetRuntimeVars(kv map[string]string)
	GetHooksMapForTrigger(trigger string) callable.HooksMap
	GetAllHooks() callable.Hooks
	IsEnabled() bool
	GetCurrentRunNumber() uint32
	ConsolidatedVarStack() (varStack map[string]string, err error)
	GetEnvironmentId() uid.ID
	// contains filtered or unexported methods
}

type SafeState struct {
	// contains filtered or unexported fields
}

type SafeStatus struct {
	// contains filtered or unexported fields
}

type SendEvents func(event.Event)

type Updatable interface {
	VarNode
	GetParent() Updatable

	GetEnvironmentId() uid.ID
	GetPath() string
	CollectOutboundChannels() []channel.Outbound
	CollectInboundChannels() []channel.Inbound
	SendEvent(event.Event)
	GetCurrentRunNumber() uint32
	// contains filtered or unexported methods
}

type VarNode interface {
	GetDefaults() gera.StringMap
	GetVars() gera.StringMap
	GetUserVars() gera.StringMap
}