- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for RemoveEndpoints (0.14 sec)
-
pkg/controlplane/reconcilers/lease.go
// reconcile endpoints only if apiserver was not shutdown if r.stopReconcilingCalled.Load() { return nil } // Ensure that there will be no race condition with the RemoveEndpoints. r.reconcilingLock.Lock() defer r.reconcilingLock.Unlock() // Refresh the TTL on our key, independently of whether any error or // update conflict happens below. This makes sure that at least some of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 11.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
GetEndpoint(serverId string) (string, error) // UpdateLease updates the ip and port of peer servers UpdateLease(serverId string, ip string, endpointPorts []corev1.EndpointPort) error // RemoveEndpoints removes this apiserver's peer endpoint lease. RemoveLease(serverId string) error // Destroy cleans up everything on shutdown. Destroy() // StopReconciling turns any later ReconcileEndpoints call into a noop.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease_test.go
epAdapter := NewEndpointsAdapter(clientset.CoreV1(), clientset.DiscoveryV1()) r := NewLeaseEndpointReconciler(epAdapter, fakeLeases) if !test.apiServerStartup { r.StopReconciling() } err = r.RemoveEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts) // if the ip is not on the endpoints, it must return an storage error and stop reconciling if !contains(test.endpointKeys, test.ip) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 28.7K bytes - Viewed (0)