- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for servicecidrs (0.18 sec)
-
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) -
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) -
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) -
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) -
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) -
pkg/controller/nodeipam/ipam/range_allocator_test.go
_, clusterCIDR, _ := netutils.ParseCIDRSloppy("127.123.234.0/24") return []*net.IPNet{clusterCIDR} }(), ServiceCIDR: func() *net.IPNet { _, serviceCIDR, _ := netutils.ParseCIDRSloppy("127.123.234.0/26") return serviceCIDR }(), SecondaryServiceCIDR: nil, NodeCIDRMaskSizes: []int{30}, }, // it should return first /30 CIDR after service range
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 25.2K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
// clusterCIDR). for idx, cidr := range r.clusterCIDRs { // if they don't overlap then ignore the filtering if !cidr.Contains(serviceCIDR.IP.Mask(cidr.Mask)) && !serviceCIDR.Contains(cidr.IP.Mask(serviceCIDR.Mask)) { continue } // at this point, len(cidrSet) == len(clusterCidr) if err := r.cidrSets[idx].Occupy(serviceCIDR); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/validation_test.go
"k8s.io/kubernetes/pkg/features" ) func makeOptionsWithCIDRs(serviceCIDR string, secondaryServiceCIDR string) *ServerRunOptions { value := serviceCIDR if len(secondaryServiceCIDR) > 0 { value = value + "," + secondaryServiceCIDR } var primaryCIDR, secondaryCIDR net.IPNet if len(serviceCIDR) > 0 { _, cidr, _ := netutils.ParseCIDRSloppy(serviceCIDR) if cidr != nil { primaryCIDR = *(cidr) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 11.4K bytes - Viewed (0) -
cmd/kube-controller-manager/app/core.go
if len(strings.TrimSpace(controllerContext.ComponentConfig.NodeIPAMController.ServiceCIDR)) != 0 { _, serviceCIDR, err = netutils.ParseCIDRSloppy(controllerContext.ComponentConfig.NodeIPAMController.ServiceCIDR) if err != nil { logger.Info("Warning: unsuccessful parsing of service CIDR", "CIDR", controllerContext.ComponentConfig.NodeIPAMController.ServiceCIDR, "err", err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 39K bytes - Viewed (0) -
cmd/kubeadm/app/preflight/checks_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 06:58:01 UTC 2024 - 33.5K bytes - Viewed (0)