Documentation ¶
Index ¶
Constants ¶
View Source
const Port = 9002
Variables ¶
This section is empty.
Functions ¶
func Run ¶
func Run(kubeClient kubernetes.Interface, syncTracker *SyncTracker)
Types ¶
type SyncTracker ¶
type SyncTracker struct {
// contains filtered or unexported fields
}
SyncTracker tracks connections to CLIs that can be queried to get the sync status.
func NewSyncTracker ¶
func NewSyncTracker() *SyncTracker
func (*SyncTracker) RunServer ¶
func (st *SyncTracker) RunServer(namespace string, srv node.Controller_SyncNotificationsServer) error
func (*SyncTracker) WaitFor ¶
func (st *SyncTracker) WaitFor(namespace string) Waiter
WaitFor creates a waiter function that blocks until the initial sync is completed for the given namespace.
Click to show internal directories.
Click to hide internal directories.