public_git
/
postgres-operator
mirror of https://github.com/zalando/postgres-operator.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Add a missing file.

This commit is contained in:
Oleksii Kliukin 2017-01-25 16:32:38 +01:00 committed by Murat Kabilov
parent e5e0e3a148
commit b3a9516bae
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/controller/spilo.go
View File

@ -23,9 +23,9 @@ type SpiloOperator struct {
} }
func getEtcdServiceName(cls *kubernetes.Clientset, config *rest.Config, is_in_cluster bool) (etcdServiceName string) { func getEtcdServiceName(cls *kubernetes.Clientset, config *rest.Config, isInCluster bool) (etcdServiceName string) {
etcdService, _ := cls.Services("default").Get("etcd-client") etcdService, _ := cls.Services("default").Get("etcd-client")
if is_in_cluster { if isInCluster {
if len(etcdService.Spec.Ports) != 1 { if len(etcdService.Spec.Ports) != 1 {
log.Fatal("Can't find Etcd service named 'etcd-client'") log.Fatal("Can't find Etcd service named 'etcd-client'")
} }
@ -42,7 +42,7 @@ func getEtcdServiceName(cls *kubernetes.Clientset, config *rest.Config, is_in_cl
} }
func New(options Options) *SpiloOperator { func New(options Options) *SpiloOperator {
config, is_in_cluster := KubernetesConfig(options) config, isInCluster := KubernetesConfig(options)
spiloClient, err := newKubernetesSpiloClient(config) spiloClient, err := newKubernetesSpiloClient(config)
if err != nil { if err != nil {
@ -54,7 +54,7 @@ func New(options Options) *SpiloOperator {
log.Fatalf("Couldn't create Kubernetes client: %s", err) log.Fatalf("Couldn't create Kubernetes client: %s", err)
} }
etcdClient := etcd.NewEctdClient(getEtcdServiceName(clientSet, config, is_in_cluster)) etcdClient := etcd.NewEctdClient(getEtcdServiceName(clientSet, config, isInCluster))
operator := &SpiloOperator{ operator := &SpiloOperator{
Options: options, Options: options,