Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

queue

package

Go to main page

Versions in this module

v0

v0.2.0

Sep 9, 2026

Changes in this version

+ var ErrEmptyType = errors.New("queue: task type must not be empty")

+ type ArchiveStats struct

+ Archived int64

+ Hot int64

+ Watermark int64

type Filter

+ Offset int

+ Query string

+ SeverityOrder bool

+ Since *time.Time

+ Sort string

+ type PostgresStore struct

+ func OpenPostgres(ctx context.Context, dsn string, maxConns int32) (*PostgresStore, error)

+ func (s *PostgresStore) Cancel(ctx context.Context, id task.ID, reason string) error

+ func (s *PostgresStore) CancelOwned(ctx context.Context, id task.ID, owner string) error

+ func (s *PostgresStore) CancelRequested(ctx context.Context, id task.ID) (bool, error)

+ func (s *PostgresStore) CancelRunning(ctx context.Context, id task.ID, reason string) error

+ func (s *PostgresStore) ClaimDue(ctx context.Context, owner string, lease time.Duration) (task.Task, error)

+ func (s *PostgresStore) Close() error

+ func (s *PostgresStore) Complete(ctx context.Context, id task.ID, owner string, result json.RawMessage) error

+ func (s *PostgresStore) CountFacts(ctx context.Context, ftype journal.FactType, since time.Time) (int64, error)

+ func (s *PostgresStore) CountTasks(ctx context.Context, f Filter) (int, error)

+ func (s *PostgresStore) Enqueue(ctx context.Context, n task.New) (task.Task, error)

+ func (s *PostgresStore) Facts(ctx context.Context, after int64, limit int) ([]journal.Fact, error)

+ func (s *PostgresStore) FactsForTask(ctx context.Context, id string, limit int) ([]journal.Fact, error)

