Function numberOfKeysOwnedByInstance

ring/token_range_test.go:271–292

numberOfKeysOwnedByInstance returns how many of the supplied keys are owned by given instance.

(r *Ring, keys []uint32, op Operation, instanceID string, bufDescs []InstanceDesc, bufHosts, bufZones []string)

// numberOfKeysOwnedByInstance returns how many of the supplied keys are owned by given instance.
func numberOfKeysOwnedByInstance(r *Ring, keys []uint32, op Operation, instanceID string, bufDescs []InstanceDesc, bufHosts, bufZones []string) (int, error) {
	owned := 0
	if !r.HasInstance(instanceID) {
		return 0, nil
	}

	for _, tok := range keys {
		s, err := r.Get(tok, op, bufDescs, bufHosts, bufZones)
		if err != nil {
			return 0, err
		}

		for _, inst := range s.Instances {
			if inst.Id == instanceID {
				owned++
				break
			}
		}
	}

	return owned, nil
}

type nopReplicationStrategy struct{}