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
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

schema

package

Go to main page

Versions in this module

v1

v1.1.8

Mar 24, 2026

v1.1.7

Mar 24, 2026

v1.1.6

Mar 24, 2026

v1.1.5

Mar 23, 2026

v1.1.4

Mar 23, 2026

v1.1.3

Mar 10, 2026

v1.1.2

Jan 13, 2026

v1.1.1

Jan 11, 2026

Changes in this version

+ const DefaultNamespace

+ const TopicQueueInsert

v1.1.0

Jan 10, 2026

Changes in this version

+ const CleanupInterval

+ const CleanupTickerName

+ const QueueListLimit

+ const SchemaName

+ const TaskPeriod

+ const TickerListLimit

+ const TickerPeriod

+ type NamespaceList struct

+ Body []string

+ Count uint64

+ func (l *NamespaceList) Scan(row pg.Row) error

+ func (l *NamespaceList) ScanCount(row pg.Row) error

+ func (l NamespaceList) String() string

+ type NamespaceListRequest struct

+ func (l NamespaceListRequest) Select(bind *pg.Bind, op pg.Op) (string, error)

+ type Queue struct

+ Namespace string

+ func (q *Queue) Scan(row pg.Row) error

+ func (q Queue) String() string

+ type QueueCleanRequest struct

+ Queue string

+ func (q QueueCleanRequest) Select(bind *pg.Bind, op pg.Op) (string, error)

+ type QueueCleanResponse struct

+ Body []Task

+ func (l *QueueCleanResponse) Scan(row pg.Row) error

+ func (q QueueCleanResponse) String() string

+ type QueueList struct

+ Body []Queue

+ Count uint64

+ func (l *QueueList) Scan(row pg.Row) error

+ func (l *QueueList) ScanCount(row pg.Row) error

+ func (q QueueList) String() string

+ type QueueListRequest struct

+ func (l QueueListRequest) Select(bind *pg.Bind, op pg.Op) (string, error)

+ type QueueMeta struct

+ Queue string

+ Retries *uint64

+ RetryDelay *time.Duration

+ TTL *time.Duration

+ func (q QueueMeta) Insert(bind *pg.Bind) (string, error)

+ func (q QueueMeta) String() string

+ func (q QueueMeta) Update(bind *pg.Bind) error

+ type QueueName string

+ func (q QueueName) Select(bind *pg.Bind, op pg.Op) (string, error)

+ type QueueStatus struct

+ Count uint64

+ Queue string

+ Status string

+ func (q QueueStatus) String() string

+ func (s *QueueStatus) Scan(row pg.Row) error

+ type QueueStatusRequest struct

+ func (l QueueStatusRequest) Select(bind *pg.Bind, op pg.Op) (string, error)

+ type QueueStatusResponse struct

+ Body []QueueStatus

+ func (l *QueueStatusResponse) Scan(row pg.Row) error

+ type Task struct

+ CreatedAt *time.Time

+ DiesAt *time.Time

+ FinishedAt *time.Time

+ Id uint64

+ Namespace string

+ Queue string

+ Result any

+ Retries *uint64

+ StartedAt *time.Time

+ Worker *string

+ func (t *Task) Scan(row pg.Row) error

+ func (t Task) String() string

+ type TaskId uint64

+ func (t *TaskId) Scan(row pg.Row) error

+ func (t TaskId) Select(bind *pg.Bind, op pg.Op) (string, error)

+ type TaskList struct

+ Body []TaskWithStatus

+ Count uint64

+ func (l *TaskList) Scan(row pg.Row) error

+ func (l *TaskList) ScanCount(row pg.Row) error

+ func (t TaskList) String() string

+ type TaskListRequest struct

+ Status string

+ func (l TaskListRequest) Select(bind *pg.Bind, op pg.Op) (string, error)

+ type TaskMeta struct

+ DelayedAt *time.Time

+ Payload any

+ func (t TaskMeta) Insert(bind *pg.Bind) (string, error)

+ func (t TaskMeta) String() string

+ func (t TaskMeta) Update(bind *pg.Bind) error

+ type TaskRelease struct

+ Fail bool

+ Id uint64

+ Result any

+ func (t TaskRelease) Select(bind *pg.Bind, op pg.Op) (string, error)

+ type TaskRetain struct

+ Queues []string

+ Worker string

+ func (t TaskRetain) Select(bind *pg.Bind, op pg.Op) (string, error)

+ type TaskWithStatus struct

+ Status string

+ func (t *TaskWithStatus) Scan(row pg.Row) error

+ func (t TaskWithStatus) String() string

+ type Ticker struct

+ Namespace string

+ Ts *time.Time

+ func (r *Ticker) Scan(row pg.Row) error

+ func (t Ticker) String() string

+ type TickerList struct

+ Body []Ticker

+ Count uint64

+ func (l *TickerList) Scan(row pg.Row) error

+ func (l *TickerList) ScanCount(row pg.Row) error

+ func (t TickerList) String() string

+ type TickerListRequest struct

+ func (t TickerListRequest) Select(bind *pg.Bind, op pg.Op) (string, error)

+ type TickerMeta struct

+ Interval *time.Duration

+ Payload json.RawMessage

+ Ticker string

+ func (t TickerMeta) String() string

+ func (w TickerMeta) Insert(bind *pg.Bind) (string, error)

+ func (w TickerMeta) Update(bind *pg.Bind) error

+ type TickerName string

+ func (q TickerName) Select(bind *pg.Bind, op pg.Op) (string, error)

+ type TickerNext struct

+ func (t TickerNext) Select(bind *pg.Bind, op pg.Op) (string, error)