[databases]: add support for MongoDB advanced configuration

databases.go

@@ -152,9 +152,11 @@ type DatabasesService interface {
  GetPostgreSQLConfig(context.Context, string) (*PostgreSQLConfig, *Response, error)
  GetRedisConfig(context.Context, string) (*RedisConfig, *Response, error)
  GetMySQLConfig(context.Context, string) (*MySQLConfig, *Response, error)
+ GetMongoDBConfig(context.Context, string) (*MongoDBConfig, *Response, error)
  UpdatePostgreSQLConfig(context.Context, string, *PostgreSQLConfig) (*Response, error)
  UpdateRedisConfig(context.Context, string, *RedisConfig) (*Response, error)
  UpdateMySQLConfig(context.Context, string, *MySQLConfig) (*Response, error)
+ UpdateMongoDBConfig(context.Context, string, *MongoDBConfig) (*Response, error)
  ListOptions(todo context.Context) (*DatabaseOptions, *Response, error)
  UpgradeMajorVersion(context.Context, string, *UpgradeVersionRequest) (*Response, error)
  ListTopics(context.Context, string, *ListOptions) ([]DatabaseTopic, *Response, error)
@@ -648,6 +650,15 @@ type MySQLConfig struct {
  BinlogRetentionPeriod *int `json:"binlog_retention_period,omitempty"`
 }
 
+// MongoDBConfig holds advanced configurations for MongoDB database clusters.
+type MongoDBConfig struct {
+ DefaultReadConcern *string `json:"default_read_concern,omitempty"`
+ DefaultWriteConcern *string `json:"default_write_concern,omitempty"`
+ TransactionLifetimeLimitSeconds *int `json:"transaction_lifetime_limit_seconds,omitempty"`
+ SlowOpThresholdMs *int `json:"slow_op_threshold_ms,omitempty"`
+ Verbosity *int `json:"verbosity,omitempty"`
+}
+
 type databaseUserRoot struct {
  User *DatabaseUser `json:"user"`
 }
@@ -688,6 +699,10 @@ type databaseMySQLConfigRoot struct {
  Config *MySQLConfig `json:"config"`
 }
 
+type databaseMongoDBConfigRoot struct {
+ Config *MongoDBConfig `json:"config"`
+}
+
 type databaseBackupsRoot struct {
  Backups []DatabaseBackup `json:"backups"`
 }
@@ -1499,6 +1514,38 @@ func (svc *DatabasesServiceOp) UpdateMySQLConfig(ctx context.Context, databaseID
  return resp, nil
 }
 
+// GetMongoDBConfig retrieves the config for a MongoDB database cluster.
+func (svc *DatabasesServiceOp) GetMongoDBConfig(ctx context.Context, databaseID string) (*MongoDBConfig, *Response, error) {
+ path := fmt.Sprintf(databaseConfigPath, databaseID)
+ req, err := svc.client.NewRequest(ctx, http.MethodGet, path, nil)
+ if err != nil {
+ return nil, nil, err
+ }
+ root := new(databaseMongoDBConfigRoot)
+ resp, err := svc.client.Do(ctx, req, root)
+ if err != nil {
+ return nil, resp, err
+ }
+ return root.Config, resp, nil
+}
+
+// UpdateMongoDBConfig updates the config for a MongoDB database cluster.
+func (svc *DatabasesServiceOp) UpdateMongoDBConfig(ctx context.Context, databaseID string, config *MongoDBConfig) (*Response, error) {
+ path := fmt.Sprintf(databaseConfigPath, databaseID)
+ root := &databaseMongoDBConfigRoot{
+ Config: config,
+ }
+ req, err := svc.client.NewRequest(ctx, http.MethodPatch, path, root)
+ if err != nil {
+ return nil, err
+ }
+ resp, err := svc.client.Do(ctx, req, nil)
+ if err != nil {
+ return resp, err
+ }
+ return resp, nil
+}
+
 // ListOptions gets the database options available.
 func (svc *DatabasesServiceOp) ListOptions(ctx context.Context) (*DatabaseOptions, *Response, error) {
  root := new(databaseOptionsRoot)

databases_test.go

@@ -2991,6 +2991,79 @@ func TestDatabases_UpdateConfigMySQL(t *testing.T) {
  require.NoError(t, err)
 }
 
+func TestDatabases_GetConfigMongoDB(t *testing.T) {
+ setup()
+ defer teardown()
+
+ var (
+ dbSvc = client.Databases
+ dbID = "da4e0206-d019-41d7-b51f-deadbeefbb8f"
+ path = fmt.Sprintf("/v2/databases/%s/config", dbID)
+
+ mongoDBConfigJSON = `{
+ "config": {
+ "default_read_concern": "LOCAL",
+ "default_write_concern": "majority",
+ "transaction_lifetime_limit_seconds": 60,
+ "slow_op_threshold_ms": 100,
+ "verbosity": 0
+ }
+}
+`
+
+ mongoDBConfig = MongoDBConfig{
+ DefaultReadConcern: PtrTo("LOCAL"),
+ DefaultWriteConcern: PtrTo("majority"),
+ TransactionLifetimeLimitSeconds: PtrTo(60),
+ SlowOpThresholdMs: PtrTo(100),
+ Verbosity: PtrTo(0),
+ }
+ )
+
+ mux.HandleFunc(path, func(w http.ResponseWriter, r *http.Request) {
+ testMethod(t, r, http.MethodGet)
+ fmt.Fprint(w, mongoDBConfigJSON)
+ })
+
+ got, _, err := dbSvc.GetMongoDBConfig(ctx, dbID)
+ require.NoError(t, err)
+ require.Equal(t, &mongoDBConfig, got)
+}
+
+func TestDatabases_UpdateConfigMongoDB(t *testing.T) {
+ setup()
+ defer teardown()
+
+ var (
+ dbID = "deadbeef-dead-4aa5-beef-deadbeef347d"
+ path = fmt.Sprintf("/v2/databases/%s/config", dbID)
+ mongoDBConfig = &MongoDBConfig{
+ DefaultReadConcern: PtrTo("AVAILABLE"),
+ DefaultWriteConcern: PtrTo(""),
+ SlowOpThresholdMs: PtrTo(0),
+ Verbosity: PtrTo(5),
+ }
+ )
+
+ mux.HandleFunc(path, func(w http.ResponseWriter, r *http.Request) {
+ testMethod(t, r, http.MethodPatch)
+
+ var b databaseMongoDBConfigRoot
+ decoder := json.NewDecoder(r.Body)
+ err := decoder.Decode(&b)
+ require.NoError(t, err)
+
+ assert.Equal(t, b.Config, mongoDBConfig)
+ assert.Equal(t, "", *b.Config.DefaultWriteConcern, "pointers to zero value should be sent")
+ assert.Nil(t, b.Config.TransactionLifetimeLimitSeconds, "excluded value should not be sent")
+
+ w.WriteHeader(http.StatusNoContent)
+ })
+
+ _, err := client.Databases.UpdateMongoDBConfig(ctx, dbID, mongoDBConfig)
+ require.NoError(t, err)
+}
+
 func TestDatabases_UpgradeMajorVersion(t *testing.T) {
  setup()
  defer teardown()