Versions in this module Expand all Collapse all v1 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)
Go to main page