Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for ServiceCIDRs (0.19 sec)

  1. pkg/controller/servicecidrs/servicecidrs_controller.go

    		return []string{}
    	}
    
    	c.muTree.Lock()
    	defer c.muTree.Unlock()
    	serviceCIDRs := []string{}
    	// walk the tree to get all the ServiceCIDRs that contain this IP address
    	prefixes := c.tree.GetHostIPPrefixMatches(address)
    	for _, v := range prefixes {
    		serviceCIDRs = append(serviceCIDRs, v.UnsortedList()...)
    	}
    
    	return serviceCIDRs
    }
    
    func (c *Controller) worker(ctx context.Context) {
    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. 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)
  4. pkg/controller/servicecidrs/servicecidrs_controller_test.go

    			actions:    [][]string{{"patch", "servicecidrs", ""}, {"patch", "servicecidrs", "status"}},
    		},
    		{
    			name: "service CIDR must have finalizer",
    			cidrs: []*networkingapiv1alpha1.ServiceCIDR{
    				makeServiceCIDR("no-finalizer", "192.168.0.0/24", "2001:db2::/64"),
    			},
    			cidrSynced: "no-finalizer",
    			actions:    [][]string{{"patch", "servicecidrs", ""}, {"patch", "servicecidrs", "status"}},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 22K bytes
    - Viewed (0)
  5. api/discovery/apis__networking.k8s.io__v1alpha1.json

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

    		ObjectMeta: metav1.ObjectMeta{
    			Name: DefaultServiceCIDRName,
    		},
    		Spec: networkingapiv1alpha1.ServiceCIDRSpec{
    			CIDRs: c.cidrs,
    		},
    	}
    	serviceCIDR, err = c.client.NetworkingV1alpha1().ServiceCIDRs().Create(context.Background(), serviceCIDR, metav1.CreateOptions{})
    	if err != nil && !apierrors.IsAlreadyExists(err) {
    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

    	defer func() {
    		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

    		NewFunc:                   func() runtime.Object { return &networking.ServiceCIDR{} },
    		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