db

type Database interface {
	Tx
	Close()
	Transact(fn TxFunc, opts ...TxOpt) (interface{}, error)
	Metadata() (map[string]string, error)
	Stats() sql.DBStats
	WithContext(ctx context.Context) Database
	Pool() *pgxpool.Pool
}

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

type LoggedRows struct {
	pgx.Rows
	Start  time.Time
	Closed bool
	// contains filtered or unexported fields
}

type Migrator interface {
	Migrate(ctx context.Context) error
}

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

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

type Tx interface {
	Query(query string, args ...interface{}) (pgx.Rows, error)
	Select(dest interface{}, query string, args ...interface{}) error
	Get(dest interface{}, query string, args ...interface{}) error
	GetPrimitive(dest interface{}, query string, args ...interface{}) error
	Exec(query string, args ...interface{}) (pgconn.CommandTag, error)
}

type TxFunc func(tx Tx) (interface{}, error)

type TxOpt func(*TxOptions)

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