From 5b5a64e55dd72a45ed18d99ed07c48c6d36cc09e Mon Sep 17 00:00:00 2001 From: Murat Kabilov Date: Mon, 23 Jan 2017 17:22:59 +0100 Subject: [PATCH] Check if etcd service has its port exposed --- pkg/controller/spilo.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/pkg/controller/spilo.go b/pkg/controller/spilo.go index ec40f4acc..09cc54662 100644 --- a/pkg/controller/spilo.go +++ b/pkg/controller/spilo.go @@ -36,6 +36,11 @@ func New(options Options) *SpiloOperator { } ports := etcdService.Spec.Ports[0] nodeurl, _ := url.Parse(config.Host) + + if ports.NodePort == 0 { + log.Fatalln("Etcd port is not exposed") + } + etcdHostOutside := fmt.Sprintf("http://%s:%d", strings.Split(nodeurl.Host, ":")[0], ports.NodePort) spiloClient, err := newKubernetesSpiloClient(config)