type golang.org/x/net/http2.ClientConn
60 uses
golang.org/x/net/http2 (current package)
client_conn_pool.go#L25: GetClientConn(req *http.Request, addr string) (*ClientConn, error)
client_conn_pool.go#L26: MarkDead(*ClientConn)
client_conn_pool.go#L48: conns map[string][]*ClientConn // key is host:port
client_conn_pool.go#L50: keys map[*ClientConn][]string
client_conn_pool.go#L54: func (p *clientConnPool) GetClientConn(req *http.Request, addr string) (*ClientConn, error) {
client_conn_pool.go#L63: func (p *clientConnPool) getClientConn(req *http.Request, addr string, dialOnMiss bool) (*ClientConn, error) {
client_conn_pool.go#L119: res *ClientConn // valid after done is closed
client_conn_pool.go#L214: func (p *clientConnPool) addConnLocked(key string, cc *ClientConn) {
client_conn_pool.go#L221: p.conns = make(map[string][]*ClientConn)
client_conn_pool.go#L224: p.keys = make(map[*ClientConn][]string)
client_conn_pool.go#L230: func (p *clientConnPool) MarkDead(cc *ClientConn) {
client_conn_pool.go#L264: func filterOutClientConn(in []*ClientConn, exclude *ClientConn) []*ClientConn {
client_conn_pool.go#L284: func (p noDialClientConnPool) GetClientConn(req *http.Request, addr string) (*ClientConn, error) {
transport.go#L291: type ClientConn struct {
transport.go#L352: cc *ClientConn
transport.go#L656: func (t *Transport) dialClientConn(ctx context.Context, addr string, singleUse bool) (*ClientConn, error) {
transport.go#L730: func (t *Transport) NewClientConn(c net.Conn) (*ClientConn, error) {
transport.go#L734: func (t *Transport) newClientConn(c net.Conn, singleUse bool) (*ClientConn, error) {
transport.go#L735: cc := &ClientConn{
transport.go#L821: func (cc *ClientConn) healthCheck() {
transport.go#L838: func (cc *ClientConn) SetDoNotReuse() {
transport.go#L844: func (cc *ClientConn) setGoAway(f *GoAwayFrame) {
transport.go#L871: func (cc *ClientConn) CanTakeNewRequest() bool {
transport.go#L880: func (cc *ClientConn) ReserveNewRequest() bool {
transport.go#L924: func (cc *ClientConn) State() ClientConnState {
transport.go#L951: func (cc *ClientConn) idleState() clientConnIdleState {
transport.go#L957: func (cc *ClientConn) idleStateLocked() (st clientConnIdleState) {
transport.go#L979: func (cc *ClientConn) canTakeNewRequestLocked() bool {
transport.go#L986: func (cc *ClientConn) tooIdleLocked() bool {
transport.go#L1000: func (cc *ClientConn) onIdleTimeout() {
transport.go#L1004: func (cc *ClientConn) closeConn() {
transport.go#L1012: func (cc *ClientConn) forceCloseConn() {
transport.go#L1022: func (cc *ClientConn) closeIfIdle() {
transport.go#L1039: func (cc *ClientConn) isDoNotReuseAndIdle() bool {
transport.go#L1048: func (cc *ClientConn) Shutdown(ctx context.Context) error {
transport.go#L1085: func (cc *ClientConn) sendGoAway() error {
transport.go#L1111: func (cc *ClientConn) closeForError(err error) {
transport.go#L1125: func (cc *ClientConn) Close() error {
transport.go#L1132: func (cc *ClientConn) closeForLostPing() {
transport.go#L1161: func (cc *ClientConn) responseHeaderTimeout() time.Duration {
transport.go#L1201: func (cc *ClientConn) decrStreamReservations() {
transport.go#L1207: func (cc *ClientConn) decrStreamReservationsLocked() {
transport.go#L1213: func (cc *ClientConn) RoundTrip(req *http.Request) (*http.Response, error) {
transport.go#L1574: func (cc *ClientConn) awaitOpenSlotForStreamLocked(cs *clientStream) error {
transport.go#L1596: func (cc *ClientConn) writeHeaders(streamID uint32, endStream bool, maxFrameSize int, hdrs []byte) error {
transport.go#L1833: func (cc *ClientConn) encodeHeaders(req *http.Request, addGzipHeader bool, trailers string, contentLength int64) ([]byte, error) {
transport.go#L2025: func (cc *ClientConn) encodeTrailers(trailer http.Header) ([]byte, error) {
transport.go#L2055: func (cc *ClientConn) writeHeader(name, value string) {
transport.go#L2069: func (cc *ClientConn) addStreamLocked(cs *clientStream) {
transport.go#L2081: func (cc *ClientConn) forgetStreamID(id uint32) {
transport.go#L2112: cc *ClientConn
transport.go#L2116: func (cc *ClientConn) readLoop() {
transport.go#L2189: func (cc *ClientConn) countReadFrameError(err error) {
transport.go#L2890: func (cc *ClientConn) Ping(ctx context.Context) error {
transport.go#L2965: func (cc *ClientConn) writeStreamReset(streamID uint32, code ErrCode, err error) {
transport.go#L2981: func (cc *ClientConn) logf(format string, args ...interface{}) {
transport.go#L2985: func (cc *ClientConn) vlogf(format string, args ...interface{}) {
transport.go#L3107: func traceGotConn(req *http.Request, cc *ClientConn, reused bool) {