gokiq

type ClientConfig struct {
	RedisPool      *redis.Pool
	RedisNamespace string

	TestMode  bool
	TestQueue []interface{}
	// contains filtered or unexported fields
}

type Job struct {
	Type  string           `json:"class"`
	Args  *json.RawMessage `json:"args"`
	Queue string           `json:"queue,omitempty"`
	ID    string           `json:"jid"`

	Retry interface{} `json:"retry"` // can be int (number of retries) or bool (true means default)

	MaxRetries   int    `json:"-"`
	RetryCount   int    `json:"retry_count"`
	ErrorMessage string `json:"error_message,omitempty"`
	ErrorType    string `json:"error_class,omitempty"`
	RetriedAt    string `json:"retried_at,omitempty"`
	FailedAt     string `json:"failed_at,omitempty"`

	StartTime time.Time `json:"-"`
}

type JobConfig struct {
	Name       string
	Queue      string
	MaxRetries int
	At         time.Time
}

type PanicError struct {
	Err   interface{}
	Stack []StackFrame
}

type QueueConfig map[string]int

type ReportableErrorChecker interface {
	ReportableError(error) bool
}

type StackFrame struct {
	PC   uintptr
	File string
	Line int
}

type UnknownWorkerError struct{ Type string }

type WorkerConfig struct {
	inject.Injector
	RedisPool      *redis.Pool
	RedisNamespace string
	Queues         QueueConfig
	WorkerCount    int
	PollInterval   time.Duration
	StopTimeout    time.Duration
	ReportError    func(error, *Job)

	sync.RWMutex // R is locked by Run() and scheduler(), W is locked by quitHandler() when it receives a signal
	// contains filtered or unexported fields
}