- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for ReconcileEndpoints (0.19 sec)
-
pkg/controlplane/reconcilers/instancecount.go
// - All apiservers MUST use ReconcileEndpoints and only ReconcileEndpoints to manage the // endpoints for their {rw, ro} services. // - All apiservers MUST know and agree on the number of apiservers expected // to be running (c.masterCount). // - ReconcileEndpoints is called periodically from all apiservers.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 7.2K bytes - Viewed (0) -
pkg/controlplane/reconcilers/reconcilers.go
// * All apiservers MUST use ReconcileEndpoints and only ReconcileEndpoints to manage the // endpoints for their {rw, ro} services. // * ReconcileEndpoints is called periodically from all apiservers. ReconcileEndpoints(serviceName string, ip net.IP, endpointPorts []corev1.EndpointPort, reconcilePorts bool) error // RemoveEndpoints removes this apiserver's lease.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 26 13:49:31 UTC 2022 - 2.7K bytes - Viewed (0) -
pkg/controlplane/reconcilers/none.go
// nothing. It is a no-op. func NewNoneEndpointReconciler() EndpointReconciler { return &noneEndpointReconciler{} } // ReconcileEndpoints noop reconcile func (r *noneEndpointReconciler) ReconcileEndpoints(serviceName string, ip net.IP, endpointPorts []corev1.EndpointPort, reconcilePorts bool) error { return nil } // RemoveEndpoints noop reconcile
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 05 11:45:48 UTC 2022 - 1.5K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease.go
masterLeases: masterLeases, } } // ReconcileEndpoints lists keys in a special etcd directory. // Each key is expected to have a TTL of R+n, where R is the refresh interval // at which this function is called, and n is some small value. If an // apiserver goes down, it will fail to refresh its key's TTL and the key will // expire. ReconcileEndpoints will notice that the endpoints object is
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 11.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease_test.go
} // reconcile endpoints in another goroutine err = r.ReconcileEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts, false) if err != nil { t.Errorf("unexpected error reconciling: %v", err) } } else { // reconcile endpoints first err = r.ReconcileEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts, false) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 28.7K bytes - Viewed (0) -
pkg/controlplane/reconcilers/instancecount_test.go
epAdapter := NewEndpointsAdapter(fakeClient.CoreV1(), fakeClient.DiscoveryV1()) reconciler := NewMasterCountEndpointReconciler(test.additionalMasters+1, epAdapter) err := reconciler.ReconcileEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts, true) if err != nil { t.Errorf("unexpected error reconciling: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:24 UTC 2022 - 14K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller.go
return err } endpointPorts := createEndpointPortSpec(c.PublicServicePort, "https") if err := c.EndpointReconciler.ReconcileEndpoints(kubernetesServiceName, c.PublicIP, endpointPorts, reconcile); err != nil { return err } return nil } // createPortAndServiceSpec creates an array of service ports.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 9.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
// 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. StopReconciling() } type peerEndpointLeaseReconciler struct { serverLeases *peerEndpointLeases stopReconcilingCalled atomic.Bool }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0)