Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for ServiceCIDRs (0.27 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/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)
  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

    	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)
  5. pkg/registry/core/rest/storage_core.go

    	} else {
    		p.startServiceClusterIPRepair = serviceipallocatorcontroller.NewRepairIPAddress(
    			c.Services.IPRepairInterval,
    			client,
    			c.Informers.Core().V1().Services(),
    			c.Informers.Networking().V1alpha1().ServiceCIDRs(),
    			c.Informers.Networking().V1alpha1().IPAddresses(),
    		).RunUntil
    	}
    
    	return p, 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.go

    		cidrQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "servicecidrs"},
    		),
    		svcQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "services"},
    		),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  8. pkg/proxy/config/config.go

    // notifications about ServiceCIDR object changes.
    type ServiceCIDRHandler interface {
    	// OnServiceCIDRsChanged is called whenever a change is observed
    	// in any of the ServiceCIDRs, and provides complete list of service cidrs.
    	OnServiceCIDRsChanged(cidrs []string)
    }
    
    // ServiceCIDRConfig tracks a set of service configurations.
    type ServiceCIDRConfig struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  9. pkg/registry/core/service/ipallocator/controller/repairip_test.go

    	serviceInformer := informerFactory.Core().V1().Services()
    	serviceIndexer := serviceInformer.Informer().GetIndexer()
    
    	serviceCIDRInformer := informerFactory.Networking().V1alpha1().ServiceCIDRs()
    	serviceCIDRIndexer := serviceCIDRInformer.Informer().GetIndexer()
    
    	ipInformer := informerFactory.Networking().V1alpha1().IPAddresses()
    	ipIndexer := ipInformer.Informer().GetIndexer()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:06 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  10. 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)
Back to top