workers

type Action interface {
	Call(queue string, message *Msg, next func() error) error
}

type Args struct {
	// contains filtered or unexported fields
}

type ConfigureOpts struct {
	// RedisURL is a redis schemed URL as understood by redigo:
	// https://godoc.org/github.com/garyburd/redigo/redis#DialURL
	RedisURL string

	// ProcessID uniquely identifies this process. Used for uncoordinated reliable processing of messages.
	ProcessID string

	// MaxIdle is the maximum number of idle connections to keep in the redis connection pool.
	MaxIdle int

	// PoolSize is the maximum number of connections allowed by the redis conneciton pool.
	PoolSize int

	// PollInterval is how often we should poll for scheduled jobs.
	PollInterval int

	// Namespace is the namespace to use for redis keys.
	Namespace string

	RedisPool *redis.Pool
}

type EnqueueData struct {
	Queue      string      `json:"queue,omitempty"`
	Class      string      `json:"class"`
	Args       interface{} `json:"args"`
	Jid        string      `json:"jid"`
	EnqueuedAt float64     `json:"enqueued_at"`
	EnqueueOptions
}

type EnqueueOptions struct {
	RetryCount int     `json:"retry_count,omitempty"`
	Retry      bool    `json:"retry,omitempty"`
	At         float64 `json:"at,omitempty"`
}

type Fetcher interface {
	Queue() string
	Fetch()
	Acknowledge(*Msg)
	Ready() chan bool
	FinishedWork() chan bool
	Messages() chan *Msg
	Close()
	Closed() bool
	InprogressQueue() string
}

type GoWorkers interface {
	Run()
	Start()
	Quit()
	WaitForExit()
	ResetManagers() error

	Process(queue string, job jobFunc, concurrency int, mids ...Action)

	Enqueue(queue, class string, args interface{}) (string, error)
	EnqueueIn(queue, class string, in float64, args interface{}) (string, error)
	EnqueueAt(queue, class string, at time.Time, args interface{}) (string, error)
	EnqueueWithOptions(queue, class string, args interface{}, opts EnqueueOptions) (string, error)

	BeforeStart(f func())
	DuringDrain(f func())

	Ping() error
	QueueStats() (queueStats *QueueStats, err error)

	Namespace() string
	NamespacedKey(keys ...string) string
	TrimKeyNamespace(key string) string
}

type MiddlewareLogging struct{}

type MiddlewareRetry struct {
	// contains filtered or unexported fields
}

type MiddlewareStats struct {
	// contains filtered or unexported fields
}

type Middlewares struct {
	// contains filtered or unexported fields
}

type Msg struct {
	// contains filtered or unexported fields
}

type QueueDepth struct {
	Name       string
	InProgress int
	Queued     int
}

type QueueStats struct {
	Queues     []*QueueDepth
	RetryDepth int
}

type Workers struct {
	// contains filtered or unexported fields
}

type WorkersLogger interface {
	Println(...interface{})
	Printf(string, ...interface{})
}