workflow

Documentation

Index

• type IWorkflows
  • func NewWorkflows(t tasks.ITasks, logger *zap.Logger) (workflows IWorkflows)
• type Workflow
  • func (w *Workflow) Run() (err error)
  • func (w *Workflow) SplitNodes() (newWorkflowList []Workflow)
  • func (w *Workflow) Validate() (err error)
• type Workflows
  • func (w *Workflows) NewWorkflow(filePath string) (workflow *Workflow, err error)
  • func (w *Workflows) NewWorkflowFromText(text string) (workflow *Workflow, err error)

Types

type IWorkflows

type IWorkflows interface {
	NewWorkflow(string) (*Workflow, error)
	NewWorkflowFromText(string) (*Workflow, error)
}

func NewWorkflows

func NewWorkflows(t tasks.ITasks, logger *zap.Logger) (workflows IWorkflows)

type Workflow

type Workflow struct {
	Version         string                   `yaml:"version,omitempty"`
	EnvironmentList []map[string]string      `yaml:"environment,omitempty"`
	TaskList        []map[string]interface{} `yaml:"task,omitempty"`
	Node            string                   `yaml:",omitempty"`
	Tasks           tasks.ITasks             `yaml:",omitempty"`
	Logger          *zap.Logger              `yaml:",omitempty"`
}

func (*Workflow) Run

func (w *Workflow) Run() (err error)

func (*Workflow) SplitNodes

func (w *Workflow) SplitNodes() (newWorkflowList []Workflow)

func (*Workflow) Validate

func (w *Workflow) Validate() (err error)

type Workflows

type Workflows struct {
	Tasks  tasks.ITasks
	Logger *zap.Logger
}

func (*Workflows) NewWorkflow

func (w *Workflows) NewWorkflow(filePath string) (workflow *Workflow, err error)

func (*Workflows) NewWorkflowFromText

func (w *Workflows) NewWorkflowFromText(text string) (workflow *Workflow, err error)