memory

Documentation

Index

• type InMemoryStore
  • func NewInMemoryStore(queueName string, cfg config.Config, logger logger.Logger) *InMemoryStore
  • func (store *InMemoryStore) Ack(queueName string, payload string) error
  • func (store *InMemoryStore) DequeueMetrics(queueName string) (config.JobMetrics, error)
  • func (store *InMemoryStore) EnqueueMetrics(metrics config.JobMetrics) error
  • func (store *InMemoryStore) GetDbConnection() interface{}
  • func (store *InMemoryStore) IsHealthy() bool
  • func (store *InMemoryStore) Pop(queueName string) (job.JobContext, error)
  • func (store *InMemoryStore) Push(queueName string, jb job.Job, delay ...time.Duration) error
  • func (store *InMemoryStore) PushBatch(queueName string, jobs []job.Job, delay ...time.Duration) error
  • func (store *InMemoryStore) Retry(j job.Job, delay time.Duration) error
  • func (store *InMemoryStore) RetryJobWithMetadata(queueName string, rJob job.JobContext, delay ...time.Duration) error

Types

type InMemoryStore

type InMemoryStore struct {
	Queue  map[string]*queue
	Config config.Config
	Logger logger.Logger
	// contains filtered or unexported fields
}

func NewInMemoryStore

func NewInMemoryStore(queueName string, cfg config.Config, logger logger.Logger) *InMemoryStore

func (*InMemoryStore) Ack

func (store *InMemoryStore) Ack(queueName string, payload string) error

func (*InMemoryStore) DequeueMetrics

func (store *InMemoryStore) DequeueMetrics(queueName string) (config.JobMetrics, error)

func (*InMemoryStore) EnqueueMetrics

func (store *InMemoryStore) EnqueueMetrics(metrics config.JobMetrics) error

func (*InMemoryStore) GetDbConnection

func (store *InMemoryStore) GetDbConnection() interface{}

func (*InMemoryStore) IsHealthy

func (store *InMemoryStore) IsHealthy() bool

func (*InMemoryStore) Pop

func (store *InMemoryStore) Pop(queueName string) (job.JobContext, error)

func (*InMemoryStore) Push

func (store *InMemoryStore) Push(queueName string, jb job.Job, delay ...time.Duration) error

func (*InMemoryStore) PushBatch

func (store *InMemoryStore) PushBatch(queueName string, jobs []job.Job, delay ...time.Duration) error

func (*InMemoryStore) Retry

func (store *InMemoryStore) Retry(j job.Job, delay time.Duration) error

func (*InMemoryStore) RetryJobWithMetadata

func (store *InMemoryStore) RetryJobWithMetadata(queueName string, rJob job.JobContext, delay ...time.Duration) error