Documentation

Overview

    Package v3rpc implements etcd v3 RPC system based on gRPC.

    Index

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    func FiltersFromRequest

    func FiltersFromRequest(creq *pb.WatchCreateRequest) []mvcc.FilterFunc

    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, gopts ...grpc.ServerOption) *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 AuthGetter

    type AuthGetter interface {
    	AuthInfoFromCtx(ctx context.Context) (*auth.AuthInfo, error)
    	AuthStore() auth.AuthStore
    }

    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.ServerV3) *ClusterServer

    func (*ClusterServer) MemberAdd

    func (*ClusterServer) MemberList

    func (*ClusterServer) MemberRemove

    func (*ClusterServer) MemberUpdate

    type KVGetter

    type KVGetter interface {
    	KV() mvcc.ConsistentWatchableKV
    }

    type LeaderTransferrer

    type LeaderTransferrer interface {
    	MoveLeader(ctx context.Context, lead, target uint64) error
    }

    type LeaseServer

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

    func (*LeaseServer) LeaseGrant

    func (*LeaseServer) LeaseKeepAlive

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

    func (*LeaseServer) LeaseLeases

    func (*LeaseServer) LeaseRevoke

    func (*LeaseServer) LeaseTimeToLive

    type RaftStatusGetter

    type RaftStatusGetter interface {
    	etcdserver.RaftTimer
    	ID() types.ID
    	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.