sandbox

Documentation

Index

• type Flow
  • func (f Flow) AsRoot() *ScopedFlow
  • func (f Flow) BuildStackUntil(components []string) (*Stack, error)
  • func (f Flow) FindExprAtPath(path string) (*ScopedFlow, error)
  • func (f Flow) FindFlowByPathComponents(components []string) (*ScopedFlow, error)
  • func (f Flow) GetName() string
• type FlowRun
• type FlowRunParams
• type Input
• type Resolver
• type Scope
  • func NewScope(tasksInScope []*ScopedFlow) *Scope
  • func (s Scope) FindFlowAtPath(path string) (*ScopedFlow, error)
  • func (s *Scope) String() string
• type ScopedFlow
  • func NewScopedFlow(stack *Stack) *ScopedFlow
  • func (e ScopedFlow) Current() *Flow
  • func (e ScopedFlow) FindFlowByPathComponents(components []string) (*ScopedFlow, error)
  • func (e ScopedFlow) GetName() string
  • func (e ScopedFlow) Path() string
  • func (e ScopedFlow) Scope() *Scope
  • func (e ScopedFlow) ScopeInString() string
  • func (e ScopedFlow) String() string
• type Stack
  • func NewStackFromTasks(f ...*Flow) *Stack
  • func (s *Stack) Concat(other *Stack) *Stack
  • func (s *Stack) FromBottom() []*Flow
  • func (s *Stack) Pop() (*Stack, *Flow)
  • func (s *Stack) Push(flow *Flow) *Stack
  • func (s *Stack) PushMulti(tasks []*Flow) *Stack
  • func (s *Stack) Size() int
  • func (s *Stack) Top() *Flow
• type StepRunContext
• type StepRunParams

Types

type Flow

type Flow struct {
	Name   string  `yaml:"name,omitempty"`
	Inputs []Input `yaml:"inputs,omitempty"`
	// i.e. symbol table
	Tasks  []Flow            `yaml:"tasks,omitempty"`
	Script string            `yaml:"script,omitempty"`
	Env    map[string]string `yaml:"env,omitempty"`
}

func (Flow) AsRoot

func (f Flow) AsRoot() *ScopedFlow

func (Flow) BuildStackUntil

func (f Flow) BuildStackUntil(components []string) (*Stack, error)

func (Flow) FindExprAtPath

func (f Flow) FindExprAtPath(path string) (*ScopedFlow, error)

func (Flow) FindFlowByPathComponents

func (f Flow) FindFlowByPathComponents(components []string) (*ScopedFlow, error)

func (Flow) GetName

func (f Flow) GetName() string

type FlowRun

type FlowRun struct {
	Target Flow
	Params FlowRunParams
}

type FlowRunParams

type FlowRunParams struct {
	Caller *Flow
}

type Input

type Input struct {
	Name string `yaml:"name,omitempty"`
}

type Resolver

type Resolver interface {
	GetName() string
	FindExprAtPath(path string) (*ScopedFlow, error)
}

type Scope

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

func NewScope

func NewScope(tasksInScope []*ScopedFlow) *Scope

func (Scope) FindFlowAtPath

func (s Scope) FindFlowAtPath(path string) (*ScopedFlow, error)

func (*Scope) String

func (s *Scope) String() string

type ScopedFlow

type ScopedFlow struct {
	Stack *Stack
}

func NewScopedFlow

func NewScopedFlow(stack *Stack) *ScopedFlow

func (ScopedFlow) Current

func (e ScopedFlow) Current() *Flow

func (ScopedFlow) FindFlowByPathComponents

func (e ScopedFlow) FindFlowByPathComponents(components []string) (*ScopedFlow, error)

func (ScopedFlow) GetName

func (e ScopedFlow) GetName() string

func (ScopedFlow) Path

func (e ScopedFlow) Path() string

func (ScopedFlow) Scope

func (e ScopedFlow) Scope() *Scope

func (ScopedFlow) ScopeInString

func (e ScopedFlow) ScopeInString() string

func (ScopedFlow) String

func (e ScopedFlow) String() string

type Stack

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

func NewStackFromTasks

func NewStackFromTasks(f ...*Flow) *Stack

func (*Stack) Concat

func (s *Stack) Concat(other *Stack) *Stack

func (*Stack) FromBottom

func (s *Stack) FromBottom() []*Flow

func (*Stack) Pop

func (s *Stack) Pop() (*Stack, *Flow)

func (*Stack) Push

func (s *Stack) Push(flow *Flow) *Stack

func (*Stack) PushMulti

func (s *Stack) PushMulti(tasks []*Flow) *Stack

func (*Stack) Size

func (s *Stack) Size() int

func (*Stack) Top

func (s *Stack) Top() *Flow

type StepRunContext

type StepRunContext struct {
	FlowRun FlowRun
}

type StepRunParams

type StepRunParams struct {
	Context StepRunContext
}