give each test its own InMemSchemator

disco/disco.go

@@ -312,6 +312,12 @@ type inMemSchemator struct {
 	schema Schema
 }
 
+func NewInMemSchemator() *inMemSchemator {
+	return &inMemSchemator{
+		schema: make(Schema),
+	}
+}
+
 // Schema is an in-memory implementation of the Schemator Schema method.
 func (s *inMemSchemator) Schema(ctx context.Context) (Schema, error) {
 	s.mu.RLock()

holder.go

@@ -215,7 +215,7 @@ func DefaultHolderConfig() *HolderConfig {
 		OpenIDAllocator:      func(string, bool) (*idAllocator, error) { return &idAllocator{}, nil },
 		TranslationSyncer:    NopTranslationSyncer,
 		Serializer:           GobSerializer,
-		Schemator:            disco.InMemSchemator,
+		Schemator:            disco.NewInMemSchemator(),
 		Sharder:              disco.InMemSharder,
 		CacheFlushInterval:   defaultCacheFlushInterval,
 		StatsClient:          stats.NopStatsClient,

holder_internal_test.go

@@ -10,7 +10,7 @@ func mustHolderConfig() *HolderConfig {
 	cfg := DefaultHolderConfig()
 	cfg.StorageConfig.FsyncEnabled = false
 	cfg.RBFConfig.FsyncEnabled = false
-	cfg.Schemator = disco.InMemSchemator
+	cfg.Schemator = disco.NewInMemSchemator()
 	cfg.Sharder = disco.InMemSharder
 	return cfg
 }

index.go

@@ -77,7 +77,7 @@ func NewIndex(holder *Holder, path, name string) (*Index, error) {
 		holder:         holder,
 		trackExistence: true,
 
-		Schemator:  disco.InMemSchemator,
+		Schemator:  disco.NewInMemSchemator(),
 		serializer: NopSerializer,
 
 		translateStores: make(map[int]TranslateStore),