workers

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

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

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"`
	Policy     int     `json:"policy,omitempty"`
}

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

type MiddlewareLogging struct{}

type MiddlewareRetry struct{}

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

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

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