Function buildRingTokenPartitionLookups

ring/partition_ring.go:114–133

buildRingTokenPartitionLookups builds two slices parallel to ringTokens: - ringPartitionIDs[i] is the partition ID that owns ringTokens[i] - ringPartitionActive[i] is true if that partition is active Returns ErrInconsistentTokensInfo if a token has no matching partition.

(ringTokens Tokens, partitionByToken map[Token]int32, partitions map[int32]PartitionDesc)

//
// Returns ErrInconsistentTokensInfo if a token has no matching partition.
func buildRingTokenPartitionLookups(ringTokens Tokens, partitionByToken map[Token]int32, partitions map[int32]PartitionDesc) ([]int32, []bool, error) {
	ringPartitionIDs := make([]int32, len(ringTokens))
	ringPartitionActive := make([]bool, len(ringTokens))

	for i, token := range ringTokens {
		partitionID, ok := partitionByToken[Token(token)]
		if !ok {
			return nil, nil, ErrInconsistentTokensInfo
		}
		ringPartitionIDs[i] = partitionID

		partition, ok := partitions[partitionID]
		if !ok {
			return nil, nil, ErrInconsistentTokensInfo
		}
		ringPartitionActive[i] = partition.IsActive()
	}

	return ringPartitionIDs, ringPartitionActive, nil
}

// ActivePartitionForKey returns partition for the given key. Only active partitions are considered.
// Only one partition is returned: in other terms, the replication factor is always 1.