batch

Documentation

Index

• Constants
• func NewQueueJob(msg MessageParams, options ...model.QueueJobOption) (model.QueueJob, error)
• type MessageParams
  • func (p MessageParams) ApisDisabled() bool

Constants

const MessageName = "process_torrent_batch"

Functions

func NewQueueJob

func NewQueueJob(msg MessageParams, options ...model.QueueJobOption) (model.QueueJob, error)

Types

type MessageParams

type MessageParams struct {
	InfoHashGreaterThan protocol.ID
	UpdatedBefore       time.Time
	ClassifyMode        processor.ClassifyMode
	ClassifierWorkflow  string
	ClassifierFlags     classifier.Flags
	ChunkSize           uint
	BatchSize           uint
	ContentTypes        []model.NullContentType
	Orphans             bool
}

func (MessageParams) ApisDisabled

func (p MessageParams) ApisDisabled() bool