type golang.org/x/net/http2.ClientConn
62 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#L195: newclientconn func(*ClientConn)
transport.go#L356: type ClientConn struct {
transport.go#L440: cc *ClientConn
transport.go#L754: func (t *Transport) dialClientConn(ctx context.Context, addr string, singleUse bool) (*ClientConn, error) {
transport.go#L817: func (t *Transport) NewClientConn(c net.Conn) (*ClientConn, error) {
transport.go#L821: func (t *Transport) newClientConn(c net.Conn, singleUse bool) (*ClientConn, error) {
transport.go#L823: cc := &ClientConn{
transport.go#L916: func (cc *ClientConn) healthCheck() {
transport.go#L933: func (cc *ClientConn) SetDoNotReuse() {
transport.go#L939: func (cc *ClientConn) setGoAway(f *GoAwayFrame) {
transport.go#L979: func (cc *ClientConn) CanTakeNewRequest() bool {
transport.go#L988: func (cc *ClientConn) ReserveNewRequest() bool {
transport.go#L1032: func (cc *ClientConn) State() ClientConnState {
transport.go#L1059: func (cc *ClientConn) idleState() clientConnIdleState {
transport.go#L1065: func (cc *ClientConn) idleStateLocked() (st clientConnIdleState) {
transport.go#L1107: func (cc *ClientConn) currentRequestCountLocked() int {
transport.go#L1111: func (cc *ClientConn) canTakeNewRequestLocked() bool {
transport.go#L1118: func (cc *ClientConn) tooIdleLocked() bool {
transport.go#L1132: func (cc *ClientConn) onIdleTimeout() {
transport.go#L1136: func (cc *ClientConn) closeConn() {
transport.go#L1144: func (cc *ClientConn) forceCloseConn() {
transport.go#L1154: func (cc *ClientConn) closeIfIdle() {
transport.go#L1172: func (cc *ClientConn) isDoNotReuseAndIdle() bool {
transport.go#L1181: func (cc *ClientConn) Shutdown(ctx context.Context) error {
transport.go#L1219: func (cc *ClientConn) sendGoAway() error {
transport.go#L1245: func (cc *ClientConn) closeForError(err error) {
transport.go#L1259: func (cc *ClientConn) Close() error {
transport.go#L1266: func (cc *ClientConn) closeForLostPing() {
transport.go#L1278: func (cc *ClientConn) responseHeaderTimeout() time.Duration {
transport.go#L1302: func (cc *ClientConn) decrStreamReservations() {
transport.go#L1308: func (cc *ClientConn) decrStreamReservationsLocked() {
transport.go#L1314: func (cc *ClientConn) RoundTrip(req *http.Request) (*http.Response, error) {
transport.go#L1318: func (cc *ClientConn) roundTrip(req *http.Request, streamf func(*clientStream)) (*http.Response, error) {
transport.go#L1749: func (cc *ClientConn) awaitOpenSlotForStreamLocked(cs *clientStream) error {
transport.go#L1776: func (cc *ClientConn) writeHeaders(streamID uint32, endStream bool, maxFrameSize int, hdrs []byte) error {
transport.go#L2032: func (cc *ClientConn) encodeTrailers(trailer http.Header) ([]byte, error) {
transport.go#L2062: func (cc *ClientConn) writeHeader(name, value string) {
transport.go#L2076: func (cc *ClientConn) addStreamLocked(cs *clientStream) {
transport.go#L2088: func (cc *ClientConn) forgetStreamID(id uint32) {
transport.go#L2119: cc *ClientConn
transport.go#L2123: func (cc *ClientConn) readLoop() {
transport.go#L2224: func (cc *ClientConn) countReadFrameError(err error) {
transport.go#L2981: func (cc *ClientConn) Ping(ctx context.Context) error {
transport.go#L3066: func (cc *ClientConn) writeStreamReset(streamID uint32, code ErrCode, ping bool, err error) {
transport.go#L3087: func (cc *ClientConn) logf(format string, args ...interface{}) {
transport.go#L3091: func (cc *ClientConn) vlogf(format string, args ...interface{}) {
transport.go#L3221: func traceGotConn(req *http.Request, cc *ClientConn, reused bool) {