Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 343 for clusterIPs (0.15 sec)

  1. pkg/api/service/warnings_test.go

    	service := func(clusterIPs []string) *api.Service {
    		svc := api.Service{
    			ObjectMeta: metav1.ObjectMeta{
    				Name:      "svc-test",
    				Namespace: "ns",
    			},
    			Spec: api.ServiceSpec{
    				Type: api.ServiceTypeClusterIP,
    			},
    		}
    
    		if len(clusterIPs) > 0 {
    			svc.Spec.ClusterIP = clusterIPs[0]
    			svc.Spec.ClusterIPs = clusterIPs
    		}
    		return &svc
    	}
    
    	tests := []struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 26 22:57:57 UTC 2023
    - 10.4K bytes
    - Viewed (0)
  2. pkg/registry/core/service/storage/alloc.go

    	// if there is no slice to work with
    	if service.Spec.ClusterIPs == nil {
    		service.Spec.ClusterIPs = make([]string, 0, len(service.Spec.IPFamilies))
    	}
    
    	for i, ipFamily := range service.Spec.IPFamilies {
    		if i > (len(service.Spec.ClusterIPs) - 1) {
    			service.Spec.ClusterIPs = append(service.Spec.ClusterIPs, "" /* just a marker */)
    		}
    
    		toAlloc[ipFamily] = service.Spec.ClusterIPs[i]
    	}
    
    	// allocate
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 37.3K bytes
    - Viewed (0)
  3. pkg/registry/core/service/storage/storage.go

    		return
    	}
    
    	// This was an update operation
    
    	// ClusterIPs were cleared by an old client which was trying to patch
    	// some field and didn't provide ClusterIPs
    	if len(oldSvc.Spec.ClusterIPs) > 0 && len(newSvc.Spec.ClusterIPs) == 0 {
    		// if ClusterIP is the same, then it is an old client trying to
    		// patch service and didn't provide ClusterIPs
    		if oldSvc.Spec.ClusterIP == newSvc.Spec.ClusterIP {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 13:09:33 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  4. pkg/registry/core/service/ipallocator/controller/repair_test.go

    			Spec: corev1.ServiceSpec{
    				ClusterIP:  "192.168.1.1",
    				ClusterIPs: []string{"192.168.1.1"},
    				IPFamilies: []corev1.IPFamily{corev1.IPv4Protocol},
    			},
    		},
    		&corev1.Service{
    			ObjectMeta: metav1.ObjectMeta{Namespace: "two", Name: "two"},
    			Spec: corev1.ServiceSpec{
    				ClusterIP:  "192.168.1.100",
    				ClusterIPs: []string{"192.168.1.100"},
    				IPFamilies: []corev1.IPFamily{corev1.IPv4Protocol},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 21.1K bytes
    - Viewed (0)
  5. pkg/proxy/util/utils_test.go

    			service: v1.Service{
    				Spec: v1.ServiceSpec{
    					ClusterIPs: []string{"10.0.0.10"},
    					IPFamilies: []v1.IPFamily{v1.IPv4Protocol},
    				},
    			},
    		},
    
    		{
    			name:           "service single stack ipv4. want ipv6",
    			requestFamily:  v1.IPv6Protocol,
    			expectedResult: "",
    			service: v1.Service{
    				Spec: v1.ServiceSpec{
    					ClusterIPs: []string{"10.0.0.10"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 20 11:57:43 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  6. pkg/registry/core/service/ipallocator/controller/repairip.go

    //   creating the corresponding IPAddress objects
    // * IPAddress objects with wrong references or labels
    //
    // Logs about:
    // * ClusterIPs that do not match the currently configured range
    //
    // There is a one-to-one relation between Service ClusterIPs and IPAddresses.
    // The bidirectional relation is achieved using the following fields:
    // Service.Spec.Cluster == IPAddress.Name AND IPAddress.ParentRef == Service
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  7. pkg/registry/core/service/ipallocator/controller/repair.go

    // and logs any errors, and then sets the compacted and accurate list of all allocated IPs.
    //
    // Handles:
    // * Duplicate ClusterIP assignments caused by operator action or undetected race conditions
    // * ClusterIPs that do not match the currently configured range
    // * Allocations to services that were not actually created due to a crash or powerloss
    // * Migrates old versions of Kubernetes services into the atomic ipallocator model automatically
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 13.8K bytes
    - Viewed (0)
  8. pkg/registry/core/service/strategy.go

    	// If the user is switching to a type that does not need a value in
    	// clusterIP/clusterIPs (even "None" counts as a value), we might be able
    	// to wipe some fields.
    	if needsClusterIP(oldSvc) && !needsClusterIP(newSvc) {
    		if sameClusterIPs(oldSvc, newSvc) {
    			// These will be deallocated later.
    			newSvc.Spec.ClusterIP = ""
    			newSvc.Spec.ClusterIPs = nil
    		}
    		if sameIPFamilies(oldSvc, newSvc) {
    			newSvc.Spec.IPFamilies = nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 13:09:36 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  9. pkg/registry/core/service/strategy_test.go

    			if result.Spec.ClusterIP != tc.expect.Spec.ClusterIP {
    				t.Errorf("expected clusterIP %q, got %q", tc.expect.Spec.ClusterIP, result.Spec.ClusterIP)
    			}
    			if !reflect.DeepEqual(result.Spec.ClusterIPs, tc.expect.Spec.ClusterIPs) {
    				t.Errorf("expected clusterIPs %q, got %q", tc.expect.Spec.ClusterIP, result.Spec.ClusterIP)
    			}
    			if !reflect.DeepEqual(result.Spec.IPFamilies, tc.expect.Spec.IPFamilies) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 32.4K bytes
    - Viewed (0)
  10. pkg/registry/core/rest/storage_core.go

    	return "start-service-ip-repair-controllers", func(context genericapiserver.PostStartHookContext) error {
    		// We start both repairClusterIPs and repairNodePorts to ensure repair
    		// loops of ClusterIPs and NodePorts.
    		// We run both repair loops using RunUntil public interface.
    		// However, we want to fail liveness/readiness until the first
    		// successful repair loop, so we basically pass appropriate
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 19.1K bytes
    - Viewed (0)
Back to top