pgproxy

Documentation

Index

• func HandleConnection(ctx context.Context, conn net.Conn, connectionFn DSNConstructor)
• type DSNConstructor
• type PgProxy
  • func New(address string, connectionFn DSNConstructor) *PgProxy
  • func (p *PgProxy) Start(ctx context.Context) error

Functions

func HandleConnection

func HandleConnection(ctx context.Context, conn net.Conn, connectionFn DSNConstructor)

HandleConnection proxies a single connection.

This should be run as the first thing after accepting a connection. It will block until the connection is closed.

Types

type DSNConstructor

type DSNConstructor func(ctx context.Context, params map[string]string) (string, error)

DSNConstructor is a function that constructs a new connection string from parameters of the incoming connection.

parameters are pg connection parameters as described in https://www.postgresql.org/docs/current/libpq-connect.html#LIBPQ-PARAMKEYWORDS

type PgProxy

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

PgProxy is a configurable proxy for PostgreSQL connections

func New

func New(address string, connectionFn DSNConstructor) *PgProxy

New creates a new PgProxy.

address is the address to listen on for incoming connections. connectionFn is a function that constructs a new connection string from parameters of the incoming connection.

func (*PgProxy) Start

func (p *PgProxy) Start(ctx context.Context) error

Start the proxy.