dao

Documentation

Index

• type TaskExecutionDao
• type TaskExecutionDaoImpl
  • func (dao *TaskExecutionDaoImpl) FindById(id uint, db *gorm.DB) (*model.TaskExecution, error)
  • func (dao *TaskExecutionDaoImpl) FindChildTasks(parentTaskId uint, db *gorm.DB) ([]*model.TaskExecution, error)
  • func (dao *TaskExecutionDaoImpl) FindCompletedByWorkflowId(wid uint, db *gorm.DB) ([]*model.TaskExecution, error)
  • func (dao *TaskExecutionDaoImpl) FindUncompletedByWorkflowId(wid uint, db *gorm.DB) ([]*model.TaskExecution, error)
  • func (dao *TaskExecutionDaoImpl) Update(execution *model.TaskExecution, db *gorm.DB) error
• type WorkflowDao
• type WorkflowDaoImpl
  • func (dao *WorkflowDaoImpl) FindById(id uint, db *gorm.DB) (*model.Workflow, error)
  • func (dao *WorkflowDaoImpl) FindByIds(ids []uint, db *gorm.DB) ([]*model.Workflow, error)
• type WorkflowExecutionDao
• type WorkflowExecutionDaoImpl
  • func (workflowExecutionDaoImpl *WorkflowExecutionDaoImpl) Create(execution *model.WorkflowExecution, db *gorm.DB) error
  • func (workflowExecutionDaoImpl *WorkflowExecutionDaoImpl) Find(limit int, offset int, order string, db *gorm.DB) ([]*model.WorkflowExecution, error)
  • func (workflowExecutionDaoImpl *WorkflowExecutionDaoImpl) FindById(id uint, withWorkflow bool, withTasks bool, db *gorm.DB) (*model.WorkflowExecution, error)
  • func (workflowExecutionDaoImpl *WorkflowExecutionDaoImpl) FindUncompletedWorkflowExecs(db *gorm.DB) ([]*model.WorkflowExecution, error)
  • func (workflowExecutionDaoImpl *WorkflowExecutionDaoImpl) Update(execution *model.WorkflowExecution, db *gorm.DB) error

Types

type TaskExecutionDao

type TaskExecutionDao interface {
	FindById(uint, *gorm.DB) (*model.TaskExecution, error)
	FindCompletedByWorkflowId(uint, *gorm.DB) ([]*model.TaskExecution, error)
	FindUncompletedByWorkflowId(uint, *gorm.DB) ([]*model.TaskExecution, error)
	FindChildTasks(uint, *gorm.DB) ([]*model.TaskExecution, error)
	Update(*model.TaskExecution, *gorm.DB) error
}

type TaskExecutionDaoImpl

type TaskExecutionDaoImpl struct{}

func (*TaskExecutionDaoImpl) FindById

func (dao *TaskExecutionDaoImpl) FindById(id uint, db *gorm.DB) (*model.TaskExecution, error)

func (*TaskExecutionDaoImpl) FindChildTasks

func (dao *TaskExecutionDaoImpl) FindChildTasks(parentTaskId uint, db *gorm.DB) ([]*model.TaskExecution, error)

func (*TaskExecutionDaoImpl) FindCompletedByWorkflowId

func (dao *TaskExecutionDaoImpl) FindCompletedByWorkflowId(wid uint, db *gorm.DB) ([]*model.TaskExecution, error)

func (*TaskExecutionDaoImpl) FindUncompletedByWorkflowId

func (dao *TaskExecutionDaoImpl) FindUncompletedByWorkflowId(wid uint, db *gorm.DB) ([]*model.TaskExecution, error)

func (*TaskExecutionDaoImpl) Update

func (dao *TaskExecutionDaoImpl) Update(execution *model.TaskExecution, db *gorm.DB) error

type WorkflowDao

type WorkflowDao interface {
	FindById(uint, *gorm.DB) (*model.Workflow, error)
	FindByIds([]uint, *gorm.DB) ([]*model.Workflow, error)
}

type WorkflowDaoImpl

type WorkflowDaoImpl struct{}

func (*WorkflowDaoImpl) FindById

func (dao *WorkflowDaoImpl) FindById(id uint, db *gorm.DB) (*model.Workflow, error)

func (*WorkflowDaoImpl) FindByIds

func (dao *WorkflowDaoImpl) FindByIds(ids []uint, db *gorm.DB) ([]*model.Workflow, error)

type WorkflowExecutionDao

type WorkflowExecutionDao interface {
	FindById(uint, bool, bool, *gorm.DB) (*model.WorkflowExecution, error)
	Find(limit int, offset int, order string, db *gorm.DB) ([]*model.WorkflowExecution, error)
	Create(*model.WorkflowExecution, *gorm.DB) error
	Update(*model.WorkflowExecution, *gorm.DB) error
	FindUncompletedWorkflowExecs(*gorm.DB) ([]*model.WorkflowExecution, error)
}

type WorkflowExecutionDaoImpl

type WorkflowExecutionDaoImpl struct{}

func (*WorkflowExecutionDaoImpl) Create

func (workflowExecutionDaoImpl *WorkflowExecutionDaoImpl) Create(execution *model.WorkflowExecution, db *gorm.DB) error

func (*WorkflowExecutionDaoImpl) Find

func (workflowExecutionDaoImpl *WorkflowExecutionDaoImpl) Find(limit int, offset int, order string, db *gorm.DB) ([]*model.WorkflowExecution, error)

func (*WorkflowExecutionDaoImpl) FindById

func (workflowExecutionDaoImpl *WorkflowExecutionDaoImpl) FindById(id uint, withWorkflow bool, withTasks bool, db *gorm.DB) (*model.WorkflowExecution, error)

func (*WorkflowExecutionDaoImpl) FindUncompletedWorkflowExecs

func (workflowExecutionDaoImpl *WorkflowExecutionDaoImpl) FindUncompletedWorkflowExecs(db *gorm.DB) ([]*model.WorkflowExecution, error)

func (*WorkflowExecutionDaoImpl) Update

func (workflowExecutionDaoImpl *WorkflowExecutionDaoImpl) Update(execution *model.WorkflowExecution, db *gorm.DB) error