Rebase changes

kubeflow · May 15, 2019 · 4c2ae63 · 4c2ae63
1 parent a2aa391
commit 4c2ae63
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 38 deletions.
diff --git a/Gopkg.lock b/Gopkg.lock
diff --git a/pkg/common/v1alpha2/common.go b/pkg/common/v1alpha2/common.go
@@ -1,37 +1,9 @@
 package v1alpha2
 
 import (
-	"os"
-
 	"k8s.io/apimachinery/pkg/runtime/schema"
-
-	experimentsv1alpha2 "github.com/kubeflow/katib/pkg/api/operators/apis/experiment/v1alpha2"
-)
-
-const (
-	KatibManagerServiceIPEnvName        = "KATIB_MANAGER_PORT_6789_TCP_ADDR"
-	KatibManagerServicePortEnvName      = "KATIB_MANAGER_PORT_6789_TCP_PORT"
-	KatibManagerServiceNamespaceEnvName = "KATIB_MANAGER_NAMESPACE"
-	KatibManagerService                 = "katib-manager"
-	KatibManagerPort                    = "6789"
-	ManagerAddr                         = KatibManagerService + ":" + KatibManagerPort
 )
 
-func GetManagerAddr() string {
-	ns := os.Getenv(experimentsv1alpha2.DefaultKatibNamespaceEnvName)
-	if len(ns) == 0 {
-		addr := os.Getenv(KatibManagerServiceIPEnvName)
-		port := os.Getenv(KatibManagerServicePortEnvName)
-		if len(addr) > 0 && len(port) > 0 {
-			return addr + ":" + port
-		} else {
-			return ManagerAddr
-		}
-	} else {
-		return KatibManagerService + "." + ns + ":" + KatibManagerPort
-	}
-}
-
 func GetSupportedJobList() []schema.GroupVersionKind {
 	supportedJobList := []schema.GroupVersionKind{
 		schema.GroupVersionKind{