v3rpc

Documentation

Overview

Copyright 2016 CoreOS, Inc.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

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
• func Server(s *etcdserver.EtcdServer, tls *transport.TLSInfo) (*grpc.Server, error)
• type ClusterServer
  • func NewClusterServer(s *etcdserver.EtcdServer) *ClusterServer
  • func (cs *ClusterServer) MemberAdd(ctx context.Context, r *pb.MemberAddRequest) (*pb.MemberAddResponse, error)
  • func (cs *ClusterServer) MemberList(ctx context.Context, r *pb.MemberListRequest) (*pb.MemberListResponse, error)
  • func (cs *ClusterServer) MemberRemove(ctx context.Context, r *pb.MemberRemoveRequest) (*pb.MemberRemoveResponse, error)
  • func (cs *ClusterServer) MemberUpdate(ctx context.Context, r *pb.MemberUpdateRequest) (*pb.MemberUpdateResponse, error)
• 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)

Variables

var (
	ErrEmptyKey     = grpc.Errorf(codes.InvalidArgument, "etcdserver: key is not provided")
	ErrTooManyOps   = grpc.Errorf(codes.InvalidArgument, "etcdserver: too many operations in txn request")
	ErrDuplicateKey = grpc.Errorf(codes.InvalidArgument, "etcdserver: duplicate key given in txn request")
	ErrCompacted    = grpc.Errorf(codes.OutOfRange, "etcdserver: "+storage.ErrCompacted.Error())
	ErrFutureRev    = grpc.Errorf(codes.OutOfRange, "etcdserver: "+storage.ErrFutureRev.Error())

	ErrLeaseNotFound = grpc.Errorf(codes.NotFound, "etcdserver: requested lease not found")
	ErrLeaseExist    = grpc.Errorf(codes.FailedPrecondition, "etcdserver: lease already exists")

	ErrMemberExist    = grpc.Errorf(codes.FailedPrecondition, "etcdserver: member ID already exist")
	ErrPeerURLExist   = grpc.Errorf(codes.FailedPrecondition, "etcdserver: Peer URLs already exists")
	ErrMemberBadURLs  = grpc.Errorf(codes.InvalidArgument, "etcdserver: given member URLs are invalid")
	ErrMemberNotFound = grpc.Errorf(codes.NotFound, "etcdserver: member not found")

	ErrRequestTooLarge = grpc.Errorf(codes.InvalidArgument, "etcdserver: request is too large")
)

var (

	// Max operations per txn list. For example, Txn.Success can have at most 128 operations,
	// and Txn.Failure can have at most 128 operations.
	MaxOpsPerTxn = 128
)

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

func Server

func Server(s *etcdserver.EtcdServer, tls *transport.TLSInfo) (*grpc.Server, error)

Types

type ClusterServer

type ClusterServer struct {
	// contains filtered or unexported fields
}

func NewClusterServer

func NewClusterServer(s *etcdserver.EtcdServer) *ClusterServer

func (*ClusterServer) MemberAdd

func (cs *ClusterServer) MemberAdd(ctx context.Context, r *pb.MemberAddRequest) (*pb.MemberAddResponse, error)

func (*ClusterServer) MemberList

func (cs *ClusterServer) MemberList(ctx context.Context, r *pb.MemberListRequest) (*pb.MemberListResponse, error)

func (*ClusterServer) MemberRemove

func (cs *ClusterServer) MemberRemove(ctx context.Context, r *pb.MemberRemoveRequest) (*pb.MemberRemoveResponse, error)

func (*ClusterServer) MemberUpdate

func (cs *ClusterServer) MemberUpdate(ctx context.Context, r *pb.MemberUpdateRequest) (*pb.MemberUpdateResponse, error)

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)