callable

Documentation

Index

• func AcquireTimeout(defaultTimeout time.Duration, varStack map[string]string, callName string, ...) time.Duration
• type Call
  • func NewCall(funcCall string, returnVar string, parent ParentRole) (call *Call)
  • func (c *Call) Await() error
  • func (c *Call) Call() error
  • func (c *Call) GetName() string
  • func (c *Call) GetParentRole() interface{}
  • func (c *Call) GetParentRolePath() string
  • func (c *Call) GetTraits() task.Traits
  • func (c *Call) Start()
• type Calls
  • func (s Calls) AwaitAll() map[*Call]error
  • func (s Calls) CallAll() map[*Call]error
  • func (s Calls) StartAll()
• type CallsMap
  • func (m CallsMap) GetWeights() []HookWeight
• type Hook
• type HookWeight
  • func ParseTriggerExpression(triggerExpr string) (triggerName string, triggerWeight HookWeight)
• type Hooks
  • func (s Hooks) FilterCalls() (calls Calls)
  • func (s Hooks) FilterTasks() (tasks task.Tasks)
• type HooksMap
  • func (m HooksMap) GetWeights() []HookWeight
• type ParentRole

Functions

func AcquireTimeout

func AcquireTimeout(defaultTimeout time.Duration, varStack map[string]string, callName string, envId string) time.Duration

Types

type Call

type Call struct {
	Func     string
	Return   string
	VarStack map[string]string
	Traits   task.Traits
	// contains filtered or unexported fields
}

func NewCall

func NewCall(funcCall string, returnVar string, parent ParentRole) (call *Call)

func (*Call) Await

func (c *Call) Await() error

func (*Call) Call

func (c *Call) Call() error

func (*Call) GetName

func (c *Call) GetName() string

func (*Call) GetParentRole

func (c *Call) GetParentRole() interface{}

func (*Call) GetParentRolePath

func (c *Call) GetParentRolePath() string

func (*Call) GetTraits

func (c *Call) GetTraits() task.Traits

func (*Call) Start

func (c *Call) Start()

type Calls

type Calls []*Call

func (Calls) AwaitAll

func (s Calls) AwaitAll() map[*Call]error

func (Calls) CallAll

func (s Calls) CallAll() map[*Call]error

func (Calls) StartAll

func (s Calls) StartAll()

type CallsMap

type CallsMap map[HookWeight]Calls

func (CallsMap) GetWeights

func (m CallsMap) GetWeights() []HookWeight

type Hook

type Hook interface {
	GetParentRole() interface{}
	GetParentRolePath() string
	GetName() string
	GetTraits() task.Traits
}

type HookWeight

type HookWeight int

func ParseTriggerExpression

func ParseTriggerExpression(triggerExpr string) (triggerName string, triggerWeight HookWeight)

type Hooks

type Hooks []Hook

func (Hooks) FilterCalls

func (s Hooks) FilterCalls() (calls Calls)

func (Hooks) FilterTasks

func (s Hooks) FilterTasks() (tasks task.Tasks)

type HooksMap

type HooksMap map[HookWeight]Hooks

func (HooksMap) GetWeights

func (m HooksMap) GetWeights() []HookWeight

type ParentRole

type ParentRole interface {
	GetPath() string
	GetTaskTraits() task.Traits
	GetEnvironmentId() uid.ID
	ConsolidatedVarStack() (varStack map[string]string, err error)
	SendEvent(event.Event)
	SetRuntimeVar(key string, value string)
	SetRuntimeVars(kv map[string]string)
	DeleteRuntimeVar(key string)
	DeleteRuntimeVars(keys []string)
	SetGlobalRuntimeVar(key string, value string)
	SetGlobalRuntimeVars(kv map[string]string)
	DeleteGlobalRuntimeVar(key string)
	DeleteGlobalRuntimeVars(keys []string)
	GetCurrentRunNumber() uint32
}