Documentation
¶
Index ¶
- 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
- type StatusCount
- type Task
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewRunReadModel ¶
NewRunReadModel ...
func NewRunRepository ¶
NewRunRepository ...
func RunPOToRunDO ¶
func StatusCountPOToStatusCountDTO ¶
func StatusCountPOToStatusCountDTO(count *StatusCount) *query.StatusCount
Types ¶
type Run ¶
type Run struct {
ID string
Name string `gorm:"type:varchar(200);not null;uniqueIndex:sub_run"`
SubmissionID string `gorm:"type:varchar(32);not null;uniqueIndex:sub_run"`
Inputs map[string]interface{} `gorm:"serializer:json"`
Outputs *map[string]interface{} `gorm:"serializer:json"`
EngineRunID string `gorm:"type:varchar(128);not null"`
Status string `gorm:"type:varchar(32);not null"`
Log *string `gorm:"type:longtext"`
Message *string `gorm:"type:longtext"`
StartTime time.Time
FinishTime *time.Time
}
Run ...
func RunDOToRunPO ¶
type Task ¶
type Task struct {
Name string `gorm:"type:varchar(267);primary_key"`
RunID string `gorm:"type:varchar(32);primary_key"`
Status string `gorm:"type:varchar(32);not null"`
Stdout string `gorm:"type:longtext;not null"`
Stderr string `gorm:"type:longtext;not null"`
StartTime time.Time
FinishTime *time.Time
}
Task ...
func RunDOToTaskPOList ¶
Click to show internal directories.
Click to hide internal directories.