subscriptiondb

Documentation

Overview

Package subscriptiondb contains subscription related CRUD functionality.

Index

• type Store
  • func NewStore(log *zerolog.Logger, db *sqlx.DB) *Store
  • func (s *Store) Create(sub subscription.Subscription) error
  • func (s *Store) Delete(sub subscription.Subscription) error
  • func (s *Store) Query(pageNumber int, rowsPerPage int) ([]subscription.Subscription, error)
  • func (s *Store) QueryByID(id uuid.UUID) (subscription.Subscription, error)
  • func (s *Store) WithinTran(fn func(subscription.Storer) error) error

Types

type Store

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

Store manages the set of APIs for subscription database access.

func NewStore

func NewStore(log *zerolog.Logger, db *sqlx.DB) *Store

NewStore constructs the api for data access.

func (*Store) Create

func (s *Store) Create(sub subscription.Subscription) error

Create inserts a new subscription into the database.

func (*Store) Delete

func (s *Store) Delete(sub subscription.Subscription) error

Delete removes a subscription from the database.

func (*Store) Query

func (s *Store) Query(pageNumber int, rowsPerPage int) ([]subscription.Subscription, error)

Query retrieves a list of existing subscriptions from the database.

func (*Store) QueryByID

func (s *Store) QueryByID(id uuid.UUID) (subscription.Subscription, error)

QueryByID gets the specified subscription from the database by id.

func (*Store) WithinTran

func (s *Store) WithinTran(fn func(subscription.Storer) error) error

WithinTran runs passed function and do commit/rollback at the end.