repository

type WorkflowExecutionStage struct {
	Id           int                         `sql:"id,pk"`
	StageName    bean.WorkflowStageName      `sql:"stage_name,notnull"` // same as app name
	Status       bean.WorkflowStageStatus    `sql:"status"`
	StatusFor    bean.WorkflowStageStatusFor `sql:"status_for"`
	Message      string                      `sql:"message"`
	Metadata     string                      `sql:"metadata"`
	WorkflowId   int                         `sql:"workflow_id,notnull"`
	WorkflowType string                      `sql:"workflow_type,notnull"`
	StartTime    string                      `sql:"start_time"`
	EndTime      string                      `sql:"end_time"`

	sql.AuditLog
	// contains filtered or unexported fields
}

type WorkflowStageRepository interface {
	SaveWorkflowStages(workflowStage []*WorkflowExecutionStage, tx *pg.Tx) ([]*WorkflowExecutionStage, error)
	UpdateWorkflowStages(workflowStage []*WorkflowExecutionStage, tx *pg.Tx) ([]*WorkflowExecutionStage, error)
	GetWorkflowStagesByWorkflowIdAndType(workflowId int, workflowType string) ([]*WorkflowExecutionStage, error)
	GetWorkflowStagesByWorkflowIdAndWtype(wfId int, wfType string) ([]*WorkflowExecutionStage, error)
	GetWorkflowStagesByWorkflowIdsAndWtype(wfIds []int, wfType string) ([]*WorkflowExecutionStage, error)
}

type WorkflowStageRepositoryImpl struct {
	// contains filtered or unexported fields
}