queue

Mar 20, 2026

Changes in this version

+ var SchemaPostgres string

+ var SchemaSQLite string

+ func SetupPostgres(ctx context.Context, db *sql.DB) error

+ func SetupWithDialect(ctx context.Context, db *sql.DB, d dialect.Dialect) error

type NewOpts

+ Dialect dialect.Dialect

Nov 18, 2025

Changes in this version

+ func Setup(ctx context.Context, db *sql.DB) error

+ type ID string

+ type Interface interface

+ Delete func(context.Context, ID) error

+ Extend func(context.Context, ID, time.Duration) error

+ MaxReceive func() int

+ MoveToDeadLetter func(context.Context, ID, string, string, string) error

+ Receive func(context.Context) (*Message, error)

+ ReceiveAndWait func(context.Context, time.Duration) (*Message, error)

+ Send func(context.Context, Message) error

+ SendAndGetID func(context.Context, Message) (ID, error)

+ SendTx func(context.Context, *sql.Tx, Message) error

+ Timeout func() time.Duration

+ type Message struct

+ Body []byte

+ Delay time.Duration

+ ID ID

+ Received int

+ type NewOpts struct

+ DB *sql.DB

+ Logger logger.StandardLogger

+ MaxReceive int

+ Name string

+ Timeout time.Duration

+ type Queue struct

+ func New(opts NewOpts) (*Queue, error)

+ func (q *Queue) Delete(ctx context.Context, id ID) error

+ func (q *Queue) Extend(ctx context.Context, id ID, delay time.Duration) error

+ func (q *Queue) MaxReceive() int

+ func (q *Queue) MoveToDeadLetter(ctx context.Context, id ID, jobName, failureReason, errorMsg string) error

+ func (q *Queue) Receive(ctx context.Context) (*Message, error)

+ func (q *Queue) ReceiveAndWait(ctx context.Context, interval time.Duration) (*Message, error)

+ func (q *Queue) Send(ctx context.Context, m Message) error

+ func (q *Queue) SendAndGetID(ctx context.Context, m Message) (ID, error)

+ func (q *Queue) SendTx(ctx context.Context, tx *sql.Tx, m Message) error

+ func (q *Queue) Timeout() time.Duration