Struct BatchNode

pocketflow.go:343–358

--- Batch Node (Processes items individually) --- BatchNode implements BaseNode to process slices of items.

// BatchNode implements BaseNode to process slices of items.
type BatchNode struct {
	nodeCore
	MaxRetries       int
	WaitMilliseconds time.Duration

	// User-defined functions
	// Prep returns a slice (or error)
	PrepFunc func(ctx *PfContext, params map[string]any) ([]any, error)
	// ExecItem operates on a single item from the Prep slice
	ExecItemFunc func(ctx *PfContext, params map[string]any, item any) (any, error)
	// Post receives the original prep slice and the slice of exec results
	PostFunc func(ctx *PfContext, params map[string]any, prepResult []any, execResult []any) (string, error)

	// Optional fallback for individual item processing
	ExecItemFallbackFunc func(ctx *PfContext, params map[string]any, item any, lastErr error) (any, error)
}

// NewBatchNode creates a new BatchNode with default settings.
func NewBatchNode() *BatchNode {