downloadservice

type Job struct {
	ID           string                 `json:"id"`
	TaskType     string                 `json:"taskType"`
	ModelJob     runtimetypes.QueueItem `json:"modelJob"`
	ScheduledFor int64                  `json:"scheduledFor"`
	ValidUntil   int64                  `json:"validUntil"`
	CreatedAt    time.Time              `json:"createdAt"`
}

type Service interface {
	CurrentDownloadQueueState(ctx context.Context) ([]Job, error)
	CancelDownloads(ctx context.Context, url string) error
	RemoveDownloadFromQueue(ctx context.Context, modelName string) error
	DownloadInProgress(ctx context.Context, statusCh chan<- *runtimetypes.Status) error
}