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 (*ParentAdapter) CollectInboundChannels() []channel.Inbound
- 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
- type SafeState
- type SafeStatus
- type Updatable
- type VarNode
Constants ¶
View Source
const ( PATH_SEPARATOR = "." PATH_SEPARATOR_RUNE = '.' )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GetEnvIdFunc ¶
type GetStringMapFunc ¶ added in v0.12.90
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) CollectInboundChannels ¶ added in v0.13.90
func (*ParentAdapter) CollectInboundChannels() []channel.Inbound
func (*ParentAdapter) CollectOutboundChannels ¶
func (*ParentAdapter) CollectOutboundChannels() []channel.Outbound
func (*ParentAdapter) GetDefaults ¶ added in v0.12.90
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 ¶ added in v0.12.90
func (p *ParentAdapter) GetUserVars() gera.StringMap
func (*ParentAdapter) GetVars ¶ added in v0.12.90
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
}
type SafeStatus ¶
type SafeStatus struct {
// contains filtered or unexported fields
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.