wflib

package
v0.0.0-...-0f879ca Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 10, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL