Documentation
¶
Index ¶
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 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
}
func GetProcessor ¶
func GetProcessor(node *domain.WorkflowNode) (NodeProcessor, error)
Source Files
Click to show internal directories.
Click to hide internal directories.