batch

package
v0.10.1-beta.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 21, 2026 License: MIT Imports: 5 Imported by: 0

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL