Method Increment

onecache/onecache_rpc.go:240–255

Increment increments the value of a key.

(args StorageArgs, resp *int64)

// Increment increments the value of a key.
func (r *rpcServer) Increment(args StorageArgs, resp *int64) error {
	target := r.targetNode(args.Key, args.ExplicitPeer)
	if target != r.n.name {
		return r.forward(target, "Node.Increment", args, resp)
	}

	incr, err := r.n.data.Increment(args.Key, args.Delta)
	if err != nil {
		return err
	}
	*resp = incr

	r.n.replicator.MarkDirty(args.Key)
	r.markClientVersion(args.Key)
	return nil
}

// Decrement decrements the value of a key.
func (r *rpcServer) Decrement(args StorageArgs, resp *int64) error {