Remove removes the key.
(args StorageArgs, resp *struct{})
| 302 | |
| 303 | // Remove removes the key. |
| 304 | func (r *rpcServer) Remove(args StorageArgs, resp *struct{}) error { |
| 305 | target := r.targetNode(args.Key, args.ExplicitPeer) |
| 306 | if target != r.n.name { |
| 307 | return r.forward(target, "Node.Remove", args, resp) |
| 308 | } |
| 309 | |
| 310 | if err := r.n.data.Delete(args.Key); err != nil { |
| 311 | return err |
| 312 | } |
| 313 | |
| 314 | r.n.replicator.MarkDeleted(args.Key) |
| 315 | r.markClientVersion(args.Key) |
| 316 | return nil |
| 317 | } |
| 318 | |
| 319 | // Get returns the value of the key. |
| 320 | func (r *rpcServer) Get(args StorageArgs, resp *ttlstore.KeyData) error { |