default settings

lib/gat/modes/zalando_operator_discovery/server.go

@@ -139,11 +139,21 @@ func (T *Server) addPool(name string, userCreds, serverCreds auth.Credentials, d
 
 	poolOptions := pool.Options{
 		Credentials:                userCreds,
+		ServerReconnectInitialTime: 5 * time.Second,
+		ServerReconnectMaxTime:     5 * time.Second,
+		TrackedParameters: []strutil.CIString{
+			strutil.MakeCIString("client_encoding"),
+			strutil.MakeCIString("datestyle"),
+			strutil.MakeCIString("timezone"),
+			strutil.MakeCIString("standard_conforming_strings"),
+			strutil.MakeCIString("application_name"),
+		},
 	}
 	switch T.opConfig.Mode {
 	case "transaction":
 		poolOptions = transaction.Apply(poolOptions)
 	case "session":
+		poolOptions.ServerResetQuery = "discard all"
 		poolOptions = session.Apply(poolOptions)
 	default:
 		log.Printf(`unknown pool mode "%s"`, T.opConfig.Mode)
@@ -151,8 +161,14 @@ func (T *Server) addPool(name string, userCreds, serverCreds auth.Credentials, d
 	}
 	p := pool.NewPool(poolOptions)
 
+	var maxConnections int
+	if T.opConfig.MaxDBConnections != nil {
+		maxConnections = int(*T.opConfig.MaxDBConnections)
+	}
+
 	recipeOptions := recipe.Options{
 		Dialer:         d,
+		MaxConnections: maxConnections,
 	}
 	r := recipe.NewRecipe(recipeOptions)
 

lib/gat/pool/pool.go

@@ -280,9 +280,9 @@ func (T *Pool) acquireServer(client *Client) *Server {
 }
 
 func (T *Pool) releaseServer(server *Server) {
+	if T.options.ServerResetQuery != "" {
 		server.SetState(metrics.ConnStateRunningResetQuery, uuid.Nil)
 
-	if T.options.ServerResetQuery != "" {
 		err := backends.QueryString(new(backends.Context), server.GetReadWriter(), T.options.ServerResetQuery)
 		if err != nil {
 			T.removeServer(server)