scrumdb

Documentation

Overview

Package scrumdb contains scrum related CRUD functionality.

Index

• type Store
  • func NewStore(log *logger.Logger, db *sqlx.DB) *Store
  • func (s *Store) Count(ctx context.Context, filter scrumbus.QueryFilter) (int, error)
  • func (s *Store) Create(ctx context.Context, scrum scrumbus.Scrum) error
  • func (s *Store) Delete(ctx context.Context, scrum scrumbus.Scrum) error
  • func (s *Store) NewWithTx(tx sqldb.CommitRollbacker) (scrumbus.Storer, error)
  • func (s *Store) Query(ctx context.Context, filter scrumbus.QueryFilter, orderBy order.By, ...) ([]scrumbus.Scrum, error)
  • func (s *Store) QueryByID(ctx context.Context, scrumID uuid.UUID) (scrumbus.Scrum, error)
  • func (s *Store) QueryByUserID(ctx context.Context, userID uuid.UUID) ([]scrumbus.Scrum, error)
  • func (s *Store) Update(ctx context.Context, scrum scrumbus.Scrum) error

Types

type Store

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

Store manages the set of APIs for scrum database access.

func NewStore

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

NewStore constructs the api for data access.

func (*Store) Count

func (s *Store) Count(ctx context.Context, filter scrumbus.QueryFilter) (int, error)

Count returns the total number of scrums in the DB.

func (*Store) Create

func (s *Store) Create(ctx context.Context, scrum scrumbus.Scrum) error

Create inserts a new scrum into the database.

func (*Store) Delete

func (s *Store) Delete(ctx context.Context, scrum scrumbus.Scrum) error

Delete removes a scrum from the database.

func (*Store) NewWithTx

func (s *Store) NewWithTx(tx sqldb.CommitRollbacker) (scrumbus.Storer, error)

NewWithTx constructs a new Store value replacing the sqlx DB value with a sqlx DB value that is currently inside a transaction.

func (*Store) Query

func (s *Store) Query(ctx context.Context, filter scrumbus.QueryFilter, orderBy order.By, page page.Page) ([]scrumbus.Scrum, error)

Query retrieves a list of existing scrums from the database.

func (*Store) QueryByID

func (s *Store) QueryByID(ctx context.Context, scrumID uuid.UUID) (scrumbus.Scrum, error)

QueryByID gets the specified scrum from the database.

func (*Store) QueryByUserID

func (s *Store) QueryByUserID(ctx context.Context, userID uuid.UUID) ([]scrumbus.Scrum, error)

QueryByUserID gets the specified scrum from the database by user id.

func (*Store) Update

func (s *Store) Update(ctx context.Context, scrum scrumbus.Scrum) error

Update replaces a scrum document in the database.