// Start function runs the k8scontext and continues to listen to the
// event channel and enqueue events before stopChannel is closed
Start function runs the k8scontext and continues to listen to the
event channel and enqueue events before stopChannel is closed
// Start function runs the k8scontext and continues to listen to the // event channel and enqueue events before stopChannel is closed
func (c *AppGwIngressController) Start() {
	go c.eventQueue.Run(time.Second, c.stopChannel)
	c.k8sContext.Run()
	for {
		select {
		case obj := <-c.k8sUpdateChannel.Out():
			event := obj.(k8scontext.Event)
			c.eventQueue.Enqueue(event)
		case <-c.stopChannel:
			break
		}
	}
}
func ( c * AppGwIngressController ) Start ( ) { go c . eventQueue . Run ( time . Second , c . stopChannel ) c . k8sContext . Run ( ) for { select { case obj := <- c . k8sUpdateChannel . Out ( ) : event := obj . ( k8scontext . Event ) c . eventQueue . Enqueue ( event ) case <- c . stopChannel : break } } }
Start function runs the k8scontext and continues to listen to the
event channel and enqueue events before stopChannel is closed
Start function runs the k8scontext and continues to listen to the event channel and enqueue events before stopChannel is closed
// Starts event queue // Starts k8scontext which contains all the informers // Continue to enqueue events into eventqueue until stopChannel is closed