kubernetes/test/integration/apiserver/peerproxy/peer_proxy_test.go

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

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

func setupStorageVersionGC(ctx context.Context, kubeClientSet *kubernetes.Clientset, informers informers.SharedInformerFactory) { … }

func createProxyCertContent() (kastesting.ProxyCA, error) { … }

func createJobResource() *v1.Job { … }