Versions in this module Expand all Collapse all v1 v1.5.0 Oct 12, 2026 Changes in this version + const ScheduleTriggerModeCron + const ScheduleTriggerModeInterval + const ScheduleTriggerModeOnce + const WebhookResponseModeImmediate + const WebhookResponseModeWhenFinished + func Register(registry *dataflow.Registry, pool *expr.Pool) + type Filter struct + func NewFilter(pool *expr.Pool) *Filter + func (n *Filter) Description() dataflow.NodeDescription + func (n *Filter) Execute(ctx context.Context, rt *dataflow.Runtime, input []dataflow.Item, ...) (dataflow.Output, error) + func (n *Filter) ValidateParameters(params map[string]any) error + type HTTPRequest struct + func NewHTTPRequest() *HTTPRequest + func (n *HTTPRequest) Description() dataflow.NodeDescription + func (n *HTTPRequest) Execute(ctx context.Context, rt *dataflow.Runtime, input []dataflow.Item, ...) (dataflow.Output, error) + func (n *HTTPRequest) ValidateParameters(params map[string]any) error + type If struct + func NewIf(pool *expr.Pool) *If + func (n *If) Description() dataflow.NodeDescription + func (n *If) Execute(ctx context.Context, rt *dataflow.Runtime, input []dataflow.Item, ...) (dataflow.Output, error) + func (n *If) ValidateParameters(params map[string]any) error + type Merge struct + func NewMerge() Merge + func (Merge) Description() dataflow.NodeDescription + func (Merge) Execute(_ context.Context, _ *dataflow.Runtime, input []dataflow.Item, ...) (dataflow.Output, error) + func (Merge) ValidateParameters(map[string]any) error + type ScheduleTrigger struct + func NewScheduleTrigger() ScheduleTrigger + func (ScheduleTrigger) Description() dataflow.NodeDescription + func (ScheduleTrigger) Execute(_ context.Context, _ *dataflow.Runtime, input []dataflow.Item, ...) (dataflow.Output, error) + func (ScheduleTrigger) ValidateParameters(params map[string]any) error + type Set struct + func NewSet(pool *expr.Pool) *Set + func (n *Set) Description() dataflow.NodeDescription + func (n *Set) Execute(ctx context.Context, rt *dataflow.Runtime, input []dataflow.Item, ...) (dataflow.Output, error) + func (n *Set) ValidateParameters(map[string]any) error + type Switch struct + func NewSwitch(pool *expr.Pool) *Switch + func (n *Switch) Description() dataflow.NodeDescription + func (n *Switch) Execute(ctx context.Context, rt *dataflow.Runtime, input []dataflow.Item, ...) (dataflow.Output, error) + func (n *Switch) ValidateParameters(params map[string]any) error + type Wait struct + func NewWait() Wait + func (Wait) Description() dataflow.NodeDescription + func (Wait) Execute(ctx context.Context, _ *dataflow.Runtime, input []dataflow.Item, ...) (dataflow.Output, error) + func (Wait) ValidateParameters(params map[string]any) error + type WebhookTrigger struct + func NewWebhookTrigger() WebhookTrigger + func (WebhookTrigger) Description() dataflow.NodeDescription + func (WebhookTrigger) Execute(_ context.Context, _ *dataflow.Runtime, input []dataflow.Item, ...) (dataflow.Output, error) + func (WebhookTrigger) ValidateParameters(params map[string]any) error
Go to main page