Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for IsServiceIPSet (0.28 sec)

  1. pkg/apis/core/v1/helper/helpers.go

    func IsAttachableVolumeResourceName(name v1.ResourceName) bool {
    	return strings.HasPrefix(string(name), v1.ResourceAttachableVolumesPrefix)
    }
    
    // IsServiceIPSet aims to check if the service's ClusterIP is set or not
    // the objective is not to perform validation here
    func IsServiceIPSet(service *v1.Service) bool {
    	return service.Spec.ClusterIP != v1.ClusterIPNone && service.Spec.ClusterIP != ""
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 23:03:54 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  2. pkg/apis/core/helper/helpers.go

    func IsIntegerResourceName(name core.ResourceName) bool {
    	return integerResources.Has(name) || IsExtendedResourceName(name)
    }
    
    // IsServiceIPSet aims to check if the service's ClusterIP is set or not
    // the objective is not to perform validation here
    func IsServiceIPSet(service *core.Service) bool {
    	// This function assumes that the service is semantically validated
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Oct 28 07:31:28 UTC 2023
    - 16.1K bytes
    - Viewed (0)
  3. pkg/registry/core/service/ipallocator/controller/repair.go

    			return v1.IPv6Protocol
    		}
    		return v1.IPv4Protocol
    	}
    
    	// Check every Service's ClusterIP, and rebuild the state as we think it should be.
    	for _, svc := range list.Items {
    		if !helper.IsServiceIPSet(&svc) {
    			// didn't need a cluster IP
    			continue
    		}
    
    		for _, ip := range svc.Spec.ClusterIPs {
    			ip := netutils.ParseIPSloppy(ip)
    			if ip == nil {
    				// cluster IP is corrupt
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 13.8K bytes
    - Viewed (0)
  4. pkg/registry/core/service/ipallocator/controller/repairip.go

    	if err != nil {
    		return err
    	}
    	svc, err := r.serviceLister.Services(namespace).Get(name)
    	if err != nil {
    		// nothing to do
    		return nil
    	}
    	if !helper.IsServiceIPSet(svc) {
    		// didn't need a ClusterIP
    		return nil
    	}
    
    	for _, clusterIP := range svc.Spec.ClusterIPs {
    		ip := netutils.ParseIPSloppy(clusterIP)
    		if ip == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  5. pkg/controller/endpoint/endpoints_controller.go

    	} else {
    		delete(newEndpoints.Annotations, v1.EndpointsOverCapacity)
    	}
    
    	if newEndpoints.Labels == nil {
    		newEndpoints.Labels = make(map[string]string)
    	}
    
    	if !helper.IsServiceIPSet(service) {
    		newEndpoints.Labels = utillabels.CloneAndAddLabel(newEndpoints.Labels, v1.IsHeadlessService, "")
    	} else {
    		newEndpoints.Labels = utillabels.CloneAndRemoveLabel(newEndpoints.Labels, v1.IsHeadlessService)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 26.3K bytes
    - Viewed (0)
Back to top