Method handleGetConfig

rest/admin_api.go:474–550

Get admin config info

()

// Get admin config info
func (h *handler) handleGetConfig() error {
	if redact, _ := h.getOptBoolQuery("redact", true); !redact {
		return base.HTTPErrorf(http.StatusBadRequest, "redact=false is no longer supported")
	}

	includeRuntime, _ := h.getOptBoolQuery("include_runtime", false)
	if includeRuntime {
		cfg := RunTimeServerConfigResponse{}
		var err error

		allDbNames := h.server.AllDatabaseNames()
		databaseMap := make(map[string]*DbConfig, len(allDbNames))
		cfg.StartupConfig, err = h.server.Config.Redacted()
		if err != nil {
			return err
		}

		for _, dbName := range allDbNames {
			// defensive check - in-flight requests could've removed this database since we got the name of it
			dbConfig := h.server.GetDbConfig(dbName)
			if dbConfig == nil {
				continue
			}

			dbConfig, err := MergeDatabaseConfigWithDefaults(h.server.Config, dbConfig)
			if err != nil {
				return err
			}

			databaseMap[dbName], err = dbConfig.Redacted(h.ctx())
			if err != nil {
				return err
			}
		}

		for dbName, dbConfig := range databaseMap {
			database, err := h.server.GetDatabase(h.ctx(), dbName)
			if err != nil {
				return err
			}

			if database.SGReplicateMgr != nil {
				replications, err := database.SGReplicateMgr.GetReplications()
				if err != nil {
					return err
				}

				dbConfig.Replications = make(map[string]*db.ReplicationConfig, len(replications))

				for replicationName, replicationConfig := range replications {
					dbConfig.Replications[replicationName] = replicationConfig.ReplicationConfig.Redacted(h.ctx())
				}
			}
		}

		// grab cluster uuid for runtime config
		clusterUUID, err := h.server.getClusterUUID(h.ctx())
		if err != nil {