func newStorage(t *testing.T, ipFamilies []api.IPFamily) (*wrapperRESTForTests, *StatusREST, *etcd3testing.EtcdTestServer) { … }
func newStorageWithPods(t *testing.T, ipFamilies []api.IPFamily, pods []api.Pod, endpoints []*api.Endpoints) (*wrapperRESTForTests, *StatusREST, *etcd3testing.EtcdTestServer) { … }
func makeIPAllocator(cidr *net.IPNet) ipallocator.Interface { … }
func makePortAllocator(ports machineryutilnet.PortRange) portallocator.Interface { … }
type wrapperRESTForTests …
func (f *wrapperRESTForTests) Create(ctx context.Context, obj runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (runtime.Object, error) { … }
func validService() *api.Service { … }
func TestGenericCreate(t *testing.T) { … }
func TestGenericUpdate(t *testing.T) { … }
func TestGenericDelete(t *testing.T) { … }
func TestGenericGet(t *testing.T) { … }
func TestGenericList(t *testing.T) { … }
func TestGenericWatch(t *testing.T) { … }
func TestGenericShortNames(t *testing.T) { … }
func TestGenericCategories(t *testing.T) { … }
func TestNormalizeClusterIPs(t *testing.T) { … }
func TestPatchAllocatedValues(t *testing.T) { … }
func TestServiceDefaultOnRead(t *testing.T) { … }
type cudTestCase …
type svcTestCase …
type svcTestProof …
func helpTestCreateUpdateDelete(t *testing.T, testCases []cudTestCase) { … }
func helpTestCreateUpdateDeleteWithFamilies(t *testing.T, testCases []cudTestCase, ipFamilies []api.IPFamily) { … }
func line() string { … }
type testingTInterface …
type fakeTestingT …
func (f fakeTestingT) Helper() { … }
func (f fakeTestingT) Errorf(format string, args ...interface{ … }
func verifyEquiv(t testingTInterface, call string, tc *svcTestCase, got *api.Service) bool { … }
func TestVerifyEquiv(t *testing.T) { … }
func verifyExpectations(t *testing.T, storage *wrapperRESTForTests, tc svcTestCase, before, after *api.Service) { … }
func callName(before, after *api.Service) string { … }
func ipIsAllocated(t *testing.T, alloc ipallocator.Interface, ipstr string) bool { … }
func portIsAllocated(t *testing.T, alloc portallocator.Interface, port int32) bool { … }
func proveClusterIPsAllocated(t *testing.T, storage *wrapperRESTForTests, before, after *api.Service) { … }
func proveClusterIPsDeallocated(t *testing.T, storage *wrapperRESTForTests, before, after *api.Service) { … }
func proveHeadless(t *testing.T, storage *wrapperRESTForTests, before, after *api.Service) { … }
func proveNodePortsAllocated(t *testing.T, storage *wrapperRESTForTests, before, after *api.Service) { … }
func proveNodePortsDeallocated(t *testing.T, storage *wrapperRESTForTests, before, after *api.Service) { … }
func proveHealthCheckNodePortAllocated(t *testing.T, storage *wrapperRESTForTests, before, after *api.Service) { … }
func proveHealthCheckNodePortDeallocated(t *testing.T, storage *wrapperRESTForTests, before, after *api.Service) { … }
func fmtIPFamilyPolicy(pol *api.IPFamilyPolicy) string { … }
func fmtInternalTrafficPolicy(pol *api.ServiceInternalTrafficPolicy) string { … }
func fmtIPFamilies(fams []api.IPFamily) string { … }
func TestCreateIgnoresIPsForExternalName(t *testing.T) { … }
func TestCreateInitClusterIPsFromClusterIP(t *testing.T) { … }
func TestCreateInitIPFields(t *testing.T) { … }
func TestCreateInvalidClusterIPInputs(t *testing.T) { … }
func TestCreateDeleteReuse(t *testing.T) { … }
func TestCreateInitNodePorts(t *testing.T) { … }
func TestCreateSkipsAllocationsForHeadless(t *testing.T) { … }
func TestCreateDryRun(t *testing.T) { … }
func TestDeleteWithFinalizer(t *testing.T) { … }
func TestDeleteDryRun(t *testing.T) { … }
func TestUpdateDryRun(t *testing.T) { … }
func TestUpdatePatchAllocatedValues(t *testing.T) { … }
func TestUpdateIPsFromSingleStack(t *testing.T) { … }
func TestUpdateIPsFromDualStack(t *testing.T) { … }
func TestFeatureExternalName(t *testing.T) { … }
func TestFeatureSelector(t *testing.T) { … }
func TestFeatureClusterIPs(t *testing.T) { … }
func TestFeaturePorts(t *testing.T) { … }
func TestFeatureSessionAffinity(t *testing.T) { … }
func TestFeatureType(t *testing.T) { … }
func TestFeatureExternalTrafficPolicy(t *testing.T) { … }
func TestFeatureInternalTrafficPolicy(t *testing.T) { … }
func makePod(name string, ips ...string) api.Pod { … }
func TestServiceRegistryResourceLocation(t *testing.T) { … }
func TestUpdateServiceLoadBalancerStatus(t *testing.T) { … }
func loadbalancerIPModeInUse(status api.ServiceStatus) bool { … }