Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 80 for servicecidrs (0.23 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/controlplane/controller/defaultservicecidr/default_servicecidr_controller_test.go

    		name    string
    		cidrs   []*networkingapiv1alpha1.ServiceCIDR
    		actions [][]string // verb and resource
    	}{
    		{
    			name:    "no existing service CIDRs",
    			actions: [][]string{{"create", "servicecidrs"}, {"patch", "servicecidrs"}},
    		},
    		{
    			name: "existing default service CIDR update Ready condition",
    			cidrs: []*networkingapiv1alpha1.ServiceCIDR{
    				{
    					ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 14 23:31:58 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  3. 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)
  4. api/discovery/apis__networking.k8s.io__v1alpha1.json

            "deletecollection",
            "get",
            "list",
            "patch",
            "update",
            "watch"
          ]
        },
        {
          "kind": "ServiceCIDR",
          "name": "servicecidrs",
          "namespaced": false,
          "singularName": "servicecidr",
          "storageVersionHash": "3cDF5hqTkLY=",
          "verbs": [
            "create",
            "delete",
            "deletecollection",
            "get",
            "list",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 1K bytes
    - Viewed (0)
  5. 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)
  6. cmd/kube-controller-manager/app/networking.go

    		}}
    }
    func startServiceCIDRsController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) {
    	go servicecidrs.NewController(
    		ctx,
    		controllerContext.InformerFactory.Networking().V1alpha1().ServiceCIDRs(),
    		controllerContext.InformerFactory.Networking().V1alpha1().IPAddresses(),
    		controllerContext.ClientBuilder.ClientOrDie("service-cidrs-controller"),
    	).Run(ctx, 5)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  7. pkg/registry/networking/rest/storage_settings.go

    		ipAddressStorage, err := ipaddressstore.NewREST(restOptionsGetter)
    		if err != nil {
    			return storage, err
    		}
    		storage[resource] = ipAddressStorage
    	}
    
    	// servicecidrs
    	if resource := "servicecidrs"; apiResourceConfigSource.ResourceEnabled(networkingapiv1alpha1.SchemeGroupVersion.WithResource(resource)) {
    		serviceCIDRStorage, serviceCIDRStatusStorage, err := servicecidrstore.NewREST(restOptionsGetter)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:04 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  8. pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller.go

    			CIDRs: c.cidrs,
    		},
    	}
    	serviceCIDR, err = c.client.NetworkingV1alpha1().ServiceCIDRs().Create(context.Background(), serviceCIDR, metav1.CreateOptions{})
    	if err != nil && !apierrors.IsAlreadyExists(err) {
    		c.eventRecorder.Eventf(serviceCIDR, v1.EventTypeWarning, "KubernetesDefaultServiceCIDRError", "The default ServiceCIDR can not be created")
    		return err
    	}
    	c.syncStatus(serviceCIDR)
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  9. 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)
  10. pkg/registry/networking/servicecidr/storage/storage.go

    		NewListFunc:               func() runtime.Object { return &networking.ServiceCIDRList{} },
    		DefaultQualifiedResource:  networking.Resource("servicecidrs"),
    		SingularQualifiedResource: networking.Resource("servicecidr"),
    
    		CreateStrategy:      servicecidr.Strategy,
    		UpdateStrategy:      servicecidr.Strategy,
    		DeleteStrategy:      servicecidr.Strategy,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:04 UTC 2023
    - 3.9K bytes
    - Viewed (0)
Back to top