branch

Documentation

Index

• func DecideBranch(ctx context.Context, w v1alpha1.BaseWorkflowWithStatus, nodeID v1alpha1.NodeID, ...) (*v1alpha1.NodeID, error)
• func Evaluate(lValue *core.Primitive, rValue *core.Primitive, ...) (bool, error)
• func Evaluate1(lValue *core.Primitive, rValue *core.Literal, ...) (bool, error)
• func Evaluate2(lValue *core.Literal, rValue *core.Primitive, ...) (bool, error)
• func EvaluateBooleanExpression(expr *core.BooleanExpression, nodeInputs *handler.Data) (bool, error)
• func EvaluateComparison(expr *core.ComparisonExpression, nodeInputs *handler.Data) (bool, error)
• func EvaluateIfBlock(block v1alpha1.ExecutableIfBlock, nodeInputs *handler.Data, ...) (*v1alpha1.NodeID, []*v1alpha1.NodeID, error)
• func EvaluateLiterals(lValue *core.Literal, rValue *core.Literal, ...) (bool, error)
• func New(executor executors.Node, eventSink events.EventSink, scope promutils.Scope) handler.IFace

Functions

func DecideBranch

func DecideBranch(ctx context.Context, w v1alpha1.BaseWorkflowWithStatus, nodeID v1alpha1.NodeID, node v1alpha1.ExecutableBranchNode, nodeInputs *handler.Data) (*v1alpha1.NodeID, error)

Decides the branch to be taken, returns the nodeId of the selected node or an error The branchnode is marked as success. This is used by downstream node to determine if it can be executed All downstream nodes are marked as skipped

func Evaluate

func Evaluate(lValue *core.Primitive, rValue *core.Primitive, op core.ComparisonExpression_Operator) (bool, error)

func Evaluate1

func Evaluate1(lValue *core.Primitive, rValue *core.Literal, op core.ComparisonExpression_Operator) (bool, error)

func Evaluate2

func Evaluate2(lValue *core.Literal, rValue *core.Primitive, op core.ComparisonExpression_Operator) (bool, error)

func EvaluateBooleanExpression

func EvaluateBooleanExpression(expr *core.BooleanExpression, nodeInputs *handler.Data) (bool, error)

func EvaluateComparison

func EvaluateComparison(expr *core.ComparisonExpression, nodeInputs *handler.Data) (bool, error)

func EvaluateIfBlock

func EvaluateIfBlock(block v1alpha1.ExecutableIfBlock, nodeInputs *handler.Data, skippedNodeIds []*v1alpha1.NodeID) (*v1alpha1.NodeID, []*v1alpha1.NodeID, error)

func EvaluateLiterals

func EvaluateLiterals(lValue *core.Literal, rValue *core.Literal, op core.ComparisonExpression_Operator) (bool, error)

func New

func New(executor executors.Node, eventSink events.EventSink, scope promutils.Scope) handler.IFace