Method getDatabaseConfig

rest/config_manager.go:498–520

getDatabaseConfig retrieves the database config, and enforces version match. On config not found or mismatched version, will retry with backoff (to wait for in-flight updates to complete). After retry timeout, triggers registry rollback and returns rollback error

(ctx context.Context, bucketName, groupID, dbName string, version string, registry *GatewayRegistry)

// version, will retry with backoff (to wait for in-flight updates to complete).  After retry timeout,
// triggers registry rollback and returns rollback error
func (b *bootstrapContext) getDatabaseConfig(ctx context.Context, bucketName, groupID, dbName string, version string, registry *GatewayRegistry) (*DatabaseConfig, error) {

	ctx = b.addDatabaseLogContext(ctx, &DbConfig{Name: dbName})
	config, err := b.getConfigVersionWithRetry(ctx, bucketName, groupID, dbName, version)
	if err != nil {
		if err == base.ErrConfigRegistryRollback {
			base.InfofCtx(ctx, base.KeyConfig, "Registry rollback required for bucket: %s, groupID: %s, dbName:%s", bucketName, groupID, dbName)
			rollbackErr := b.rollbackRegistry(ctx, bucketName, groupID, dbName, config, registry)
			// On successful registry rollback, caller needs reload registry
			if rollbackErr == nil {
				return nil, base.ErrConfigRegistryReloadRequired
			}
			// On unsuccessful rollback due to CAS failure, caller also needs to reload registry
			if base.IsCasMismatch(rollbackErr) {
				base.InfofCtx(ctx, base.KeyConfig, "Unsuccessful rollback for db:%s - CAS mismatch", dbName)
				return nil, base.ErrConfigRegistryReloadRequired
			}
			return nil, rollbackErr
		}
		return nil, err
	}
	return config, nil
}

// waitForConfigDelete waits for a config file to be deleted.  After retry timeout, returns latest cas
// and version, will backoff retry (to wait for in-flight updates to complete).  After retry timeout,