pgxreconnect

README

pgx-reconnect

Wrapper for https://github.com/jackc/pgx with support for reconnecting when a recoverable TCP error occurs.

Documentation

Index

• Variables
• type ReConn
  • func Connect(ctx context.Context, connString string, bo backoff.BackOff) (*ReConn, error)
  • func (c *ReConn) Close(ctx context.Context) error
  • func (c *ReConn) Exec(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error)
  • func (c *ReConn) IsClosed() bool
  • func (c *ReConn) Ping(ctx context.Context) error
  • func (c *ReConn) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
  • func (c *ReConn) QueryRow(ctx context.Context, sql string, args ...any) (pgx.Row, error)
  • func (c *ReConn) Reconnect(ctx context.Context) error

Variables

var (
	ErrNoConnString = errors.New("no connection string provided")
	ErrReconnect    = errors.New("error while reconnecting")
)

Types

type ReConn

type ReConn struct {
	ConnString string
	Conn       *pgx.Conn
	Backoff    backoff.BackOff
}

func Connect

func Connect(ctx context.Context, connString string, bo backoff.BackOff) (*ReConn, error)

func (*ReConn) Close

func (c *ReConn) Close(ctx context.Context) error

func (*ReConn) Exec

func (c *ReConn) Exec(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error)

func (*ReConn) IsClosed

func (c *ReConn) IsClosed() bool

func (*ReConn) Ping

func (c *ReConn) Ping(ctx context.Context) error

func (*ReConn) Query

func (c *ReConn) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

func (*ReConn) QueryRow

func (c *ReConn) QueryRow(ctx context.Context, sql string, args ...any) (pgx.Row, error)

func (*ReConn) Reconnect

func (c *ReConn) Reconnect(ctx context.Context) error