diff --git a/cmd/eksterd/main.go b/cmd/eksterd/main.go index c721a61..122f505 100644 --- 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 index 91afd01..a7b0f9c 100644 --- 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)