Commit bf5ba0f4 authored by Ajit Jagtap's avatar Ajit Jagtap
Browse files

Merge branch 'coremongo_package_update' into 'devbranch'

Coremongo package update

See merge request !103
parents b82221bf 8bcda582
Branches
Tags
2 merge requests!10420Aug V2 Merge Dev to Stg,!103Coremongo package update
Showing with 4 additions and 4 deletions
......@@ -63,7 +63,7 @@ func InitUsingJSON(configs []MongoHost) error {
loggermdl.LogError(bindMongoServerWithPort(hostDetails.Server, hostDetails.Port))
clientOption.SetHosts([]string{bindMongoServerWithPort(hostDetails.Server, hostDetails.Port)}).
SetConnectTimeout(hostDetails.ConnMaxLifetime).
SetMaxPoolSize(uint16(hostDetails.MaxOpenConns)).
SetMaxPoolSize(uint64(hostDetails.MaxOpenConns)).
SetReadPreference(readpref.Primary()).
SetDirect(true) // important if in cluster, connect to primary only.
if hostDetails.Username != "" {
......@@ -125,7 +125,7 @@ func InitNewSession(hostDetails MongoHost) error {
clientOption := options.Client()
clientOption.SetHosts([]string{bindMongoServerWithPort(hostDetails.Server, hostDetails.Port)}).
SetConnectTimeout(hostDetails.ConnMaxLifetime).
SetMaxPoolSize(uint16(hostDetails.MaxOpenConns)).
SetMaxPoolSize(uint64(hostDetails.MaxOpenConns)).
SetReadPreference(readpref.Primary()).
SetDirect(true) // important if in cluster, connect to primary only.
if hostDetails.Username != "" {
......
......@@ -27,12 +27,12 @@ func TotalCheck() (string, error) {
return res.GetData(), nil
}
var instances map[string]*grpcpool.Pool
var instances = make(map[string]*grpcpool.Pool)
var instancesList map[string]map[string]*grpcpool.Pool
// Init init
func Init(grpcServerURLList []string, grpcClients []string) {
instances = make(map[string]*grpcpool.Pool)
// instances = make(map[string]*grpcpool.Pool)
loggermdl.LogError("Length of grpcServerURLList", len(grpcServerURLList))
for index := 0; index < len(grpcServerURLList); index++ {
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment