Method Get

onecache/onecache_rpc.go:320–333

Get returns the value of the key.

(args StorageArgs, resp *ttlstore.KeyData)

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

	data, err := r.n.data.Get(args.Key)
	if err != nil {
		return err
	}

	*resp = *data
	return nil
}

// ReplicaStorageArgs is a versioned key set by a replica peer.
type ReplicaStorageArgs struct {