- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 46 for servicecidrs (0.25 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) -
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/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) -
staging/src/k8s.io/api/networking/v1alpha1/generated.proto
} // ServiceCIDRList contains a list of ServiceCIDR objects. message ServiceCIDRList { // Standard object's metadata. // More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata // +optional optional .k8s.io.apimachinery.pkg.apis.meta.v1.ListMeta metadata = 1; // items is the list of ServiceCIDRs. repeated ServiceCIDR items = 2; }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
// staleChains contains information about chains to be deleted later staleChains map[string]time.Time // serviceCIDRs is a comma separated list of ServiceCIDRs belonging to the IPFamily // which proxier is operating on, can be directly consumed by knftables. serviceCIDRs string logger klog.Logger } // Proxier implements proxy.Provider var _ proxy.Provider = &Proxier{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K 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/kubeapiserver/default_storage_factory_builder.go
// apisstorage.Resource("csistoragecapacities").WithVersion("v1beta1"), networking.Resource("ipaddresses").WithVersion("v1alpha1"), networking.Resource("servicecidrs").WithVersion("v1alpha1"), certificates.Resource("clustertrustbundles").WithVersion("v1alpha1"), storage.Resource("volumeattributesclasses").WithVersion("v1alpha1"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 20:14:51 UTC 2024 - 6.6K bytes - Viewed (0) -
pkg/proxy/metaproxier/meta_proxier.go
func (proxier *metaProxier) OnNodeSynced() { proxier.ipv4Proxier.OnNodeSynced() proxier.ipv6Proxier.OnNodeSynced() } // OnServiceCIDRsChanged is called whenever a change is observed // in any of the ServiceCIDRs, and provides complete list of service cidrs. func (proxier *metaProxier) OnServiceCIDRsChanged(cidrs []string) { proxier.ipv4Proxier.OnServiceCIDRsChanged(cidrs) proxier.ipv6Proxier.OnServiceCIDRsChanged(cidrs)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 21 14:28:37 UTC 2024 - 5.9K bytes - Viewed (0)