Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2023 Changes in this version + func NewRunReadModel(ctx context.Context, db *gorm.DB) (query.ReadModel, error) + func NewRunRepository(ctx context.Context, db *gorm.DB) (run.Repository, error) + func RunPOToRunDO(runPO *Run) *run.Run + func RunPOToRunDTO(ctx context.Context, run *Run) (*query.RunItem, error) + func StatusCountPOToStatusCountDTO(count *StatusCount) *query.StatusCount + func TaskPOToTaskDTO(ctx context.Context, task *Task) *query.TaskItem + type Run struct + EngineRunID string + FinishTime *time.Time + ID string + Inputs map[string]interface{} + Log *string + Message *string + Name string + Outputs *map[string]interface{} + StartTime time.Time + Status string + SubmissionID string + func RunDOToRunPO(runDO *run.Run) *Run + func (r *Run) TableName() string + type StatusCount struct + Count int64 + Status string + type Task struct + FinishTime *time.Time + Name string + RunID string + StartTime time.Time + Status string + Stderr string + Stdout string + func RunDOToTaskPOList(runDO *run.Run) []*Task + func (t *Task) TableName() string