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

type quotaKVServer …

type quotaAlarmer …

// check whether request satisfies the quota. If there is not enough space,
// ignore request and raise the free space alarm.
func (qa *quotaAlarmer) check(ctx context.Context, r interface{ … }

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

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

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

type quotaLeaseServer …

func (s *quotaLeaseServer) LeaseGrant(ctx context.Context, cr *pb.LeaseGrantRequest) (*pb.LeaseGrantResponse, error) { … }

func NewQuotaLeaseServer(s *etcdserver.EtcdServer) pb.LeaseServer { … }