Method GetInUseIndexesFromDefs

db/database.go:795–830

GetInUseIndexesFromDefs returns the name of the indexes on this database. indexDefs refers to the global indexDefs as sgIndexes, or a testing seam passed in.

(indexDefs map[SGIndexType]SGIndex)

// GetInUseIndexesFromDefs returns the name of the indexes on this database. indexDefs refers to the global indexDefs as sgIndexes, or a testing seam passed in.
func (dbCtx *DatabaseContext) GetInUseIndexesFromDefs(indexDefs map[SGIndexType]SGIndex) CollectionIndexes {
	dataStores := dbCtx.getDataStores()
	inUseIndexes := make(CollectionIndexes)
	for _, ds := range dataStores {
		options := InitializeIndexOptions{
			NumPartitions:       dbCtx.numIndexPartitions(),
			NumReplicas:         dbCtx.Options.NumIndexReplicas,
			UseXattrs:           dbCtx.UseXattrs(),
			LegacySyncDocsIndex: dbCtx.UseLegacySyncDocsIndex(),
		}
		if base.IsDefaultCollection(ds.ScopeName(), ds.CollectionName()) {
			if dbCtx.HasDefaultCollection() {
				options.MetadataIndexes = IndexesAll
			} else {
				options.MetadataIndexes = IndexesMetadataOnly
			}
		} else {
			options.MetadataIndexes = IndexesWithoutMetadata
		}
		dsName := base.ScopeAndCollectionName{
			Scope:      ds.ScopeName(),
			Collection: ds.CollectionName(),
		}
		// datastore can be listed twice for explicit default and for metadata store
		if _, ok := inUseIndexes[dsName]; !ok {
			inUseIndexes[dsName] = make(map[string]struct{})
		}
		if dbCtx.UseViews() {
			continue
		}
		for _, index := range GetIndexNames(options, indexDefs) {
			inUseIndexes[dsName][index] = struct{}{}
		}
	}
	return inUseIndexes
}

// Trigger terminate check handling for connected continuous replications.
// TODO: The underlying code (NotifyCheckForTermination) doesn't actually leverage the specific username - should be refactored