executer

Documentation

Index

• type WorkflowStarter
  • func NewWorkflowStarter(logger logr.Logger, workflow_id string, dag *parser.NodeSet) *WorkflowStarter
  • func (w *WorkflowStarter) CreateWorkflow() error

Types

type WorkflowStarter

type WorkflowStarter struct {
	Workflow_id string

	Logger logr.Logger
	// contains filtered or unexported fields
}

func NewWorkflowStarter

func NewWorkflowStarter(logger logr.Logger, workflow_id string, dag *parser.NodeSet) *WorkflowStarter

Constructor of the workflow initiator

func (*WorkflowStarter) CreateWorkflow

func (w *WorkflowStarter) CreateWorkflow() error

Enter the information for the DAG and turn the map into a real workflow