postgres

Documentation

Index

• Variables
• type Config
  • func (c *Config) Repair()
  • func (c *Config) String() string
• type Conn
  • func Connect(ctx context.Context, conf Config) (*Conn, error)
  • func (conn *Conn) Close()
  • func (conn *Conn) Migrate(ctx context.Context, migrations *embed.FS) error
  • func (conn *Conn) MigrateTo(ctx context.Context, migrations *embed.FS, targetNumber int) error
  • func (conn *Conn) Tx(ctx context.Context, f func(tx Tx) error) error
• type Tx

Variables

var (
	ErrNoRows = pgx.ErrNoRows

	ErrTxClosed         = pgx.ErrTxClosed
	ErrTxCommitRollback = pgx.ErrTxCommitRollback
)

Types

type Config

type Config struct {
	Username string `yaml:"username"`
	Password string `yaml:"password"`

	Database string `yaml:"database"`
	Address  string `yaml:"address"`
}

func (*Config) Repair

func (c *Config) Repair()

func (*Config) String

func (c *Config) String() string

type Conn

type Conn struct {
	*pgxpool.Pool
	// contains filtered or unexported fields
}

func Connect

func Connect(ctx context.Context, conf Config) (*Conn, error)

func (*Conn) Close

func (conn *Conn) Close()

func (*Conn) Migrate

func (conn *Conn) Migrate(ctx context.Context, migrations *embed.FS) error

func (*Conn) MigrateTo

func (conn *Conn) MigrateTo(ctx context.Context, migrations *embed.FS, targetNumber int) error

func (*Conn) Tx

func (conn *Conn) Tx(ctx context.Context, f func(tx Tx) error) error

type Tx

type Tx = pgx.Tx