Enable distributed resync if EE (#8340)

Author: torcolvin

db/background_mgr_resync_dcp_test.go

@@ -624,7 +624,7 @@ func NewDatabaseContext(ctx context.Context, dbName string, bucket base.Bucket,
 		return nil, err
 	}
 
-	distributedResync := false // when ready, this will flip to  db.useShardedDCP()
+	distributedResync := dbContext.useShardedDCP()
 	dbContext.ResyncManager = NewResyncManagerDCP(dbContext, distributedResync)
 	dbContext.AsyncIndexInitManager = NewAsyncIndexInitManager(metadataStore, dbContext.MetadataKeys)
 

db/database.go

@@ -48,6 +48,9 @@ func setupTestDBAllowConflicts(t testing.TB) (*Database, context.Context) {
 	dbcOptions := DatabaseContextOptions{
 		AllowConflicts: base.Ptr(true),
 		CacheOptions:   base.Ptr(DefaultCacheOptions()),
+		UnsupportedOptions: &UnsupportedOptions{
+			ResyncPartitions: base.Ptr(uint16(2)),
+		},
 	}
 	return SetupTestDBWithOptions(t, dbcOptions)
 }

db/database_test.go

@@ -1191,27 +1191,3 @@ func (db *DatabaseContext) RestartChangeListener(t testing.TB, flushCache bool)
 func (db *DatabaseContext) FlushChannelCache(t testing.TB) {
 	db.RestartChangeListener(t, true)
 }
-
-type ResyncTestCase struct {
-	Name        string // name of test case
-	Distributed bool   // use distributed resync
-}
-
-// ResyncTestModes returns the test modes to run resync tests in for a given test run. Distributed resync requires Couchbase Server and EE.
-func ResyncTestModes() []ResyncTestCase {
-	testCases := []ResyncTestCase{
-		{
-			Name:        "distributed=false",
-			Distributed: false,
-		},
-	}
-	/* CBG-5419 enable tests
-	if !base.UnitTestUrlIsWalrus() && base.IsEnterpriseEdition() {
-		testCases = append(testCases, ResyncTestCase{
-			Name:        "distributed=true",
-			Distributed: true,
-		})
-	}
-	*/
-	return testCases
-}