kubernetes/pkg/proxy/config/config_test.go

type sortedServices …

func (s sortedServices) Len() int { … }

func (s sortedServices) Swap(i, j int) { … }

func (s sortedServices) Less(i, j int) bool { … }

type ServiceHandlerMock …

func NewServiceHandlerMock() *ServiceHandlerMock { … }

func (h *ServiceHandlerMock) OnServiceAdd(service *v1.Service) { … }

func (h *ServiceHandlerMock) OnServiceUpdate(oldService, service *v1.Service) { … }

func (h *ServiceHandlerMock) OnServiceDelete(service *v1.Service) { … }

func (h *ServiceHandlerMock) OnServiceSynced() { … }

func (h *ServiceHandlerMock) sendServices() { … }

func (h *ServiceHandlerMock) ValidateServices(t *testing.T, expectedServices []*v1.Service) { … }

type sortedEndpointSlices …

func (s sortedEndpointSlices) Len() int { … }

func (s sortedEndpointSlices) Swap(i, j int) { … }

func (s sortedEndpointSlices) Less(i, j int) bool { … }

type EndpointSliceHandlerMock …

func NewEndpointSliceHandlerMock() *EndpointSliceHandlerMock { … }

func (h *EndpointSliceHandlerMock) OnEndpointSliceAdd(slice *discoveryv1.EndpointSlice) { … }

func (h *EndpointSliceHandlerMock) OnEndpointSliceUpdate(oldSlice, slice *discoveryv1.EndpointSlice) { … }

func (h *EndpointSliceHandlerMock) OnEndpointSliceDelete(slice *discoveryv1.EndpointSlice) { … }

func (h *EndpointSliceHandlerMock) OnEndpointSlicesSynced() { … }

func (h *EndpointSliceHandlerMock) sendEndpointSlices() { … }

func (h *EndpointSliceHandlerMock) ValidateEndpointSlices(t *testing.T, expectedSlices []*discoveryv1.EndpointSlice) { … }

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

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

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

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

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