queue

Mar 23, 2026

Changes in this version

type CompletedItem

+ ScriptFirstFailureAt *time.Time

+ ScriptRetryCount int

type PaginationParams

+ Status string

+ type PendingArticleCheck struct

+ CompletedItemID string

+ CreatedAt time.Time

+ FirstFailureAt time.Time

+ Groups string

+ ID int64

+ LastCheckedAt *time.Time

+ MessageID string

+ NextRetryAt time.Time

+ RetryCount int

+ Status string

type Queue

+ func (q *Queue) AddPendingArticleChecks(ctx context.Context, completedItemID string, articles []PendingArticleCheck) error

+ func (q *Queue) CancelFile(ctx context.Context, msgID goqite.ID) error

+ func (q *Queue) GetArticlesForCheck(ctx context.Context, limit int) ([]PendingArticleCheck, error)

+ func (q *Queue) GetItemsForScriptRetry(ctx context.Context, limit int) ([]CompletedItem, error)

+ func (q *Queue) GetPendingCheckCountForItem(ctx context.Context, completedItemID string) (total int, pending int, failed int, err error)

+ func (q *Queue) MarkArticleCheckFailed(ctx context.Context, id int64) error

+ func (q *Queue) MarkArticleVerified(ctx context.Context, id int64) error

+ func (q *Queue) MarkScriptCompleted(ctx context.Context, itemID string) error

+ func (q *Queue) MarkScriptFailed(ctx context.Context, itemID string, lastError string) error

+ func (q *Queue) UpdateArticleCheckRetry(ctx context.Context, id int64, retryCount int, nextRetryAt time.Time) error

+ func (q *Queue) UpdateCompletedItemVerificationStatus(ctx context.Context, completedItemID string, status string) error

+ func (q *Queue) UpdateScriptStatus(ctx context.Context, itemID string, status string, retryCount int, ...) error

type QueueItem

+ ScriptLastError *string

+ ScriptNextRetryAt *time.Time

+ ScriptRetryCount int

+ ScriptStatus *string

+ VerificationStatus *string

Aug 24, 2025

Changes in this version

+ type PaginatedResult struct

+ CurrentPage int

+ HasNext bool

+ HasPrev bool

+ Items []QueueItem

+ ItemsPerPage int

+ TotalItems int

+ TotalPages int

+ type PaginationParams struct

+ Limit int

+ Order string

+ Page int

+ SortBy string

Aug 4, 2025

Changes in this version

type Queue

+ func (q *Queue) IsPathInQueue(path string) (bool, error)

type QueueInterface

+ IsPathInQueue func(path string) (bool, error)

Aug 1, 2025

Changes in this version

+ type GooseMigrationRunner struct

+ func NewGooseMigrationRunner(db *sql.DB) *GooseMigrationRunner

+ func (gmr *GooseMigrationRunner) EnsureMigrationCompatibility() error

+ func (gmr *GooseMigrationRunner) GetStatus() (*GooseMigrationStatus, error)

+ func (gmr *GooseMigrationRunner) IsLegacyDatabase() (bool, error)

+ func (gmr *GooseMigrationRunner) MigrateDown() error

+ func (gmr *GooseMigrationRunner) MigrateTo(version int64) error

+ func (gmr *GooseMigrationRunner) MigrateUp() error

+ func (gmr *GooseMigrationRunner) RecreateDatabase() error

+ func (gmr *GooseMigrationRunner) Reset() error

+ func (gmr *GooseMigrationRunner) SetupGoose() error

+ type GooseMigrationStatus struct

+ CurrentVersion int64

type Queue

+ func (q *Queue) EnsureMigrationCompatibility() error

+ func (q *Queue) GetMigrationStatus() (*GooseMigrationStatus, error)

+ func (q *Queue) IsLegacyDatabase() (bool, error)

+ func (q *Queue) MigrateTo(version int64) error

+ func (q *Queue) RecreateDatabase() error

+ func (q *Queue) ResetDatabase() error

+ func (q *Queue) RollbackMigration() error

+ func (q *Queue) RunMigrations() error

+ func (q *Queue) SetQueueItemPriorityWithReorder(ctx context.Context, id string, newPriority int) error

+ type QueueInterface interface

+ AddFile func(ctx context.Context, path string, size int64) error

+ ClearQueue func() error

+ EnsureMigrationCompatibility func() error

+ GetMigrationStatus func() (*GooseMigrationStatus, error)

+ GetQueueItems func() ([]QueueItem, error)

+ GetQueueStats func() (map[string]interface{}, error)

+ IsLegacyDatabase func() (bool, error)

+ MigrateTo func(version int64) error

+ RecreateDatabase func() error

+ RemoveFromQueue func(id string) error

+ ResetDatabase func() error

+ RollbackMigration func() error

+ RunMigrations func() error

+ SetQueueItemPriorityWithReorder func(ctx context.Context, id string, newPriority int) error

Jul 11, 2025

Changes in this version

+ const StatusComplete

+ const StatusError

+ const StatusPending

+ const StatusRunning

+ type CompletedItem struct

+ CompletedAt time.Time

+ CreatedAt time.Time

+ ID string

+ JobData []byte

+ NzbPath string

+ Path string

+ Priority int

+ Size int64

+ type FileJob struct

+ CreatedAt time.Time

+ Path string

+ Priority int

+ RetryCount int

+ Size int64

+ type Queue struct

+ func New(ctx context.Context, cfg config.QueueConfig) (*Queue, error)

+ func (q *Queue) AddFile(ctx context.Context, path string, size int64) error

+ func (q *Queue) AddFileWithPriority(ctx context.Context, path string, size int64, priority int) error

+ func (q *Queue) AddFileWithPriorityWithoutDuplicateCheck(ctx context.Context, path string, size int64, priority int) error

+ func (q *Queue) AddFileWithoutDuplicateCheck(ctx context.Context, path string, size int64) error

+ func (q *Queue) ClearCompletedItems() error

+ func (q *Queue) ClearQueue() error

+ func (q *Queue) Close() error

+ func (q *Queue) CompleteFile(ctx context.Context, msgID goqite.ID, nzbPath string, job *FileJob) error

+ func (q *Queue) DebugQueueItem(id string) (map[string]interface{}, error)

+ func (q *Queue) ExtendTimeout(ctx context.Context, msgID goqite.ID, duration time.Duration) error

+ func (q *Queue) GetCompletedItemNzbPath(id string) (string, error)

+ func (q *Queue) GetQueueItems() ([]QueueItem, error)

+ func (q *Queue) GetQueueStats() (map[string]interface{}, error)

+ func (q *Queue) MarkAsError(ctx context.Context, msgID goqite.ID, job *FileJob, errMsg string) error

+ func (q *Queue) ReaddJob(ctx context.Context, job *FileJob) error

+ func (q *Queue) ReceiveFile(ctx context.Context) (*goqite.Message, *FileJob, error)

+ func (q *Queue) RemoveCompletedItem(id string) error

+ func (q *Queue) RemoveErroredItem(id string) error

+ func (q *Queue) RemoveFromQueue(id string) error

+ func (q *Queue) RetryErroredJob(ctx context.Context, id string) error

+ func (q *Queue) SetQueueItemPriority(id string, priority int) error

+ type QueueItem struct

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ ErrorMessage *string

+ FileName string

+ ID string

+ NzbPath *string

+ Path string

+ Priority int

+ RetryCount int

+ Size int64

+ Status string

+ UpdatedAt time.Time