storage

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

type Retries struct {
	TotalRetryCount int64
	RetryJobs       []RetryJobStats
}

type RetryJobStats struct {
	Class        string
	ErrorMessage string
	FailedAt     string
	JobID        string
	Queue        string
	RetryCount   int64
}

type Stats struct {
	Processed  int64
	Failed     int64
	RetryCount int64
	Enqueued   map[string]int64
}

type StorageError string

type Store interface {

	// General queue operations
	CreateQueue(queue string) error
	ListMessages(queue string) ([]string, error)
	AcknowledgeMessage(queue string, message string) error
	EnqueueMessage(queue string, priority float64, message string) error
	EnqueueMessageNow(queue string, message string) error
	DequeueMessage(queue string, inprogressQueue string, timeout time.Duration) (string, error)

	// Special purpose queue operations
	EnqueueScheduledMessage(priority float64, message string) error
	DequeueScheduledMessage(priority float64) (string, error)

	EnqueueRetriedMessage(priority float64, message string) error
	DequeueRetriedMessage(priority float64) (string, error)

	// Stats
	IncrementStats(metric string) error
	GetAllStats(queues []string) (*Stats, error)

	// Retries
	GetAllRetries() (*Retries, error)
}