postgres

package

v0.1.0 Latest Latest Go to latest Published: Nov 10, 2026 License: AGPL-3.0 Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var Schema string

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

type Repository struct{ DB *sql.DB }

func (r *Repository) CheckRuntime(ctx context.Context) error

func (r *Repository) Cleanup(ctx context.Context, before time.Time, limit int) (int64, error)

func (r *Repository) Consume(ctx context.Context, d n.Event, hash string, now time.Time, window time.Duration) (n.Result, error)

func (r *Repository) List(ctx context.Context, owner string, c n.Cursor, limit int) ([]n.Notification, error)

func (r *Repository) MarkAllRead(ctx context.Context, owner string, now time.Time) error

func (r *Repository) MarkRead(ctx context.Context, owner, id string, now time.Time) error

func (r *Repository) Preferences(ctx context.Context, owner string, value *bool) (n.Preferences, error)

func (r *Repository) Unread(ctx context.Context, owner string) (int64, error)