Decrement decrements the value of a key.
(args StorageArgs, resp *int64)
| 256 | |
| 257 | // Decrement decrements the value of a key. |
| 258 | func (r *rpcServer) Decrement(args StorageArgs, resp *int64) error { |
| 259 | target := r.targetNode(args.Key, args.ExplicitPeer) |
| 260 | if target != r.n.name { |
| 261 | return r.forward(target, "Node.Decrement", args, resp) |
| 262 | } |
| 263 | |
| 264 | decr, err := r.n.data.Decrement(args.Key, args.Delta) |
| 265 | if err != nil { |
| 266 | return err |
| 267 | } |
| 268 | *resp = decr |
| 269 | |
| 270 | r.n.replicator.MarkDirty(args.Key) |
| 271 | r.markClientVersion(args.Key) |
| 272 | return nil |
| 273 | } |
| 274 | |
| 275 | // Contains returns whether a key exists. |
| 276 | func (r *rpcServer) Contains(args StorageArgs, resp *bool) error { |
no test coverage detected