postgres

Documentation

Index

• type Database
• type Provider
  • func NewProvider(postgresURL string, logger *zap.Logger) (*Provider, error)
  • func (provider *Provider) Close()
  • func (provider *Provider) GetClient() *pg.DB
  • func (provider *Provider) GetDatabase() Database
  • func (provider *Provider) NotifyFail(ce chan error)

Types

type Database

type Database interface {
	orm.DB

	Begin() (Database, error)
	Rollback() error
	Commit() error
}

type Provider

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

func NewProvider

func NewProvider(postgresURL string, logger *zap.Logger) (*Provider, error)

func (*Provider) Close

func (provider *Provider) Close()

func (*Provider) GetClient

func (provider *Provider) GetClient() *pg.DB

func (*Provider) GetDatabase

func (provider *Provider) GetDatabase() Database

func (*Provider) NotifyFail

func (provider *Provider) NotifyFail(ce chan error)