Help us shape the future of Go! Take the 2026 Go Developer Survey

trigger

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 22, 2026 License: BSD-2-Clause Imports: 7 Imported by: 0

Documentation

Overview

Package trigger provides trigger node implementations for workflow graph execution.

Index

Constants

View Source 
const (
	EventInputPortExternal = "external"
	EventOutputPortSuccess = "success"
)
View Source 
const (
	KafkaInputPortExternal = "external"
	KafkaOutputPortSuccess = "success"
	KafkaOutputPortError   = "error"
)
View Source 
const (
	SchedulerInputPortExternal = "external"
	SchedulerOutputPortSuccess = "success"
	SchedulerOutputPortError   = "error"
)
View Source 
const (
	WebhookInputPortExternal = "external"
	WebhookOutputPortSuccess = "success"
	WebhookOutputPortError   = "error"
)

Variables

This section is empty.

Functions

func NewEventTriggerNodeFactory 

func NewEventTriggerNodeFactory() protocol.NodeFactory

func NewKafkaTriggerNodeFactory 

func NewKafkaTriggerNodeFactory() protocol.NodeFactory

func NewSchedulerTriggerNodeFactory 

func NewSchedulerTriggerNodeFactory() protocol.NodeFactory

NewSchedulerTriggerNodeFactory creates a new scheduler trigger node factory.

func NewWebhookTriggerNodeFactory 

func NewWebhookTriggerNodeFactory() protocol.NodeFactory

NewWebhookTriggerNodeFactory creates a new webhook trigger node factory.

Types

type EventTriggerNode 

type EventTriggerNode struct {
	// contains filtered or unexported fields
}

func NewEventTriggerNode 

func NewEventTriggerNode(id string, config map[string]any) (*EventTriggerNode, error)

func (*EventTriggerNode) Execute 

func (n *EventTriggerNode) Execute(_ models.ExecutionContext, inputs map[string]models.NodeResult) (map[string]models.NodeResult, error)

func (*EventTriggerNode) ID 

func (n *EventTriggerNode) ID() string

func (*EventTriggerNode) InputPorts 

func (n *EventTriggerNode) InputPorts() []models.InputPort

func (*EventTriggerNode) OutputPorts 

func (n *EventTriggerNode) OutputPorts() []models.OutputPort

func (*EventTriggerNode) Type 

func (n *EventTriggerNode) Type() string

func (*EventTriggerNode) Validate 

func (n *EventTriggerNode) Validate(config map[string]any) error

type EventTriggerNodeFactory 

type EventTriggerNodeFactory struct{}

func (*EventTriggerNodeFactory) Create 

func (f *EventTriggerNodeFactory) Create(_ context.Context, id string, config map[string]any) (protocol.Node, error)

func (*EventTriggerNodeFactory) Description 

func (f *EventTriggerNodeFactory) Description() string

func (*EventTriggerNodeFactory) ID 

func (f *EventTriggerNodeFactory) ID() string

func (*EventTriggerNodeFactory) Name 

func (f *EventTriggerNodeFactory) Name() string

func (*EventTriggerNodeFactory) Schema 

func (f *EventTriggerNodeFactory) Schema() map[string]any

type KafkaTriggerNode 

type KafkaTriggerNode struct {
	// contains filtered or unexported fields
}

KafkaTriggerNode implements the Node interface for Kafka triggers.

func NewKafkaTriggerNode 

func NewKafkaTriggerNode(id string, config map[string]any) (*KafkaTriggerNode, error)

NewKafkaTriggerNode creates a new Kafka trigger node.

func (*KafkaTriggerNode) Execute 

func (n *KafkaTriggerNode) Execute(ctx models.ExecutionContext, inputs map[string]models.NodeResult) (map[string]models.NodeResult, error)

Execute processes the Kafka message data from external input.

func (*KafkaTriggerNode) ID 

func (n *KafkaTriggerNode) ID() string

ID returns the node ID.

func (*KafkaTriggerNode) InputPorts 

func (n *KafkaTriggerNode) InputPorts() []models.InputPort

InputPorts returns the input ports for the Kafka trigger node.

func (*KafkaTriggerNode) OutputPorts 

func (n *KafkaTriggerNode) OutputPorts() []models.OutputPort

OutputPorts returns the output ports for the Kafka trigger node.

func (*KafkaTriggerNode) Type 

func (n *KafkaTriggerNode) Type() string

Type returns the node type.

func (*KafkaTriggerNode) Validate 

func (n *KafkaTriggerNode) Validate(config map[string]any) error

Validate validates the node configuration.

type KafkaTriggerNodeFactory 

type KafkaTriggerNodeFactory struct{}

KafkaTriggerNodeFactory creates KafkaTriggerNode instances.

func (*KafkaTriggerNodeFactory) Create 

func (f *KafkaTriggerNodeFactory) Create(ctx context.Context, id string, config map[string]any) (protocol.Node, error)

Create creates a new KafkaTriggerNode instance.

func (*KafkaTriggerNodeFactory) Description 

func (f *KafkaTriggerNodeFactory) Description() string

Description returns the factory description.

func (*KafkaTriggerNodeFactory) ID 

func (f *KafkaTriggerNodeFactory) ID() string

ID returns the factory ID.

func (*KafkaTriggerNodeFactory) Name 

func (f *KafkaTriggerNodeFactory) Name() string

