Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrAlreadyProcessing = errors.New("already processing") ErrDuplicatedJob = errors.New("duplicated job") ErrHandlerNotFound = errors.New("job handler not found") ErrQueueClosed = errors.New("queue closed") )
Errors.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
CollectJobs uint // Number of jobs to process for collect-iteration.
CollectPeriod uint // Collect-iteration period, in milliseconds.
WorkerBufLen uint // Worker buffer length.
Workers uint // Number of workers, 0 means number of CPUs.
TypeConfig // Default type configuration.
Types map[string]TypeConfig // Type-specific overrides.
}
Config is a job queue configuration.
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue is a job processing queue.
func (*Queue) Close ¶
func (q *Queue) Close()
Close causes currently running Process() function to exit.
type TypeConfig ¶
type TypeConfig struct {
TryLimit uint8 // Default number of tries to complete job.
TryPeriod uint // Default retry period, in milliseconds.
Duplicated bool // Whether do or do not check for duplicates.
}
TypeConfig is a configuration for specific job type.
Source Files
Click to show internal directories.
Click to hide internal directories.