- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for servicecidrs (0.37 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/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) -
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
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
// since right now it depends on the service-cidr flags and // sets the default IPFamily that may not be coherent with the // existing default ServiceCIDR primaryClusterIPAllocator, err = ipallocator.NewMetaAllocator( networkingv1alphaClient, c.Informers.Networking().V1alpha1().ServiceCIDRs(), c.Informers.Networking().V1alpha1().IPAddresses(), netutils.IsIPv6CIDR(&serviceClusterIPRange), ) if err != 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_test.go
serviceCIDR := &networkingv1alpha1.ServiceCIDR{ ObjectMeta: metav1.ObjectMeta{ Name: name, }, Spec: networkingv1alpha1.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: Tue Oct 31 21:05:06 UTC 2023 - 20.3K 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) -
pkg/apis/networking/types.go
// ServiceCIDRStatus describes the current state of the ServiceCIDR. type ServiceCIDRStatus struct { // conditions holds an array of metav1.Condition that describe the state of the ServiceCIDR. Conditions []metav1.Condition } // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object // +k8s:prerelease-lifecycle-gen:introduced=1.27 // ServiceCIDRList contains a list of ServiceCIDR objects. type ServiceCIDRList struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 27.7K bytes - Viewed (0)