database

package

v0.2.5 Latest Latest Go to latest Published: Jan 27, 2026 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type DatabaseStore struct {
	Db *sql.DB
	// contains filtered or unexported fields
}

func NewDatabaseStore(cfg config.DatabaseConfig, log logger.Logger, config config.Config) (*DatabaseStore, error)

NewDatabaseStore creates a new database store with the given configuration

func (ds *DatabaseStore) Ack(queueName string, jobID string) error

Ack acknowledges that a job was processed successfully

func (ds *DatabaseStore) DequeueMetrics(queueName string) (config.JobMetrics, error)

DequeueMetrics retrieves job metrics from the metrics queue and then deletes them

func (ds *DatabaseStore) EnqueueMetrics(metrics config.JobMetrics) error

EnqueueMetrics adds job metrics to the metrics queue

func (ds *DatabaseStore) GetDbConnection() interface{}

func (ds *DatabaseStore) IsHealthy() bool

IsHealthy returns whether the database connection is healthy

func (ds *DatabaseStore) Pop(queueName string) (job.JobContext, error)

Pop retrieves a job from the queue

func (ds *DatabaseStore) Push(queueName string, job job.Job, delay ...time.Duration) error

Push adds a single job to the queue

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

PushBatch adds multiple jobs to the queue in a single call

func (ds *DatabaseStore) Retry(j job.Job, delay time.Duration) error

Retry adds a job back to the queue for retry

func (ds *DatabaseStore) RetryJobWithMetadata(queueName string, jobCtx job.JobContext, delay ...time.Duration) error

RetryJobWithMetadata adds a job with its metadata back to the queue for retry

Path	Synopsis
migrations