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 ParentAdapter
- func (*ParentAdapter) CollectOutboundChannels() []channel.Outbound
- func (p *ParentAdapter) GetEnvironmentId() uuid.Array
- func (i *ParentAdapter) GetParent() Updatable
- func (*ParentAdapter) GetPath() string
- 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
Constants ¶
View Source
const ( PATH_SEPARATOR = "." PATH_SEPARATOR_RUNE = '.' )
View Source
const (
ConfigBasePath = "o2/control/workflows"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GetEnvIdFunc ¶
type ParentAdapter ¶
type ParentAdapter struct {
// contains filtered or unexported fields
}
func NewParentAdapter ¶
func NewParentAdapter(getEnvId GetEnvIdFunc) *ParentAdapter
func (*ParentAdapter) CollectOutboundChannels ¶
func (*ParentAdapter) CollectOutboundChannels() []channel.Outbound
func (*ParentAdapter) GetEnvironmentId ¶
func (p *ParentAdapter) GetEnvironmentId() uuid.Array
func (*ParentAdapter) GetParent ¶
func (i *ParentAdapter) GetParent() Updatable
func (*ParentAdapter) GetPath ¶
func (*ParentAdapter) GetPath() string
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 {
GetParent() Updatable
GetParentRole() Role
GetRoles() []Role
GetPath() string
GetName() string
GetStatus() task.Status
GetState() task.State
GetTasks() []*task.Task
GenerateTaskDescriptors() task.Descriptors
ProcessTemplates() error
GlobFilter(g glob.Glob) []Role
// contains filtered or unexported methods
}
func Load ¶
func Load(cfg configuration.Configuration, workflowPath string, parent Updatable) (workflow Role, err error)
FIXME: workflowPath should be of type configuration.Path, not string
type SafeStatus ¶
type SafeStatus struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.