engine

package

v0.1.0 Latest Latest Go to latest Published: Oct 20, 2026 License: BSD-2-Clause Imports: 8 Imported by: 0

Details

View Source

const (
	ResumePort = protocol.ResumePort
)

This section is empty.

This section is empty.

type Activation struct {
	NodeID  string
	Port    string
	Data    map[string]any
	Attempt int
}

func TriggerActivation(triggerNodeID string, data map[string]any) Activation

type Deferred struct {
	Activation

	RunAt time.Time
}

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

func New(nodes NodeCreator) *Engine

func (e *Engine) Run(ctx context.Context, workflow *models.Workflow, execution *models.ExecutionContext, start Activation) ([]Deferred, error)

func (e *Engine) Validate(ctx context.Context, workflow *models.Workflow) error

type NodeCreator interface {
	CreateNode(ctx context.Context, nodeType, nodeID string, config map[string]any) (protocol.Node, error)
}