postgres

Documentation

Index

• Constants
• type Store
  • func New(dsn string) (s *Store, err error)
  • func (s *Store) Drop(ctx context.Context) error
  • func (s *Store) GetAggregates(ctx context.Context) (*models.Totals, []models.Delay, error)
  • func (s *Store) Init(ctx context.Context) error
  • func (s *Store) Insert(ctx context.Context, msg *models.Message) error
  • func (s *Store) Select(ctx context.Context, taskID uint64) (*models.Message, error)
  • func (s *Store) Update(ctx context.Context, msg *models.Message) error
  • func (s *Store) UpdateDelay(ctx context.Context, msg *models.Message) error

Constants

const (
	DDL = `` /* 659-byte string literal not displayed */

)

Types

type Store

type Store struct {
	Pool *pgxpool.Pool
}

Store ...

func New

func New(dsn string) (s *Store, err error)

New ...

func (*Store) Drop

func (s *Store) Drop(ctx context.Context) error

Drop clears database (for testing purpose onle)

func (*Store) GetAggregates

func (s *Store) GetAggregates(ctx context.Context) (*models.Totals, []models.Delay, error)

GetAggregates extracts statistics about finished and declined tasks and its delay

func (*Store) Init

func (s *Store) Init(ctx context.Context) error

Init creates schema, type and tables

func (*Store) Insert

func (s *Store) Insert(ctx context.Context, msg *models.Message) error

Insert adds event about task that has not been stored yet

func (*Store) Select

func (s *Store) Select(ctx context.Context, taskID uint64) (*models.Message, error)

Select extracts an event with specified ID

func (*Store) Update

func (s *Store) Update(ctx context.Context, msg *models.Message) error

Update changes event about particular task in database with msg values

func (*Store) UpdateDelay

func (s *Store) UpdateDelay(ctx context.Context, msg *models.Message) error

UpdateDelay sets data about particular task in database with msg values and calculated delay