const APIServerIdentityLabel …
type PeerAdvertiseAddress …
type peerEndpointLeases …
type PeerEndpointLeaseReconciler …
type peerEndpointLeaseReconciler …
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 { … }
func (c *PeerEndpointLeaseController) Start(stopCh <-chan struct{ … }
func (c *PeerEndpointLeaseController) Run(stopCh <-chan struct{ … }
func (c *PeerEndpointLeaseController) Stop() { … }
func (c *PeerEndpointLeaseController) UpdatePeerEndpointLeases() error { … }
func (r *peerEndpointLeaseReconciler) UpdateLease(serverId string, ip string, endpointPorts []corev1.EndpointPort) error { … }
func (r *peerEndpointLeaseReconciler) ListLeases() ([]string, error) { … }
func (r *peerEndpointLeaseReconciler) GetLease(serverId string) (string, error) { … }
func (r *peerEndpointLeaseReconciler) StopReconciling() { … }
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) { … }
func createEndpointPortSpec(endpointPort int, endpointPortName string) []corev1.EndpointPort { … }