Function initializeCollectionIndexes

db/indextest/util.go:77–86

initializeCollectionIndexes initializes the indexes for a data store like rest.DatabaseInitManager's DatabaseInitWorker

(ctx context.Context, t *testing.T, testBucket base.Bucket, dsName sgbucket.DataStoreName, options db.InitializeIndexOptions)

// initializeCollectionIndexes initializes the indexes for a data store like rest.DatabaseInitManager's DatabaseInitWorker
func initializeCollectionIndexes(ctx context.Context, t *testing.T, testBucket base.Bucket, dsName sgbucket.DataStoreName, options db.InitializeIndexOptions) {
	gocbBucket, err := base.AsGocbV2Bucket(testBucket)
	require.NoError(t, err)

	n1qlStore, err := base.NewClusterOnlyN1QLStore(gocbBucket.GetCluster(), gocbBucket.BucketName(), dsName.ScopeName(), dsName.CollectionName())
	require.NoError(t, err)

	ctx = base.CollectionLogCtx(ctx, dsName.ScopeName(), dsName.CollectionName())
	require.NoError(t, db.InitializeIndexes(ctx, n1qlStore, options))
}

func requireCoveredQuery(t *testing.T, database *db.Database, statement string, isCovered bool) {
	n1QLStore, ok := base.AsN1QLStore(database.MetadataStore)