kubernetes/staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler_test.go

const requestTimeout …

const localServerID …

const remoteServerID …

type FakeSVMapData …

type server …

type reconciler …

func TestPeerProxy(t *testing.T) { … }

func newFakePeerEndpointReconciler(t *testing.T) reconcilers.PeerEndpointLeaseReconciler { … }

func newHandlerChain(t *testing.T, handler http.Handler, reconciler reconcilers.PeerEndpointLeaseReconciler, informerFinishedSync bool, svdata FakeSVMapData) http.Handler { … }

func newFakePeerProxyHandler(reconciler reconcilers.PeerEndpointLeaseReconciler, svdata FakeSVMapData, id string, s runtime.NegotiatedSerializer) (*peerProxyHandler, error) { … }

func (h *peerProxyHandler) addToStorageVersionMap(gvr schema.GroupVersionResource, serverIDs []string) { … }

func testDataExists(gvr schema.GroupVersionResource) bool { … }

func withFakeUser(handler http.Handler) http.Handler { … }

// returns a started http2 server, with a client function to send request to the server.
func createHTTP2ServerWithClient(handler http.Handler, clientTimeout time.Duration) (*httptest.Server, func(req *http.Request) (*http.Response, error)) { … }