Method handleGetRequest

ring/partition_ring_http.go:58–132

(w http.ResponseWriter, req *http.Request)

}

func (h *PartitionRingPageHandler) handleGetRequest(w http.ResponseWriter, req *http.Request) {
	var (
		ring     = h.reader.PartitionRing()
		ringDesc = ring.desc
	)
	ownedTokens := ringDesc.countTokens()

	// Prepare the data to render partitions in the page.
	partitionsByID := make(map[int32]partitionPageData, len(ringDesc.Partitions))
	for id, partition := range ringDesc.Partitions {
		owners := ring.PartitionOwnerIDsCopy(id)
		slices.Sort(owners)

		partitionsByID[id] = partitionPageData{
			ID:                id,
			Corrupted:         false,
			State:             partition.State,
			StateTimestamp:    partition.GetStateTime(),
			StateChangeLocked: partition.StateChangeLocked,
			OwnerIDs:          owners,
			Tokens:            partition.Tokens,
			NumTokens:         len(partition.Tokens),
			Ownership:         distancePercentage(ownedTokens[id]),
		}
	}

	// Look for owners of non-existing partitions. We want to provide visibility for such case
	// and we report the partition in corrupted state.
	for ownerID, owner := range ringDesc.Owners {
		partition, exists := partitionsByID[owner.OwnedPartition]

		if !exists {
			partition = partitionPageData{
				ID:             owner.OwnedPartition,
				Corrupted:      true,
				State:          PartitionUnknown,
				StateTimestamp: time.Time{},
				OwnerIDs:       []string{ownerID},
				Tokens:         partition.Tokens,
				NumTokens:      len(partition.Tokens),
				Ownership:      distancePercentage(ownedTokens[owner.OwnedPartition]),
			}

			partitionsByID[owner.OwnedPartition] = partition
		}

		if !slices.Contains(partition.OwnerIDs, ownerID) {
			partition.OwnerIDs = append(partition.OwnerIDs, ownerID)
			partitionsByID[owner.OwnedPartition] = partition
		}
	}

	// Covert partitions to a list and sort it by ID.
	partitions := make([]partitionPageData, 0, len(partitionsByID))

	for _, partition := range partitionsByID {
		partitions = append(partitions, partition)
	}