func()

in pkg/clients/ingress/ingress.go [92:121]

• 26 lines of code
• 4 McCabe index (conditional complexity)

func (ing impl) Run(ctx context.Context, queue workqueue.RateLimitingInterface) {
	go ing.factory.Start(ctx.Done())

	ing.informer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
		AddFunc: func(obj interface{}) {
			if !ingressutils.IsGKE(obj) {
				klog.Info("Ignoring add for Ingress")
				return
			}

			queueutils.Add(queue, obj)
		},
		UpdateFunc: func(old, new interface{}) {
			if !ingressutils.IsGKE(new) {
				klog.Info("Ignoring update for Ingress")
				return
			}

			queueutils.Add(queue, new)
		},
		DeleteFunc: func(obj interface{}) {
			if !ingressutils.IsGKE(obj) {
				klog.Info("Ignoring delete for Ingress")
				return
			}

			queueutils.Add(queue, obj)
		},
	})
}