kubernetes/pkg/proxy/servicechangetracker_test.go

const testHostname …

func makeTestServiceInfo(clusterIP string, port int, protocol string, healthcheckNodePort int, svcInfoFuncs ...func(*BaseServicePortInfo)) *BaseServicePortInfo { … }

func makeTestService(namespace, name string, svcFunc func(*v1.Service)) *v1.Service { … }

func addTestPort(array []v1.ServicePort, name string, protocol v1.Protocol, port, nodeport int32, targetPort int) []v1.ServicePort { … }

func makeNSN(namespace, name string) types.NamespacedName { … }

func makeServicePortName(ns, name, port string, protocol v1.Protocol) ServicePortName { … }

func makeIPs(ipStr ...string) []net.IP { … }

func mustMakeCIDRs(cidrStr ...string) []*net.IPNet { … }

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

type FakeProxier …

func newFakeProxier(ipFamily v1.IPFamily, t time.Time) *FakeProxier { … }

func makeServiceMap(fake *FakeProxier, allServices ...*v1.Service) { … }

func (proxier *FakeProxier) addService(service *v1.Service) { … }

func (proxier *FakeProxier) updateService(oldService *v1.Service, service *v1.Service) { … }

func (proxier *FakeProxier) deleteService(service *v1.Service) { … }

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

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

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

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