Documentation
¶
Index ¶
- type NodeForEach
- func (nr *NodeForEach) GetID() idwrap.IDWrap
- func (n *NodeForEach) GetName() string
- func (nr *NodeForEach) IsLoopCoordinator() bool
- func (nr *NodeForEach) RunAsync(ctx context.Context, req *node.FlowNodeRequest, ...)
- func (nr *NodeForEach) RunSync(ctx context.Context, req *node.FlowNodeRequest) node.FlowNodeResult
- func (nr *NodeForEach) SetID(id idwrap.IDWrap)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NodeForEach ¶
type NodeForEach struct {
FlowNodeID idwrap.IDWrap
Name string
IterPath string
Timeout time.Duration
Condition mcondition.Condition
ErrorHandling mflow.ErrorHandling
}
func New ¶
func New(id idwrap.IDWrap, name string, iterPath string, timeout time.Duration, condition mcondition.Condition, errorHandling mflow.ErrorHandling, ) *NodeForEach
func (*NodeForEach) GetID ¶
func (nr *NodeForEach) GetID() idwrap.IDWrap
func (*NodeForEach) GetName ¶
func (n *NodeForEach) GetName() string
func (*NodeForEach) IsLoopCoordinator ¶
func (nr *NodeForEach) IsLoopCoordinator() bool
func (*NodeForEach) RunAsync ¶
func (nr *NodeForEach) RunAsync(ctx context.Context, req *node.FlowNodeRequest, resultChan chan node.FlowNodeResult)
func (*NodeForEach) RunSync ¶
func (nr *NodeForEach) RunSync(ctx context.Context, req *node.FlowNodeRequest) node.FlowNodeResult
func (*NodeForEach) SetID ¶
func (nr *NodeForEach) SetID(id idwrap.IDWrap)
Click to show internal directories.
Click to hide internal directories.