faultyconn

type Conn ¶

type Conn struct {
	// HandleFrontendMessage is called for each frontend message received. It should use backendWriter to write to the
	// backend.
	HandleFrontendMessage func(backendWriter io.Writer, msg pgproto3.FrontendMessage) error
	// contains filtered or unexported fields
}

Conn is a wrapper for a net.Conn that allows inspection and modification of messages between a PostgreSQL client and server. It is designed to be used in tests that use a *pgx.Conn or *pgconn.PgConn connected to a real PostgreSQL server. Instead of mocking an entire server connection, this is used to specify and modify only the particular aspects of a connection that are necessary. This can be easier to setup and is more true to real world conditions.

It currently only supports handling frontend messages.

func New(c net.Conn) *Conn

func (c *Conn) Close() error

func (c *Conn) LocalAddr() net.Addr

func (c *Conn) Read(b []byte) (n int, err error)

func (c *Conn) RemoteAddr() net.Addr

func (c *Conn) SetDeadline(t time.Time) error

func (c *Conn) SetReadDeadline(t time.Time) error

func (c *Conn) SetWriteDeadline(t time.Time) error

func (c *Conn) Write(b []byte) (n int, err error)