workflowstate

Documentation

Index

• type Registry
• type RegistryImpl
  • func (registry *RegistryImpl) GetProcessor(execution *model.WorkflowExecution) (StateProcessor, error)
• type RunningStateProcessor
  • func (processor *RunningStateProcessor) ToNextState(execution *model.WorkflowExecution, db *gorm.DB) (bool, error)
• type ScheduledStateProcessor
  • func (scheduledState *ScheduledStateProcessor) ToNextState(execution *model.WorkflowExecution, db *gorm.DB) (bool, error)
• type StateProcessor

Types

type Registry

type Registry interface {
	GetProcessor(*model.WorkflowExecution) (StateProcessor, error)
}

type RegistryImpl

type RegistryImpl struct {
	ScheduleState *ScheduledStateProcessor
	RunningState  *RunningStateProcessor
}

func (*RegistryImpl) GetProcessor

func (registry *RegistryImpl) GetProcessor(execution *model.WorkflowExecution) (StateProcessor, error)

type RunningStateProcessor

type RunningStateProcessor struct {
	WorkflowExecutionDao dao.WorkflowExecutionDao
	TaskExecutionDao     dao.TaskExecutionDao
	TaskExecutorFactory  taskexecutor.Factory
	TaskPollerFactory    taskpoller.Factory
	KubeClient           kubernetes.Interface
}

func (*RunningStateProcessor) ToNextState

func (processor *RunningStateProcessor) ToNextState(execution *model.WorkflowExecution, db *gorm.DB) (bool, error)

type ScheduledStateProcessor

type ScheduledStateProcessor struct {
	WorkflowExecutionDao dao.WorkflowExecutionDao
	TaskExecutorFactory  taskexecutor.Factory
}

func (*ScheduledStateProcessor) ToNextState

func (scheduledState *ScheduledStateProcessor) ToNextState(execution *model.WorkflowExecution, db *gorm.DB) (bool, error)

type StateProcessor

type StateProcessor interface {
	// Change execution state to Next.
	// return true if change executed.
	ToNextState(*model.WorkflowExecution, *gorm.DB) (bool, error)
}