From 03899af5107a270d9aaf46aba5ee54a34a1e2a9d Mon Sep 17 00:00:00 2001 From: Philip O'Toole Date: Thu, 2 Feb 2017 23:33:15 -0800 Subject: [PATCH] Set params on store before opening --- cmd/rqlited/main.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/cmd/rqlited/main.go b/cmd/rqlited/main.go index bcced8a2..bd91ccb9 100644 --- a/cmd/rqlited/main.go +++ b/cmd/rqlited/main.go @@ -175,9 +175,8 @@ func main() { Dir: dataPath, Tn: raftTn, }) - if err := store.Open(joinAddr == ""); err != nil { - log.Fatalf("failed to open store: %s", err.Error()) - } + + // Set optional parameters on store. store.SnapshotThreshold = raftSnapThreshold store.HeartbeatTimeout, err = time.ParseDuration(raftHeartbeatTimeout) if err != nil { @@ -192,6 +191,11 @@ func main() { log.Fatalf("failed to parse Raft open timeout %s: %s", raftOpenTimeout, err.Error()) } + // Now, open it. + if err := store.Open(joinAddr == ""); err != nil { + log.Fatalf("failed to open store: %s", err.Error()) + } + // Create and configure cluster service. tn := mux.Listen(muxMetaHeader) cs := cluster.NewService(tn, store)