kubernetes/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/v3rpc/key.go

type kvServer …

func NewKVServer(s *etcdserver.EtcdServer) pb.KVServer { … }

func (s *kvServer) Range(ctx context.Context, r *pb.RangeRequest) (*pb.RangeResponse, error) { … }

func (s *kvServer) Put(ctx context.Context, r *pb.PutRequest) (*pb.PutResponse, error) { … }

func (s *kvServer) DeleteRange(ctx context.Context, r *pb.DeleteRangeRequest) (*pb.DeleteRangeResponse, error) { … }

func (s *kvServer) Txn(ctx context.Context, r *pb.TxnRequest) (*pb.TxnResponse, error) { … }

func (s *kvServer) Compact(ctx context.Context, r *pb.CompactionRequest) (*pb.CompactionResponse, error) { … }

func checkRangeRequest(r *pb.RangeRequest) error { … }

func checkPutRequest(r *pb.PutRequest) error { … }

func checkDeleteRequest(r *pb.DeleteRangeRequest) error { … }

func checkTxnRequest(r *pb.TxnRequest, maxTxnOps int) error { … }

// checkIntervals tests whether puts and deletes overlap for a list of ops. If
// there is an overlap, returns an error. If no overlap, return put and delete
// sets for recursive evaluation.
func checkIntervals(reqs []*pb.RequestOp) (map[string]struct{ … }

func checkRequestOp(u *pb.RequestOp, maxTxnOps int) error { … }