v3rpc

package
v3.2.18+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 29, 2018 License: Apache-2.0 Imports: 34 Imported by: 32

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 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 (as *AuthServer) AuthDisable(ctx context.Context, r *pb.AuthDisableRequest) (*pb.AuthDisableResponse, error)

func (*AuthServer) AuthEnable 

func (as *AuthServer) AuthEnable(ctx context.Context, r *pb.AuthEnableRequest) (*pb.AuthEnableResponse, error)

func (*AuthServer) Authenticate 

func (as *AuthServer) Authenticate(ctx context.Context, r *pb.AuthenticateRequest) (*pb.AuthenticateResponse, error)

func (*AuthServer) RoleAdd 

func (as *AuthServer) RoleAdd(ctx context.Context, r *pb.AuthRoleAddRequest) (*pb.AuthRoleAddResponse, error)

func (*AuthServer) RoleDelete 

func (as *AuthServer) RoleDelete(ctx context.Context, r *pb.AuthRoleDeleteRequest) (*pb.AuthRoleDeleteResponse, error)

func (*AuthServer) RoleGet 

func (as *AuthServer) RoleGet(ctx context.Context, r *pb.AuthRoleGetRequest) (*pb.AuthRoleGetResponse, error)

func (*AuthServer) RoleGrantPermission 

func (as *AuthServer) RoleGrantPermission(ctx context.Context, r *pb.AuthRoleGrantPermissionRequest) (*pb.AuthRoleGrantPermissionResponse, error)

func (*AuthServer) RoleList 

func (as *AuthServer) RoleList(ctx context.Context, r *pb.AuthRoleListRequest) (*pb.AuthRoleListResponse, error)

func (*AuthServer) RoleRevokePermission 

func (as *AuthServer) RoleRevokePermission(ctx context.Context, r *pb.AuthRoleRevokePermissionRequest) (*pb.AuthRoleRevokePermissionResponse, error)

func (*AuthServer) UserAdd 

func (as *AuthServer) UserAdd(ctx context.Context, r *pb.AuthUserAddRequest) (*pb.AuthUserAddResponse, error)

func (*AuthServer) UserChangePassword 

func (as *AuthServer) UserChangePassword(ctx context.Context, r *pb.AuthUserChangePasswordRequest) (*pb.AuthUserChangePasswordResponse, error)

func (*AuthServer) UserDelete 

func (as *AuthServer) UserDelete(ctx context.Context, r *pb.AuthUserDeleteRequest) (*pb.AuthUserDeleteResponse, error)

func (*AuthServer) UserGet 

func (as *AuthServer) UserGet(ctx context.Context, r *pb.AuthUserGetRequest) (*pb.AuthUserGetResponse, error)

func (*AuthServer) UserGrantRole 

func (as *AuthServer) UserGrantRole(ctx context.Context, r *pb.AuthUserGrantRoleRequest) (*pb.AuthUserGrantRoleResponse, error)

func (*AuthServer) UserList 

func (as *AuthServer) UserList(ctx context.Context, r *pb.AuthUserListRequest) (*pb.AuthUserListResponse, error)

func (*AuthServer) UserRevokeRole 

func (as *AuthServer) UserRevokeRole(ctx context.Context, r *pb.AuthUserRevokeRoleRequest) (*pb.AuthUserRevokeRoleResponse, error)

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 (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 KVGetter 

type KVGetter interface {
	KV() mvcc.ConsistentWatchableKV
}

type LeaseServer 

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

func (*LeaseServer) LeaseGrant 

func (ls *LeaseServer) LeaseGrant(ctx context.Context, cr *pb.LeaseGrantRequest) (*pb.LeaseGrantResponse, error)

func (*LeaseServer) LeaseKeepAlive 

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

func (*LeaseServer) LeaseRevoke 

func (ls *LeaseServer) LeaseRevoke(ctx context.Context, rr *pb.LeaseRevokeRequest) (*pb.LeaseRevokeResponse, error)

func (*LeaseServer) LeaseTimeToLive 

func (ls *LeaseServer) LeaseTimeToLive(ctx context.Context, rr *pb.LeaseTimeToLiveRequest) (*pb.LeaseTimeToLiveResponse, error)

type RaftStatusGetter 

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

Source Files

View all Source files

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.