memory

package

v0.2.3-danish Latest Latest Go to latest Published: Jan 12, 2026 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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