postgres

Documentation

Index

• type Postgres
  • func New(connStr string) (*Postgres, error)
  • func (p *Postgres) Close() error
  • func (p *Postgres) Compare(ctx context.Context, conf *conf.ComparisonsConf) ([]metrics.Comparison, error)
  • func (p *Postgres) Freshness(ctx context.Context, conf *conf.FreshnessConf) ([]metrics.TableFreshness, error)
  • func (p *Postgres) SQLDB() *sql.DB
  • func (p *Postgres) TableAccesses(ctx context.Context, conf *conf.LastUpdateConf) ([]metrics.TableAccess, error)

Types

type Postgres

type Postgres struct {
	DB *sql.DB
}

func New

func New(connStr string) (*Postgres, error)

func (*Postgres) Close

func (p *Postgres) Close() error

func (*Postgres) Compare

func (p *Postgres) Compare(ctx context.Context, conf *conf.ComparisonsConf) ([]metrics.Comparison, error)

func (*Postgres) Freshness

func (p *Postgres) Freshness(ctx context.Context, conf *conf.FreshnessConf) ([]metrics.TableFreshness, error)

func (*Postgres) SQLDB

func (p *Postgres) SQLDB() *sql.DB

func (*Postgres) TableAccesses

func (p *Postgres) TableAccesses(ctx context.Context, conf *conf.LastUpdateConf) ([]metrics.TableAccess, error)