Name returns the factory name.

func (*KafkaTriggerNodeFactory) Schema 

func (f *KafkaTriggerNodeFactory) Schema() map[string]any

Schema returns the JSON schema for Kafka trigger node configuration.

type SchedulerTriggerConfig 

type SchedulerTriggerConfig struct {
	CronExpression string `json:"cron_expression"`
	Timezone       string `json:"timezone"`
}

SchedulerTriggerConfig defines the configuration for scheduler trigger nodes.

type SchedulerTriggerNode 

type SchedulerTriggerNode struct {
	// contains filtered or unexported fields
}

SchedulerTriggerNode implements the Node interface for scheduler triggers.

func NewSchedulerTriggerNode 

func NewSchedulerTriggerNode(id string, config map[string]any) (*SchedulerTriggerNode, error)

NewSchedulerTriggerNode creates a new scheduler trigger node.

func (*SchedulerTriggerNode) Execute 

func (n *SchedulerTriggerNode) Execute(ctx models.ExecutionContext, inputs map[string]models.NodeResult) (map[string]models.NodeResult, error)

Execute processes the scheduler event data from external input.

func (*SchedulerTriggerNode) ID 

func (n *SchedulerTriggerNode) ID() string

ID returns the node ID.

func (*SchedulerTriggerNode) InputPorts 

func (n *SchedulerTriggerNode) InputPorts() []models.InputPort

InputPorts returns the input ports for the scheduler trigger node.

func (*SchedulerTriggerNode) OutputPorts 

func (n *SchedulerTriggerNode) OutputPorts() []models.OutputPort

OutputPorts returns the output ports for the scheduler trigger node.

func (*SchedulerTriggerNode) Type 

func (n *SchedulerTriggerNode) Type() string

Type returns the node type.

func (*SchedulerTriggerNode) Validate 

func (n *SchedulerTriggerNode) Validate(config map[string]any) error

Validate validates the node configuration.

type SchedulerTriggerNodeFactory 

type SchedulerTriggerNodeFactory struct{}

SchedulerTriggerNodeFactory creates SchedulerTriggerNode instances.

func (*SchedulerTriggerNodeFactory) Create 

func (f *SchedulerTriggerNodeFactory) Create(ctx context.Context, id string, config map[string]any) (protocol.Node, error)

Create creates a new SchedulerTriggerNode instance.

func (*SchedulerTriggerNodeFactory) Description 

func (f *SchedulerTriggerNodeFactory) Description() string

Description returns the factory description.

func (*SchedulerTriggerNodeFactory) ID 

func (f *SchedulerTriggerNodeFactory) ID() string

ID returns the factory ID.

func (*SchedulerTriggerNodeFactory) Name 

func (f *SchedulerTriggerNodeFactory) Name() string

Name returns the factory name.

func (*SchedulerTriggerNodeFactory) Schema 

func (f *SchedulerTriggerNodeFactory) Schema() map[string]any

Schema returns the JSON schema for scheduler trigger node configuration.

type WebhookTriggerNode 

type WebhookTriggerNode struct {
	// contains filtered or unexported fields
}

WebhookTriggerNode implements the Node interface for webhook triggers.

func NewWebhookTriggerNode 

func NewWebhookTriggerNode(id string, config map[string]any) (*WebhookTriggerNode, error)

NewWebhookTriggerNode creates a new webhook trigger node.

func (*WebhookTriggerNode) Execute 

func (n *WebhookTriggerNode) Execute(ctx models.ExecutionContext, inputs map[string]models.NodeResult) (map[string]models.NodeResult, error)

Execute processes the webhook event data from external input.

func (*WebhookTriggerNode) ID 

func (n *WebhookTriggerNode) ID() string

ID returns the node ID.

func (*WebhookTriggerNode) InputPorts 

func (n *WebhookTriggerNode) InputPorts() []models.InputPort

InputPorts returns the input ports for the webhook trigger node.

func (*WebhookTriggerNode) OutputPorts 

func (n *WebhookTriggerNode) OutputPorts() []models.OutputPort

OutputPorts returns the output ports for the webhook trigger node.

func (*WebhookTriggerNode) Type 

func (n *WebhookTriggerNode) Type() string

Type returns the node type.

func (*WebhookTriggerNode) Validate 

func (n *WebhookTriggerNode) Validate(config map[string]any) error

Validate validates the node configuration.

type WebhookTriggerNodeFactory 

type WebhookTriggerNodeFactory struct{}

WebhookTriggerNodeFactory creates WebhookTriggerNode instances.

func (*WebhookTriggerNodeFactory) Create 

func (f *WebhookTriggerNodeFactory) Create(ctx context.Context, id string, config map[string]any) (protocol.Node, error)

Create creates a new WebhookTriggerNode instance.

func (*WebhookTriggerNodeFactory) Description 

func (f *WebhookTriggerNodeFactory) Description() string

Description returns the factory description.

func (*WebhookTriggerNodeFactory) ID 

func (f *WebhookTriggerNodeFactory) ID() string

ID returns the factory ID.

func (*WebhookTriggerNodeFactory) Name 

func (f *WebhookTriggerNodeFactory) Name() string

Name returns the factory name.

func (*WebhookTriggerNodeFactory) Schema 

func (f *WebhookTriggerNodeFactory) Schema() map[string]any

Schema returns the JSON schema for webhook trigger node configuration.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.