Merge pull request #91 from Nefelim4ag/fix_ipvs_flush

Reset IPVS after API client init

pkg/cmd/main.go

@@ -54,7 +54,7 @@ var (
 
 	configMapName = flags.String("services-configmap", "",
 		`Name of the ConfigMap that contains the definition of the services to expose.
-		The key in the map indicates the external IP to use. The value is the name of the 
+		The key in the map indicates the external IP to use. The value is the name of the
 		service with the format namespace/serviceName and the port of the service could be a number or the
 		name of the port.`)
 
@@ -73,8 +73,8 @@ var (
 	}
 
 	vrid = flags.Int("vrid", 50,
-		`The keepalived VRID (Virtual Router Identifier, between 0 and 255 as per 
-      RFC-5798), which must be different for every Virtual Router (ie. every 
+		`The keepalived VRID (Virtual Router Identifier, between 0 and 255 as per
+      RFC-5798), which must be different for every Virtual Router (ie. every
       keepalived sets) running on the same network.`)
 
 	iface = flags.String("iface", "", `network interface to listen on. If undefined, the nodes
@@ -123,11 +123,6 @@ func main() {
 		glog.Fatalf("unexpected error: %v", err)
 	}
 
-	err = resetIPVS()
-	if err != nil {
-		glog.Fatalf("unexpected error: %v", err)
-	}
-
 	if *proxyMode {
 		copyHaproxyCfg()
 	}
@@ -139,6 +134,14 @@ func main() {
 	glog.Info("starting LVS configuration")
 	ipvsc := controller.NewIPVSController(kubeClient, *watchNamespace, *useUnicast, *configMapName, *vrid, *proxyMode, *iface, *httpPort)
 
+	// If kube-proxy running in ipvs mode
+	// Reset of IPVS lead to connection loss with API server
+	// If connection established goclient will retry itself
+	err = resetIPVS()
+	if err != nil {
+		glog.Fatalf("unexpected error: %v", err)
+	}
+
 	ipvsc.Start()
 }