DevFW-CICD/ingress-nginx-helm
16
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add flag to specify the api server url

Browse source
This commit is contained in:
Manuel de Brito Fontes 2017-04-05 10:10:17 -03:00
parent 88a2751234
commit e492a4b396
1 changed files with 17 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
controllers/gce/main.go
View file

@ -38,6 +38,7 @@ import (
api_v1 "k8s.io/client-go/pkg/api/v1" api_v1 "k8s.io/client-go/pkg/api/v1"
"k8s.io/client-go/rest" "k8s.io/client-go/rest"
"k8s.io/client-go/tools/clientcmd" "k8s.io/client-go/tools/clientcmd"
clientcmdapi "k8s.io/client-go/tools/clientcmd/api"
"k8s.io/ingress/controllers/gce/controller" "k8s.io/ingress/controllers/gce/controller"
"k8s.io/ingress/controllers/gce/loadbalancers" "k8s.io/ingress/controllers/gce/loadbalancers"
@ -87,6 +88,12 @@ var (
`Optional, if this controller is running in a kubernetes cluster, use the `Optional, if this controller is running in a kubernetes cluster, use the
pod secrets for creating a Kubernetes client.`) pod secrets for creating a Kubernetes client.`)
apiServerHost = flags.String("apiserver-host", "", "The address of the Kubernetes Apiserver "+
"to connect to in the format of protocol://address:port, e.g., "+
"http://localhost:8080. If not specified, the assumption is that the binary runs inside a "+
"Kubernetes cluster and local discovery is attempted.")
kubeConfigFile = flags.String("kubeconfig", "", "Path to kubeconfig file with authorization and master location information.")
// TODO: Consolidate this flag and running-in-cluster. People already use // TODO: Consolidate this flag and running-in-cluster. People already use
// the first one to mean "running in dev", unfortunately. // the first one to mean "running in dev", unfortunately.
useRealCloud = flags.Bool("use-real-cloud", false, useRealCloud = flags.Bool("use-real-cloud", false,
@ -174,7 +181,6 @@ func main() {
// We only really need a binary switch from light, v(2) logging to // We only really need a binary switch from light, v(2) logging to
// heavier debug style V(4) logging, which we use --verbose for. // heavier debug style V(4) logging, which we use --verbose for.
flags.Parse(os.Args) flags.Parse(os.Args)
//clientConfig := kubectl_util.DefaultClientConfig(flags)
// Set glog verbosity levels, unconditionally set --alsologtostderr. // Set glog verbosity levels, unconditionally set --alsologtostderr.
go_flag.Lookup("logtostderr").Value.Set("true") go_flag.Lookup("logtostderr").Value.Set("true")
@ -193,10 +199,17 @@ func main() {
glog.Fatalf("error creating client configuration: %v", err) glog.Fatalf("error creating client configuration: %v", err)
} }
} else { } else {
config, err = clientcmd.NewNonInteractiveDeferredLoadingClientConfig( if *apiServerHost == "" {
&clientcmd.ClientConfigLoadingRules{}, glog.Fatalf("please specify the api server address using the flag --apiserver-host")
&clientcmd.ConfigOverrides{}).ClientConfig() }
config, err = clientcmd.NewNonInteractiveDeferredLoadingClientConfig(
&clientcmd.ClientConfigLoadingRules{ExplicitPath: *kubeConfigFile},
&clientcmd.ConfigOverrides{
ClusterInfo: clientcmdapi.Cluster{
Server: *apiServerHost,
},
}).ClientConfig()
if err != nil { if err != nil {
glog.Fatalf("error creating client configuration: %v", err) glog.Fatalf("error creating client configuration: %v", err)
} }