Versions in this module Expand all Collapse all v1 v1.118.0 Aug 1, 2026 Changes in this version + const NotifyChannel + type Listener struct + func NewListener(dsn string, notifiers ...notifier) *Listener + func (l *Listener) Start(_ context.Context) error + func (l *Listener) Stop() + type PostgresStore struct + func NewPostgresStore(db *sql.DB) *PostgresStore + func (s *PostgresStore) ClaimDigest(ctx context.Context, lease time.Duration) ([]notification.Notification, error) + func (s *PostgresStore) ClaimImmediate(ctx context.Context, lease time.Duration) (*notification.Notification, error) + func (s *PostgresStore) Count(ctx context.Context, filter notification.HistoryFilter) (int, error) + func (s *PostgresStore) CountsByStatus(ctx context.Context, filter notification.HistoryFilter) (map[string]int, error) + func (s *PostgresStore) Enqueue(ctx context.Context, n notification.Notification) error + func (s *PostgresStore) Fail(ctx context.Context, ids []int64, sendErr string) error + func (s *PostgresStore) List(ctx context.Context, filter notification.HistoryFilter) ([]notification.Notification, error) + func (s *PostgresStore) MarkSent(ctx context.Context, ids []int64) error + func (s *PostgresStore) PurgeOld(ctx context.Context, resolvedRetention, pendingTTL time.Duration) (int64, error) + func (s *PostgresStore) Retry(ctx context.Context, ids []int64, sendErr string, backoff time.Duration) error
Go to main page