delaynode

package

v0.2.0 Latest Latest Go to latest Published: Aug 26, 2026 License: MIT Imports: 5 Imported by: 0

Details

Package delaynode 提供让 workflow 在节点处等待指定时间的默认 node 节点。

View Source

const NodeType = "delay"

This section is empty.

func Definition() node.Definition

Definition 返回延迟节点的完整注册定义。

type Config struct {
	DurationMs int `json:"durationMs"`
}

Config 是 delay node 从 node.config 解码得到的内部配置。

func DefaultConfig() *Config

type Node struct{}

Node 会响应 context 取消，避免延迟节点阻塞整条执行链路退出。

func NewNode() *Node

func (e *Node) Execute(fc *core.FlowContext, node *core.NodeDefine) (interface{}, error)