sqlite

Apr 8, 2026

Changes in this version

+ var Schema string

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

+ type Service struct

+ func New(db *sql.DB, opts ...queue.QueueOption) *Service

+ func (s *Service) Close(_ context.Context) error

+ func (s *Service) Enqueue(ctx context.Context, topicName string, payload []byte, ...) error

+ func (s *Service) Subscribe(ctx context.Context, topicName string, h queue.Handler, ...) (queue.Consumer, error)