Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for IsServiceIPSet (0.13 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/proxy/util/utils.go

    	}
    	return false
    }
    
    // ShouldSkipService checks if a given service should skip proxying
    func ShouldSkipService(service *v1.Service) bool {
    	// if ClusterIP is "None" or empty, skip proxying
    	if !helper.IsServiceIPSet(service) {
    		klog.V(3).InfoS("Skipping service due to cluster IP", "service", klog.KObj(service), "clusterIP", service.Spec.ClusterIP)
    		return true
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 20 11:57:43 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. pkg/kubelet/kubelet_pods.go

    	}
    
    	// project the services in namespace ns onto the master services
    	for i := range services {
    		service := services[i]
    		// ignore services where ClusterIP is "None" or empty
    		if !v1helper.IsServiceIPSet(service) {
    			continue
    		}
    		serviceName := service.Name
    
    		// We always want to add environment variabled for master services
    		// from the default namespace, even if enableServiceLinks is false.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
Back to top