Method allDatabaseSummaries

rest/server_context.go:425–467

()

}

func (sc *ServerContext) allDatabaseSummaries() []DbSummary {
	sc._databasesLock.RLock()
	defer sc._databasesLock.RUnlock()

	dbs := make([]DbSummary, 0, len(sc._databases))
	for name, dbctx := range sc._databases {
		state := db.RunStateString[atomic.LoadUint32(&dbctx.State)]
		summary := DbSummary{
			DBName:        name,
			Bucket:        dbctx.Bucket.GetName(),
			State:         state,
			DatabaseError: dbctx.DatabaseStartupError,
		}
		if state == db.RunStateString[db.DBOffline] {
			if len(dbctx.RequireResync.ScopeAndCollectionNames()) > 0 {
				summary.RequireResync = true
			}
		}
		if sc.DatabaseInitManager.HasActiveInitialization(name) {
			summary.InitializationActive = true
		}
		dbs = append(dbs, summary)
	}
	sc.invalidDatabaseConfigTracking.m.RLock()
	defer sc.invalidDatabaseConfigTracking.m.RUnlock()
	for name, invalidConfig := range sc.invalidDatabaseConfigTracking.dbNames {
		// skip adding any invalid dbs with no error associated with them or that exist in above list
		if invalidConfig.databaseError == nil || sc._databases[name] != nil {
			continue
		}
		summary := DbSummary{
			DBName:        name,
			Bucket:        invalidConfig.configBucketName,
			State:         db.RunStateString[db.DBOffline], // db can always be reported as offline if we have an invalid config
			DatabaseError: invalidConfig.databaseError,
		}
		dbs = append(dbs, summary)
	}
	sort.Slice(dbs, func(i, j int) bool {
		return dbs[i].DBName < dbs[j].DBName
	})
	return dbs
}

// AllDatabases returns a copy of the _databases map.
func (sc *ServerContext) AllDatabases() map[string]*db.DatabaseContext {