kubernetes/pkg/proxy/endpointschangetracker_test.go

func (proxier *FakeProxier) addEndpointSlice(slice *discovery.EndpointSlice) { … }

func (proxier *FakeProxier) updateEndpointSlice(oldSlice, slice *discovery.EndpointSlice) { … }

func (proxier *FakeProxier) deleteEndpointSlice(slice *discovery.EndpointSlice) { … }

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

func makeTestEndpointSlice(namespace, name string, slice int, epsFunc func(*discovery.EndpointSlice)) *discovery.EndpointSlice { … }

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

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

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

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

func compareEndpointsMapsStr(t *testing.T, newMap EndpointsMap, expected map[ServicePortName][]*BaseEndpointInfo) { … }

func initializeCache(endpointSliceCache *EndpointSliceCache, endpointSlices []*discovery.EndpointSlice) { … }