wflib

Documentation

Index

• type IfElseBody
• type LHWorkflow
  • func NewWorkflow(threadFunc ThreadFunc, name string) *LHWorkflow
  • func (l *LHWorkflow) Compile() (*model.PutWfSpecPb, error)
• type NodeOutput
  • func (n *NodeOutput) JsonPath(path string) NodeOutput
• type SpawnedThread
• type ThreadBuilder
  • func (t *ThreadBuilder) AddVariable(name string, varType model.VariableTypePb) *WfRunVariable
  • func (t *ThreadBuilder) Condition(lhs interface{}, op model.ComparatorPb, rhs interface{}) *WorkflowCondition
  • func (t *ThreadBuilder) DoIf(cond *WorkflowCondition, doIf IfElseBody)
  • func (t *ThreadBuilder) DoIfElse(cond *WorkflowCondition, doIf IfElseBody, doElse IfElseBody)
  • func (t *ThreadBuilder) DoWhile(cond *WorkflowCondition, whileBody ThreadFunc)
  • func (t *ThreadBuilder) Execute(name string, args ...interface{}) NodeOutput
  • func (t *ThreadBuilder) Fail(content interface{}, failureName string, msg *string)
  • func (t *ThreadBuilder) HandleException(nodeOutput *NodeOutput, exceptionName *string, handler ThreadFunc)
  • func (t *ThreadBuilder) HandleInterrupt(interruptName string, handler ThreadFunc)
  • func (t *ThreadBuilder) Mutate(lhs *WfRunVariable, mutation model.VariableMutationTypePb, rhs interface{})
  • func (t *ThreadBuilder) Sleep(sleepSeconds int)
  • func (t *ThreadBuilder) SpawnThread(tFunc ThreadFunc, threadName string, args map[string]interface{}) *SpawnedThread
  • func (t *ThreadBuilder) WaitForEvent(eventName string) NodeOutput
  • func (t *ThreadBuilder) WaitForThread(s *SpawnedThread) NodeOutput
• type ThreadFunc
• type WfRunVariable
  • func (w *WfRunVariable) JsonPath(path string) WfRunVariable
• type WorkflowCondition

Types

type IfElseBody

type IfElseBody func(t *ThreadBuilder)

type LHWorkflow

type LHWorkflow struct {
	EntrypointThread ThreadFunc
	Name             string
	// contains filtered or unexported fields
}

func NewWorkflow

func NewWorkflow(threadFunc ThreadFunc, name string) *LHWorkflow

func (*LHWorkflow) Compile

func (l *LHWorkflow) Compile() (*model.PutWfSpecPb, error)

type NodeOutput

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

func (*NodeOutput) JsonPath

func (n *NodeOutput) JsonPath(path string) NodeOutput

type SpawnedThread

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

type ThreadBuilder

type ThreadBuilder struct {
	Name string
	// contains filtered or unexported fields
}

func (*ThreadBuilder) AddVariable

func (t *ThreadBuilder) AddVariable(
	name string, varType model.VariableTypePb,
) *WfRunVariable

func (*ThreadBuilder) Condition

func (t *ThreadBuilder) Condition(
	lhs interface{}, op model.ComparatorPb, rhs interface{},
) *WorkflowCondition

func (*ThreadBuilder) DoIf

func (t *ThreadBuilder) DoIf(cond *WorkflowCondition, doIf IfElseBody)

func (*ThreadBuilder) DoIfElse

func (t *ThreadBuilder) DoIfElse(cond *WorkflowCondition, doIf IfElseBody, doElse IfElseBody)

func (*ThreadBuilder) DoWhile

func (t *ThreadBuilder) DoWhile(cond *WorkflowCondition, whileBody ThreadFunc)

func (*ThreadBuilder) Execute

func (t *ThreadBuilder) Execute(name string, args ...interface{}) NodeOutput

func (*ThreadBuilder) Fail

func (t *ThreadBuilder) Fail(content interface{}, failureName string, msg *string)

func (*ThreadBuilder) HandleException

func (t *ThreadBuilder) HandleException(
	nodeOutput *NodeOutput,
	exceptionName *string,
	handler ThreadFunc,
)

func (*ThreadBuilder) HandleInterrupt

func (t *ThreadBuilder) HandleInterrupt(interruptName string, handler ThreadFunc)

func (*ThreadBuilder) Mutate

func (t *ThreadBuilder) Mutate(
	lhs *WfRunVariable,
	mutation model.VariableMutationTypePb,
	rhs interface{},
)

func (*ThreadBuilder) Sleep

func (t *ThreadBuilder) Sleep(sleepSeconds int)

func (*ThreadBuilder) SpawnThread

func (t *ThreadBuilder) SpawnThread(
	tFunc ThreadFunc, threadName string, args map[string]interface{},
) *SpawnedThread

func (*ThreadBuilder) WaitForEvent

func (t *ThreadBuilder) WaitForEvent(eventName string) NodeOutput

func (*ThreadBuilder) WaitForThread

func (t *ThreadBuilder) WaitForThread(s *SpawnedThread) NodeOutput

type ThreadFunc

type ThreadFunc func(*ThreadBuilder)

type WfRunVariable

type WfRunVariable struct {
	Name    string
	VarType *model.VariableTypePb
	// contains filtered or unexported fields
}

func (*WfRunVariable) JsonPath

func (w *WfRunVariable) JsonPath(path string) WfRunVariable

type WorkflowCondition

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