nodeprocessor

Jun 9, 2025

Changes in this version

+ func GetAllNodeOutputs(ctx context.Context) map[string]map[string]any

Jun 2, 2025

Changes in this version

+ func AddNodeOutput(ctx context.Context, nodeId string, output map[string]any) context.Context

+ func GetNodeOutput(ctx context.Context, nodeId string) map[string]any

+ func GetNodeOutputValue(ctx context.Context, nodeId string, key string) (any, bool)

+ func GetNodeOutputs(ctx context.Context) map[string]map[string]any

+ func HasNodeOutput(ctx context.Context, nodeId string) bool

+ func NewMonitorNode(node *domain.WorkflowNode) *monitorNode

type NodeProcessor

+ GetOutputs func() map[string]any

Mar 21, 2025

Changes in this version

type NodeProcessor

+ GetLogger func() *slog.Logger

+ SetLogger func(*slog.Logger)

Mar 5, 2025

Changes in this version

+ func NewApplyNode(node *domain.WorkflowNode) *applyNode

+ func NewConditionNode(node *domain.WorkflowNode) *conditionNode

+ func NewDeployNode(node *domain.WorkflowNode) *deployNode

+ func NewExecuteFailureNode(node *domain.WorkflowNode) *executeFailureNode

+ func NewExecuteSuccessNode(node *domain.WorkflowNode) *executeSuccessNode

+ func NewNotifyNode(node *domain.WorkflowNode) *notifyNode

+ func NewStartNode(node *domain.WorkflowNode) *startNode

+ func NewUploadNode(node *domain.WorkflowNode) *uploadNode

+ type NodeProcessor interface

+ AppendLogRecord func(ctx context.Context, level domain.WorkflowRunLogLevel, content string, ...)

+ GetLog func(ctx context.Context) *domain.WorkflowRunLog

+ Process func(ctx context.Context) error

+ func GetProcessor(node *domain.WorkflowNode) (NodeProcessor, error)