job

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.
}

type Handler func(j *data.Job) error

type HandlerMap map[string]Handler

type Queue interface {
	Add(tx *reform.TX, j *data.Job) error
	Process() error
	Close()
	Subscribe(subKeys []string, subID string, subFunc SubFunc) error
	Unsubscribe(subKeys []string, subID string) error
}

type QueueMock func(method int, tx *reform.TX, job *data.Job,
	relatedIDs []string, subID string, subFunc SubFunc) error

type SubFunc func(job *data.Job, result error)

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.
	FirstStartDelay uint  // Default first run delay after job added, in milliseconds.
}