fix(mongodb): change mongodb session mode to fix session closed expli…

…citly (#272)
caicloud · Nov 29, 2017 · c307e9e · c307e9e
1 parent 3533cf6
commit c307e9e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/store/store.go b/store/store.go
@@ -80,7 +80,9 @@ func Init(host string, gracePeriod time.Duration, closing chan struct{}) (*mgo.S
 	}
 
 	log.Infof("connect to mongodb addr: %s", host)
-	session.SetMode(mgo.Strong, true)
+	// Set the session mode as Eventual to ensure that the socket is created for each request.
+	// Can switch to other mode only after the old APIs are cleaned up.
+	session.SetMode(mgo.Eventual, true)
 
 	go backgroundMongo(closing)