kubernetes/staging/src/k8s.io/apiserver/pkg/server/egressselector/egress_selector_test.go

type fakeEgressSelection …

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

func (s *fakeEgressSelection) fakeDirectDialer(ctx context.Context, network, address string) (net.Conn, error) { … }

func validateDirectDialer(dialer utilnet.DialFunc, s *fakeEgressSelection) (bool, error) { … }

type fakeProxyServerConnector …

func (f *fakeProxyServerConnector) connect(context.Context) (proxier, error) { … }

type fakeProxier …

func (f *fakeProxier) proxy(_ context.Context, _ string) (net.Conn, error) { … }

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

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