v2.3.8+incompatible Latest Latest

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

Go to latest
Published: Feb 16, 2017 License: Apache-2.0 Imports: 17 Imported by: 0



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


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.



This section is empty.


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
View Source
var (
	// expose for testing purpose. External test can change this to a
	// small value to finish fast.
	ProgressReportInterval = 10 * time.Minute


func NewKVServer

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

func NewLeaseServer

func NewLeaseServer(le etcdserver.Lessor) pb.LeaseServer

func NewMaintenanceServer

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

func NewWatchServer

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

func Server

func Server(s *etcdserver.EtcdServer, tls *transport.TLSInfo) (*grpc.Server, 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) RoleGrant

func (*AuthServer) RoleRevoke

func (*AuthServer) UserAdd

func (*AuthServer) UserChangePassword

func (*AuthServer) UserDelete

func (*AuthServer) UserGet

func (*AuthServer) UserGrant

func (*AuthServer) UserRevoke

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 LeaseServer

type LeaseServer struct {
	// contains filtered or unexported fields

func (*LeaseServer) LeaseCreate

func (*LeaseServer) LeaseKeepAlive

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

func (*LeaseServer) LeaseRevoke


Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL