workflow

Documentation

Overview

Package workflow defines the Role interface, along with tooling to build the control tree. A workflow is a tree of Roles, and it's loaded from Configuration with a combination of YAML unmarshaling and Go template execution.

Index

• Constants
• type GetEnvIdFunc
• type GetStringMapFunc
• type ParentAdapter
  • func NewParentAdapter(getEnvId GetEnvIdFunc, getDefaults GetStringMapFunc, getVars GetStringMapFunc, ...) *ParentAdapter
  • func (*ParentAdapter) CollectOutboundChannels() []channel.Outbound
  • func (p *ParentAdapter) GetDefaults() gera.StringMap
  • func (p *ParentAdapter) GetEnvironmentId() uuid.Array
  • func (p *ParentAdapter) GetParent() Updatable
  • func (*ParentAdapter) GetPath() string
  • func (p *ParentAdapter) GetUserVars() gera.StringMap
  • func (p *ParentAdapter) GetVars() gera.StringMap
  • func (p *ParentAdapter) SubscribeToStateChange(subscriptionId string, c chan task.State)
  • func (p *ParentAdapter) SubscribeToStatusChange(subscriptionId string, c chan task.Status)
  • func (p *ParentAdapter) UnsubscribeFromStateChange(subscriptionId string)
  • func (p *ParentAdapter) UnsubscribeFromStatusChange(subscriptionId string)
• type Role
  • func Load(workflowPath string, parent Updatable, taskManager *task.Manager, ...) (workflow Role, err error)
• type SafeState
• type SafeStatus
• type Updatable
• type VarNode

Constants

const (
	PATH_SEPARATOR      = "."
	PATH_SEPARATOR_RUNE = '.'
)

const (
	ConfigBasePath = "o2/control/workflows"
)

Types

type GetEnvIdFunc

type GetEnvIdFunc func() uuid.Array

type GetStringMapFunc

type GetStringMapFunc func() gera.StringMap

type ParentAdapter

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

func NewParentAdapter

func NewParentAdapter(getEnvId GetEnvIdFunc,
	getDefaults GetStringMapFunc,
	getVars GetStringMapFunc,
	getUserVars GetStringMapFunc) *ParentAdapter

func (*ParentAdapter) CollectOutboundChannels

func (*ParentAdapter) CollectOutboundChannels() []channel.Outbound

func (*ParentAdapter) GetDefaults

func (p *ParentAdapter) GetDefaults() gera.StringMap

func (*ParentAdapter) GetEnvironmentId

func (p *ParentAdapter) GetEnvironmentId() uuid.Array

func (*ParentAdapter) GetParent

func (p *ParentAdapter) GetParent() Updatable

func (*ParentAdapter) GetPath

func (*ParentAdapter) GetPath() string

func (*ParentAdapter) GetUserVars

func (p *ParentAdapter) GetUserVars() gera.StringMap

func (*ParentAdapter) GetVars

func (p *ParentAdapter) GetVars() gera.StringMap

func (*ParentAdapter) SubscribeToStateChange

func (p *ParentAdapter) SubscribeToStateChange(subscriptionId string, c chan task.State)

func (*ParentAdapter) SubscribeToStatusChange

func (p *ParentAdapter) SubscribeToStatusChange(subscriptionId string, c chan task.Status)

func (*ParentAdapter) UnsubscribeFromStateChange

func (p *ParentAdapter) UnsubscribeFromStateChange(subscriptionId string)

func (*ParentAdapter) UnsubscribeFromStatusChange

func (p *ParentAdapter) UnsubscribeFromStatusChange(subscriptionId string)

type Role

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

	ProcessTemplates(workflowRepo *repos.Repo) error
	GlobFilter(g glob.Glob) []Role
	SetRuntimeVar(key string, value string)
	SetRuntimeVars(kv map[string]string)
	// contains filtered or unexported methods
}

func Load

func Load(workflowPath string, parent Updatable, taskManager *task.Manager, userProperties map[string]string) (workflow Role, err error)

FIXME: workflowPath should be of type configuration.Path, not string

type SafeState

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

type SafeStatus

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

type Updatable

type Updatable interface {
	VarNode
	GetParent() Updatable

	GetEnvironmentId() uuid.Array
	GetPath() string
	CollectOutboundChannels() []channel.Outbound
	// contains filtered or unexported methods
}

type VarNode

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