code: func (r *ProxyREST) Connect(ctx context.Context, id string, opts runtime.Object, responder rest.Responder) (http.Handler, error) {
  	proxyOpts, ok := opts.(*api.PodProxyOptions)
  	if !ok {
  		return nil, fmt.Errorf("Invalid options object: %#v", opts)
  	}
  	location, transport, err := pod.ResourceLocation(r.Store, r.ProxyTransport, ctx, id)
  	if err != nil {
  		return nil, err
  	}
  	location.Path = net.JoinPreservingTrailingSlash(location.Path, proxyOpts.Path)
  	// Return a proxy handler that uses the desired transport, wrapped with additional proxy handling (to get URL rewriting, X-Forwarded-* headers, etc)
  	return newThrottledUpgradeAwareProxyHandler(location, transport, true, false, false, responder), nil
  }
docs: // Connect returns a handler for the pod proxy