updated rethinkdb driver parameters

tinode · Aug 1, 2018 · 875939b · 875939b
1 parent 3fcf521
commit 875939b
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 13 deletions.
diff --git a/server/db/rethinkdb/adapter.go b/server/db/rethinkdb/adapter.go
@@ -32,17 +32,21 @@ const (
 	adapterName = "rethinkdb"
 )
 
+// See https://godoc.org/github.com/GoRethink/gorethink#ConnectOpts for explanations.
 type configType struct {
-	Database            string      `json:"database,omitempty"`
-	Addresses           interface{} `json:"addresses,omitempty"`
-	AuthKey             string      `json:"authkey,omitempty"`
-	Timeout             int         `json:"timeout,omitempty"`
-	WriteTimeout        int         `json:"write_timeout,omitempty"`
-	ReadTimeout         int         `json:"read_timeout,omitempty"`
-	MaxIdle             int         `json:"max_idle,omitempty"`
-	MaxOpen             int         `json:"max_open,omitempty"`
-	DiscoverHosts       bool        `json:"discover_hosts,omitempty"`
-	NodeRefreshInterval int         `json:"node_refresh_interval,omitempty"`
+	Database          string      `json:"database,omitempty"`
+	Addresses         interface{} `json:"addresses,omitempty"`
+	Username          string      `json:"username,omitempty"`
+	Password          string      `json:"password,omitempty"`
+	AuthKey           string      `json:"authkey,omitempty"`
+	Timeout           int         `json:"timeout,omitempty"`
+	WriteTimeout      int         `json:"write_timeout,omitempty"`
+	ReadTimeout       int         `json:"read_timeout,omitempty"`
+	KeepAlivePeriod   int         `json:"keep_alive_timeout,omitempty"`
+	InitialCap        int         `json:"initial_cap,omitempty"`
+	MaxOpen           int         `json:"max_open,omitempty"`
+	DiscoverHosts     bool        `json:"discover_hosts,omitempty"`
+	HostDecayDuration int         `json:"host_decay_duration,omitempty"`
 }
 
 // TODO: convert hard-coded limits to config options
@@ -85,14 +89,17 @@ func (a *adapter) Open(jsonconfig string) error {
 	}
 
 	opts.Database = a.dbName
+	opts.Username = config.Username
+	opts.Password = config.Password
 	opts.AuthKey = config.AuthKey
 	opts.Timeout = time.Duration(config.Timeout) * time.Second
 	opts.WriteTimeout = time.Duration(config.WriteTimeout) * time.Second
 	opts.ReadTimeout = time.Duration(config.ReadTimeout) * time.Second
-	opts.MaxIdle = config.MaxIdle
+	opts.KeepAlivePeriod = time.Duration(config.KeepAlivePeriod) * time.Second
+	opts.InitialCap = config.InitialCap
 	opts.MaxOpen = config.MaxOpen
 	opts.DiscoverHosts = config.DiscoverHosts
-	opts.NodeRefreshInterval = time.Duration(config.NodeRefreshInterval) * time.Second
+	opts.HostDecayDuration = time.Duration(config.HostDecayDuration) * time.Second
 
 	a.conn, err = rdb.Connect(opts)
 	if err != nil {

diff --git a/server/tinode.conf b/server/tinode.conf
@@ -114,7 +114,8 @@
 				"database": "tinode"
 			},
 
-			// RethinkDB configuration.
+			// RethinkDB configuration. See https://godoc.org/github.com/GoRethink/gorethink#ConnectOpts
+			// for other possible options.
 			"rethinkdb": {
 				// Address(es) of RethinkDB node(s): either a string or an array of strings.
 				"addresses": "localhost:28015"	,