Versions in this module Expand all Collapse all v0 v0.1.1 Apr 30, 2025 v0.1.0 Apr 28, 2025 Changes in this version + type Config struct + DB int + Host string + Password string + Port int + type Handler func(job *Job) error + type Job struct + Attempts int + CreatedAt time.Time + Data map[string]interface{} + ID string + MaxRetries int + Type string + type Queue struct + func New(host string, password string, db int) (*Queue, error) + func (q *Queue) Enqueue(jobType string, data map[string]interface{}, maxRetries int) (*Job, error) + func (q *Queue) IsRunning() bool + func (q *Queue) RegisterHandler(jobType string, handler Handler) + func (q *Queue) Shutdown() error + func (q *Queue) Start() + func (q *Queue) Stop()
Go to main page