- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for ServiceCIDRs (0.41 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)