Versions in this module Expand all Collapse all v1 v1.5.0 Oct 12, 2026 Changes in this version + func NewMySQL() *sqlNode + func NewPostgres() *sqlNode + func NewSQLite() *sqlNode + func Register(registry *dataflow.Registry) + type Elasticsearch struct + func NewElasticsearch() *Elasticsearch + func (n *Elasticsearch) Description() dataflow.NodeDescription + func (n *Elasticsearch) Execute(ctx context.Context, rt *dataflow.Runtime, input []dataflow.Item, ...) (dataflow.Output, error) + func (n *Elasticsearch) TestConnection(ctx context.Context, rt *dataflow.Runtime, params map[string]any) error + func (n *Elasticsearch) ValidateParameters(params map[string]any) error + type MongoDB struct + func NewMongoDB() MongoDB + func (MongoDB) Description() dataflow.NodeDescription + func (MongoDB) Execute(ctx context.Context, rt *dataflow.Runtime, input []dataflow.Item, ...) (dataflow.Output, error) + func (MongoDB) TestConnection(ctx context.Context, rt *dataflow.Runtime, params map[string]any) error + func (MongoDB) ValidateParameters(params map[string]any) error + type Redis struct + func NewRedis() Redis + func (Redis) Description() dataflow.NodeDescription + func (Redis) Execute(ctx context.Context, rt *dataflow.Runtime, input []dataflow.Item, ...) (dataflow.Output, error) + func (Redis) TestConnection(ctx context.Context, rt *dataflow.Runtime, params map[string]any) error + func (Redis) ValidateParameters(params map[string]any) error
Go to main page