Function TestServerlessUpdateSuspendedDb

rest/serverless_test.go:476–521

Checks what happens to a suspended database when the config is modified by another node and the periodic fetchAndLoadConfigs gets called. Currently, it will be unsuspended however that behaviour may be changed in the future

(t *testing.T)

// Checks what happens to a suspended database when the config is modified by another node and the periodic fetchAndLoadConfigs gets called.
// Currently, it will be unsuspended however that behaviour may be changed in the future
func TestServerlessUpdateSuspendedDb(t *testing.T) {
	RequireBucketSpecificCredentials(t)
	ctx := base.TestCtx(t)
	tb := base.GetTestBucket(t)
	defer tb.Close(ctx)

	rt := NewRestTester(t, &RestTesterConfig{
		CustomTestBucket: tb.NoCloseClone(),
		PersistentConfig: true,
		MutateStartupConfig: func(config *StartupConfig) {
			config.Bootstrap.ConfigUpdateFrequency = base.NewConfigDuration(0)
		},
	})
	defer rt.Close()
	sc := rt.ServerContext()

	resp := rt.SendAdminRequest(http.MethodPut, "/db/",
		fmt.Sprintf(
			`{"bucket": "%s", "num_index_replicas": 0, "enable_shared_bucket_access": %t, "use_views": %t, "suspendable": true}`,
			tb.GetName(), base.TestUseXattrs(), base.TestsDisableGSI(),
		),
	)
	RequireStatus(t, resp, http.StatusCreated)

	// Suspend the database
	assert.NoError(t, sc.suspendDatabase(t, rt.Context(), "db"))
	// Update database config
	newCas, err := sc.BootstrapContext.UpdateConfig(base.TestCtx(t), tb.GetName(), sc.Config.Bootstrap.ConfigGroupID, "db", func(bucketDbConfig *DatabaseConfig) (updatedConfig *DatabaseConfig, err error) {
		config := sc._dbConfigs["db"].ToDatabaseConfig()
		config.cfgCas = bucketDbConfig.cfgCas
		return config, nil
	})
	require.NoError(t, err)
	// Confirm dbConfig cas did not update yet in SG, or get unsuspended
	assert.NotEqual(t, sc._dbConfigs["db"].cfgCas, newCas)
	assert.True(t, sc.isDatabaseSuspended(t, "db"))
	assert.Nil(t, sc._databases["db"])
	// Trigger update frequency (would usually happen every ConfigUpdateFrequency seconds)
	count, err := sc.fetchAndLoadConfigs(rt.Context(), false)
	require.NoError(t, err)
	assert.Equal(t, 1, count)

	// Make sure database is still suspended
	assert.True(t, sc.isDatabaseSuspended(t, "db"))
	assert.Nil(t, sc._databases["db"])
}

// Tests scenarios a database is and is not allowed to suspend
func TestSuspendingFlags(t *testing.T) {