storage

Jan 24, 2020

Changes in this version

+ const NoMessage

+ const RetryKey

+ const ScheduledJobsKey

+ type Msg struct

+ type Retries struct

+ RetryJobs []RetryJobStats

+ TotalRetryCount int64

+ type RetryJobStats struct

+ Class string

+ ErrorMessage string

+ FailedAt string

+ JobID string

+ Queue string

+ RetryCount int64

+ type Stats struct

+ Enqueued map[string]int64

+ Failed int64

+ Processed int64

+ RetryCount int64

+ type StorageError string

+ func (e StorageError) Error() string

+ type Store interface

+ AcknowledgeMessage func(queue string, message string) error

+ CreateQueue func(queue string) error

+ DequeueMessage func(queue string, inprogressQueue string, timeout time.Duration) (string, error)

+ DequeueRetriedMessage func(priority float64) (string, error)

+ DequeueScheduledMessage func(priority float64) (string, error)

+ EnqueueMessage func(queue string, priority float64, message string) error

+ EnqueueMessageNow func(queue string, message string) error

+ EnqueueRetriedMessage func(priority float64, message string) error

+ EnqueueScheduledMessage func(priority float64, message string) error

+ GetAllRetries func() (*Retries, error)

+ GetAllStats func(queues []string) (*Stats, error)

+ IncrementStats func(metric string) error

+ ListMessages func(queue string) ([]string, error)

+ func NewRedisStore(namespace string, client *redis.Client) Store