replicateDelete replicates the deletion of a key.
(key, peer string)
| 407 | |
| 408 | // replicateDelete replicates the deletion of a key. |
| 409 | func (p *peerSync) replicateDelete(key, peer string) error { |
| 410 | var resp struct{} |
| 411 | args := StorageArgs{ |
| 412 | Key: key, |
| 413 | ExplicitPeer: peer, |
| 414 | } |
| 415 | |
| 416 | return p.r.n.server.Remove(args, &resp) |
| 417 | } |
| 418 | |
| 419 | // Collapses the passed operation log returning the final replication task. |
| 420 | func collapseOpLog(log []replicationTask) (replicationTask, error) { |