Next connects this node to another node for a specific action. Returns the *next* node for chaining.

SetExec sets the ExecFunc.

SetParams sets node-specific parameters. Returns the node for chaining.

GetParams returns the node's current parameters.

Run executes a single node's lifecycle (prep, exec, post). Useful for standalone execution. Returns the resulting action and error.

SetPost sets the PostFunc.

SetRetry configures retry behaviour.

SetPrep sets the PrepFunc.

resultCaptureNode creates a node that captures the context value into its own params.

Run starts the flow execution.

addNumberNode creates a node that adds a number based on context.

orchestrate executes the node chain starting from startNode. initialParams are merged with the flow's own params for the *first* node. Returns the las

--- Test Node Implementations using Functional Style --- setNumberNode creates a node that sets a number in the context.

Exec iterates through the prepResult slice, calling ExecItemFunc for each item with retries.

Exec for the Flow initiates the orchestration. Should not be called directly by user.

GetNextNode retrieves the successor node for a given action (or DefaultAction).

InternalRun is used by Flow orchestration to execute the node lifecycle. Separated from Run to prevent potential issues if Run is overridden incorrect

InternalRun implements the retry logic at the item level within Exec.

InternalRun executes the flow's lifecycle: Prep, Orchestrate (via Exec), Post.

InternalRun executes the BatchFlow lifecycle: PrepBatch, Exec(orchestrate per batch), PostBatch.

Post calls the user-defined PostFunc.

Post for the Flow runs after orchestration completes. Default returns the final action.

Post for BatchFlow runs its PostBatchFunc.

Prep calls the user-defined PrepFunc.

Prep for the Flow itself. Default is no-op. Can be overridden if needed.

--- BaseNode Implementation Overrides for BatchFlow --- Prep for BatchFlow runs its PrepBatchFunc.

Run starts the BatchFlow execution.

SetExecItem sets the ExecItemFunc for processing individual items.

SetFallback sets the ExecFallbackFunc.

SetItemFallback sets the ExecItemFallbackFunc.

--- BaseNode Implementation for Flow --- Most BaseNode methods are less relevant for Flow itself, focused on orchestration.

SetPostBatch sets the function to run after all batches complete.

SetPrepBatch sets the function to generate batch parameters.

simpleLogNode creates a node for BatchFlow testing.

Exec performs the main work using the result from Prep. Returns the execution result (can be nil) and an error.

Exec for BatchFlow runs the orchestration for each batch item. The 'prepResult' here is the []*pfContext from BatchFlow.Prep.

GetSuccessors returns the map of action->node successors.

NewBatchFlow creates a new BatchFlow.

NewBatchNode creates a new BatchNode with default settings.

NewFlow creates a new Flow, optionally with a starting node.

NewNode creates a new Node with default retry settings (1 try, 0 wait).

Next for a Flow doesn't make logical sense in the standard execution model.

Post processes results, updates context, and returns the next action string. An empty string implies DefaultAction. Returns an error if post-processin

Prep prepares input for Exec using the shared context. Returns the prepared data (can be nil) and an error.

--- BaseNode Implementation for Node ---

--- BaseNode Implementation for BatchNode ---

SetPost sets the PostFunc. Receives []any prep and []any exec results.

SetPrep sets the PrepFunc. Expects a function returning []any.

SetRetry configures retry behaviour.

Start sets the initial node for the flow. Returns the start node for chaining setup.

--- Additional Tests ---

--- Test Methods ---

Unwrap allows PocketFlowError to work with errors.Is and errors.As.