engine

Mar 30, 2026

Changes in this version

type QueueManager

+ func (m *QueueManager) Delete(id string) bool

+ func (m *QueueManager) IsPaused() bool

+ func (m *QueueManager) Pause() bool

+ func (m *QueueManager) ReloadRuntime(appCtx *app.Context)

+ func (m *QueueManager) Resume() bool

Feb 14, 2026

Changes in this version

+ type Downloader struct

+ func NewDownloader(ctx *app.Context, writer *FileWriter) *Downloader

+ func (s *Downloader) Download(ctx context.Context, item *domain.QueueItem) error

+ func (s *Downloader) RenderCLIProgress(item *domain.QueueItem, speedMbps float64, final bool)

+ func (s *Downloader) SetProgressHandler(fn func(*domain.QueueItem))

+ type QueueManager struct

+ func NewQueueManager(app *app.Context, loadExisting bool) *QueueManager

+ func (m *QueueManager) Add(ctx context.Context, releaseID string, title string) (*domain.QueueItem, error)

+ func (m *QueueManager) Cancel(id string) bool

+ func (m *QueueManager) GetActiveItem() *domain.QueueItem

+ func (m *QueueManager) GetAllItems() []*domain.QueueItem

+ func (m *QueueManager) GetItem(ctx context.Context, id string) (*domain.QueueItem, bool)

+ func (m *QueueManager) HydrateItem(ctx context.Context, item *domain.QueueItem) error

+ func (m *QueueManager) Start(ctx context.Context)

+ func (m *QueueManager) Stop()

+ func (m *QueueManager) UpdateStatus(ctx context.Context, item *domain.QueueItem, status domain.JobStatus)

Jan 19, 2026

Changes in this version

+ type DownloadJob struct

+ File *nzb.DownloadFile

+ Groups []string

+ Offset int64

+ RetryCount int

+ Segment nzb.Segment

+ type DownloadResult struct

+ Error error

+ Job DownloadJob

+ type FileWriter struct

+ func NewFileWriter() *FileWriter

+ func (fw *FileWriter) CloseAll()

+ func (fw *FileWriter) CloseFile(path string, finalSize int64) error

+ func (fw *FileWriter) PreAllocate(path string, size int64) error

+ func (fw *FileWriter) WriteAt(path string, data []byte, offset int64) error

+ type Service struct

+ func NewService(ctx *app.Context, writer *FileWriter) *Service

+ func (s *Service) Download(ctx context.Context, nzb *nzb.Model) error

+ type WriteRequest struct

+ Data []byte

+ Done chan error

+ FilePath string

+ Offset int64