Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for servicecidrs (0.18 sec)

  1. pkg/controller/servicecidrs/servicecidrs_controller.go

    				serviceCIDRs.Insert(v.UnsortedList()...)
    				return false
    			})
    			if serviceCIDRs.Len() == 1 && serviceCIDRs.Has(serviceCIDR.Name) {
    				hasParent = false
    			}
    		}
    	}
    
    	// All the existing IP addresses will be contained on the parent ServiceCIDRs,
    	// it is safe to delete, remove the finalizer.
    	if hasParent {
    		logger.V(2).Info("Removing finalizer for ServiceCIDR", "ServiceCIDR", serviceCIDR.String())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 18K bytes
    - Viewed (0)
  2. pkg/registry/core/service/ipallocator/cidrallocator.go

    		klog.V(2).Infof("Finished sync for CIDRs took %v", time.Since(now))
    	}()
    
    	serviceCIDRs, err := c.serviceCIDRLister.List(labels.Everything())
    	if err != nil {
    		return err
    	}
    
    	cidrsSet := sets.New[string]()
    	cidrReady := map[string]bool{}
    	for _, serviceCIDR := range serviceCIDRs {
    		ready := true
    		if !isReady(serviceCIDR) || !serviceCIDR.DeletionTimestamp.IsZero() {
    			ready = false
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  3. pkg/registry/core/service/ipallocator/controller/repairip.go

    	if err == nil {
    		r.cidrQueue.Forget(key)
    		return
    	}
    
    	if r.cidrQueue.NumRequeues(key) < maxRetries {
    		klog.V(2).InfoS("Error syncing ServiceCIDR, retrying", "serviceCIDR", key, "err", err)
    		r.cidrQueue.AddRateLimited(key)
    		return
    	}
    
    	klog.Warningf("Dropping ServiceCIDR %q out of the queue: %v", key, err)
    	r.cidrQueue.Forget(key)
    	runtime.HandleError(err)
    }
    
    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/proxy/config/config.go

    // events on ServiceCIDR objects and call downstream event handlers.
    func (c *ServiceCIDRConfig) handleServiceCIDREvent(oldObj, newObj interface{}) {
    	var oldServiceCIDR, newServiceCIDR *networkingv1alpha1.ServiceCIDR
    	var ok bool
    
    	if oldObj != nil {
    		oldServiceCIDR, ok = oldObj.(*networkingv1alpha1.ServiceCIDR)
    		if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  5. cmd/kube-proxy/app/server.go

    		informers.WithTweakListOptions(func(options *metav1.ListOptions) {
    			options.LabelSelector = labelSelector.String()
    		}))
    
    	// Create configs (i.e. Watches for Services, EndpointSlices and ServiceCIDRs)
    	// Note: RegisterHandler() calls need to happen before creation of Sources because sources
    	// only notify on changes, and the initial update (on process start) may be lost if no handlers
    	// are registered yet.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 46.8K bytes
    - Viewed (0)
  6. pkg/controller/nodeipam/ipam/range_allocator_test.go

    					_, clusterCIDR, _ := netutils.ParseCIDRSloppy("127.123.234.0/24")
    					return []*net.IPNet{clusterCIDR}
    				}(),
    				ServiceCIDR: func() *net.IPNet {
    					_, serviceCIDR, _ := netutils.ParseCIDRSloppy("127.123.234.0/26")
    					return serviceCIDR
    				}(),
    				SecondaryServiceCIDR: nil,
    				NodeCIDRMaskSizes:    []int{30},
    			},
    			// it should return first /30 CIDR after service range
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 10:06:15 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  7. pkg/controller/nodeipam/ipam/range_allocator.go

    	// clusterCIDR).
    	for idx, cidr := range r.clusterCIDRs {
    		// if they don't overlap then ignore the filtering
    		if !cidr.Contains(serviceCIDR.IP.Mask(cidr.Mask)) && !serviceCIDR.Contains(cidr.IP.Mask(serviceCIDR.Mask)) {
    			continue
    		}
    
    		// at this point, len(cidrSet) == len(clusterCidr)
    		if err := r.cidrSets[idx].Occupy(serviceCIDR); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 10:06:15 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  8. cmd/kube-apiserver/app/options/validation_test.go

    	"k8s.io/kubernetes/pkg/features"
    )
    
    func makeOptionsWithCIDRs(serviceCIDR string, secondaryServiceCIDR string) *ServerRunOptions {
    	value := serviceCIDR
    	if len(secondaryServiceCIDR) > 0 {
    		value = value + "," + secondaryServiceCIDR
    	}
    
    	var primaryCIDR, secondaryCIDR net.IPNet
    	if len(serviceCIDR) > 0 {
    		_, cidr, _ := netutils.ParseCIDRSloppy(serviceCIDR)
    		if cidr != nil {
    			primaryCIDR = *(cidr)
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  9. cmd/kube-controller-manager/app/core.go

    	if len(strings.TrimSpace(controllerContext.ComponentConfig.NodeIPAMController.ServiceCIDR)) != 0 {
    		_, serviceCIDR, err = netutils.ParseCIDRSloppy(controllerContext.ComponentConfig.NodeIPAMController.ServiceCIDR)
    		if err != nil {
    			logger.Info("Warning: unsuccessful parsing of service CIDR", "CIDR", controllerContext.ComponentConfig.NodeIPAMController.ServiceCIDR, "err", err)
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 39K bytes
    - Viewed (0)
  10. cmd/kubeadm/app/preflight/checks_test.go

    	ipv6File := "FileContent--proc-sys-net-ipv6-conf-default-forwarding"
    	var tests = []struct {
    		testName    string
    		PodSubnet   string
    		serviceCidr string
    		expStr      []string
    	}{
    		{
    			testName:    "dual stack",
    			PodSubnet:   "fda9:d324:354d:0::/56",
    			serviceCidr: "10.96.0.0/16,fda9:d324:354d:1::/112",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 06:58:01 UTC 2024
    - 33.5K bytes
    - Viewed (0)
Back to top