fix conflict

linkernetworks · Jun 27, 2018 · 0ad7fa8 · 0ad7fa8
1 parent 4a7bfc1
commit 0ad7fa8
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 98 deletions.
diff --git a/src/networkcontroller/networkcontroller.go b/src/networkcontroller/networkcontroller.go
diff --git a/src/serviceprovider/serviceprovider.go b/src/serviceprovider/serviceprovider.go
@@ -43,16 +43,8 @@ func New(cf config.Config) *Container {
 	logger.Infof("Connecting to mongodb: %s", cf.Mongo.Url)
 	mongo := mongo.New(cf.Mongo.Url)
 
-	kubeconfig := filepath.Join(os.Getenv("HOME"), ".kube", "config")
-	k8s, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
-	if err != nil {
-		k8s, err = rest.InClusterConfig()
-		if err != nil {
-			panic(fmt.Errorf("Load the kubernetes config fail"))
-		}
-	}
-
-	clientset := kubernetes.NewForConfigOrDie(k8s)
+	logger.Infof("Connecting to prometheus: %s", cf.Prometheus.Url)
+	prometheus := prometheus.New(cf.Prometheus.Url)
 
 	kubeconfig := filepath.Join(os.Getenv("HOME"), ".kube", "config")
 	k8s, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
@@ -92,32 +84,11 @@ func NewForTesting(cf config.Config) *Container {
 	clientset := fakeclientset.NewSimpleClientset()
 
 	sp := &Container{
-		Config:  cf,
-		Redis:   redisService,
-		Mongo:   mongo,
-		KubeCtl: kubeCtl.New(clientset, "default"),
-	}
-
-	return sp
-}
-
-func NewForTesting(cf config.Config) *Container {
-	// setup logger configuration
-	logger.Setup(cf.Logger)
-
-	logger.Infof("Connecting to redis: %s", cf.Redis.Addr())
-	redisService := redis.New(cf.Redis)
-
-	logger.Infof("Connecting to mongodb: %s", cf.Mongo.Url)
-	mongo := mongo.New(cf.Mongo.Url)
-
-	clientset := fakeclientset.NewSimpleClientset()
-
-	sp := &Container{
-		Config:  cf,
-		Redis:   redisService,
-		Mongo:   mongo,
-		KubeCtl: kubeCtl.New(clientset, "default"),
+		Config:     cf,
+		Redis:      redisService,
+		Mongo:      mongo,
+		Prometheus: prometheus,
+		KubeCtl:    kubeCtl.New(clientset, "default"),
 	}
 
 	return sp