Method deleteKeys

internal/dmap/delete.go:142–170

(ctx context.Context, keys ...string)

}

func (dm *DMap) deleteKeys(ctx context.Context, keys ...string) (int, error) {
	members := make(map[discovery.Member][]string)
	for _, key := range keys {
		hkey := partitions.HKey(dm.name, key)
		member := dm.s.primary.PartitionByHKey(hkey).Owner()
		members[member] = append(members[member], key)
	}

	for member, distributedKeys := range members {
		if member.CompareByName(dm.s.rt.This()) {
			for _, key := range distributedKeys {
				if err := dm.deleteKey(key); err != nil {
					return 0, err
				}
			}
		} else {
			cmd := protocol.NewDel(dm.name, distributedKeys...).Command(dm.s.ctx)
			rc := dm.s.client.Get(member.String())
			err := rc.Process(ctx, cmd)
			if err != nil {
				return 0, protocol.ConvertError(err)
			}

			return 0, protocol.ConvertError(cmd.Err())
		}
	}

	return len(keys), nil
}

// Delete deletes the value for the given key. Delete will not return error if key doesn't exist. It's thread-safe.
// It is safe to modify the contents of the argument after Delete returns.