Method deleteBackupOnCluster

internal/dmap/delete.go:72–89

(hkey uint64, key string)

}

func (dm *DMap) deleteBackupOnCluster(hkey uint64, key string) error {
	owners := dm.s.backup.PartitionOwnersByHKey(hkey)
	var g errgroup.Group
	for _, owner := range owners {
		mem := owner
		g.Go(func() error {
			cmd := protocol.NewDelEntry(dm.name, key).SetReplica().Command(dm.s.ctx)
			rc := dm.s.client.Get(mem.String())
			err := rc.Process(dm.s.ctx, cmd)
			if err != nil {
				dm.s.log.V(3).Printf("[ERROR] Failed to delete replica key/value on %s: %s", dm.name, err)
				return protocol.ConvertError(err)
			}
			return protocol.ConvertError(cmd.Err())
		})
	}
	return g.Wait()
}

// deleteOnCluster is not a thread-safe function
func (dm *DMap) deleteOnCluster(hkey uint64, key string, f *fragment) error {