Documentation
¶
Overview ¶
Package v3rpc implements etcd v3 RPC system based on gRPC.
Index ¶
- Variables
- func NewKVServer(s *etcdserver.EtcdServer) pb.KVServer
- func NewLeaseServer(le etcdserver.Lessor) pb.LeaseServer
- func NewWatchServer(s *etcdserver.EtcdServer) pb.WatchServer
- type LeaseServer
- func (ls *LeaseServer) LeaseCreate(ctx context.Context, cr *pb.LeaseCreateRequest) (*pb.LeaseCreateResponse, error)
- func (ls *LeaseServer) LeaseKeepAlive(stream pb.Lease_LeaseKeepAliveServer) error
- func (ls *LeaseServer) LeaseRevoke(ctx context.Context, rr *pb.LeaseRevokeRequest) (*pb.LeaseRevokeResponse, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrEmptyKey = grpc.Errorf(codes.InvalidArgument, "key is not provided") ErrCompacted = grpc.Errorf(codes.OutOfRange, storage.ErrCompacted.Error()) ErrFutureRev = grpc.Errorf(codes.OutOfRange, storage.ErrFutureRev.Error()) ErrLeaseNotFound = grpc.Errorf(codes.NotFound, "requested lease not found") )
Functions ¶
func NewKVServer ¶
func NewKVServer(s *etcdserver.EtcdServer) pb.KVServer
func NewLeaseServer ¶
func NewLeaseServer(le etcdserver.Lessor) pb.LeaseServer
func NewWatchServer ¶
func NewWatchServer(s *etcdserver.EtcdServer) pb.WatchServer
Types ¶
type LeaseServer ¶
type LeaseServer struct {
// contains filtered or unexported fields
}
func (*LeaseServer) LeaseCreate ¶
func (ls *LeaseServer) LeaseCreate(ctx context.Context, cr *pb.LeaseCreateRequest) (*pb.LeaseCreateResponse, error)
func (*LeaseServer) LeaseKeepAlive ¶
func (ls *LeaseServer) LeaseKeepAlive(stream pb.Lease_LeaseKeepAliveServer) error
func (*LeaseServer) LeaseRevoke ¶
func (ls *LeaseServer) LeaseRevoke(ctx context.Context, rr *pb.LeaseRevokeRequest) (*pb.LeaseRevokeResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.