fix gocyclo

Author: lichuqiang

pkg/controller/source/source.go

@@ -110,18 +110,7 @@ func (cs *ChannelSource) Start(
 
 	cs.once.Do(func() {
 		// Distribute GenericEvents to all EventHandler / Queue pairs Watching this source
-		go func() {
-			for {
-				select {
-				case <-cs.stop:
-					// Close destination channels
-					cs.doStop()
-					return
-				case evt := <-cs.Source:
-					cs.distribute(evt)
-				}
-			}
-		}()
+		go cs.syncLoop()
 	})
 
 	dst := make(chan event.GenericEvent, cs.DestBufferSize)
@@ -172,6 +161,19 @@ func (cs *ChannelSource) distribute(evt event.GenericEvent) {
 	}
 }
 
+func (cs *ChannelSource) syncLoop() {
+	for {
+		select {
+		case <-cs.stop:
+			// Close destination channels
+			cs.doStop()
+			return
+		case evt := <-cs.Source:
+			cs.distribute(evt)
+		}
+	}
+}
+
 // KindSource is used to provide a source of events originating inside the cluster from Watches (eh.g. Pod Create)
 type KindSource struct {
 	// Type is the type of object to watch.  e.g. &v1.Pod{}