+ func (s *PostgresStore) Fail(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ func (s *PostgresStore) FailPermanent(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ func (s *PostgresStore) Get(ctx context.Context, id task.ID) (task.Task, error)

+ func (s *PostgresStore) HeadSeq(ctx context.Context) (int64, error)

+ func (s *PostgresStore) Heartbeat(ctx context.Context, id task.ID, owner string, extend time.Duration) error

+ func (s *PostgresStore) LastFacts(ctx context.Context, limit int) ([]journal.Fact, error)

+ func (s *PostgresStore) List(ctx context.Context, f Filter) ([]task.Task, error)

+ func (s *PostgresStore) ListWatermarks(ctx context.Context) ([]WatermarkEntry, error)

+ func (s *PostgresStore) MarkOrphaned(ctx context.Context, cutoff time.Time) (int, error)

+ func (s *PostgresStore) ProjectCounts(ctx context.Context) (map[string]map[task.Status]int, error)

+ func (s *PostgresStore) Requeue(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ func (s *PostgresStore) RescueDead(ctx context.Context, id task.ID, maxAttempts int) error

+ func (s *PostgresStore) SaveWatermark(ctx context.Context, consumer string, seq int64) error

+ func (s *PostgresStore) SetWatermark(ctx context.Context, consumer string, seq int64) error

+ func (s *PostgresStore) StatusCounts(ctx context.Context) (map[task.Status]int, error)

+ func (s *PostgresStore) Watermark(ctx context.Context, consumer string) (int64, bool, error)

+ type RequeueEvidence struct

+ Reason string

+ RetryIn int64

type SQLiteStore

+ func (s *SQLiteStore) ArchiveFactsBefore(ctx context.Context, cutoff int64) (int64, error)

+ func (s *SQLiteStore) ArchiveSummary(ctx context.Context) (ArchiveStats, error)

+ func (s *SQLiteStore) CancelOwned(ctx context.Context, id task.ID, owner string) error

+ func (s *SQLiteStore) CancelRequested(ctx context.Context, id task.ID) (bool, error)

+ func (s *SQLiteStore) CancelRunning(ctx context.Context, id task.ID, reason string) error

+ func (s *SQLiteStore) CountFacts(ctx context.Context, ftype journal.FactType, since time.Time) (int64, error)

+ func (s *SQLiteStore) CountTasks(ctx context.Context, f Filter) (int, error)

+ func (s *SQLiteStore) FactsForTask(ctx context.Context, id string, limit int) ([]journal.Fact, error)

+ func (s *SQLiteStore) HeadSeq(ctx context.Context) (int64, error)

+ func (s *SQLiteStore) LastFacts(ctx context.Context, limit int) ([]journal.Fact, error)

+ func (s *SQLiteStore) ListWatermarks(ctx context.Context) ([]WatermarkEntry, error)

+ func (s *SQLiteStore) MarkOrphaned(ctx context.Context, cutoff time.Time) (int, error)

+ func (s *SQLiteStore) ProjectCounts(ctx context.Context) (map[string]map[task.Status]int, error)

+ func (s *SQLiteStore) Requeue(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ func (s *SQLiteStore) SaveWatermark(ctx context.Context, consumer string, seq int64) error

+ func (s *SQLiteStore) SetWatermark(ctx context.Context, consumer string, seq int64) error

+ func (s *SQLiteStore) StatusCounts(ctx context.Context) (map[task.Status]int, error)

+ func (s *SQLiteStore) Watermark(ctx context.Context, consumer string) (int64, bool, error)

type Store

+ CancelOwned func(ctx context.Context, id task.ID, owner string) error

+ CancelRequested func(ctx context.Context, id task.ID) (bool, error)

+ CancelRunning func(ctx context.Context, id task.ID, reason string) error

+ CountFacts func(ctx context.Context, ftype journal.FactType, since time.Time) (int64, error)

+ CountTasks func(ctx context.Context, f Filter) (int, error)

+ FactsForTask func(ctx context.Context, id string, limit int) ([]journal.Fact, error)

+ HeadSeq func(ctx context.Context) (int64, error)

+ LastFacts func(ctx context.Context, limit int) ([]journal.Fact, error)

+ MarkOrphaned func(ctx context.Context, cutoff time.Time) (int, error)

+ ProjectCounts func(ctx context.Context) (map[string]map[task.Status]int, error)

+ Requeue func(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ SaveWatermark func(ctx context.Context, consumer string, seq int64) error

+ StatusCounts func(ctx context.Context) (map[task.Status]int, error)

+ Watermark func(ctx context.Context, consumer string) (seq int64, exists bool, err error)

+ type WatermarkEntry struct

+ Consumer string

+ Seq int64

+ UpdatedAt int64

v0.1.0

Sep 6, 2026

Changes in this version

+ var ErrNoTaskDue = errors.New("queue: no due task")

+ type Filter struct

+ Limit int

+ Project *string

+ Status *task.Status

+ Type *string

+ type Queue struct

+ func New(s Store) *Queue

+ func (q *Queue) Enqueue(ctx context.Context, n task.New) (task.Task, error)

+ type SQLiteStore struct

+ func OpenSQLite(path string, opts ...StoreOption) (*SQLiteStore, error)

+ func (s *SQLiteStore) Cancel(ctx context.Context, id task.ID) error

+ func (s *SQLiteStore) ClaimDue(ctx context.Context, owner string, lease time.Duration) (task.Task, error)

+ func (s *SQLiteStore) Close() error

+ func (s *SQLiteStore) Complete(ctx context.Context, id task.ID, owner string, result json.RawMessage) error

+ func (s *SQLiteStore) Enqueue(ctx context.Context, n task.New) (task.Task, error)

+ func (s *SQLiteStore) Facts(ctx context.Context, after int64) ([]journal.Fact, error)

+ func (s *SQLiteStore) Fail(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ func (s *SQLiteStore) FailPermanent(ctx context.Context, id task.ID, owner string, errText string) error

+ func (s *SQLiteStore) Get(ctx context.Context, id task.ID) (task.Task, error)

+ func (s *SQLiteStore) Heartbeat(ctx context.Context, id task.ID, owner string, extend time.Duration) error

+ func (s *SQLiteStore) List(ctx context.Context, f Filter) ([]task.Task, error)

+ func (s *SQLiteStore) RescueDead(ctx context.Context, id task.ID, maxAttempts int) error

+ type Store interface

+ Cancel func(ctx context.Context, id task.ID) error

+ ClaimDue func(ctx context.Context, owner string, lease time.Duration) (task.Task, error)

+ Close func() error

+ Complete func(ctx context.Context, id task.ID, owner string, result json.RawMessage) error

+ Enqueue func(ctx context.Context, n task.New) (task.Task, error)

+ Facts func(ctx context.Context, after int64) ([]journal.Fact, error)

+ Fail func(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ FailPermanent func(ctx context.Context, id task.ID, owner string, errText string) error

+ Get func(ctx context.Context, id task.ID) (task.Task, error)

+ Heartbeat func(ctx context.Context, id task.ID, owner string, extend time.Duration) error

+ List func(ctx context.Context, f Filter) ([]task.Task, error)

+ RescueDead func(ctx context.Context, id task.ID, maxAttempts int) error

+ type StoreOption func(*storeOptions)

+ func WithProjectExclusivity() StoreOption

Other modules containing this package

github.com/larsartmann/go-taskqueue/internal/queue