From 8ada821b68ea4c42284454be7dd07333ca17837d Mon Sep 17 00:00:00 2001
From: Murat Kabilov <murat.kabilov@zalando.de>
Date: Tue, 23 May 2017 10:42:21 +0200
Subject: [PATCH] go fmt
---
pkg/cluster/cluster.go | 44 +++++++++++++++++++++---------------------
1 file changed, 22 insertions(+), 22 deletions(-)
diff --git a/pkg/cluster/cluster.go b/pkg/cluster/cluster.go
index a8a313ae..d3e187ed 100644
--- a/pkg/cluster/cluster.go
+++ b/pkg/cluster/cluster.go
@@ -55,17 +55,17 @@ type Cluster struct {
kubeResources
spec.Postgresql
Config
- logger *logrus.Entry
- pgUsers map[string]spec.PgUser
- systemUsers map[string]spec.PgUser
- podEvents chan spec.PodEvent
- podSubscribers map[spec.NamespacedName]chan spec.PodEvent
- podSubscribersMu sync.RWMutex
- pgDb *sql.DB
- mu sync.Mutex
- masterLess bool
- userSyncStrategy spec.UserSyncer
- deleteOptions *meta_v1.DeleteOptions
+ logger *logrus.Entry
+ pgUsers map[string]spec.PgUser
+ systemUsers map[string]spec.PgUser
+ podEvents chan spec.PodEvent
+ podSubscribers map[spec.NamespacedName]chan spec.PodEvent
+ podSubscribersMu sync.RWMutex
+ pgDb *sql.DB
+ mu sync.Mutex
+ masterLess bool
+ userSyncStrategy spec.UserSyncer
+ deleteOptions *meta_v1.DeleteOptions
podEventsQueue *cache.FIFO
}
@@ -84,17 +84,17 @@ func New(cfg Config, pgSpec spec.Postgresql, logger *logrus.Entry) *Cluster {
})
cluster := &Cluster{
- Config: cfg,
- Postgresql: pgSpec,
- logger: lg,
- pgUsers: make(map[string]spec.PgUser),
- systemUsers: make(map[string]spec.PgUser),
- podEvents: make(chan spec.PodEvent),
- podSubscribers: make(map[spec.NamespacedName]chan spec.PodEvent),
- kubeResources: kubeResources,
- masterLess: false,
- userSyncStrategy: users.DefaultUserSyncStrategy{},
- deleteOptions: &meta_v1.DeleteOptions{OrphanDependents: &orphanDependents},
+ Config: cfg,
+ Postgresql: pgSpec,
+ logger: lg,
+ pgUsers: make(map[string]spec.PgUser),
+ systemUsers: make(map[string]spec.PgUser),
+ podEvents: make(chan spec.PodEvent),
+ podSubscribers: make(map[spec.NamespacedName]chan spec.PodEvent),
+ kubeResources: kubeResources,
+ masterLess: false,
+ userSyncStrategy: users.DefaultUserSyncStrategy{},
+ deleteOptions: &meta_v1.DeleteOptions{OrphanDependents: &orphanDependents},
podEventsQueue: podEventsQueue,
}
--
GitLab