Function New

internal/faultyconn/faultyconn.go:35–46

NewConn creates a new Conn that proxies the messages sent to and from the given net.Conn. New can be used with pgconn.Config.AfterNetConnect to wrap a net.Conn for testing purposes.

(c net.Conn)

// NewConn creates a new Conn that proxies the messages sent to and from the given net.Conn. New can be used with
// pgconn.Config.AfterNetConnect to wrap a net.Conn for testing purposes.
func New(c net.Conn) *Conn {
	fromFrontendBuf := &bytes.Buffer{}
	fromBackendBuf := &bytes.Buffer{}

	return &Conn{
		conn:            c,
		fromFrontendBuf: fromFrontendBuf,
		fromBackendBuf:  fromBackendBuf,
		backend:         pgproto3.NewBackend(fromFrontendBuf, c),
		frontend:        pgproto3.NewFrontend(fromBackendBuf, c),
	}
}

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