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

go fmt

This commit is contained in:
Murat Kabilov 2017-05-23 10:42:21 +02:00
parent 289980f1e1
commit 8ada821b68
1 changed files with 22 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
pkg/cluster/cluster.go
View File

@ -55,17 +55,17 @@ type Cluster struct {
kubeResources kubeResources
spec.Postgresql spec.Postgresql
Config Config
logger *logrus.Entry logger *logrus.Entry
pgUsers map[string]spec.PgUser pgUsers map[string]spec.PgUser
systemUsers map[string]spec.PgUser systemUsers map[string]spec.PgUser
podEvents chan spec.PodEvent podEvents chan spec.PodEvent
podSubscribers map[spec.NamespacedName]chan spec.PodEvent podSubscribers map[spec.NamespacedName]chan spec.PodEvent
podSubscribersMu sync.RWMutex podSubscribersMu sync.RWMutex
pgDb *sql.DB pgDb *sql.DB
mu sync.Mutex mu sync.Mutex
masterLess bool masterLess bool
userSyncStrategy spec.UserSyncer userSyncStrategy spec.UserSyncer
deleteOptions *meta_v1.DeleteOptions deleteOptions *meta_v1.DeleteOptions
podEventsQueue *cache.FIFO podEventsQueue *cache.FIFO
} }
@ -84,17 +84,17 @@ func New(cfg Config, pgSpec spec.Postgresql, logger *logrus.Entry) *Cluster {
}) })
cluster := &Cluster{ cluster := &Cluster{
Config: cfg, Config: cfg,
Postgresql: pgSpec, Postgresql: pgSpec,
logger: lg, logger: lg,
pgUsers: make(map[string]spec.PgUser), pgUsers: make(map[string]spec.PgUser),
systemUsers: make(map[string]spec.PgUser), systemUsers: make(map[string]spec.PgUser),
podEvents: make(chan spec.PodEvent), podEvents: make(chan spec.PodEvent),
podSubscribers: make(map[spec.NamespacedName]chan spec.PodEvent), podSubscribers: make(map[spec.NamespacedName]chan spec.PodEvent),
kubeResources: kubeResources, kubeResources: kubeResources,
masterLess: false, masterLess: false,
userSyncStrategy: users.DefaultUserSyncStrategy{}, userSyncStrategy: users.DefaultUserSyncStrategy{},
deleteOptions: &meta_v1.DeleteOptions{OrphanDependents: &orphanDependents}, deleteOptions: &meta_v1.DeleteOptions{OrphanDependents: &orphanDependents},
podEventsQueue: podEventsQueue, podEventsQueue: podEventsQueue,
} }