Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for IsServiceIPSet (0.15 sec)

  1. pkg/kubelet/envvars/envvars.go

    		// ignore services where ClusterIP is "None" or empty
    		// the services passed to this method should be pre-filtered
    		// only services that have the cluster IP set should be included here
    		if !v1helper.IsServiceIPSet(service) {
    			continue
    		}
    
    		// Host
    		name := makeEnvVariableName(service.Name) + "_SERVICE_HOST"
    		result = append(result, v1.EnvVar{Name: name, Value: service.Spec.ClusterIP})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 09 11:14:08 UTC 2017
    - 3.3K bytes
    - Viewed (0)
  2. 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)
  3. pkg/api/service/warnings.go

    		warnings = append(warnings, fmt.Sprintf("annotation %s is deprecated, please use %s instead", api.DeprecatedAnnotationTopologyAwareHints, api.AnnotationTopologyMode))
    	}
    
    	if helper.IsServiceIPSet(service) {
    		for i, clusterIP := range service.Spec.ClusterIPs {
    			warnings = append(warnings, getWarningsForIP(field.NewPath("spec").Child("clusterIPs").Index(i), clusterIP)...)
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 26 22:57:57 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. pkg/apis/core/helper/helpers_test.go

    			},
    
    			output: true,
    		},
    	}
    
    	for _, tc := range testCases {
    		t.Run(tc.name, func(t *testing.T) {
    			s := core.Service{
    				Spec: tc.input,
    			}
    			if IsServiceIPSet(&s) != tc.output {
    				t.Errorf("case, input: %v, expected: %v, got: %v", tc.input, tc.output, !tc.output)
    			}
    		})
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Oct 28 07:31:28 UTC 2023
    - 9.2K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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