github.com/jackc/pgconn.PgConn.conn (field)

50 uses

	github.com/jackc/pgconn (current package)
		auth_scram.go#L44: 	_, err = c.conn.Write(saslInitialResponse.Encode(nil))
		auth_scram.go#L63: 	_, err = c.conn.Write(saslResponse.Encode(nil))
		pgconn.go#L72: 	conn              net.Conn          // the underlying TCP or unix domain socket connection
		pgconn.go#L170: 			pgConn.conn.Close()
		pgconn.go#L218: 	pgConn.conn, err = config.DialFunc(ctx, network, address)
		pgconn.go#L227: 			pgConn.conn.Close()
		pgconn.go#L234: 		func() { pgConn.conn.SetDeadline(time.Date(1, 1, 1, 1, 1, 1, 1, time.UTC)) },
		pgconn.go#L235: 		func() { pgConn.conn.SetDeadline(time.Time{}) },
		pgconn.go#L241: 	pgConn.frontend = config.BuildFrontend(pgConn.conn, pgConn.conn)
		pgconn.go#L258: 	if _, err := pgConn.conn.Write(startupMsg.Encode(pgConn.wbuf)); err != nil {
		pgconn.go#L259: 		pgConn.conn.Close()
		pgconn.go#L266: 			pgConn.conn.Close()
		pgconn.go#L282: 				pgConn.conn.Close()
		pgconn.go#L289: 				pgConn.conn.Close()
		pgconn.go#L295: 				pgConn.conn.Close()
		pgconn.go#L311: 					pgConn.conn.Close()
		pgconn.go#L319: 			pgConn.conn.Close()
		pgconn.go#L322: 			pgConn.conn.Close()
		pgconn.go#L329: 	err = binary.Write(pgConn.conn, binary.BigEndian, []int32{8, 80877103})
		pgconn.go#L335: 	if _, err = io.ReadFull(pgConn.conn, response); err != nil {
		pgconn.go#L343: 	pgConn.conn = tls.Client(pgConn.conn, tlsConfig)
		pgconn.go#L350: 	_, err = pgConn.conn.Write(msg.Encode(pgConn.wbuf))
		pgconn.go#L399: 	n, err := pgConn.conn.Write(buf)
		pgconn.go#L495: 			pgConn.conn.Close() // Ignore error as the connection is already broken and there is already an error to return.
		pgconn.go#L514: 	return pgConn.conn
		pgconn.go#L549: 	defer pgConn.conn.Close()
		pgconn.go#L568: 	pgConn.conn.Write([]byte{'X', 0, 0, 0, 4})
		pgconn.go#L569: 	pgConn.conn.Read(make([]byte, 1))
		pgconn.go#L571: 	return pgConn.conn.Close()
		pgconn.go#L584: 		defer pgConn.conn.Close()
		pgconn.go#L593: 		pgConn.conn.SetDeadline(deadline)
		pgconn.go#L595: 		pgConn.conn.Write([]byte{'X', 0, 0, 0, 4})
		pgconn.go#L596: 		pgConn.conn.Read(make([]byte, 1))
		pgconn.go#L760: 	n, err := pgConn.conn.Write(buf)
		pgconn.go#L833: 	serverAddr := pgConn.conn.RemoteAddr()
		pgconn.go#L932: 	n, err := pgConn.conn.Write(buf)
		pgconn.go#L1078: 	n, err := pgConn.conn.Write(buf)
		pgconn.go#L1112: 	n, err := pgConn.conn.Write(buf)
		pgconn.go#L1172: 	n, err := pgConn.conn.Write(buf)
		pgconn.go#L1215: 				_, writeErr := pgConn.conn.Write(buf)
		pgconn.go#L1218: 					pgConn.conn.Close()
		pgconn.go#L1266: 	_, err = pgConn.conn.Write(buf)
		pgconn.go#L1621: 		_, err := pgConn.conn.Write(batch.buf)
		pgconn.go#L1623: 			pgConn.conn.Close()
		pgconn.go#L1674: 		Conn:              pgConn.conn,
		pgconn.go#L1691: 		conn:              hc.Conn,
		pgconn.go#L1706: 		func() { pgConn.conn.SetDeadline(time.Date(1, 1, 1, 1, 1, 1, 1, time.UTC)) },
		pgconn.go#L1707: 		func() { pgConn.conn.SetDeadline(time.Time{}) },