Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for servicecidrs (0.24 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/controller/servicecidrs/servicecidrs_controller_test.go

    func makeServiceCIDR(name, primary, secondary string) *networkingapiv1alpha1.ServiceCIDR {
    	serviceCIDR := &networkingapiv1alpha1.ServiceCIDR{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: name,
    		},
    		Spec: networkingapiv1alpha1.ServiceCIDRSpec{},
    	}
    	serviceCIDR.Spec.CIDRs = append(serviceCIDR.Spec.CIDRs, primary)
    	if secondary != "" {
    		serviceCIDR.Spec.CIDRs = append(serviceCIDR.Spec.CIDRs, secondary)
    	}
    	return serviceCIDR
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 22K bytes
    - Viewed (0)
  3. pkg/registry/core/service/ipallocator/cidrallocator_test.go

    	serviceCIDRInformer := informerFactory.Networking().V1alpha1().ServiceCIDRs()
    	serviceCIDRStore := serviceCIDRInformer.Informer().GetIndexer()
    	serviceCIDRInformer.Informer().HasSynced()
    	ipInformer := informerFactory.Networking().V1alpha1().IPAddresses()
    	ipStore := ipInformer.Informer().GetIndexer()
    
    	client.PrependReactor("create", "servicecidrs", k8stesting.ReactionFunc(func(action k8stesting.Action) (bool, runtime.Object, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:06 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  4. 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)
  5. pkg/registry/core/rest/storage_core.go

    		// since right now it depends on the service-cidr flags and
    		// sets the default IPFamily that may not be coherent with the
    		// existing default ServiceCIDR
    		primaryClusterIPAllocator, err = ipallocator.NewMetaAllocator(
    			networkingv1alphaClient,
    			c.Informers.Networking().V1alpha1().ServiceCIDRs(),
    			c.Informers.Networking().V1alpha1().IPAddresses(),
    			netutils.IsIPv6CIDR(&serviceClusterIPRange),
    		)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 19.1K bytes
    - Viewed (0)
  6. plugin/pkg/auth/authorizer/rbac/bootstrappolicy/controller_policy.go

    				rbacv1helpers.NewRule("get", "list", "watch", "patch", "update").Groups(networkingGroup).Resources("servicecidrs").RuleOrDie(),
    				rbacv1helpers.NewRule("patch", "update").Groups(networkingGroup).Resources("servicecidrs/finalizers").RuleOrDie(),
    				rbacv1helpers.NewRule("patch", "update").Groups(networkingGroup).Resources("servicecidrs/status").RuleOrDie(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 19:25:10 UTC 2024
    - 28.9K bytes
    - Viewed (0)
  7. pkg/registry/core/service/ipallocator/controller/repairip_test.go

    	serviceCIDR := &networkingv1alpha1.ServiceCIDR{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: name,
    		},
    		Spec: networkingv1alpha1.ServiceCIDRSpec{},
    	}
    	serviceCIDR.Spec.CIDRs = append(serviceCIDR.Spec.CIDRs, primary)
    	if secondary != "" {
    		serviceCIDR.Spec.CIDRs = append(serviceCIDR.Spec.CIDRs, secondary)
    	}
    	return serviceCIDR
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:06 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. pkg/apis/networking/types.go

    // ServiceCIDRStatus describes the current state of the ServiceCIDR.
    type ServiceCIDRStatus struct {
    	// conditions holds an array of metav1.Condition that describe the state of the ServiceCIDR.
    	Conditions []metav1.Condition
    }
    
    // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
    // +k8s:prerelease-lifecycle-gen:introduced=1.27
    
    // ServiceCIDRList contains a list of ServiceCIDR objects.
    type ServiceCIDRList struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:06 UTC 2023
    - 27.7K bytes
    - Viewed (0)
Back to top