const APIServerIdentityLabel … type PeerAdvertiseAddress … type peerEndpointLeases … type PeerEndpointLeaseReconciler … type peerEndpointLeaseReconciler … // NewPeerEndpointLeaseReconciler creates a new peer endpoint lease reconciler func NewPeerEndpointLeaseReconciler(config *storagebackend.ConfigForResource, baseKey string, leaseTime time.Duration) (PeerEndpointLeaseReconciler, error) { … } type PeerEndpointLeaseController … func New(serverId string, peeraddress string, reconciler PeerEndpointLeaseReconciler, endpointInterval time.Duration, client kubernetes.Interface) *PeerEndpointLeaseController { … } // Start begins the peer endpoint lease reconciler loop that must exist for bootstrapping // a cluster. func (c *PeerEndpointLeaseController) Start(stopCh <-chan struct{ … } // RunPeerEndpointReconciler periodically updates the peer endpoint leases func (c *PeerEndpointLeaseController) Run(stopCh <-chan struct{ … } // Stop cleans up this apiserver's peer endpoint leases. func (c *PeerEndpointLeaseController) Stop() { … } // UpdatePeerEndpointLeases attempts to update the peer endpoint leases. func (c *PeerEndpointLeaseController) UpdatePeerEndpointLeases() error { … } // It will also do the following if UnknownVersionInteroperabilityProxy feature is enabled // 1. store the apiserverId as a label // 2. store the values passed to --peer-advertise-ip and --peer-advertise-port flags to kube-apiserver as an annotation // with value of format <ip:port> func (r *peerEndpointLeaseReconciler) UpdateLease(serverId string, ip string, endpointPorts []corev1.EndpointPort) error { … } // ListLeases retrieves a list of the current server IPs from storage func (r *peerEndpointLeaseReconciler) ListLeases() ([]string, error) { … } // GetLease retrieves the server IP and port for a specific server id func (r *peerEndpointLeaseReconciler) GetLease(serverId string) (string, error) { … } func (r *peerEndpointLeaseReconciler) StopReconciling() { … } // RemoveLease removes the lease on a server IP in storage // We use the first element in endpointPorts as a part of the lease's base key // This is done to support out tests that simulate 2 apiservers running on the same ip but // different ports func (r *peerEndpointLeaseReconciler) RemoveLease(serverId string) error { … } func (r *peerEndpointLeaseReconciler) Destroy() { … } func (r *peerEndpointLeaseReconciler) GetEndpoint(serverId string) (string, error) { … } func (r *peerEndpointLeaseReconciler) getIpInfoList(storageOpts storage.ListOptions) (*corev1.EndpointsList, error) { … } // createEndpointPortSpec creates the endpoint ports func createEndpointPortSpec(endpointPort int, endpointPortName string) []corev1.EndpointPort { … }
Codebase Browser
kubernetes