Initialize pool earlier

pstuifzand · Mar 23, 2019 · baab9e6 · baab9e6
1 parent 76819ac
commit baab9e6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/cmd/eksterd/main.go b/cmd/eksterd/main.go
@@ -111,10 +111,9 @@ func NewApp(options AppOptions) *App {
 		options: options,
 	}
 
-	app.backend = loadMemoryBackend()
+	app.backend = loadMemoryBackend(options.pool)
 	app.backend.AuthEnabled = options.AuthEnabled
 	app.backend.baseURL = options.BaseURL
-	app.backend.pool = options.pool
 
 	app.hubBackend = &hubIncomingBackend{app.backend, options.BaseURL, options.pool}
 

diff --git a/cmd/eksterd/memory.go b/cmd/eksterd/memory.go
@@ -137,8 +137,8 @@ func (b *memoryBackend) save() {
 	jw.Encode(b)
 }
 
-func loadMemoryBackend() *memoryBackend {
-	backend := &memoryBackend{}
+func loadMemoryBackend(pool *redis.Pool) *memoryBackend {
+	backend := &memoryBackend{pool: pool}
 	err := backend.load()
 	if err != nil {
 		log.Printf("Error while loadingbackend: %v\n", err)