Documentation

Overview

    Package v3rpc implements etcd v3 RPC system based on gRPC.

    Index

    Constants

    This section is empty.

    Variables

    View Source
    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 GetProgressReportInterval

    func GetProgressReportInterval() time.Duration

    func NewKVServer

    func NewKVServer(s *etcdserver.EtcdServer) pb.KVServer

    func NewLeaseServer

    func NewLeaseServer(s *etcdserver.EtcdServer) pb.LeaseServer

    func NewMaintenanceServer

    func NewMaintenanceServer(s *etcdserver.EtcdServer) pb.MaintenanceServer

    func NewQuotaKVServer

    func NewQuotaKVServer(s *etcdserver.EtcdServer) pb.KVServer

    func NewQuotaLeaseServer

    func NewQuotaLeaseServer(s *etcdserver.EtcdServer) pb.LeaseServer

    func NewWatchServer

    func NewWatchServer(s *etcdserver.EtcdServer) pb.WatchServer

    func Server

    func Server(s *etcdserver.EtcdServer, tls *tls.Config) *grpc.Server

    func SetProgressReportInterval

    func SetProgressReportInterval(newTimeout time.Duration)

    Types

    type Alarmer

    type Alarmer interface {
    	Alarm(ctx context.Context, ar *pb.AlarmRequest) (*pb.AlarmResponse, error)
    }

    type AuthServer

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

    func NewAuthServer

    func NewAuthServer(s *etcdserver.EtcdServer) *AuthServer

    func (*AuthServer) AuthDisable

    func (*AuthServer) AuthEnable

    func (*AuthServer) Authenticate

    func (*AuthServer) RoleAdd

    func (*AuthServer) RoleDelete

    func (*AuthServer) RoleGet

    func (*AuthServer) RoleList

    func (*AuthServer) UserAdd

    func (*AuthServer) UserDelete

    func (*AuthServer) UserGet

    func (*AuthServer) UserGrantRole

    func (*AuthServer) UserList

    func (*AuthServer) UserRevokeRole

    type BackendGetter

    type BackendGetter interface {
    	Backend() backend.Backend
    }

    type ClusterServer

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

    func NewClusterServer

    func NewClusterServer(s *etcdserver.EtcdServer) *ClusterServer

    func (*ClusterServer) MemberAdd

    func (*ClusterServer) MemberList

    func (*ClusterServer) MemberRemove

    func (*ClusterServer) MemberUpdate

    type KVGetter

    type KVGetter interface {
    	KV() mvcc.ConsistentWatchableKV
    }

    type LeaseServer

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

    func (*LeaseServer) LeaseGrant

    func (*LeaseServer) LeaseKeepAlive

    func (ls *LeaseServer) LeaseKeepAlive(stream pb.Lease_LeaseKeepAliveServer) error

    func (*LeaseServer) LeaseRevoke

    type RaftStatusGetter

    type RaftStatusGetter interface {
    	Index() uint64
    	Term() uint64
    	Leader() types.ID
    }

    Directories

    Path Synopsis
    Package rpctypes has types and values shared by the etcd server and client for v3 RPC interaction.
    Package rpctypes has types and values shared by the etcd server and client for v3 RPC interaction.