manager

Documentation

Index

• type EnqueueReprocessTorrentsBatchRequest
• type Manager
• type Params
• type PurgeJobsRequest
• type Result
  • func New(params Params) Result

Types

type EnqueueReprocessTorrentsBatchRequest

type EnqueueReprocessTorrentsBatchRequest struct {
	BatchSize           uint
	ChunkSize           uint
	ContentTypes        []model.NullContentType
	Orphans             bool
	ClassifyMode        processor.ClassifyMode
	ClassifierWorkflow  string
	ClassifierFlags     classifier.Flags
	ApisDisabled        bool
	LocalSearchDisabled bool
}

type Manager

type Manager interface {
	PurgeJobs(context.Context, PurgeJobsRequest) error
	EnqueueReprocessTorrentsBatch(context.Context, EnqueueReprocessTorrentsBatchRequest) error
}

type Params

type Params struct {
	fx.In
	Dao lazy.Lazy[*dao.Query]
}

type PurgeJobsRequest

type PurgeJobsRequest struct {
	Queues   []string
	Statuses []model.QueueJobStatus
}

type Result

type Result struct {
	fx.Out
	Manager lazy.Lazy[Manager]
}

func New

func New(params Params) Result