- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 80 for servicecidrs (0.23 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/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) -
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) -
api/discovery/apis__networking.k8s.io__v1alpha1.json
"deletecollection", "get", "list", "patch", "update", "watch" ] }, { "kind": "ServiceCIDR", "name": "servicecidrs", "namespaced": false, "singularName": "servicecidr", "storageVersionHash": "3cDF5hqTkLY=", "verbs": [ "create", "delete", "deletecollection", "get", "list",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 1K 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) -
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) -
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) -
pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller.go
CIDRs: c.cidrs, }, } serviceCIDR, err = c.client.NetworkingV1alpha1().ServiceCIDRs().Create(context.Background(), serviceCIDR, metav1.CreateOptions{}) if err != nil && !apierrors.IsAlreadyExists(err) { c.eventRecorder.Eventf(serviceCIDR, v1.EventTypeWarning, "KubernetesDefaultServiceCIDRError", "The default ServiceCIDR can not be created") return err } c.syncStatus(serviceCIDR) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 7.5K 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/networking/servicecidr/storage/storage.go
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)