v3rpc

package
v2.3.1 Latest Latest
Warning

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

 Go to latest Published: Apr 1, 2016 License: Apache-2.0 Imports: 17 Imported by: 0

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

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

Functions

func NewKVServer added in v2.3.0 

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

func NewLeaseServer added in v2.3.0 

func NewLeaseServer(le etcdserver.Lessor) pb.LeaseServer

func NewMaintenanceServer added in v2.3.0 

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

func NewWatchServer added in v2.3.0 

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

func Server added in v2.3.0 

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

Types

type AuthServer added in v2.3.0 

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

func NewAuthServer added in v2.3.0 

func NewAuthServer(s *etcdserver.EtcdServer) *AuthServer

func (*AuthServer) AuthDisable added in v2.3.0 

func (as *AuthServer) AuthDisable(ctx context.Context, r *pb.AuthDisableRequest) (*pb.AuthDisableResponse, error)

func (*AuthServer) AuthEnable added in v2.3.0 

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

func (*AuthServer) Authenticate added in v2.3.0 

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

func (*AuthServer) RoleAdd added in v2.3.0 

func (as *AuthServer) RoleAdd(ctx context.Context, r *pb.RoleAddRequest) (*pb.RoleAddResponse, error)

func (*AuthServer) RoleDelete added in v2.3.0 

func (as *AuthServer) RoleDelete(ctx context.Context, r *pb.RoleDeleteRequest) (*pb.RoleDeleteResponse, error)

func (*AuthServer) RoleGet added in v2.3.0 

func (as *AuthServer) RoleGet(ctx context.Context, r *pb.RoleGetRequest) (*pb.RoleGetResponse, error)

func (*AuthServer) RoleGrant added in v2.3.0 

func (as *AuthServer) RoleGrant(ctx context.Context, r *pb.RoleGrantRequest) (*pb.RoleGrantResponse, error)

func (*AuthServer) RoleRevoke added in v2.3.0 

func (as *AuthServer) RoleRevoke(ctx context.Context, r *pb.RoleRevokeRequest) (*pb.RoleRevokeResponse, error)

func (*AuthServer) UserAdd added in v2.3.0 

func (as *AuthServer) UserAdd(ctx context.Context, r *pb.UserAddRequest) (*pb.UserAddResponse, error)

func (*AuthServer) UserChangePassword added in v2.3.0 

func (as *AuthServer) UserChangePassword(ctx context.Context, r *pb.UserChangePasswordRequest) (*pb.UserChangePasswordResponse, error)

func (*AuthServer) UserDelete added in v2.3.0 

func (as *AuthServer) UserDelete(ctx context.Context, r *pb.UserDeleteRequest) (*pb.UserDeleteResponse, error)

func (*AuthServer) UserGet added in v2.3.0 

func (as *AuthServer) UserGet(ctx context.Context, r *pb.UserGetRequest) (*pb.UserGetResponse, error)

func (*AuthServer) UserGrant added in v2.3.0 

func (as *AuthServer) UserGrant(ctx context.Context, r *pb.UserGrantRequest) (*pb.UserGrantResponse, error)

func (*AuthServer) UserRevoke added in v2.3.0 

func (as *AuthServer) UserRevoke(ctx context.Context, r *pb.UserRevokeRequest) (*pb.UserRevokeResponse, error)

type BackendGetter added in v2.3.0 

type BackendGetter interface {
	Backend() backend.Backend
}

type ClusterServer added in v2.3.0 

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

func NewClusterServer added in v2.3.0 

func NewClusterServer(s *etcdserver.EtcdServer) *ClusterServer

func (*ClusterServer) MemberAdd added in v2.3.0 

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

func (*ClusterServer) MemberList added in v2.3.0 

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

func (*ClusterServer) MemberRemove added in v2.3.0 

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

func (*ClusterServer) MemberUpdate added in v2.3.0 

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

type LeaseServer added in v2.3.0 

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

func (*LeaseServer) LeaseCreate added in v2.3.0 

func (ls *LeaseServer) LeaseCreate(ctx context.Context, cr *pb.LeaseCreateRequest) (*pb.LeaseCreateResponse, error)

func (*LeaseServer) LeaseKeepAlive added in v2.3.0 

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

func (*LeaseServer) LeaseRevoke added in v2.3.0 

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

Source Files

View all Source files

Directories

Path Synopsis

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.