Skip to content
Switch branches/tags
Go to file
Cannot retrieve contributors at this time
package proc
import (
// Config is processor configuration.
type Config struct {
// NewConfig creates a default processor configuration.
func NewConfig() *Config {
return &Config{}
// Processor encapsulates a set of top-level business logic routines.
type Processor struct {
conf *Config
db *reform.DB
queue job.Queue
// NewProcessor creates a new processor.
func NewProcessor(
conf *Config, db *reform.DB, queue job.Queue) *Processor {
return &Processor{
conf: conf,
db: db,
queue: queue,
// Processor-specific errors.
var (
ErrBadServiceStatus = errors.New("bad service status")
ErrActiveJobsExist = errors.New("active jobs exist")
ErrSameJobExists = errors.New("same job exists")