Documentation
¶
Index ¶
Constants ¶
View Source
const MessageName = "process_torrent_batch"
Variables ¶
This section is empty.
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
Click to show internal directories.
Click to hide internal directories.