nfor

package

v0.0.0-...-36d6306 Latest Latest Go to latest Published: Jul 5, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/the-dev-tools/dev-tools

Links

Open Source Insights

Documentation ¶

Index ¶

type NodeFor
- func New(id idwrap.IDWrap, name string, iterCount int64, timeout time.Duration, ...) *NodeFor
- func NewWithCondition(id idwrap.IDWrap, name string, iterCount int64, timeout time.Duration, ...) *NodeFor

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type NodeFor ¶

type NodeFor struct {
	FlowNodeID    idwrap.IDWrap
	Name          string
	IterCount     int64
	Timeout       time.Duration
	Condition     mcondition.Condition
	ErrorHandling mflow.ErrorHandling
}

func New ¶

func New(id idwrap.IDWrap, name string, iterCount int64, timeout time.Duration, errorHandling mflow.ErrorHandling) *NodeFor

New creates a NodeFor without condition data (for backward compatibility)

func NewWithCondition ¶

func NewWithCondition(id idwrap.IDWrap, name string, iterCount int64, timeout time.Duration, errorHandling mflow.ErrorHandling, condition mcondition.Condition) *NodeFor

NewWithCondition creates a NodeFor with condition data for break logic

func (*NodeFor) GetID ¶

func (nr *NodeFor) GetID() idwrap.IDWrap

func (*NodeFor) GetName ¶

func (n *NodeFor) GetName() string

func (*NodeFor) GetOutputVariables ¶

func (nr *NodeFor) GetOutputVariables() []string

GetOutputVariables implements node.VariableIntrospector. Returns the output paths this For node produces.

func (*NodeFor) GetRequiredVariables ¶

func (nr *NodeFor) GetRequiredVariables() []string

GetRequiredVariables implements node.VariableIntrospector. It extracts variable references from the break condition expression.

func (*NodeFor) IsLoopCoordinator ¶

func (nr *NodeFor) IsLoopCoordinator() bool

func (*NodeFor) RunAsync ¶

func (nr *NodeFor) RunAsync(ctx context.Context, req *node.FlowNodeRequest, resultChan chan node.FlowNodeResult)

func (*NodeFor) RunSync ¶

func (nr *NodeFor) RunSync(ctx context.Context, req *node.FlowNodeRequest) node.FlowNodeResult

func (*NodeFor) SetID ¶

func (nr *NodeFor) SetID(id idwrap.IDWrap)

Source Files ¶

View all Source files

nfor.go

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