postgres

Documentation

Index

• type Store
  • func NewStore(pool *pgxpool.Pool) *Store
  • func TestStore(ctx context.Context, t testing.TB) *Store
  • func (s *Store) Created(ctx context.Context) ([]uuid.UUID, error)
  • func (s *Store) DeleteNotifications(ctx context.Context, id uuid.UUID) error
  • func (s *Store) Deleted(ctx context.Context) ([]uuid.UUID, error)
  • func (s *Store) Failed(ctx context.Context) ([]uuid.UUID, error)
  • func (s *Store) Notifications(ctx context.Context, id uuid.UUID, page *notifier.Page) ([]notifier.Notification, notifier.Page, error)
  • func (s *Store) PutNotifications(ctx context.Context, opts notifier.PutOpts) error
  • func (s *Store) PutReceipt(ctx context.Context, updater string, r notifier.Receipt) error
  • func (s *Store) Receipt(ctx context.Context, id uuid.UUID) (notifier.Receipt, error)
  • func (s *Store) ReceiptByUOID(ctx context.Context, id uuid.UUID) (notifier.Receipt, error)
  • func (s *Store) SetDeleted(ctx context.Context, id uuid.UUID) error
  • func (s *Store) SetDelivered(ctx context.Context, id uuid.UUID) error
  • func (s *Store) SetDeliveryFailed(ctx context.Context, id uuid.UUID) error

Types

type Store

type Store struct {
	// contains filtered or unexported fields
}

Store implements the notifier.Store interface

func NewStore

func NewStore(pool *pgxpool.Pool) *Store

func TestStore

func TestStore(ctx context.Context, t testing.TB) *Store

func (*Store) Created

func (s *Store) Created(ctx context.Context) ([]uuid.UUID, error)

Created returns a slice of notification ids in created status

func (*Store) DeleteNotifications

func (s *Store) DeleteNotifications(ctx context.Context, id uuid.UUID) error

DeleteNotifications garbage collects all notifications associated with a notification id.

Normally Receipter.SetDeleted will be issues first, however application logic may decide to gc notifications which have not been set deleted after some period of time, thus this condition should not be checked.

func (*Store) Deleted

func (s *Store) Deleted(ctx context.Context) ([]uuid.UUID, error)

Deleted returns a slice of notification ids in deleted status

func (*Store) Failed

func (s *Store) Failed(ctx context.Context) ([]uuid.UUID, error)

Failed returns a slice of notification ids in failed status

func (*Store) Notifications

func (s *Store) Notifications(ctx context.Context, id uuid.UUID, page *notifier.Page) ([]notifier.Notification, notifier.Page, error)

Notifications retrieves the list of notifications associated with a notification id

func (*Store) PutNotifications

func (s *Store) PutNotifications(ctx context.Context, opts notifier.PutOpts) error

PutNotifications persists the provided notifications and associates them with the provided notification id

PutNotifications must update the latest update operation for the provided updater in such a way that UpdateOperation returns the the provided update operation id when queried with the updater name

PutNotifications must create a Receipt with status created status on successful persistence of notifications in such a way that Receipter.Created() returns the persisted notification id.

func (*Store) PutReceipt

func (s *Store) PutReceipt(ctx context.Context, updater string, r notifier.Receipt) error

func (*Store) Receipt

func (s *Store) Receipt(ctx context.Context, id uuid.UUID) (notifier.Receipt, error)

Receipt returns the Receipt for a given notification id

func (*Store) ReceiptByUOID

func (s *Store) ReceiptByUOID(ctx context.Context, id uuid.UUID) (notifier.Receipt, error)

ReceiptByUOID returns the Receipt for a given notification UOID

func (*Store) SetDeleted

func (s *Store) SetDeleted(ctx context.Context, id uuid.UUID) error

SetDeleted marks the provided notification id as deleted

func (*Store) SetDelivered

func (s *Store) SetDelivered(ctx context.Context, id uuid.UUID) error

SetDelivered marks the provided notification id as delivered

func (*Store) SetDeliveryFailed

func (s *Store) SetDeliveryFailed(ctx context.Context, id uuid.UUID) error

SetDeliveryFailed marks the provided notification id failed to be delivere