Function GetServerUUID

base/bucket.go:380–398

GetServerUUID returns Couchbase Server Cluster UUID on a timeout. If running against rosmar, do return an empty string.

(ctx context.Context, bucket Bucket)

// GetServerUUID returns Couchbase Server Cluster UUID on a timeout. If running against rosmar, do return an empty string.
func GetServerUUID(ctx context.Context, bucket Bucket) (string, error) {
	gocbV2Bucket, err := AsGocbV2Bucket(bucket)
	if err != nil {
		return "", nil
	}
	// start a retry loop to get server ID
	worker := func() (bool, error, string) {
		respBytes, _, err := gocbV2Bucket.MgmtRequest(ctx, http.MethodGet, "/pools", "application/json", nil)
		if err != nil {
			return true, err, ""
		}

		uuid, err := ParseClusterUUID(respBytes)
		return false, err, uuid
	}

	err, uuid := RetryLoop(ctx, "Getting ServerUUID", worker, GetNewDatabaseSleeperFunc())
	return uuid, err
}

func ParseClusterUUID(respBytes []byte) (string, error) {
	var responseJson struct {