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 `json:"InfoHashGreaterThan,omitempty"`
UpdatedBefore time.Time `json:"UpdatedBefore,omitempty"`
ClassifyMode processor.ClassifyMode `json:"ClassifyMode,omitempty"`
ClassifierWorkflow string `json:"ClassifierWorkflow,omitempty"`
ClassifierFlags classifier.Flags `json:"ClassifierFlags,omitempty"`
ChunkSize uint `json:"ChunkSize,omitempty"`
BatchSize uint `json:"BatchSize,omitempty"`
ContentTypes []model.NullContentType `json:"ContentTypes,omitempty"`
Orphans bool `json:"Orphans,omitempty"`
}
func (MessageParams) ApisDisabled ¶
func (p MessageParams) ApisDisabled() bool
Click to show internal directories.
Click to hide internal directories.