run

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

type CreateRunParam struct {
	ID           string
	Name         string
	SubmissionID string
	Inputs       map[string]interface{}  `gorm:"serializer:json"`
	Outputs      *map[string]interface{} `gorm:"serializer:json"`
	EngineRunID  string
	Status       string
	Log          *string
	Message      *string
	StartTime    time.Time
	FinishTime   *time.Time
}

type CreateTaskParam struct {
	Name       string
	RunID      string
	Status     string
	Stdout     string
	Stderr     string
	StartTime  time.Time
	FinishTime *time.Time
}

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

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

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

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

type Factory struct{}

type Repository interface {
	Save(ctx context.Context, r *Run) error
	Get(ctx context.Context, id string) (*Run, error)
	Delete(ctx context.Context, r *Run) error
}

type Run struct {
	ID           string
	Name         string
	SubmissionID string
	Inputs       map[string]interface{}  `gorm:"serializer:json"`
	Outputs      *map[string]interface{} `gorm:"serializer:json"`
	EngineRunID  string
	Status       string
	Log          *string
	Message      *string
	StartTime    time.Time
	FinishTime   *time.Time
	Tasks        []*Task
}

type Service interface {
	Upsert(context.Context, *Run, []*Task) error
	Create(context.Context, *Run, []*Task) error
	Update(context.Context, *Run, []*Task) error
	Delete(ctx context.Context, id string) error
	Cancel(ctx context.Context, id string) error
	CheckWorkspaceExist(ctx context.Context, workspaceID string) error
}

type Task struct {
	Name       string
	RunID      string
	Status     string
	Stdout     string
	Stderr     string
	StartTime  time.Time
	FinishTime *time.Time
}