kubernetes/vendor/google.golang.org/grpc/internal/transport/proxy.go

const proxyAuthHeaderKey …

var httpProxyFromEnvironment …

func mapAddress(address string) (*url.URL, error) { … }

type bufConn …

func (c *bufConn) Read(b []byte) (int, error) { … }

func basicAuth(username, password string) string { … }

func doHTTPConnectHandshake(ctx context.Context, conn net.Conn, backendAddr string, proxyURL *url.URL, grpcUA string) (_ net.Conn, err error) { … }

// proxyDial dials, connecting to a proxy first if necessary. Checks if a proxy
// is necessary, dials, does the HTTP CONNECT handshake, and returns the
// connection.
func proxyDial(ctx context.Context, addr string, grpcUA string) (net.Conn, error) { … }

func sendHTTPRequest(ctx context.Context, req *http.Request, conn net.Conn) error { … }