postgres

Documentation

Index

• type Postgres
  • func Connect(ctx context.Context, cfg *pgxpool.Config, now func() time.Time) (*Postgres, error)
  • func (p *Postgres) Check(ctx context.Context) error
  • func (p *Postgres) Close()
  • func (p *Postgres) CreateAddress(ctx context.Context, address *storage.Address) error
  • func (p *Postgres) ExecTx(ctx context.Context, fn func(tx pgx.Tx) error, op errors.Op) error
  • func (p *Postgres) GetAddress(ctx context.Context, cep string) (*storage.Address, error)
  • func (p *Postgres) ListAddresses(ctx context.Context, params storage.ListParams) ([]*storage.Address, error)
  • func (p *Postgres) UpdateAddress(ctx context.Context, cep string, updater storage.Updater) error

Types

type Postgres

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

func Connect

func Connect(ctx context.Context, cfg *pgxpool.Config, now func() time.Time) (*Postgres, error)

Connect parses a database URL into options that can be used to connect to PostgreSQL.

func (*Postgres) Check

func (p *Postgres) Check(ctx context.Context) error

func (*Postgres) Close

func (p *Postgres) Close()

func (*Postgres) CreateAddress

func (p *Postgres) CreateAddress(ctx context.Context, address *storage.Address) error

func (*Postgres) ExecTx

func (p *Postgres) ExecTx(ctx context.Context, fn func(tx pgx.Tx) error, op errors.Op) error

func (*Postgres) GetAddress

func (p *Postgres) GetAddress(ctx context.Context, cep string) (*storage.Address, error)

func (*Postgres) ListAddresses

func (p *Postgres) ListAddresses(ctx context.Context, params storage.ListParams) ([]*storage.Address, error)

func (*Postgres) UpdateAddress

func (p *Postgres) UpdateAddress(ctx context.Context, cep string, updater storage.Updater) error