Function NewBatchNode

compose/batch/batch/node.go:51–62

NewBatchNode creates a new batch processing node. Example: batchNode := batch.NewBatchNode(&batch.NodeConfig[Request, Response]{ Name: "MyBatchProcessor", InnerTask: myWorkflow, MaxConcurrency: 5, })

(config *NodeConfig[I, O])

//	    MaxConcurrency: 5,
//	})
func NewBatchNode[I, O any](config *NodeConfig[I, O]) *Node[I, O] {
	name := config.Name
	if name == "" {
		name = "Node"
	}
	return &Node[I, O]{
		name:                name,
		innerTask:           config.InnerTask,
		maxConcurrency:      config.MaxConcurrency,
		innerCompileOptions: config.InnerCompileOptions,
	}
}

// GetType returns the node name for callback identification.
// Implements components.Typer interface.