type fakeListener … func newFakeListener() *fakeListener { … } func (fake *fakeListener) hasPort(addr string) bool { … } func (fake *fakeListener) Listen(_ context.Context, addrs ...string) (net.Listener, error) { … } type fakeNetListener … type fakeAddr … func (fa fakeAddr) Network() string { … } func (fa fakeAddr) String() string { … } func (fake *fakeNetListener) Accept() (net.Conn, error) { … } func (fake *fakeNetListener) Close() error { … } func (fake *fakeNetListener) Addr() net.Addr { … } type fakeHTTPServerFactory … func newFakeHTTPServerFactory() *fakeHTTPServerFactory { … } func (fake *fakeHTTPServerFactory) New(handler http.Handler) httpServer { … } type fakeHTTPServer … func (fake *fakeHTTPServer) Serve(listener net.Listener) error { … } func (fake *fakeHTTPServer) Close() error { … } func mknsn(ns, name string) types.NamespacedName { … } type hcPayload … type healthzPayload … type fakeProxierHealthChecker … func (fake fakeProxierHealthChecker) IsHealthy() bool { … } func TestServer(t *testing.T) { … } func testHandler(hcs *server, nsn types.NamespacedName, status int, endpoints int, t *testing.T) { … } func testHandlerWithHealth(hcs *server, nsn types.NamespacedName, status int, endpoints int, kubeProxyHealthy bool, t *testing.T) { … } func tHandler(hcs *server, nsn types.NamespacedName, status int, endpoints int, kubeProxyHealthy bool, t *testing.T) { … } type nodeTweak … func makeNode(tweaks ...nodeTweak) *v1.Node { … } func tweakDeleted() nodeTweak { … } func tweakTainted(key string) nodeTweak { … } type serverTest … func TestHealthzServer(t *testing.T) { … } func TestLivezServer(t *testing.T) { … } type url … var healthzURL … var livezURL … func testProxierHealthUpdater(hs *ProxierHealthServer, hsTest *serverTest, fakeClock *testingclock.FakeClock, t *testing.T) { … } func testHTTPHandler(hsTest *serverTest, status int, t *testing.T) { … } func testMetricEquals(metric basemetrics.CounterMetric, expected float64, t *testing.T) { … } func TestServerWithSelectiveListeningAddress(t *testing.T) { … }
Codebase Browser
kubernetes