- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewRepairIPAddress (0.15 sec)
-
pkg/registry/core/rest/storage_core.go
rangeRegistries.clusterIP, &c.Services.SecondaryClusterIPRange, rangeRegistries.secondaryClusterIP, ).RunUntil } 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
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 19.1K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip_test.go
ip := action.(k8stesting.DeleteAction).GetName() err := ipIndexer.Delete(ip) return false, &networkingv1alpha1.IPAddress{}, err })) r := NewRepairIPAddress(0*time.Second, fakeClient, serviceInformer, serviceCIDRInformer, ipInformer, ) return fakeClient, &fakeRepair{r, serviceIndexer, ipIndexer, serviceCIDRIndexer} }
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
} // NewRepair creates a controller that periodically ensures that all clusterIPs are uniquely allocated across the cluster // and generates informational warnings for a cluster that is not in sync. func NewRepairIPAddress(interval time.Duration, client kubernetes.Interface, serviceInformer coreinformers.ServiceInformer, serviceCIDRInformer networkinginformers.ServiceCIDRInformer,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0)