Documentation
¶
Index ¶
- func AddNodeOutput(ctx context.Context, nodeId string, output map[string]any) context.Context
- func GetAllNodeOutputs(ctx context.Context) map[string]map[string]any
- func GetNodeOutput(ctx context.Context, nodeId string) map[string]any
- 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 NewMonitorNode(node *domain.WorkflowNode) *monitorNode
- func NewNotifyNode(node *domain.WorkflowNode) *notifyNode
- func NewStartNode(node *domain.WorkflowNode) *startNode
- func NewUploadNode(node *domain.WorkflowNode) *uploadNode
- type NodeProcessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddNodeOutput ¶
添加节点输出到上下文
func GetAllNodeOutputs ¶
获取所有节点输出
func GetNodeOutput ¶
从上下文获取节点输出
func NewApplyNode ¶
func NewApplyNode(node *domain.WorkflowNode) *applyNode
func NewConditionNode ¶
func NewConditionNode(node *domain.WorkflowNode) *conditionNode
func NewDeployNode ¶
func NewDeployNode(node *domain.WorkflowNode) *deployNode
func NewExecuteFailureNode ¶
func NewExecuteFailureNode(node *domain.WorkflowNode) *executeFailureNode
func NewExecuteSuccessNode ¶
func NewExecuteSuccessNode(node *domain.WorkflowNode) *executeSuccessNode
func NewMonitorNode ¶
func NewMonitorNode(node *domain.WorkflowNode) *monitorNode
func NewNotifyNode ¶
func NewNotifyNode(node *domain.WorkflowNode) *notifyNode
func NewStartNode ¶
func NewStartNode(node *domain.WorkflowNode) *startNode
func NewUploadNode ¶
func NewUploadNode(node *domain.WorkflowNode) *uploadNode
Types ¶
type NodeProcessor ¶
type NodeProcessor interface {
GetLogger() *slog.Logger
SetLogger(*slog.Logger)
Process(ctx context.Context) error
GetOutputs() map[string]any
}
func GetProcessor ¶
func GetProcessor(node *domain.WorkflowNode) (NodeProcessor, error)
Source Files
Click to show internal directories.
Click to hide internal directories.