queue

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 30, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Service

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

func NewService

func NewService(appCtx *app.Context) *Service

func (*Service) Cancel

func (s *Service) Cancel(id string) bool

func (*Service) CancelMany

func (s *Service) CancelMany(ids []string) int

func (*Service) ClearHistory

func (s *Service) ClearHistory(ctx context.Context) (int64, error)

func (*Service) DeleteMany

func (s *Service) DeleteMany(ctx context.Context, ids []string) (int64, error)

func (*Service) EnqueueByReleaseID

func (s *Service) EnqueueByReleaseID(ctx context.Context, releaseID, title string) (*domain.QueueItem, error)

func (*Service) EnqueueNZB

func (s *Service) EnqueueNZB(ctx context.Context, filename string, file io.Reader) (*domain.QueueItem, error)

CHANGED: keep existing native API call shape as a wrapper.

func (*Service) EnqueueNZBWithCategory

func (s *Service) EnqueueNZBWithCategory(ctx context.Context, filename, category string, file io.Reader) (*domain.QueueItem, error)

CHANGED: SAB-compatible enqueue path can preserve client category.

func (*Service) GetItem

func (s *Service) GetItem(ctx context.Context, id string) (*domain.QueueItem, error)

func (*Service) GetItemEvents

func (s *Service) GetItemEvents(ctx context.Context, id string) ([]*domain.QueueItemEvent, error)

func (*Service) GetItemFiles

func (s *Service) GetItemFiles(ctx context.Context, id string) ([]*domain.DownloadFile, error)

func (*Service) IsPaused

func (s *Service) IsPaused() bool

func (*Service) ListActive

func (s *Service) ListActive() []*domain.QueueItem

func (*Service) ListHistory

func (s *Service) ListHistory(ctx context.Context, status string, limit, offset int) ([]*domain.QueueItem, int, error)

func (*Service) Pause

func (s *Service) Pause() bool

func (*Service) Resume

func (s *Service) Resume() bool

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL