Documentation
¶
Overview ¶
Package transform provides data transformation node factory for registry integration.
Package transform provides data transformation node implementation for workflow graph execution.
Index ¶
- Constants
- func NewTransformNodeFactory() protocol.NodeFactory
- type TransformNode
- func (n *TransformNode) Execute(ctx models.ExecutionContext, inputs map[string]models.NodeResult) (map[string]models.NodeResult, error)
- func (n *TransformNode) ID() string
- func (n *TransformNode) InputPorts() []models.InputPort
- func (n *TransformNode) OutputPorts() []models.OutputPort
- func (n *TransformNode) Type() string
- func (n *TransformNode) Validate(config map[string]any) error
- type TransformNodeFactory
- func (f *TransformNodeFactory) Create(ctx context.Context, id string, config map[string]any) (protocol.Node, error)
- func (f *TransformNodeFactory) Description() string
- func (f *TransformNodeFactory) ID() string
- func (f *TransformNodeFactory) Name() string
- func (f *TransformNodeFactory) Schema() map[string]any
Constants ¶
const ( OutputPortSuccess = "success" OutputPortError = "error" InputPortMain = "main" )
Variables ¶
This section is empty.
Functions ¶
func NewTransformNodeFactory ¶
func NewTransformNodeFactory() protocol.NodeFactory
NewTransformNodeFactory creates a new factory instance.
Types ¶
type TransformNode ¶
type TransformNode struct {
// contains filtered or unexported fields
}
TransformNode implements the Node interface for data transformation.
func NewTransformNode ¶
func NewTransformNode(id string, config map[string]any) (*TransformNode, error)
NewTransformNode creates a new data transformation node.
func (*TransformNode) Execute ¶
func (n *TransformNode) Execute(ctx models.ExecutionContext, inputs map[string]models.NodeResult) (map[string]models.NodeResult, error)
Execute performs data transformation using Go templates.
func (*TransformNode) InputPorts ¶
func (n *TransformNode) InputPorts() []models.InputPort
InputPorts returns the input ports for the node.
func (*TransformNode) OutputPorts ¶
func (n *TransformNode) OutputPorts() []models.OutputPort
OutputPorts returns the output ports for the node.
type TransformNodeFactory ¶
type TransformNodeFactory struct{}
TransformNodeFactory creates TransformNode instances.
func (*TransformNodeFactory) Create ¶
func (f *TransformNodeFactory) Create(ctx context.Context, id string, config map[string]any) (protocol.Node, error)
Create creates a new TransformNode instance.
func (*TransformNodeFactory) Description ¶
func (f *TransformNodeFactory) Description() string
Description returns the factory description.
func (*TransformNodeFactory) ID ¶
func (f *TransformNodeFactory) ID() string
ID returns the factory ID.
func (*TransformNodeFactory) Name ¶
func (f *TransformNodeFactory) Name() string
Name returns the factory name.
func (*TransformNodeFactory) Schema ¶
func (f *TransformNodeFactory) Schema() map[string]any
Schema returns the JSON schema for Transform node configuration.
Source Files