Method handleGetClusterInfo

rest/admin_api.go:2318–2363

Get SG cluster information. Iterates over all buckets associated with the server, and returns cluster information (registry) for each

()

// Get SG cluster information.  Iterates over all buckets associated with the server, and returns cluster
// information (registry) for each
func (h *handler) handleGetClusterInfo() error {

	clusterInfo := ClusterInfo{
		Buckets: make(map[string]BucketInfo),
	}

	eccv := h.server.getBucketCCVSettings()
	if h.server.persistentConfig {

		bucketNames, err := h.server.GetBucketNames()
		if err != nil {
			return err
		}

		clusterInfo = ClusterInfo{
			Buckets: make(map[string]BucketInfo, len(bucketNames)),
		}

		for _, bucketName := range bucketNames {
			registry, err := h.server.BootstrapContext.getGatewayRegistry(h.ctx(), bucketName)
			if err != nil {
				base.InfofCtx(h.ctx(), base.KeyAll, "Unable to retrieve registry for bucket %s during getClusterInfo: %v", base.MD(bucketName), err)
				continue
			}

			bucketInfo := BucketInfo{
				Registry:                     registry,
				EnableCrossClusterVersioning: eccv[bucketName],
			}
			clusterInfo.Buckets[bucketName] = bucketInfo
		}
	} else {
		clusterInfo.LegacyConfig = true

		for bucketName, eccvVal := range eccv {
			bucketInfo := BucketInfo{
				EnableCrossClusterVersioning: eccvVal,
			}
			clusterInfo.Buckets[bucketName] = bucketInfo
		}
	}

	base.Audit(h.ctx(), base.AuditIDClusterInfoRead, nil)
	h.writeJSON(clusterInfo)
	return nil
}

// databaseLoadErrorAsHTTPError converts an error loading a database into an error with an http status code. Pulled into a function so we can duplicate persistent and non persistent config logic.
func databaseLoadErrorAsHTTPError(err error) error {