etcdserverpb

package
v0.0.0-...-d88c8b5 Latest Latest
Warning

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

Go to latest
Published: Feb 9, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation ΒΆ

Overview ΒΆ

Package etcdserverpb is a generated protocol buffer package.

It is generated from these files:

etcdserver.proto
raft_internal.proto
rpc.proto

It has these top-level messages:

Request
Metadata
RequestHeader
InternalRaftRequest
EmptyResponse
InternalAuthenticateRequest
ResponseHeader
RangeRequest
RangeResponse
PutRequest
PutResponse
DeleteRangeRequest
DeleteRangeResponse
RequestOp
ResponseOp
Compare
TxnRequest
TxnResponse
CompactionRequest
CompactionResponse
HashRequest
HashKVRequest
HashKVResponse
HashResponse
SnapshotRequest
SnapshotResponse
WatchRequest
WatchCreateRequest
WatchCancelRequest
WatchProgressRequest
WatchResponse
LeaseGrantRequest
LeaseGrantResponse
LeaseRevokeRequest
LeaseRevokeResponse
LeaseCheckpoint
LeaseCheckpointRequest
LeaseCheckpointResponse
LeaseKeepAliveRequest
LeaseKeepAliveResponse
LeaseTimeToLiveRequest
LeaseTimeToLiveResponse
LeaseLeasesRequest
LeaseStatus
LeaseLeasesResponse
Member
MemberAddRequest
MemberAddResponse
MemberRemoveRequest
MemberRemoveResponse
MemberUpdateRequest
MemberUpdateResponse
MemberListRequest
MemberListResponse
MemberPromoteRequest
MemberPromoteResponse
DefragmentRequest
DefragmentResponse
MoveLeaderRequest
MoveLeaderResponse
AlarmRequest
AlarmMember
AlarmResponse
StatusRequest
StatusResponse
AuthEnableRequest
AuthDisableRequest
AuthenticateRequest
AuthUserAddRequest
AuthUserGetRequest
AuthUserDeleteRequest
AuthUserChangePasswordRequest
AuthUserGrantRoleRequest
AuthUserRevokeRoleRequest
AuthRoleAddRequest
AuthRoleGetRequest
AuthUserListRequest
AuthRoleListRequest
AuthRoleDeleteRequest
AuthRoleGrantPermissionRequest
AuthRoleRevokePermissionRequest
AuthEnableResponse
AuthDisableResponse
AuthenticateResponse
AuthUserAddResponse
AuthUserGetResponse
AuthUserDeleteResponse
AuthUserChangePasswordResponse
AuthUserGrantRoleResponse
AuthUserRevokeRoleResponse
AuthRoleAddResponse
AuthRoleGetResponse
AuthRoleListResponse
AuthUserListResponse
AuthRoleDeleteResponse
AuthRoleGrantPermissionResponse
AuthRoleRevokePermissionResponse

Index ΒΆ

Constants ΒΆ

This section is empty.

Variables ΒΆ

View Source
var (
	ErrInvalidLengthEtcdserver = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEtcdserver   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthRaftInternal = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaftInternal   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc   = fmt.Errorf("proto: integer overflow")
)
View Source
var AlarmRequest_AlarmAction_name = map[int32]string{
	0: "GET",
	1: "ACTIVATE",
	2: "DEACTIVATE",
}
View Source
var AlarmRequest_AlarmAction_value = map[string]int32{
	"GET":        0,
	"ACTIVATE":   1,
	"DEACTIVATE": 2,
}
View Source
var AlarmType_name = map[int32]string{
	0: "NONE",
	1: "NOSPACE",
	2: "CORRUPT",
}
View Source
var AlarmType_value = map[string]int32{
	"NONE":    0,
	"NOSPACE": 1,
	"CORRUPT": 2,
}
View Source
var Compare_CompareResult_name = map[int32]string{
	0: "EQUAL",
	1: "GREATER",
	2: "LESS",
	3: "NOT_EQUAL",
}
View Source
var Compare_CompareResult_value = map[string]int32{
	"EQUAL":     0,
	"GREATER":   1,
	"LESS":      2,
	"NOT_EQUAL": 3,
}
View Source
var Compare_CompareTarget_name = map[int32]string{
	0: "VERSION",
	1: "CREATE",
	2: "MOD",
	3: "VALUE",
	4: "LEASE",
}
View Source
var Compare_CompareTarget_value = map[string]int32{
	"VERSION": 0,
	"CREATE":  1,
	"MOD":     2,
	"VALUE":   3,
	"LEASE":   4,
}
View Source
var RangeRequest_SortOrder_name = map[int32]string{
	0: "NONE",
	1: "ASCEND",
	2: "DESCEND",
}
View Source
var RangeRequest_SortOrder_value = map[string]int32{
	"NONE":    0,
	"ASCEND":  1,
	"DESCEND": 2,
}
View Source
var RangeRequest_SortTarget_name = map[int32]string{
	0: "KEY",
	1: "VERSION",
	2: "CREATE",
	3: "MOD",
	4: "VALUE",
}
View Source
var RangeRequest_SortTarget_value = map[string]int32{
	"KEY":     0,
	"VERSION": 1,
	"CREATE":  2,
	"MOD":     3,
	"VALUE":   4,
}
View Source
var WatchCreateRequest_FilterType_name = map[int32]string{
	0: "NOPUT",
	1: "NODELETE",
}
View Source
var WatchCreateRequest_FilterType_value = map[string]int32{
	"NOPUT":    0,
	"NODELETE": 1,
}

Functions ΒΆ

func NewLoggablePutRequest ΒΆ

func NewLoggablePutRequest(request *PutRequest) *loggablePutRequest

func NewLoggableTxnRequest ΒΆ

func NewLoggableTxnRequest(request *TxnRequest) *txnRequestStringer

func RegisterAuthServer ΒΆ

func RegisterAuthServer(s *grpc.Server, srv AuthServer)

func RegisterClusterServer ΒΆ

func RegisterClusterServer(s *grpc.Server, srv ClusterServer)

func RegisterKVServer ΒΆ

func RegisterKVServer(s *grpc.Server, srv KVServer)

func RegisterLeaseServer ΒΆ

func RegisterLeaseServer(s *grpc.Server, srv LeaseServer)

func RegisterMaintenanceServer ΒΆ

func RegisterMaintenanceServer(s *grpc.Server, srv MaintenanceServer)

func RegisterWatchServer ΒΆ

func RegisterWatchServer(s *grpc.Server, srv WatchServer)

Types ΒΆ

type AlarmMember ΒΆ

type AlarmMember struct {
	// memberID is the ID of the member associated with the raised alarm.
	MemberID uint64 `protobuf:"varint,1,opt,name=memberID,proto3" json:"memberID,omitempty"`
	// alarm is the type of alarm which has been raised.
	Alarm AlarmType `protobuf:"varint,2,opt,name=alarm,proto3,enum=etcdserverpb.AlarmType" json:"alarm,omitempty"`
}

func (*AlarmMember) Descriptor ΒΆ

func (*AlarmMember) Descriptor() ([]byte, []int)

func (*AlarmMember) GetAlarm ΒΆ

func (m *AlarmMember) GetAlarm() AlarmType

func (*AlarmMember) GetMemberID ΒΆ

func (m *AlarmMember) GetMemberID() uint64

func (*AlarmMember) Marshal ΒΆ

func (m *AlarmMember) Marshal() (dAtA []byte, err error)

func (*AlarmMember) MarshalTo ΒΆ

func (m *AlarmMember) MarshalTo(dAtA []byte) (int, error)

func (*AlarmMember) ProtoMessage ΒΆ

func (*AlarmMember) ProtoMessage()

func (*AlarmMember) Reset ΒΆ

func (m *AlarmMember) Reset()

func (*AlarmMember) Size ΒΆ

func (m *AlarmMember) Size() (n int)

func (*AlarmMember) String ΒΆ

func (m *AlarmMember) String() string

func (*AlarmMember) Unmarshal ΒΆ

func (m *AlarmMember) Unmarshal(dAtA []byte) error

type AlarmRequest ΒΆ

type AlarmRequest struct {
	// action is the kind of alarm request to issue. The action
	// may GET alarm statuses, ACTIVATE an alarm, or DEACTIVATE a
	// raised alarm.
	Action AlarmRequest_AlarmAction `protobuf:"varint,1,opt,name=action,proto3,enum=etcdserverpb.AlarmRequest_AlarmAction" json:"action,omitempty"`
	// memberID is the ID of the member associated with the alarm. If memberID is 0, the
	// alarm request covers all members.
	MemberID uint64 `protobuf:"varint,2,opt,name=memberID,proto3" json:"memberID,omitempty"`
	// alarm is the type of alarm to consider for this request.
	Alarm AlarmType `protobuf:"varint,3,opt,name=alarm,proto3,enum=etcdserverpb.AlarmType" json:"alarm,omitempty"`
}

func (*AlarmRequest) Descriptor ΒΆ

func (*AlarmRequest) Descriptor() ([]byte, []int)

func (*AlarmRequest) GetAction ΒΆ

func (m *AlarmRequest) GetAction() AlarmRequest_AlarmAction

func (*AlarmRequest) GetAlarm ΒΆ

func (m *AlarmRequest) GetAlarm() AlarmType

func (*AlarmRequest) GetMemberID ΒΆ

func (m *AlarmRequest) GetMemberID() uint64

func (*AlarmRequest) Marshal ΒΆ

func (m *AlarmRequest) Marshal() (dAtA []byte, err error)

func (*AlarmRequest) MarshalTo ΒΆ

func (m *AlarmRequest) MarshalTo(dAtA []byte) (int, error)

func (*AlarmRequest) ProtoMessage ΒΆ

func (*AlarmRequest) ProtoMessage()

func (*AlarmRequest) Reset ΒΆ

func (m *AlarmRequest) Reset()

func (*AlarmRequest) Size ΒΆ

func (m *AlarmRequest) Size() (n int)

func (*AlarmRequest) String ΒΆ

func (m *AlarmRequest) String() string

func (*AlarmRequest) Unmarshal ΒΆ

func (m *AlarmRequest) Unmarshal(dAtA []byte) error

type AlarmRequest_AlarmAction ΒΆ

type AlarmRequest_AlarmAction int32
const (
	AlarmRequest_GET        AlarmRequest_AlarmAction = 0
	AlarmRequest_ACTIVATE   AlarmRequest_AlarmAction = 1
	AlarmRequest_DEACTIVATE AlarmRequest_AlarmAction = 2
)

func (AlarmRequest_AlarmAction) EnumDescriptor ΒΆ

func (AlarmRequest_AlarmAction) EnumDescriptor() ([]byte, []int)

func (AlarmRequest_AlarmAction) String ΒΆ

func (x AlarmRequest_AlarmAction) String() string

type AlarmResponse ΒΆ

type AlarmResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// alarms is a list of alarms associated with the alarm request.
	Alarms []*AlarmMember `protobuf:"bytes,2,rep,name=alarms" json:"alarms,omitempty"`
}

func (*AlarmResponse) Descriptor ΒΆ

func (*AlarmResponse) Descriptor() ([]byte, []int)

func (*AlarmResponse) GetAlarms ΒΆ

func (m *AlarmResponse) GetAlarms() []*AlarmMember

func (*AlarmResponse) GetHeader ΒΆ

func (m *AlarmResponse) GetHeader() *ResponseHeader

func (*AlarmResponse) Marshal ΒΆ

func (m *AlarmResponse) Marshal() (dAtA []byte, err error)

func (*AlarmResponse) MarshalTo ΒΆ

func (m *AlarmResponse) MarshalTo(dAtA []byte) (int, error)

func (*AlarmResponse) ProtoMessage ΒΆ

func (*AlarmResponse) ProtoMessage()

func (*AlarmResponse) Reset ΒΆ

func (m *AlarmResponse) Reset()

func (*AlarmResponse) Size ΒΆ

func (m *AlarmResponse) Size() (n int)

func (*AlarmResponse) String ΒΆ

func (m *AlarmResponse) String() string

func (*AlarmResponse) Unmarshal ΒΆ

func (m *AlarmResponse) Unmarshal(dAtA []byte) error

type AlarmType ΒΆ

type AlarmType int32
const (
	AlarmType_NONE    AlarmType = 0
	AlarmType_NOSPACE AlarmType = 1
	AlarmType_CORRUPT AlarmType = 2
)

func (AlarmType) EnumDescriptor ΒΆ

func (AlarmType) EnumDescriptor() ([]byte, []int)

func (AlarmType) String ΒΆ

func (x AlarmType) String() string

type AuthClient ΒΆ

type AuthClient interface {
	// AuthEnable enables authentication.
	AuthEnable(ctx context.Context, in *AuthEnableRequest, opts ...grpc.CallOption) (*AuthEnableResponse, error)
	// AuthDisable disables authentication.
	AuthDisable(ctx context.Context, in *AuthDisableRequest, opts ...grpc.CallOption) (*AuthDisableResponse, error)
	// Authenticate processes an authenticate request.
	Authenticate(ctx context.Context, in *AuthenticateRequest, opts ...grpc.CallOption) (*AuthenticateResponse, error)
	// UserAdd adds a new user. User name cannot be empty.
	UserAdd(ctx context.Context, in *AuthUserAddRequest, opts ...grpc.CallOption) (*AuthUserAddResponse, error)
	// UserGet gets detailed user information.
	UserGet(ctx context.Context, in *AuthUserGetRequest, opts ...grpc.CallOption) (*AuthUserGetResponse, error)
	// UserList gets a list of all users.
	UserList(ctx context.Context, in *AuthUserListRequest, opts ...grpc.CallOption) (*AuthUserListResponse, error)
	// UserDelete deletes a specified user.
	UserDelete(ctx context.Context, in *AuthUserDeleteRequest, opts ...grpc.CallOption) (*AuthUserDeleteResponse, error)
	// UserChangePassword changes the password of a specified user.
	UserChangePassword(ctx context.Context, in *AuthUserChangePasswordRequest, opts ...grpc.CallOption) (*AuthUserChangePasswordResponse, error)
	// UserGrant grants a role to a specified user.
	UserGrantRole(ctx context.Context, in *AuthUserGrantRoleRequest, opts ...grpc.CallOption) (*AuthUserGrantRoleResponse, error)
	// UserRevokeRole revokes a role of specified user.
	UserRevokeRole(ctx context.Context, in *AuthUserRevokeRoleRequest, opts ...grpc.CallOption) (*AuthUserRevokeRoleResponse, error)
	// RoleAdd adds a new role. Role name cannot be empty.
	RoleAdd(ctx context.Context, in *AuthRoleAddRequest, opts ...grpc.CallOption) (*AuthRoleAddResponse, error)
	// RoleGet gets detailed role information.
	RoleGet(ctx context.Context, in *AuthRoleGetRequest, opts ...grpc.CallOption) (*AuthRoleGetResponse, error)
	// RoleList gets lists of all roles.
	RoleList(ctx context.Context, in *AuthRoleListRequest, opts ...grpc.CallOption) (*AuthRoleListResponse, error)
	// RoleDelete deletes a specified role.
	RoleDelete(ctx context.Context, in *AuthRoleDeleteRequest, opts ...grpc.CallOption) (*AuthRoleDeleteResponse, error)
	// RoleGrantPermission grants a permission of a specified key or range to a specified role.
	RoleGrantPermission(ctx context.Context, in *AuthRoleGrantPermissionRequest, opts ...grpc.CallOption) (*AuthRoleGrantPermissionResponse, error)
	// RoleRevokePermission revokes a key or range permission of a specified role.
	RoleRevokePermission(ctx context.Context, in *AuthRoleRevokePermissionRequest, opts ...grpc.CallOption) (*AuthRoleRevokePermissionResponse, error)
}

func NewAuthClient ΒΆ

func NewAuthClient(cc *grpc.ClientConn) AuthClient

type AuthDisableRequest ΒΆ

type AuthDisableRequest struct {
}

func (*AuthDisableRequest) Descriptor ΒΆ

func (*AuthDisableRequest) Descriptor() ([]byte, []int)

func (*AuthDisableRequest) Marshal ΒΆ

func (m *AuthDisableRequest) Marshal() (dAtA []byte, err error)

func (*AuthDisableRequest) MarshalTo ΒΆ

func (m *AuthDisableRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthDisableRequest) ProtoMessage ΒΆ

func (*AuthDisableRequest) ProtoMessage()

func (*AuthDisableRequest) Reset ΒΆ

func (m *AuthDisableRequest) Reset()

func (*AuthDisableRequest) Size ΒΆ

func (m *AuthDisableRequest) Size() (n int)

func (*AuthDisableRequest) String ΒΆ

func (m *AuthDisableRequest) String() string

func (*AuthDisableRequest) Unmarshal ΒΆ

func (m *AuthDisableRequest) Unmarshal(dAtA []byte) error

type AuthDisableResponse ΒΆ

type AuthDisableResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*AuthDisableResponse) Descriptor ΒΆ

func (*AuthDisableResponse) Descriptor() ([]byte, []int)

func (*AuthDisableResponse) GetHeader ΒΆ

func (m *AuthDisableResponse) GetHeader() *ResponseHeader

func (*AuthDisableResponse) Marshal ΒΆ

func (m *AuthDisableResponse) Marshal() (dAtA []byte, err error)

func (*AuthDisableResponse) MarshalTo ΒΆ

func (m *AuthDisableResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthDisableResponse) ProtoMessage ΒΆ

func (*AuthDisableResponse) ProtoMessage()

func (*AuthDisableResponse) Reset ΒΆ

func (m *AuthDisableResponse) Reset()

func (*AuthDisableResponse) Size ΒΆ

func (m *AuthDisableResponse) Size() (n int)

func (*AuthDisableResponse) String ΒΆ

func (m *AuthDisableResponse) String() string

func (*AuthDisableResponse) Unmarshal ΒΆ

func (m *AuthDisableResponse) Unmarshal(dAtA []byte) error

type AuthEnableRequest ΒΆ

type AuthEnableRequest struct {
}

func (*AuthEnableRequest) Descriptor ΒΆ

func (*AuthEnableRequest) Descriptor() ([]byte, []int)

func (*AuthEnableRequest) Marshal ΒΆ

func (m *AuthEnableRequest) Marshal() (dAtA []byte, err error)

func (*AuthEnableRequest) MarshalTo ΒΆ

func (m *AuthEnableRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthEnableRequest) ProtoMessage ΒΆ

func (*AuthEnableRequest) ProtoMessage()

func (*AuthEnableRequest) Reset ΒΆ

func (m *AuthEnableRequest) Reset()

func (*AuthEnableRequest) Size ΒΆ

func (m *AuthEnableRequest) Size() (n int)

func (*AuthEnableRequest) String ΒΆ

func (m *AuthEnableRequest) String() string

func (*AuthEnableRequest) Unmarshal ΒΆ

func (m *AuthEnableRequest) Unmarshal(dAtA []byte) error

type AuthEnableResponse ΒΆ

type AuthEnableResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*AuthEnableResponse) Descriptor ΒΆ

func (*AuthEnableResponse) Descriptor() ([]byte, []int)

func (*AuthEnableResponse) GetHeader ΒΆ

func (m *AuthEnableResponse) GetHeader() *ResponseHeader

func (*AuthEnableResponse) Marshal ΒΆ

func (m *AuthEnableResponse) Marshal() (dAtA []byte, err error)

func (*AuthEnableResponse) MarshalTo ΒΆ

func (m *AuthEnableResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthEnableResponse) ProtoMessage ΒΆ

func (*AuthEnableResponse) ProtoMessage()

func (*AuthEnableResponse) Reset ΒΆ

func (m *AuthEnableResponse) Reset()

func (*AuthEnableResponse) Size ΒΆ

func (m *AuthEnableResponse) Size() (n int)

func (*AuthEnableResponse) String ΒΆ

func (m *AuthEnableResponse) String() string

func (*AuthEnableResponse) Unmarshal ΒΆ

func (m *AuthEnableResponse) Unmarshal(dAtA []byte) error

type AuthRoleAddRequest ΒΆ

type AuthRoleAddRequest struct {
	// name is the name of the role to add to the authentication system.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*AuthRoleAddRequest) Descriptor ΒΆ

func (*AuthRoleAddRequest) Descriptor() ([]byte, []int)

func (*AuthRoleAddRequest) GetName ΒΆ

func (m *AuthRoleAddRequest) GetName() string

func (*AuthRoleAddRequest) Marshal ΒΆ

func (m *AuthRoleAddRequest) Marshal() (dAtA []byte, err error)

func (*AuthRoleAddRequest) MarshalTo ΒΆ

func (m *AuthRoleAddRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthRoleAddRequest) ProtoMessage ΒΆ

func (*AuthRoleAddRequest) ProtoMessage()

func (*AuthRoleAddRequest) Reset ΒΆ

func (m *AuthRoleAddRequest) Reset()

func (*AuthRoleAddRequest) Size ΒΆ

func (m *AuthRoleAddRequest) Size() (n int)

func (*AuthRoleAddRequest) String ΒΆ

func (m *AuthRoleAddRequest) String() string

func (*AuthRoleAddRequest) Unmarshal ΒΆ

func (m *AuthRoleAddRequest) Unmarshal(dAtA []byte) error

type AuthRoleAddResponse ΒΆ

type AuthRoleAddResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*AuthRoleAddResponse) Descriptor ΒΆ

func (*AuthRoleAddResponse) Descriptor() ([]byte, []int)

func (*AuthRoleAddResponse) GetHeader ΒΆ

func (m *AuthRoleAddResponse) GetHeader() *ResponseHeader

func (*AuthRoleAddResponse) Marshal ΒΆ

func (m *AuthRoleAddResponse) Marshal() (dAtA []byte, err error)

func (*AuthRoleAddResponse) MarshalTo ΒΆ

func (m *AuthRoleAddResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthRoleAddResponse) ProtoMessage ΒΆ

func (*AuthRoleAddResponse) ProtoMessage()

func (*AuthRoleAddResponse) Reset ΒΆ

func (m *AuthRoleAddResponse) Reset()

func (*AuthRoleAddResponse) Size ΒΆ

func (m *AuthRoleAddResponse) Size() (n int)

func (*AuthRoleAddResponse) String ΒΆ

func (m *AuthRoleAddResponse) String() string

func (*AuthRoleAddResponse) Unmarshal ΒΆ

func (m *AuthRoleAddResponse) Unmarshal(dAtA []byte) error

type AuthRoleDeleteRequest ΒΆ

type AuthRoleDeleteRequest struct {
	Role string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
}

func (*AuthRoleDeleteRequest) Descriptor ΒΆ

func (*AuthRoleDeleteRequest) Descriptor() ([]byte, []int)

func (*AuthRoleDeleteRequest) GetRole ΒΆ

func (m *AuthRoleDeleteRequest) GetRole() string

func (*AuthRoleDeleteRequest) Marshal ΒΆ

func (m *AuthRoleDeleteRequest) Marshal() (dAtA []byte, err error)

func (*AuthRoleDeleteRequest) MarshalTo ΒΆ

func (m *AuthRoleDeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthRoleDeleteRequest) ProtoMessage ΒΆ

func (*AuthRoleDeleteRequest) ProtoMessage()

func (*AuthRoleDeleteRequest) Reset ΒΆ

func (m *AuthRoleDeleteRequest) Reset()

func (*AuthRoleDeleteRequest) Size ΒΆ

func (m *AuthRoleDeleteRequest) Size() (n int)

func (*AuthRoleDeleteRequest) String ΒΆ

func (m *AuthRoleDeleteRequest) String() string

func (*AuthRoleDeleteRequest) Unmarshal ΒΆ

func (m *AuthRoleDeleteRequest) Unmarshal(dAtA []byte) error

type AuthRoleDeleteResponse ΒΆ

type AuthRoleDeleteResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*AuthRoleDeleteResponse) Descriptor ΒΆ

func (*AuthRoleDeleteResponse) Descriptor() ([]byte, []int)

func (*AuthRoleDeleteResponse) GetHeader ΒΆ

func (m *AuthRoleDeleteResponse) GetHeader() *ResponseHeader

func (*AuthRoleDeleteResponse) Marshal ΒΆ

func (m *AuthRoleDeleteResponse) Marshal() (dAtA []byte, err error)

func (*AuthRoleDeleteResponse) MarshalTo ΒΆ

func (m *AuthRoleDeleteResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthRoleDeleteResponse) ProtoMessage ΒΆ

func (*AuthRoleDeleteResponse) ProtoMessage()

func (*AuthRoleDeleteResponse) Reset ΒΆ

func (m *AuthRoleDeleteResponse) Reset()

func (*AuthRoleDeleteResponse) Size ΒΆ

func (m *AuthRoleDeleteResponse) Size() (n int)

func (*AuthRoleDeleteResponse) String ΒΆ

func (m *AuthRoleDeleteResponse) String() string

func (*AuthRoleDeleteResponse) Unmarshal ΒΆ

func (m *AuthRoleDeleteResponse) Unmarshal(dAtA []byte) error

type AuthRoleGetRequest ΒΆ

type AuthRoleGetRequest struct {
	Role string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
}

func (*AuthRoleGetRequest) Descriptor ΒΆ

func (*AuthRoleGetRequest) Descriptor() ([]byte, []int)

func (*AuthRoleGetRequest) GetRole ΒΆ

func (m *AuthRoleGetRequest) GetRole() string

func (*AuthRoleGetRequest) Marshal ΒΆ

func (m *AuthRoleGetRequest) Marshal() (dAtA []byte, err error)

func (*AuthRoleGetRequest) MarshalTo ΒΆ

func (m *AuthRoleGetRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthRoleGetRequest) ProtoMessage ΒΆ

func (*AuthRoleGetRequest) ProtoMessage()

func (*AuthRoleGetRequest) Reset ΒΆ

func (m *AuthRoleGetRequest) Reset()

func (*AuthRoleGetRequest) Size ΒΆ

func (m *AuthRoleGetRequest) Size() (n int)

func (*AuthRoleGetRequest) String ΒΆ

func (m *AuthRoleGetRequest) String() string

func (*AuthRoleGetRequest) Unmarshal ΒΆ

func (m *AuthRoleGetRequest) Unmarshal(dAtA []byte) error

type AuthRoleGetResponse ΒΆ

type AuthRoleGetResponse struct {
	Header *ResponseHeader      `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Perm   []*authpb.Permission `protobuf:"bytes,2,rep,name=perm" json:"perm,omitempty"`
}

func (*AuthRoleGetResponse) Descriptor ΒΆ

func (*AuthRoleGetResponse) Descriptor() ([]byte, []int)

func (*AuthRoleGetResponse) GetHeader ΒΆ

func (m *AuthRoleGetResponse) GetHeader() *ResponseHeader

func (*AuthRoleGetResponse) GetPerm ΒΆ

func (m *AuthRoleGetResponse) GetPerm() []*authpb.Permission

func (*AuthRoleGetResponse) Marshal ΒΆ

func (m *AuthRoleGetResponse) Marshal() (dAtA []byte, err error)

func (*AuthRoleGetResponse) MarshalTo ΒΆ

func (m *AuthRoleGetResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthRoleGetResponse) ProtoMessage ΒΆ

func (*AuthRoleGetResponse) ProtoMessage()

func (*AuthRoleGetResponse) Reset ΒΆ

func (m *AuthRoleGetResponse) Reset()

func (*AuthRoleGetResponse) Size ΒΆ

func (m *AuthRoleGetResponse) Size() (n int)

func (*AuthRoleGetResponse) String ΒΆ

func (m *AuthRoleGetResponse) String() string

func (*AuthRoleGetResponse) Unmarshal ΒΆ

func (m *AuthRoleGetResponse) Unmarshal(dAtA []byte) error

type AuthRoleGrantPermissionRequest ΒΆ

type AuthRoleGrantPermissionRequest struct {
	// name is the name of the role which will be granted the permission.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// perm is the permission to grant to the role.
	Perm *authpb.Permission `protobuf:"bytes,2,opt,name=perm" json:"perm,omitempty"`
}

func (*AuthRoleGrantPermissionRequest) Descriptor ΒΆ

func (*AuthRoleGrantPermissionRequest) Descriptor() ([]byte, []int)

func (*AuthRoleGrantPermissionRequest) GetName ΒΆ

func (*AuthRoleGrantPermissionRequest) GetPerm ΒΆ

func (*AuthRoleGrantPermissionRequest) Marshal ΒΆ

func (m *AuthRoleGrantPermissionRequest) Marshal() (dAtA []byte, err error)

func (*AuthRoleGrantPermissionRequest) MarshalTo ΒΆ

func (m *AuthRoleGrantPermissionRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthRoleGrantPermissionRequest) ProtoMessage ΒΆ

func (*AuthRoleGrantPermissionRequest) ProtoMessage()

func (*AuthRoleGrantPermissionRequest) Reset ΒΆ

func (m *AuthRoleGrantPermissionRequest) Reset()

func (*AuthRoleGrantPermissionRequest) Size ΒΆ

func (m *AuthRoleGrantPermissionRequest) Size() (n int)

func (*AuthRoleGrantPermissionRequest) String ΒΆ

func (*AuthRoleGrantPermissionRequest) Unmarshal ΒΆ

func (m *AuthRoleGrantPermissionRequest) Unmarshal(dAtA []byte) error

type AuthRoleGrantPermissionResponse ΒΆ

type AuthRoleGrantPermissionResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*AuthRoleGrantPermissionResponse) Descriptor ΒΆ

func (*AuthRoleGrantPermissionResponse) Descriptor() ([]byte, []int)

func (*AuthRoleGrantPermissionResponse) GetHeader ΒΆ

func (*AuthRoleGrantPermissionResponse) Marshal ΒΆ

func (m *AuthRoleGrantPermissionResponse) Marshal() (dAtA []byte, err error)

func (*AuthRoleGrantPermissionResponse) MarshalTo ΒΆ

func (m *AuthRoleGrantPermissionResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthRoleGrantPermissionResponse) ProtoMessage ΒΆ

func (*AuthRoleGrantPermissionResponse) ProtoMessage()

func (*AuthRoleGrantPermissionResponse) Reset ΒΆ

func (*AuthRoleGrantPermissionResponse) Size ΒΆ

func (m *AuthRoleGrantPermissionResponse) Size() (n int)

func (*AuthRoleGrantPermissionResponse) String ΒΆ

func (*AuthRoleGrantPermissionResponse) Unmarshal ΒΆ

func (m *AuthRoleGrantPermissionResponse) Unmarshal(dAtA []byte) error

type AuthRoleListRequest ΒΆ

type AuthRoleListRequest struct {
}

func (*AuthRoleListRequest) Descriptor ΒΆ

func (*AuthRoleListRequest) Descriptor() ([]byte, []int)

func (*AuthRoleListRequest) Marshal ΒΆ

func (m *AuthRoleListRequest) Marshal() (dAtA []byte, err error)

func (*AuthRoleListRequest) MarshalTo ΒΆ

func (m *AuthRoleListRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthRoleListRequest) ProtoMessage ΒΆ

func (*AuthRoleListRequest) ProtoMessage()

func (*AuthRoleListRequest) Reset ΒΆ

func (m *AuthRoleListRequest) Reset()

func (*AuthRoleListRequest) Size ΒΆ

func (m *AuthRoleListRequest) Size() (n int)

func (*AuthRoleListRequest) String ΒΆ

func (m *AuthRoleListRequest) String() string

func (*AuthRoleListRequest) Unmarshal ΒΆ

func (m *AuthRoleListRequest) Unmarshal(dAtA []byte) error

type AuthRoleListResponse ΒΆ

type AuthRoleListResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Roles  []string        `protobuf:"bytes,2,rep,name=roles" json:"roles,omitempty"`
}

func (*AuthRoleListResponse) Descriptor ΒΆ

func (*AuthRoleListResponse) Descriptor() ([]byte, []int)

func (*AuthRoleListResponse) GetHeader ΒΆ

func (m *AuthRoleListResponse) GetHeader() *ResponseHeader

func (*AuthRoleListResponse) GetRoles ΒΆ

func (m *AuthRoleListResponse) GetRoles() []string

func (*AuthRoleListResponse) Marshal ΒΆ

func (m *AuthRoleListResponse) Marshal() (dAtA []byte, err error)

func (*AuthRoleListResponse) MarshalTo ΒΆ

func (m *AuthRoleListResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthRoleListResponse) ProtoMessage ΒΆ

func (*AuthRoleListResponse) ProtoMessage()

func (*AuthRoleListResponse) Reset ΒΆ

func (m *AuthRoleListResponse) Reset()

func (*AuthRoleListResponse) Size ΒΆ

func (m *AuthRoleListResponse) Size() (n int)

func (*AuthRoleListResponse) String ΒΆ

func (m *AuthRoleListResponse) String() string

func (*AuthRoleListResponse) Unmarshal ΒΆ

func (m *AuthRoleListResponse) Unmarshal(dAtA []byte) error

type AuthRoleRevokePermissionRequest ΒΆ

type AuthRoleRevokePermissionRequest struct {
	Role     string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	Key      []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	RangeEnd []byte `protobuf:"bytes,3,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
}

func (*AuthRoleRevokePermissionRequest) Descriptor ΒΆ

func (*AuthRoleRevokePermissionRequest) Descriptor() ([]byte, []int)

func (*AuthRoleRevokePermissionRequest) GetKey ΒΆ

func (m *AuthRoleRevokePermissionRequest) GetKey() []byte

func (*AuthRoleRevokePermissionRequest) GetRangeEnd ΒΆ

func (m *AuthRoleRevokePermissionRequest) GetRangeEnd() []byte

func (*AuthRoleRevokePermissionRequest) GetRole ΒΆ

func (*AuthRoleRevokePermissionRequest) Marshal ΒΆ

func (m *AuthRoleRevokePermissionRequest) Marshal() (dAtA []byte, err error)

func (*AuthRoleRevokePermissionRequest) MarshalTo ΒΆ

func (m *AuthRoleRevokePermissionRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthRoleRevokePermissionRequest) ProtoMessage ΒΆ

func (*AuthRoleRevokePermissionRequest) ProtoMessage()

func (*AuthRoleRevokePermissionRequest) Reset ΒΆ

func (*AuthRoleRevokePermissionRequest) Size ΒΆ

func (m *AuthRoleRevokePermissionRequest) Size() (n int)

func (*AuthRoleRevokePermissionRequest) String ΒΆ

func (*AuthRoleRevokePermissionRequest) Unmarshal ΒΆ

func (m *AuthRoleRevokePermissionRequest) Unmarshal(dAtA []byte) error

type AuthRoleRevokePermissionResponse ΒΆ

type AuthRoleRevokePermissionResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*AuthRoleRevokePermissionResponse) Descriptor ΒΆ

func (*AuthRoleRevokePermissionResponse) Descriptor() ([]byte, []int)

func (*AuthRoleRevokePermissionResponse) GetHeader ΒΆ

func (*AuthRoleRevokePermissionResponse) Marshal ΒΆ

func (m *AuthRoleRevokePermissionResponse) Marshal() (dAtA []byte, err error)

func (*AuthRoleRevokePermissionResponse) MarshalTo ΒΆ

func (m *AuthRoleRevokePermissionResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthRoleRevokePermissionResponse) ProtoMessage ΒΆ

func (*AuthRoleRevokePermissionResponse) ProtoMessage()

func (*AuthRoleRevokePermissionResponse) Reset ΒΆ

func (*AuthRoleRevokePermissionResponse) Size ΒΆ

func (m *AuthRoleRevokePermissionResponse) Size() (n int)

func (*AuthRoleRevokePermissionResponse) String ΒΆ

func (*AuthRoleRevokePermissionResponse) Unmarshal ΒΆ

func (m *AuthRoleRevokePermissionResponse) Unmarshal(dAtA []byte) error

type AuthServer ΒΆ

type AuthServer interface {
	// AuthEnable enables authentication.
	AuthEnable(context.Context, *AuthEnableRequest) (*AuthEnableResponse, error)
	// AuthDisable disables authentication.
	AuthDisable(context.Context, *AuthDisableRequest) (*AuthDisableResponse, error)
	// Authenticate processes an authenticate request.
	Authenticate(context.Context, *AuthenticateRequest) (*AuthenticateResponse, error)
	// UserAdd adds a new user. User name cannot be empty.
	UserAdd(context.Context, *AuthUserAddRequest) (*AuthUserAddResponse, error)
	// UserGet gets detailed user information.
	UserGet(context.Context, *AuthUserGetRequest) (*AuthUserGetResponse, error)
	// UserList gets a list of all users.
	UserList(context.Context, *AuthUserListRequest) (*AuthUserListResponse, error)
	// UserDelete deletes a specified user.
	UserDelete(context.Context, *AuthUserDeleteRequest) (*AuthUserDeleteResponse, error)
	// UserChangePassword changes the password of a specified user.
	UserChangePassword(context.Context, *AuthUserChangePasswordRequest) (*AuthUserChangePasswordResponse, error)
	// UserGrant grants a role to a specified user.
	UserGrantRole(context.Context, *AuthUserGrantRoleRequest) (*AuthUserGrantRoleResponse, error)
	// UserRevokeRole revokes a role of specified user.
	UserRevokeRole(context.Context, *AuthUserRevokeRoleRequest) (*AuthUserRevokeRoleResponse, error)
	// RoleAdd adds a new role. Role name cannot be empty.
	RoleAdd(context.Context, *AuthRoleAddRequest) (*AuthRoleAddResponse, error)
	// RoleGet gets detailed role information.
	RoleGet(context.Context, *AuthRoleGetRequest) (*AuthRoleGetResponse, error)
	// RoleList gets lists of all roles.
	RoleList(context.Context, *AuthRoleListRequest) (*AuthRoleListResponse, error)
	// RoleDelete deletes a specified role.
	RoleDelete(context.Context, *AuthRoleDeleteRequest) (*AuthRoleDeleteResponse, error)
	// RoleGrantPermission grants a permission of a specified key or range to a specified role.
	RoleGrantPermission(context.Context, *AuthRoleGrantPermissionRequest) (*AuthRoleGrantPermissionResponse, error)
	// RoleRevokePermission revokes a key or range permission of a specified role.
	RoleRevokePermission(context.Context, *AuthRoleRevokePermissionRequest) (*AuthRoleRevokePermissionResponse, error)
}

type AuthUserAddRequest ΒΆ

type AuthUserAddRequest struct {
	Name     string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Password string                 `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Options  *authpb.UserAddOptions `protobuf:"bytes,3,opt,name=options" json:"options,omitempty"`
}

func (*AuthUserAddRequest) Descriptor ΒΆ

func (*AuthUserAddRequest) Descriptor() ([]byte, []int)

func (*AuthUserAddRequest) GetName ΒΆ

func (m *AuthUserAddRequest) GetName() string

func (*AuthUserAddRequest) GetOptions ΒΆ

func (m *AuthUserAddRequest) GetOptions() *authpb.UserAddOptions

func (*AuthUserAddRequest) GetPassword ΒΆ

func (m *AuthUserAddRequest) GetPassword() string

func (*AuthUserAddRequest) Marshal ΒΆ

func (m *AuthUserAddRequest) Marshal() (dAtA []byte, err error)

func (*AuthUserAddRequest) MarshalTo ΒΆ

func (m *AuthUserAddRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserAddRequest) ProtoMessage ΒΆ

func (*AuthUserAddRequest) ProtoMessage()

func (*AuthUserAddRequest) Reset ΒΆ

func (m *AuthUserAddRequest) Reset()

func (*AuthUserAddRequest) Size ΒΆ

func (m *AuthUserAddRequest) Size() (n int)

func (*AuthUserAddRequest) String ΒΆ

func (m *AuthUserAddRequest) String() string

func (*AuthUserAddRequest) Unmarshal ΒΆ

func (m *AuthUserAddRequest) Unmarshal(dAtA []byte) error

type AuthUserAddResponse ΒΆ

type AuthUserAddResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*AuthUserAddResponse) Descriptor ΒΆ

func (*AuthUserAddResponse) Descriptor() ([]byte, []int)

func (*AuthUserAddResponse) GetHeader ΒΆ

func (m *AuthUserAddResponse) GetHeader() *ResponseHeader

func (*AuthUserAddResponse) Marshal ΒΆ

func (m *AuthUserAddResponse) Marshal() (dAtA []byte, err error)

func (*AuthUserAddResponse) MarshalTo ΒΆ

func (m *AuthUserAddResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserAddResponse) ProtoMessage ΒΆ

func (*AuthUserAddResponse) ProtoMessage()

func (*AuthUserAddResponse) Reset ΒΆ

func (m *AuthUserAddResponse) Reset()

func (*AuthUserAddResponse) Size ΒΆ

func (m *AuthUserAddResponse) Size() (n int)

func (*AuthUserAddResponse) String ΒΆ

func (m *AuthUserAddResponse) String() string

func (*AuthUserAddResponse) Unmarshal ΒΆ

func (m *AuthUserAddResponse) Unmarshal(dAtA []byte) error

type AuthUserChangePasswordRequest ΒΆ

type AuthUserChangePasswordRequest struct {
	// name is the name of the user whose password is being changed.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// password is the new password for the user.
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
}

func (*AuthUserChangePasswordRequest) Descriptor ΒΆ

func (*AuthUserChangePasswordRequest) Descriptor() ([]byte, []int)

func (*AuthUserChangePasswordRequest) GetName ΒΆ

func (*AuthUserChangePasswordRequest) GetPassword ΒΆ

func (m *AuthUserChangePasswordRequest) GetPassword() string

func (*AuthUserChangePasswordRequest) Marshal ΒΆ

func (m *AuthUserChangePasswordRequest) Marshal() (dAtA []byte, err error)

func (*AuthUserChangePasswordRequest) MarshalTo ΒΆ

func (m *AuthUserChangePasswordRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserChangePasswordRequest) ProtoMessage ΒΆ

func (*AuthUserChangePasswordRequest) ProtoMessage()

func (*AuthUserChangePasswordRequest) Reset ΒΆ

func (m *AuthUserChangePasswordRequest) Reset()

func (*AuthUserChangePasswordRequest) Size ΒΆ

func (m *AuthUserChangePasswordRequest) Size() (n int)

func (*AuthUserChangePasswordRequest) String ΒΆ

func (*AuthUserChangePasswordRequest) Unmarshal ΒΆ

func (m *AuthUserChangePasswordRequest) Unmarshal(dAtA []byte) error

type AuthUserChangePasswordResponse ΒΆ

type AuthUserChangePasswordResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*AuthUserChangePasswordResponse) Descriptor ΒΆ

func (*AuthUserChangePasswordResponse) Descriptor() ([]byte, []int)

func (*AuthUserChangePasswordResponse) GetHeader ΒΆ

func (*AuthUserChangePasswordResponse) Marshal ΒΆ

func (m *AuthUserChangePasswordResponse) Marshal() (dAtA []byte, err error)

func (*AuthUserChangePasswordResponse) MarshalTo ΒΆ

func (m *AuthUserChangePasswordResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserChangePasswordResponse) ProtoMessage ΒΆ

func (*AuthUserChangePasswordResponse) ProtoMessage()

func (*AuthUserChangePasswordResponse) Reset ΒΆ

func (m *AuthUserChangePasswordResponse) Reset()

func (*AuthUserChangePasswordResponse) Size ΒΆ

func (m *AuthUserChangePasswordResponse) Size() (n int)

func (*AuthUserChangePasswordResponse) String ΒΆ

func (*AuthUserChangePasswordResponse) Unmarshal ΒΆ

func (m *AuthUserChangePasswordResponse) Unmarshal(dAtA []byte) error

type AuthUserDeleteRequest ΒΆ

type AuthUserDeleteRequest struct {
	// name is the name of the user to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*AuthUserDeleteRequest) Descriptor ΒΆ

func (*AuthUserDeleteRequest) Descriptor() ([]byte, []int)

func (*AuthUserDeleteRequest) GetName ΒΆ

func (m *AuthUserDeleteRequest) GetName() string

func (*AuthUserDeleteRequest) Marshal ΒΆ

func (m *AuthUserDeleteRequest) Marshal() (dAtA []byte, err error)

func (*AuthUserDeleteRequest) MarshalTo ΒΆ

func (m *AuthUserDeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserDeleteRequest) ProtoMessage ΒΆ

func (*AuthUserDeleteRequest) ProtoMessage()

func (*AuthUserDeleteRequest) Reset ΒΆ

func (m *AuthUserDeleteRequest) Reset()

func (*AuthUserDeleteRequest) Size ΒΆ

func (m *AuthUserDeleteRequest) Size() (n int)

func (*AuthUserDeleteRequest) String ΒΆ

func (m *AuthUserDeleteRequest) String() string

func (*AuthUserDeleteRequest) Unmarshal ΒΆ

func (m *AuthUserDeleteRequest) Unmarshal(dAtA []byte) error

type AuthUserDeleteResponse ΒΆ

type AuthUserDeleteResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*AuthUserDeleteResponse) Descriptor ΒΆ

func (*AuthUserDeleteResponse) Descriptor() ([]byte, []int)

func (*AuthUserDeleteResponse) GetHeader ΒΆ

func (m *AuthUserDeleteResponse) GetHeader() *ResponseHeader

func (*AuthUserDeleteResponse) Marshal ΒΆ

func (m *AuthUserDeleteResponse) Marshal() (dAtA []byte, err error)

func (*AuthUserDeleteResponse) MarshalTo ΒΆ

func (m *AuthUserDeleteResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserDeleteResponse) ProtoMessage ΒΆ

func (*AuthUserDeleteResponse) ProtoMessage()

func (*AuthUserDeleteResponse) Reset ΒΆ

func (m *AuthUserDeleteResponse) Reset()

func (*AuthUserDeleteResponse) Size ΒΆ

func (m *AuthUserDeleteResponse) Size() (n int)

func (*AuthUserDeleteResponse) String ΒΆ

func (m *AuthUserDeleteResponse) String() string

func (*AuthUserDeleteResponse) Unmarshal ΒΆ

func (m *AuthUserDeleteResponse) Unmarshal(dAtA []byte) error

type AuthUserGetRequest ΒΆ

type AuthUserGetRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*AuthUserGetRequest) Descriptor ΒΆ

func (*AuthUserGetRequest) Descriptor() ([]byte, []int)

func (*AuthUserGetRequest) GetName ΒΆ

func (m *AuthUserGetRequest) GetName() string

func (*AuthUserGetRequest) Marshal ΒΆ

func (m *AuthUserGetRequest) Marshal() (dAtA []byte, err error)

func (*AuthUserGetRequest) MarshalTo ΒΆ

func (m *AuthUserGetRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserGetRequest) ProtoMessage ΒΆ

func (*AuthUserGetRequest) ProtoMessage()

func (*AuthUserGetRequest) Reset ΒΆ

func (m *AuthUserGetRequest) Reset()

func (*AuthUserGetRequest) Size ΒΆ

func (m *AuthUserGetRequest) Size() (n int)

func (*AuthUserGetRequest) String ΒΆ

func (m *AuthUserGetRequest) String() string

func (*AuthUserGetRequest) Unmarshal ΒΆ

func (m *AuthUserGetRequest) Unmarshal(dAtA []byte) error

type AuthUserGetResponse ΒΆ

type AuthUserGetResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Roles  []string        `protobuf:"bytes,2,rep,name=roles" json:"roles,omitempty"`
}

func (*AuthUserGetResponse) Descriptor ΒΆ

func (*AuthUserGetResponse) Descriptor() ([]byte, []int)

func (*AuthUserGetResponse) GetHeader ΒΆ

func (m *AuthUserGetResponse) GetHeader() *ResponseHeader

func (*AuthUserGetResponse) GetRoles ΒΆ

func (m *AuthUserGetResponse) GetRoles() []string

func (*AuthUserGetResponse) Marshal ΒΆ

func (m *AuthUserGetResponse) Marshal() (dAtA []byte, err error)

func (*AuthUserGetResponse) MarshalTo ΒΆ

func (m *AuthUserGetResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserGetResponse) ProtoMessage ΒΆ

func (*AuthUserGetResponse) ProtoMessage()

func (*AuthUserGetResponse) Reset ΒΆ

func (m *AuthUserGetResponse) Reset()

func (*AuthUserGetResponse) Size ΒΆ

func (m *AuthUserGetResponse) Size() (n int)

func (*AuthUserGetResponse) String ΒΆ

func (m *AuthUserGetResponse) String() string

func (*AuthUserGetResponse) Unmarshal ΒΆ

func (m *AuthUserGetResponse) Unmarshal(dAtA []byte) error

type AuthUserGrantRoleRequest ΒΆ

type AuthUserGrantRoleRequest struct {
	// user is the name of the user which should be granted a given role.
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// role is the name of the role to grant to the user.
	Role string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
}

func (*AuthUserGrantRoleRequest) Descriptor ΒΆ

func (*AuthUserGrantRoleRequest) Descriptor() ([]byte, []int)

func (*AuthUserGrantRoleRequest) GetRole ΒΆ

func (m *AuthUserGrantRoleRequest) GetRole() string

func (*AuthUserGrantRoleRequest) GetUser ΒΆ

func (m *AuthUserGrantRoleRequest) GetUser() string

func (*AuthUserGrantRoleRequest) Marshal ΒΆ

func (m *AuthUserGrantRoleRequest) Marshal() (dAtA []byte, err error)

func (*AuthUserGrantRoleRequest) MarshalTo ΒΆ

func (m *AuthUserGrantRoleRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserGrantRoleRequest) ProtoMessage ΒΆ

func (*AuthUserGrantRoleRequest) ProtoMessage()

func (*AuthUserGrantRoleRequest) Reset ΒΆ

func (m *AuthUserGrantRoleRequest) Reset()

func (*AuthUserGrantRoleRequest) Size ΒΆ

func (m *AuthUserGrantRoleRequest) Size() (n int)

func (*AuthUserGrantRoleRequest) String ΒΆ

func (m *AuthUserGrantRoleRequest) String() string

func (*AuthUserGrantRoleRequest) Unmarshal ΒΆ

func (m *AuthUserGrantRoleRequest) Unmarshal(dAtA []byte) error

type AuthUserGrantRoleResponse ΒΆ

type AuthUserGrantRoleResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*AuthUserGrantRoleResponse) Descriptor ΒΆ

func (*AuthUserGrantRoleResponse) Descriptor() ([]byte, []int)

func (*AuthUserGrantRoleResponse) GetHeader ΒΆ

func (m *AuthUserGrantRoleResponse) GetHeader() *ResponseHeader

func (*AuthUserGrantRoleResponse) Marshal ΒΆ

func (m *AuthUserGrantRoleResponse) Marshal() (dAtA []byte, err error)

func (*AuthUserGrantRoleResponse) MarshalTo ΒΆ

func (m *AuthUserGrantRoleResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserGrantRoleResponse) ProtoMessage ΒΆ

func (*AuthUserGrantRoleResponse) ProtoMessage()

func (*AuthUserGrantRoleResponse) Reset ΒΆ

func (m *AuthUserGrantRoleResponse) Reset()

func (*AuthUserGrantRoleResponse) Size ΒΆ

func (m *AuthUserGrantRoleResponse) Size() (n int)

func (*AuthUserGrantRoleResponse) String ΒΆ

func (m *AuthUserGrantRoleResponse) String() string

func (*AuthUserGrantRoleResponse) Unmarshal ΒΆ

func (m *AuthUserGrantRoleResponse) Unmarshal(dAtA []byte) error

type AuthUserListRequest ΒΆ

type AuthUserListRequest struct {
}

func (*AuthUserListRequest) Descriptor ΒΆ

func (*AuthUserListRequest) Descriptor() ([]byte, []int)

func (*AuthUserListRequest) Marshal ΒΆ

func (m *AuthUserListRequest) Marshal() (dAtA []byte, err error)

func (*AuthUserListRequest) MarshalTo ΒΆ

func (m *AuthUserListRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserListRequest) ProtoMessage ΒΆ

func (*AuthUserListRequest) ProtoMessage()

func (*AuthUserListRequest) Reset ΒΆ

func (m *AuthUserListRequest) Reset()

func (*AuthUserListRequest) Size ΒΆ

func (m *AuthUserListRequest) Size() (n int)

func (*AuthUserListRequest) String ΒΆ

func (m *AuthUserListRequest) String() string

func (*AuthUserListRequest) Unmarshal ΒΆ

func (m *AuthUserListRequest) Unmarshal(dAtA []byte) error

type AuthUserListResponse ΒΆ

type AuthUserListResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Users  []string        `protobuf:"bytes,2,rep,name=users" json:"users,omitempty"`
}

func (*AuthUserListResponse) Descriptor ΒΆ

func (*AuthUserListResponse) Descriptor() ([]byte, []int)

func (*AuthUserListResponse) GetHeader ΒΆ

func (m *AuthUserListResponse) GetHeader() *ResponseHeader

func (*AuthUserListResponse) GetUsers ΒΆ

func (m *AuthUserListResponse) GetUsers() []string

func (*AuthUserListResponse) Marshal ΒΆ

func (m *AuthUserListResponse) Marshal() (dAtA []byte, err error)

func (*AuthUserListResponse) MarshalTo ΒΆ

func (m *AuthUserListResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserListResponse) ProtoMessage ΒΆ

func (*AuthUserListResponse) ProtoMessage()

func (*AuthUserListResponse) Reset ΒΆ

func (m *AuthUserListResponse) Reset()

func (*AuthUserListResponse) Size ΒΆ

func (m *AuthUserListResponse) Size() (n int)

func (*AuthUserListResponse) String ΒΆ

func (m *AuthUserListResponse) String() string

func (*AuthUserListResponse) Unmarshal ΒΆ

func (m *AuthUserListResponse) Unmarshal(dAtA []byte) error

type AuthUserRevokeRoleRequest ΒΆ

type AuthUserRevokeRoleRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Role string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
}

func (*AuthUserRevokeRoleRequest) Descriptor ΒΆ

func (*AuthUserRevokeRoleRequest) Descriptor() ([]byte, []int)

func (*AuthUserRevokeRoleRequest) GetName ΒΆ

func (m *AuthUserRevokeRoleRequest) GetName() string

func (*AuthUserRevokeRoleRequest) GetRole ΒΆ

func (m *AuthUserRevokeRoleRequest) GetRole() string

func (*AuthUserRevokeRoleRequest) Marshal ΒΆ

func (m *AuthUserRevokeRoleRequest) Marshal() (dAtA []byte, err error)

func (*AuthUserRevokeRoleRequest) MarshalTo ΒΆ

func (m *AuthUserRevokeRoleRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserRevokeRoleRequest) ProtoMessage ΒΆ

func (*AuthUserRevokeRoleRequest) ProtoMessage()

func (*AuthUserRevokeRoleRequest) Reset ΒΆ

func (m *AuthUserRevokeRoleRequest) Reset()

func (*AuthUserRevokeRoleRequest) Size ΒΆ

func (m *AuthUserRevokeRoleRequest) Size() (n int)

func (*AuthUserRevokeRoleRequest) String ΒΆ

func (m *AuthUserRevokeRoleRequest) String() string

func (*AuthUserRevokeRoleRequest) Unmarshal ΒΆ

func (m *AuthUserRevokeRoleRequest) Unmarshal(dAtA []byte) error

type AuthUserRevokeRoleResponse ΒΆ

type AuthUserRevokeRoleResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*AuthUserRevokeRoleResponse) Descriptor ΒΆ

func (*AuthUserRevokeRoleResponse) Descriptor() ([]byte, []int)

func (*AuthUserRevokeRoleResponse) GetHeader ΒΆ

func (*AuthUserRevokeRoleResponse) Marshal ΒΆ

func (m *AuthUserRevokeRoleResponse) Marshal() (dAtA []byte, err error)

func (*AuthUserRevokeRoleResponse) MarshalTo ΒΆ

func (m *AuthUserRevokeRoleResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthUserRevokeRoleResponse) ProtoMessage ΒΆ

func (*AuthUserRevokeRoleResponse) ProtoMessage()

func (*AuthUserRevokeRoleResponse) Reset ΒΆ

func (m *AuthUserRevokeRoleResponse) Reset()

func (*AuthUserRevokeRoleResponse) Size ΒΆ

func (m *AuthUserRevokeRoleResponse) Size() (n int)

func (*AuthUserRevokeRoleResponse) String ΒΆ

func (m *AuthUserRevokeRoleResponse) String() string

func (*AuthUserRevokeRoleResponse) Unmarshal ΒΆ

func (m *AuthUserRevokeRoleResponse) Unmarshal(dAtA []byte) error

type AuthenticateRequest ΒΆ

type AuthenticateRequest struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
}

func (*AuthenticateRequest) Descriptor ΒΆ

func (*AuthenticateRequest) Descriptor() ([]byte, []int)

func (*AuthenticateRequest) GetName ΒΆ

func (m *AuthenticateRequest) GetName() string

func (*AuthenticateRequest) GetPassword ΒΆ

func (m *AuthenticateRequest) GetPassword() string

func (*AuthenticateRequest) Marshal ΒΆ

func (m *AuthenticateRequest) Marshal() (dAtA []byte, err error)

func (*AuthenticateRequest) MarshalTo ΒΆ

func (m *AuthenticateRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthenticateRequest) ProtoMessage ΒΆ

func (*AuthenticateRequest) ProtoMessage()

func (*AuthenticateRequest) Reset ΒΆ

func (m *AuthenticateRequest) Reset()

func (*AuthenticateRequest) Size ΒΆ

func (m *AuthenticateRequest) Size() (n int)

func (*AuthenticateRequest) String ΒΆ

func (m *AuthenticateRequest) String() string

func (*AuthenticateRequest) Unmarshal ΒΆ

func (m *AuthenticateRequest) Unmarshal(dAtA []byte) error

type AuthenticateResponse ΒΆ

type AuthenticateResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// token is an authorized token that can be used in succeeding RPCs
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
}

func (*AuthenticateResponse) Descriptor ΒΆ

func (*AuthenticateResponse) Descriptor() ([]byte, []int)

func (*AuthenticateResponse) GetHeader ΒΆ

func (m *AuthenticateResponse) GetHeader() *ResponseHeader

func (*AuthenticateResponse) GetToken ΒΆ

func (m *AuthenticateResponse) GetToken() string

func (*AuthenticateResponse) Marshal ΒΆ

func (m *AuthenticateResponse) Marshal() (dAtA []byte, err error)

func (*AuthenticateResponse) MarshalTo ΒΆ

func (m *AuthenticateResponse) MarshalTo(dAtA []byte) (int, error)

func (*AuthenticateResponse) ProtoMessage ΒΆ

func (*AuthenticateResponse) ProtoMessage()

func (*AuthenticateResponse) Reset ΒΆ

func (m *AuthenticateResponse) Reset()

func (*AuthenticateResponse) Size ΒΆ

func (m *AuthenticateResponse) Size() (n int)

func (*AuthenticateResponse) String ΒΆ

func (m *AuthenticateResponse) String() string

func (*AuthenticateResponse) Unmarshal ΒΆ

func (m *AuthenticateResponse) Unmarshal(dAtA []byte) error

type ClusterClient ΒΆ

type ClusterClient interface {
	// MemberAdd adds a member into the cluster.
	MemberAdd(ctx context.Context, in *MemberAddRequest, opts ...grpc.CallOption) (*MemberAddResponse, error)
	// MemberRemove removes an existing member from the cluster.
	MemberRemove(ctx context.Context, in *MemberRemoveRequest, opts ...grpc.CallOption) (*MemberRemoveResponse, error)
	// MemberUpdate updates the member configuration.
	MemberUpdate(ctx context.Context, in *MemberUpdateRequest, opts ...grpc.CallOption) (*MemberUpdateResponse, error)
	// MemberList lists all the members in the cluster.
	MemberList(ctx context.Context, in *MemberListRequest, opts ...grpc.CallOption) (*MemberListResponse, error)
	// MemberPromote promotes a member from raft learner (non-voting) to raft voting member.
	MemberPromote(ctx context.Context, in *MemberPromoteRequest, opts ...grpc.CallOption) (*MemberPromoteResponse, error)
}

func NewClusterClient ΒΆ

func NewClusterClient(cc *grpc.ClientConn) ClusterClient

type ClusterServer ΒΆ

type ClusterServer interface {
	// MemberAdd adds a member into the cluster.
	MemberAdd(context.Context, *MemberAddRequest) (*MemberAddResponse, error)
	// MemberRemove removes an existing member from the cluster.
	MemberRemove(context.Context, *MemberRemoveRequest) (*MemberRemoveResponse, error)
	// MemberUpdate updates the member configuration.
	MemberUpdate(context.Context, *MemberUpdateRequest) (*MemberUpdateResponse, error)
	// MemberList lists all the members in the cluster.
	MemberList(context.Context, *MemberListRequest) (*MemberListResponse, error)
	// MemberPromote promotes a member from raft learner (non-voting) to raft voting member.
	MemberPromote(context.Context, *MemberPromoteRequest) (*MemberPromoteResponse, error)
}

type CompactionRequest ΒΆ

type CompactionRequest struct {
	// revision is the key-value store revision for the compaction operation.
	Revision int64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	// physical is set so the RPC will wait until the compaction is physically
	// applied to the local database such that compacted entries are totally
	// removed from the backend database.
	Physical bool `protobuf:"varint,2,opt,name=physical,proto3" json:"physical,omitempty"`
}

CompactionRequest compacts the key-value store up to a given revision. All superseded keys with a revision less than the compaction revision will be removed.

func (*CompactionRequest) Descriptor ΒΆ

func (*CompactionRequest) Descriptor() ([]byte, []int)

func (*CompactionRequest) GetPhysical ΒΆ

func (m *CompactionRequest) GetPhysical() bool

func (*CompactionRequest) GetRevision ΒΆ

func (m *CompactionRequest) GetRevision() int64

func (*CompactionRequest) Marshal ΒΆ

func (m *CompactionRequest) Marshal() (dAtA []byte, err error)

func (*CompactionRequest) MarshalTo ΒΆ

func (m *CompactionRequest) MarshalTo(dAtA []byte) (int, error)

func (*CompactionRequest) ProtoMessage ΒΆ

func (*CompactionRequest) ProtoMessage()

func (*CompactionRequest) Reset ΒΆ

func (m *CompactionRequest) Reset()

func (*CompactionRequest) Size ΒΆ

func (m *CompactionRequest) Size() (n int)

func (*CompactionRequest) String ΒΆ

func (m *CompactionRequest) String() string

func (*CompactionRequest) Unmarshal ΒΆ

func (m *CompactionRequest) Unmarshal(dAtA []byte) error

type CompactionResponse ΒΆ

type CompactionResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*CompactionResponse) Descriptor ΒΆ

func (*CompactionResponse) Descriptor() ([]byte, []int)

func (*CompactionResponse) GetHeader ΒΆ

func (m *CompactionResponse) GetHeader() *ResponseHeader

func (*CompactionResponse) Marshal ΒΆ

func (m *CompactionResponse) Marshal() (dAtA []byte, err error)

func (*CompactionResponse) MarshalTo ΒΆ

func (m *CompactionResponse) MarshalTo(dAtA []byte) (int, error)

func (*CompactionResponse) ProtoMessage ΒΆ

func (*CompactionResponse) ProtoMessage()

func (*CompactionResponse) Reset ΒΆ

func (m *CompactionResponse) Reset()

func (*CompactionResponse) Size ΒΆ

func (m *CompactionResponse) Size() (n int)

func (*CompactionResponse) String ΒΆ

func (m *CompactionResponse) String() string

func (*CompactionResponse) Unmarshal ΒΆ

func (m *CompactionResponse) Unmarshal(dAtA []byte) error

type Compare ΒΆ

type Compare struct {
	// result is logical comparison operation for this comparison.
	Result Compare_CompareResult `protobuf:"varint,1,opt,name=result,proto3,enum=etcdserverpb.Compare_CompareResult" json:"result,omitempty"`
	// target is the key-value field to inspect for the comparison.
	Target Compare_CompareTarget `protobuf:"varint,2,opt,name=target,proto3,enum=etcdserverpb.Compare_CompareTarget" json:"target,omitempty"`
	// key is the subject key for the comparison operation.
	Key []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are valid to be assigned to TargetUnion:
	//	*Compare_Version
	//	*Compare_CreateRevision
	//	*Compare_ModRevision
	//	*Compare_Value
	//	*Compare_Lease
	TargetUnion isCompare_TargetUnion `protobuf_oneof:"target_union"`
	// range_end compares the given target to all keys in the range [key, range_end).
	// See RangeRequest for more details on key ranges.
	RangeEnd []byte `protobuf:"bytes,64,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
}

func (*Compare) Descriptor ΒΆ

func (*Compare) Descriptor() ([]byte, []int)

func (*Compare) GetCreateRevision ΒΆ

func (m *Compare) GetCreateRevision() int64

func (*Compare) GetKey ΒΆ

func (m *Compare) GetKey() []byte

func (*Compare) GetLease ΒΆ

func (m *Compare) GetLease() int64

func (*Compare) GetModRevision ΒΆ

func (m *Compare) GetModRevision() int64

func (*Compare) GetRangeEnd ΒΆ

func (m *Compare) GetRangeEnd() []byte

func (*Compare) GetResult ΒΆ

func (m *Compare) GetResult() Compare_CompareResult

func (*Compare) GetTarget ΒΆ

func (m *Compare) GetTarget() Compare_CompareTarget

func (*Compare) GetTargetUnion ΒΆ

func (m *Compare) GetTargetUnion() isCompare_TargetUnion

func (*Compare) GetValue ΒΆ

func (m *Compare) GetValue() []byte

func (*Compare) GetVersion ΒΆ

func (m *Compare) GetVersion() int64

func (*Compare) Marshal ΒΆ

func (m *Compare) Marshal() (dAtA []byte, err error)

func (*Compare) MarshalTo ΒΆ

func (m *Compare) MarshalTo(dAtA []byte) (int, error)

func (*Compare) ProtoMessage ΒΆ

func (*Compare) ProtoMessage()

func (*Compare) Reset ΒΆ

func (m *Compare) Reset()

func (*Compare) Size ΒΆ

func (m *Compare) Size() (n int)

func (*Compare) String ΒΆ

func (m *Compare) String() string

func (*Compare) Unmarshal ΒΆ

func (m *Compare) Unmarshal(dAtA []byte) error

func (*Compare) XXX_OneofFuncs ΒΆ

func (*Compare) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Compare_CompareResult ΒΆ

type Compare_CompareResult int32
const (
	Compare_EQUAL     Compare_CompareResult = 0
	Compare_GREATER   Compare_CompareResult = 1
	Compare_LESS      Compare_CompareResult = 2
	Compare_NOT_EQUAL Compare_CompareResult = 3
)

func (Compare_CompareResult) EnumDescriptor ΒΆ

func (Compare_CompareResult) EnumDescriptor() ([]byte, []int)

func (Compare_CompareResult) String ΒΆ

func (x Compare_CompareResult) String() string

type Compare_CompareTarget ΒΆ

type Compare_CompareTarget int32
const (
	Compare_VERSION Compare_CompareTarget = 0
	Compare_CREATE  Compare_CompareTarget = 1
	Compare_MOD     Compare_CompareTarget = 2
	Compare_VALUE   Compare_CompareTarget = 3
	Compare_LEASE   Compare_CompareTarget = 4
)

func (Compare_CompareTarget) EnumDescriptor ΒΆ

func (Compare_CompareTarget) EnumDescriptor() ([]byte, []int)

func (Compare_CompareTarget) String ΒΆ

func (x Compare_CompareTarget) String() string

type Compare_CreateRevision ΒΆ

type Compare_CreateRevision struct {
	CreateRevision int64 `protobuf:"varint,5,opt,name=create_revision,json=createRevision,proto3,oneof"`
}

func (*Compare_CreateRevision) MarshalTo ΒΆ

func (m *Compare_CreateRevision) MarshalTo(dAtA []byte) (int, error)

func (*Compare_CreateRevision) Size ΒΆ

func (m *Compare_CreateRevision) Size() (n int)

type Compare_Lease ΒΆ

type Compare_Lease struct {
	Lease int64 `protobuf:"varint,8,opt,name=lease,proto3,oneof"`
}

func (*Compare_Lease) MarshalTo ΒΆ

func (m *Compare_Lease) MarshalTo(dAtA []byte) (int, error)

func (*Compare_Lease) Size ΒΆ

func (m *Compare_Lease) Size() (n int)

type Compare_ModRevision ΒΆ

type Compare_ModRevision struct {
	ModRevision int64 `protobuf:"varint,6,opt,name=mod_revision,json=modRevision,proto3,oneof"`
}

func (*Compare_ModRevision) MarshalTo ΒΆ

func (m *Compare_ModRevision) MarshalTo(dAtA []byte) (int, error)

func (*Compare_ModRevision) Size ΒΆ

func (m *Compare_ModRevision) Size() (n int)

type Compare_Value ΒΆ

type Compare_Value struct {
	Value []byte `protobuf:"bytes,7,opt,name=value,proto3,oneof"`
}

func (*Compare_Value) MarshalTo ΒΆ

func (m *Compare_Value) MarshalTo(dAtA []byte) (int, error)

func (*Compare_Value) Size ΒΆ

func (m *Compare_Value) Size() (n int)

type Compare_Version ΒΆ

type Compare_Version struct {
	Version int64 `protobuf:"varint,4,opt,name=version,proto3,oneof"`
}

func (*Compare_Version) MarshalTo ΒΆ

func (m *Compare_Version) MarshalTo(dAtA []byte) (int, error)

func (*Compare_Version) Size ΒΆ

func (m *Compare_Version) Size() (n int)

type DefragmentRequest ΒΆ

type DefragmentRequest struct {
}

func (*DefragmentRequest) Descriptor ΒΆ

func (*DefragmentRequest) Descriptor() ([]byte, []int)

func (*DefragmentRequest) Marshal ΒΆ

func (m *DefragmentRequest) Marshal() (dAtA []byte, err error)

func (*DefragmentRequest) MarshalTo ΒΆ

func (m *DefragmentRequest) MarshalTo(dAtA []byte) (int, error)

func (*DefragmentRequest) ProtoMessage ΒΆ

func (*DefragmentRequest) ProtoMessage()

func (*DefragmentRequest) Reset ΒΆ

func (m *DefragmentRequest) Reset()

func (*DefragmentRequest) Size ΒΆ

func (m *DefragmentRequest) Size() (n int)

func (*DefragmentRequest) String ΒΆ

func (m *DefragmentRequest) String() string

func (*DefragmentRequest) Unmarshal ΒΆ

func (m *DefragmentRequest) Unmarshal(dAtA []byte) error

type DefragmentResponse ΒΆ

type DefragmentResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*DefragmentResponse) Descriptor ΒΆ

func (*DefragmentResponse) Descriptor() ([]byte, []int)

func (*DefragmentResponse) GetHeader ΒΆ

func (m *DefragmentResponse) GetHeader() *ResponseHeader

func (*DefragmentResponse) Marshal ΒΆ

func (m *DefragmentResponse) Marshal() (dAtA []byte, err error)

func (*DefragmentResponse) MarshalTo ΒΆ

func (m *DefragmentResponse) MarshalTo(dAtA []byte) (int, error)

func (*DefragmentResponse) ProtoMessage ΒΆ

func (*DefragmentResponse) ProtoMessage()

func (*DefragmentResponse) Reset ΒΆ

func (m *DefragmentResponse) Reset()

func (*DefragmentResponse) Size ΒΆ

func (m *DefragmentResponse) Size() (n int)

func (*DefragmentResponse) String ΒΆ

func (m *DefragmentResponse) String() string

func (*DefragmentResponse) Unmarshal ΒΆ

func (m *DefragmentResponse) Unmarshal(dAtA []byte) error

type DeleteRangeRequest ΒΆ

type DeleteRangeRequest struct {
	// key is the first key to delete in the range.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// range_end is the key following the last key to delete for the range [key, range_end).
	// If range_end is not given, the range is defined to contain only the key argument.
	// If range_end is one bit larger than the given key, then the range is all the keys
	// with the prefix (the given key).
	// If range_end is '\0', the range is all keys greater than or equal to the key argument.
	RangeEnd []byte `protobuf:"bytes,2,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	// If prev_kv is set, etcd gets the previous key-value pairs before deleting it.
	// The previous key-value pairs will be returned in the delete response.
	PrevKv bool `protobuf:"varint,3,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
}

func (*DeleteRangeRequest) Descriptor ΒΆ

func (*DeleteRangeRequest) Descriptor() ([]byte, []int)

func (*DeleteRangeRequest) GetKey ΒΆ

func (m *DeleteRangeRequest) GetKey() []byte

func (*DeleteRangeRequest) GetPrevKv ΒΆ

func (m *DeleteRangeRequest) GetPrevKv() bool

func (*DeleteRangeRequest) GetRangeEnd ΒΆ

func (m *DeleteRangeRequest) GetRangeEnd() []byte

func (*DeleteRangeRequest) Marshal ΒΆ

func (m *DeleteRangeRequest) Marshal() (dAtA []byte, err error)

func (*DeleteRangeRequest) MarshalTo ΒΆ

func (m *DeleteRangeRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteRangeRequest) ProtoMessage ΒΆ

func (*DeleteRangeRequest) ProtoMessage()

func (*DeleteRangeRequest) Reset ΒΆ

func (m *DeleteRangeRequest) Reset()

func (*DeleteRangeRequest) Size ΒΆ

func (m *DeleteRangeRequest) Size() (n int)

func (*DeleteRangeRequest) String ΒΆ

func (m *DeleteRangeRequest) String() string

func (*DeleteRangeRequest) Unmarshal ΒΆ

func (m *DeleteRangeRequest) Unmarshal(dAtA []byte) error

type DeleteRangeResponse ΒΆ

type DeleteRangeResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// deleted is the number of keys deleted by the delete range request.
	Deleted int64 `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// if prev_kv is set in the request, the previous key-value pairs will be returned.
	PrevKvs []*mvccpb.KeyValue `protobuf:"bytes,3,rep,name=prev_kvs,json=prevKvs" json:"prev_kvs,omitempty"`
}

func (*DeleteRangeResponse) Descriptor ΒΆ

func (*DeleteRangeResponse) Descriptor() ([]byte, []int)

func (*DeleteRangeResponse) GetDeleted ΒΆ

func (m *DeleteRangeResponse) GetDeleted() int64

func (*DeleteRangeResponse) GetHeader ΒΆ

func (m *DeleteRangeResponse) GetHeader() *ResponseHeader

func (*DeleteRangeResponse) GetPrevKvs ΒΆ

func (m *DeleteRangeResponse) GetPrevKvs() []*mvccpb.KeyValue

func (*DeleteRangeResponse) Marshal ΒΆ

func (m *DeleteRangeResponse) Marshal() (dAtA []byte, err error)

func (*DeleteRangeResponse) MarshalTo ΒΆ

func (m *DeleteRangeResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeleteRangeResponse) ProtoMessage ΒΆ

func (*DeleteRangeResponse) ProtoMessage()

func (*DeleteRangeResponse) Reset ΒΆ

func (m *DeleteRangeResponse) Reset()

func (*DeleteRangeResponse) Size ΒΆ

func (m *DeleteRangeResponse) Size() (n int)

func (*DeleteRangeResponse) String ΒΆ

func (m *DeleteRangeResponse) String() string

func (*DeleteRangeResponse) Unmarshal ΒΆ

func (m *DeleteRangeResponse) Unmarshal(dAtA []byte) error

type EmptyResponse ΒΆ

type EmptyResponse struct {
}

func (*EmptyResponse) Descriptor ΒΆ

func (*EmptyResponse) Descriptor() ([]byte, []int)

func (*EmptyResponse) Marshal ΒΆ

func (m *EmptyResponse) Marshal() (dAtA []byte, err error)

func (*EmptyResponse) MarshalTo ΒΆ

func (m *EmptyResponse) MarshalTo(dAtA []byte) (int, error)

func (*EmptyResponse) ProtoMessage ΒΆ

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset ΒΆ

func (m *EmptyResponse) Reset()

func (*EmptyResponse) Size ΒΆ

func (m *EmptyResponse) Size() (n int)

func (*EmptyResponse) String ΒΆ

func (m *EmptyResponse) String() string

func (*EmptyResponse) Unmarshal ΒΆ

func (m *EmptyResponse) Unmarshal(dAtA []byte) error

type HashKVRequest ΒΆ

type HashKVRequest struct {
	// revision is the key-value store revision for the hash operation.
	Revision int64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
}

func (*HashKVRequest) Descriptor ΒΆ

func (*HashKVRequest) Descriptor() ([]byte, []int)

func (*HashKVRequest) GetRevision ΒΆ

func (m *HashKVRequest) GetRevision() int64

func (*HashKVRequest) Marshal ΒΆ

func (m *HashKVRequest) Marshal() (dAtA []byte, err error)

func (*HashKVRequest) MarshalTo ΒΆ

func (m *HashKVRequest) MarshalTo(dAtA []byte) (int, error)

func (*HashKVRequest) ProtoMessage ΒΆ

func (*HashKVRequest) ProtoMessage()

func (*HashKVRequest) Reset ΒΆ

func (m *HashKVRequest) Reset()

func (*HashKVRequest) Size ΒΆ

func (m *HashKVRequest) Size() (n int)

func (*HashKVRequest) String ΒΆ

func (m *HashKVRequest) String() string

func (*HashKVRequest) Unmarshal ΒΆ

func (m *HashKVRequest) Unmarshal(dAtA []byte) error

type HashKVResponse ΒΆ

type HashKVResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// hash is the hash value computed from the responding member's MVCC keys up to a given revision.
	Hash uint32 `protobuf:"varint,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// compact_revision is the compacted revision of key-value store when hash begins.
	CompactRevision int64 `protobuf:"varint,3,opt,name=compact_revision,json=compactRevision,proto3" json:"compact_revision,omitempty"`
}

func (*HashKVResponse) Descriptor ΒΆ

func (*HashKVResponse) Descriptor() ([]byte, []int)

func (*HashKVResponse) GetCompactRevision ΒΆ

func (m *HashKVResponse) GetCompactRevision() int64

func (*HashKVResponse) GetHash ΒΆ

func (m *HashKVResponse) GetHash() uint32

func (*HashKVResponse) GetHeader ΒΆ

func (m *HashKVResponse) GetHeader() *ResponseHeader

func (*HashKVResponse) Marshal ΒΆ

func (m *HashKVResponse) Marshal() (dAtA []byte, err error)

func (*HashKVResponse) MarshalTo ΒΆ

func (m *HashKVResponse) MarshalTo(dAtA []byte) (int, error)

func (*HashKVResponse) ProtoMessage ΒΆ

func (*HashKVResponse) ProtoMessage()

func (*HashKVResponse) Reset ΒΆ

func (m *HashKVResponse) Reset()

func (*HashKVResponse) Size ΒΆ

func (m *HashKVResponse) Size() (n int)

func (*HashKVResponse) String ΒΆ

func (m *HashKVResponse) String() string

func (*HashKVResponse) Unmarshal ΒΆ

func (m *HashKVResponse) Unmarshal(dAtA []byte) error

type HashRequest ΒΆ

type HashRequest struct {
}

func (*HashRequest) Descriptor ΒΆ

func (*HashRequest) Descriptor() ([]byte, []int)

func (*HashRequest) Marshal ΒΆ

func (m *HashRequest) Marshal() (dAtA []byte, err error)

func (*HashRequest) MarshalTo ΒΆ

func (m *HashRequest) MarshalTo(dAtA []byte) (int, error)

func (*HashRequest) ProtoMessage ΒΆ

func (*HashRequest) ProtoMessage()

func (*HashRequest) Reset ΒΆ

func (m *HashRequest) Reset()

func (*HashRequest) Size ΒΆ

func (m *HashRequest) Size() (n int)

func (*HashRequest) String ΒΆ

func (m *HashRequest) String() string

func (*HashRequest) Unmarshal ΒΆ

func (m *HashRequest) Unmarshal(dAtA []byte) error

type HashResponse ΒΆ

type HashResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// hash is the hash value computed from the responding member's KV's backend.
	Hash uint32 `protobuf:"varint,2,opt,name=hash,proto3" json:"hash,omitempty"`
}

func (*HashResponse) Descriptor ΒΆ

func (*HashResponse) Descriptor() ([]byte, []int)

func (*HashResponse) GetHash ΒΆ

func (m *HashResponse) GetHash() uint32

func (*HashResponse) GetHeader ΒΆ

func (m *HashResponse) GetHeader() *ResponseHeader

func (*HashResponse) Marshal ΒΆ

func (m *HashResponse) Marshal() (dAtA []byte, err error)

func (*HashResponse) MarshalTo ΒΆ

func (m *HashResponse) MarshalTo(dAtA []byte) (int, error)

func (*HashResponse) ProtoMessage ΒΆ

func (*HashResponse) ProtoMessage()

func (*HashResponse) Reset ΒΆ

func (m *HashResponse) Reset()

func (*HashResponse) Size ΒΆ

func (m *HashResponse) Size() (n int)

func (*HashResponse) String ΒΆ

func (m *HashResponse) String() string

func (*HashResponse) Unmarshal ΒΆ

func (m *HashResponse) Unmarshal(dAtA []byte) error

type InternalAuthenticateRequest ΒΆ

type InternalAuthenticateRequest struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// simple_token is generated in API layer (etcdserver/v3_server.go)
	SimpleToken string `protobuf:"bytes,3,opt,name=simple_token,json=simpleToken,proto3" json:"simple_token,omitempty"`
}

What is the difference between AuthenticateRequest (defined in rpc.proto) and InternalAuthenticateRequest? InternalAuthenticateRequest has a member that is filled by etcdserver and shouldn't be user-facing. For avoiding misusage the field, we have an internal version of AuthenticateRequest.

func (*InternalAuthenticateRequest) Descriptor ΒΆ

func (*InternalAuthenticateRequest) Descriptor() ([]byte, []int)

func (*InternalAuthenticateRequest) Marshal ΒΆ

func (m *InternalAuthenticateRequest) Marshal() (dAtA []byte, err error)

func (*InternalAuthenticateRequest) MarshalTo ΒΆ

func (m *InternalAuthenticateRequest) MarshalTo(dAtA []byte) (int, error)

func (*InternalAuthenticateRequest) ProtoMessage ΒΆ

func (*InternalAuthenticateRequest) ProtoMessage()

func (*InternalAuthenticateRequest) Reset ΒΆ

func (m *InternalAuthenticateRequest) Reset()

func (*InternalAuthenticateRequest) Size ΒΆ

func (m *InternalAuthenticateRequest) Size() (n int)

func (*InternalAuthenticateRequest) String ΒΆ

func (m *InternalAuthenticateRequest) String() string

func (*InternalAuthenticateRequest) Unmarshal ΒΆ

func (m *InternalAuthenticateRequest) Unmarshal(dAtA []byte) error

type InternalRaftRequest ΒΆ

type InternalRaftRequest struct {
	Header                   *RequestHeader                   `protobuf:"bytes,100,opt,name=header" json:"header,omitempty"`
	ID                       uint64                           `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	V2                       *Request                         `protobuf:"bytes,2,opt,name=v2" json:"v2,omitempty"`
	Range                    *RangeRequest                    `protobuf:"bytes,3,opt,name=range" json:"range,omitempty"`
	Put                      *PutRequest                      `protobuf:"bytes,4,opt,name=put" json:"put,omitempty"`
	DeleteRange              *DeleteRangeRequest              `protobuf:"bytes,5,opt,name=delete_range,json=deleteRange" json:"delete_range,omitempty"`
	Txn                      *TxnRequest                      `protobuf:"bytes,6,opt,name=txn" json:"txn,omitempty"`
	Compaction               *CompactionRequest               `protobuf:"bytes,7,opt,name=compaction" json:"compaction,omitempty"`
	LeaseGrant               *LeaseGrantRequest               `protobuf:"bytes,8,opt,name=lease_grant,json=leaseGrant" json:"lease_grant,omitempty"`
	LeaseRevoke              *LeaseRevokeRequest              `protobuf:"bytes,9,opt,name=lease_revoke,json=leaseRevoke" json:"lease_revoke,omitempty"`
	Alarm                    *AlarmRequest                    `protobuf:"bytes,10,opt,name=alarm" json:"alarm,omitempty"`
	LeaseCheckpoint          *LeaseCheckpointRequest          `protobuf:"bytes,11,opt,name=lease_checkpoint,json=leaseCheckpoint" json:"lease_checkpoint,omitempty"`
	AuthEnable               *AuthEnableRequest               `protobuf:"bytes,1000,opt,name=auth_enable,json=authEnable" json:"auth_enable,omitempty"`
	AuthDisable              *AuthDisableRequest              `protobuf:"bytes,1011,opt,name=auth_disable,json=authDisable" json:"auth_disable,omitempty"`
	Authenticate             *InternalAuthenticateRequest     `protobuf:"bytes,1012,opt,name=authenticate" json:"authenticate,omitempty"`
	AuthUserAdd              *AuthUserAddRequest              `protobuf:"bytes,1100,opt,name=auth_user_add,json=authUserAdd" json:"auth_user_add,omitempty"`
	AuthUserDelete           *AuthUserDeleteRequest           `protobuf:"bytes,1101,opt,name=auth_user_delete,json=authUserDelete" json:"auth_user_delete,omitempty"`
	AuthUserGet              *AuthUserGetRequest              `protobuf:"bytes,1102,opt,name=auth_user_get,json=authUserGet" json:"auth_user_get,omitempty"`
	AuthUserChangePassword   *AuthUserChangePasswordRequest   `` /* 127-byte string literal not displayed */
	AuthUserGrantRole        *AuthUserGrantRoleRequest        `protobuf:"bytes,1104,opt,name=auth_user_grant_role,json=authUserGrantRole" json:"auth_user_grant_role,omitempty"`
	AuthUserRevokeRole       *AuthUserRevokeRoleRequest       `protobuf:"bytes,1105,opt,name=auth_user_revoke_role,json=authUserRevokeRole" json:"auth_user_revoke_role,omitempty"`
	AuthUserList             *AuthUserListRequest             `protobuf:"bytes,1106,opt,name=auth_user_list,json=authUserList" json:"auth_user_list,omitempty"`
	AuthRoleList             *AuthRoleListRequest             `protobuf:"bytes,1107,opt,name=auth_role_list,json=authRoleList" json:"auth_role_list,omitempty"`
	AuthRoleAdd              *AuthRoleAddRequest              `protobuf:"bytes,1200,opt,name=auth_role_add,json=authRoleAdd" json:"auth_role_add,omitempty"`
	AuthRoleDelete           *AuthRoleDeleteRequest           `protobuf:"bytes,1201,opt,name=auth_role_delete,json=authRoleDelete" json:"auth_role_delete,omitempty"`
	AuthRoleGet              *AuthRoleGetRequest              `protobuf:"bytes,1202,opt,name=auth_role_get,json=authRoleGet" json:"auth_role_get,omitempty"`
	AuthRoleGrantPermission  *AuthRoleGrantPermissionRequest  `` /* 130-byte string literal not displayed */
	AuthRoleRevokePermission *AuthRoleRevokePermissionRequest `` /* 133-byte string literal not displayed */
}

An InternalRaftRequest is the union of all requests which can be sent via raft.

func (*InternalRaftRequest) Descriptor ΒΆ

func (*InternalRaftRequest) Descriptor() ([]byte, []int)

func (*InternalRaftRequest) Marshal ΒΆ

func (m *InternalRaftRequest) Marshal() (dAtA []byte, err error)

func (*InternalRaftRequest) MarshalTo ΒΆ

func (m *InternalRaftRequest) MarshalTo(dAtA []byte) (int, error)

func (*InternalRaftRequest) ProtoMessage ΒΆ

func (*InternalRaftRequest) ProtoMessage()

func (*InternalRaftRequest) Reset ΒΆ

func (m *InternalRaftRequest) Reset()

func (*InternalRaftRequest) Size ΒΆ

func (m *InternalRaftRequest) Size() (n int)

func (*InternalRaftRequest) String ΒΆ

func (m *InternalRaftRequest) String() string

func (*InternalRaftRequest) Unmarshal ΒΆ

func (m *InternalRaftRequest) Unmarshal(dAtA []byte) error

type InternalRaftStringer ΒΆ

type InternalRaftStringer struct {
	Request *InternalRaftRequest
}

InternalRaftStringer implements custom proto Stringer: redact password, replace value fields with value_size fields.

func (*InternalRaftStringer) String ΒΆ

func (as *InternalRaftStringer) String() string

type KVClient ΒΆ

type KVClient interface {
	// Range gets the keys in the range from the key-value store.
	Range(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error)
	// Put puts the given key into the key-value store.
	// A put request increments the revision of the key-value store
	// and generates one event in the event history.
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	// DeleteRange deletes the given range from the key-value store.
	// A delete request increments the revision of the key-value store
	// and generates a delete event in the event history for every deleted key.
	DeleteRange(ctx context.Context, in *DeleteRangeRequest, opts ...grpc.CallOption) (*DeleteRangeResponse, error)
	// Txn processes multiple requests in a single transaction.
	// A txn request increments the revision of the key-value store
	// and generates events with the same revision for every completed request.
	// It is not allowed to modify the same key several times within one txn.
	Txn(ctx context.Context, in *TxnRequest, opts ...grpc.CallOption) (*TxnResponse, error)
	// Compact compacts the event history in the etcd key-value store. The key-value
	// store should be periodically compacted or the event history will continue to grow
	// indefinitely.
	Compact(ctx context.Context, in *CompactionRequest, opts ...grpc.CallOption) (*CompactionResponse, error)
}

func NewKVClient ΒΆ

func NewKVClient(cc *grpc.ClientConn) KVClient

type KVServer ΒΆ

type KVServer interface {
	// Range gets the keys in the range from the key-value store.
	Range(context.Context, *RangeRequest) (*RangeResponse, error)
	// Put puts the given key into the key-value store.
	// A put request increments the revision of the key-value store
	// and generates one event in the event history.
	Put(context.Context, *PutRequest) (*PutResponse, error)
	// DeleteRange deletes the given range from the key-value store.
	// A delete request increments the revision of the key-value store
	// and generates a delete event in the event history for every deleted key.
	DeleteRange(context.Context, *DeleteRangeRequest) (*DeleteRangeResponse, error)
	// Txn processes multiple requests in a single transaction.
	// A txn request increments the revision of the key-value store
	// and generates events with the same revision for every completed request.
	// It is not allowed to modify the same key several times within one txn.
	Txn(context.Context, *TxnRequest) (*TxnResponse, error)
	// Compact compacts the event history in the etcd key-value store. The key-value
	// store should be periodically compacted or the event history will continue to grow
	// indefinitely.
	Compact(context.Context, *CompactionRequest) (*CompactionResponse, error)
}

type LeaseCheckpoint ΒΆ

type LeaseCheckpoint struct {
	// ID is the lease ID to checkpoint.
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// Remaining_TTL is the remaining time until expiry of the lease.
	Remaining_TTL int64 `protobuf:"varint,2,opt,name=remaining_TTL,json=remainingTTL,proto3" json:"remaining_TTL,omitempty"`
}

func (*LeaseCheckpoint) Descriptor ΒΆ

func (*LeaseCheckpoint) Descriptor() ([]byte, []int)

func (*LeaseCheckpoint) GetID ΒΆ

func (m *LeaseCheckpoint) GetID() int64

func (*LeaseCheckpoint) GetRemaining_TTL ΒΆ

func (m *LeaseCheckpoint) GetRemaining_TTL() int64

func (*LeaseCheckpoint) Marshal ΒΆ

func (m *LeaseCheckpoint) Marshal() (dAtA []byte, err error)

func (*LeaseCheckpoint) MarshalTo ΒΆ

func (m *LeaseCheckpoint) MarshalTo(dAtA []byte) (int, error)

func (*LeaseCheckpoint) ProtoMessage ΒΆ

func (*LeaseCheckpoint) ProtoMessage()

func (*LeaseCheckpoint) Reset ΒΆ

func (m *LeaseCheckpoint) Reset()

func (*LeaseCheckpoint) Size ΒΆ

func (m *LeaseCheckpoint) Size() (n int)

func (*LeaseCheckpoint) String ΒΆ

func (m *LeaseCheckpoint) String() string

func (*LeaseCheckpoint) Unmarshal ΒΆ

func (m *LeaseCheckpoint) Unmarshal(dAtA []byte) error

type LeaseCheckpointRequest ΒΆ

type LeaseCheckpointRequest struct {
	Checkpoints []*LeaseCheckpoint `protobuf:"bytes,1,rep,name=checkpoints" json:"checkpoints,omitempty"`
}

func (*LeaseCheckpointRequest) Descriptor ΒΆ

func (*LeaseCheckpointRequest) Descriptor() ([]byte, []int)

func (*LeaseCheckpointRequest) GetCheckpoints ΒΆ

func (m *LeaseCheckpointRequest) GetCheckpoints() []*LeaseCheckpoint

func (*LeaseCheckpointRequest) Marshal ΒΆ

func (m *LeaseCheckpointRequest) Marshal() (dAtA []byte, err error)

func (*LeaseCheckpointRequest) MarshalTo ΒΆ

func (m *LeaseCheckpointRequest) MarshalTo(dAtA []byte) (int, error)

func (*LeaseCheckpointRequest) ProtoMessage ΒΆ

func (*LeaseCheckpointRequest) ProtoMessage()

func (*LeaseCheckpointRequest) Reset ΒΆ

func (m *LeaseCheckpointRequest) Reset()

func (*LeaseCheckpointRequest) Size ΒΆ

func (m *LeaseCheckpointRequest) Size() (n int)

func (*LeaseCheckpointRequest) String ΒΆ

func (m *LeaseCheckpointRequest) String() string

func (*LeaseCheckpointRequest) Unmarshal ΒΆ

func (m *LeaseCheckpointRequest) Unmarshal(dAtA []byte) error

type LeaseCheckpointResponse ΒΆ

type LeaseCheckpointResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*LeaseCheckpointResponse) Descriptor ΒΆ

func (*LeaseCheckpointResponse) Descriptor() ([]byte, []int)

func (*LeaseCheckpointResponse) GetHeader ΒΆ

func (m *LeaseCheckpointResponse) GetHeader() *ResponseHeader

func (*LeaseCheckpointResponse) Marshal ΒΆ

func (m *LeaseCheckpointResponse) Marshal() (dAtA []byte, err error)

func (*LeaseCheckpointResponse) MarshalTo ΒΆ

func (m *LeaseCheckpointResponse) MarshalTo(dAtA []byte) (int, error)

func (*LeaseCheckpointResponse) ProtoMessage ΒΆ

func (*LeaseCheckpointResponse) ProtoMessage()

func (*LeaseCheckpointResponse) Reset ΒΆ

func (m *LeaseCheckpointResponse) Reset()

func (*LeaseCheckpointResponse) Size ΒΆ

func (m *LeaseCheckpointResponse) Size() (n int)

func (*LeaseCheckpointResponse) String ΒΆ

func (m *LeaseCheckpointResponse) String() string

func (*LeaseCheckpointResponse) Unmarshal ΒΆ

func (m *LeaseCheckpointResponse) Unmarshal(dAtA []byte) error

type LeaseClient ΒΆ

type LeaseClient interface {
	// LeaseGrant creates a lease which expires if the server does not receive a keepAlive
	// within a given time to live period. All keys attached to the lease will be expired and
	// deleted if the lease expires. Each expired key generates a delete event in the event history.
	LeaseGrant(ctx context.Context, in *LeaseGrantRequest, opts ...grpc.CallOption) (*LeaseGrantResponse, error)
	// LeaseRevoke revokes a lease. All keys attached to the lease will expire and be deleted.
	LeaseRevoke(ctx context.Context, in *LeaseRevokeRequest, opts ...grpc.CallOption) (*LeaseRevokeResponse, error)
	// LeaseKeepAlive keeps the lease alive by streaming keep alive requests from the client
	// to the server and streaming keep alive responses from the server to the client.
	LeaseKeepAlive(ctx context.Context, opts ...grpc.CallOption) (Lease_LeaseKeepAliveClient, error)
	// LeaseTimeToLive retrieves lease information.
	LeaseTimeToLive(ctx context.Context, in *LeaseTimeToLiveRequest, opts ...grpc.CallOption) (*LeaseTimeToLiveResponse, error)
	// LeaseLeases lists all existing leases.
	LeaseLeases(ctx context.Context, in *LeaseLeasesRequest, opts ...grpc.CallOption) (*LeaseLeasesResponse, error)
}

func NewLeaseClient ΒΆ

func NewLeaseClient(cc *grpc.ClientConn) LeaseClient

type LeaseGrantRequest ΒΆ

type LeaseGrantRequest struct {
	// TTL is the advisory time-to-live in seconds. Expired lease will return -1.
	TTL int64 `protobuf:"varint,1,opt,name=TTL,proto3" json:"TTL,omitempty"`
	// ID is the requested ID for the lease. If ID is set to 0, the lessor chooses an ID.
	ID int64 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
}

func (*LeaseGrantRequest) Descriptor ΒΆ

func (*LeaseGrantRequest) Descriptor() ([]byte, []int)

func (*LeaseGrantRequest) GetID ΒΆ

func (m *LeaseGrantRequest) GetID() int64

func (*LeaseGrantRequest) GetTTL ΒΆ

func (m *LeaseGrantRequest) GetTTL() int64

func (*LeaseGrantRequest) Marshal ΒΆ

func (m *LeaseGrantRequest) Marshal() (dAtA []byte, err error)

func (*LeaseGrantRequest) MarshalTo ΒΆ

func (m *LeaseGrantRequest) MarshalTo(dAtA []byte) (int, error)

func (*LeaseGrantRequest) ProtoMessage ΒΆ

func (*LeaseGrantRequest) ProtoMessage()

func (*LeaseGrantRequest) Reset ΒΆ

func (m *LeaseGrantRequest) Reset()

func (*LeaseGrantRequest) Size ΒΆ

func (m *LeaseGrantRequest) Size() (n int)

func (*LeaseGrantRequest) String ΒΆ

func (m *LeaseGrantRequest) String() string

func (*LeaseGrantRequest) Unmarshal ΒΆ

func (m *LeaseGrantRequest) Unmarshal(dAtA []byte) error

type LeaseGrantResponse ΒΆ

type LeaseGrantResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// ID is the lease ID for the granted lease.
	ID int64 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
	// TTL is the server chosen lease time-to-live in seconds.
	TTL   int64  `protobuf:"varint,3,opt,name=TTL,proto3" json:"TTL,omitempty"`
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
}

func (*LeaseGrantResponse) Descriptor ΒΆ

func (*LeaseGrantResponse) Descriptor() ([]byte, []int)

func (*LeaseGrantResponse) GetError ΒΆ

func (m *LeaseGrantResponse) GetError() string

func (*LeaseGrantResponse) GetHeader ΒΆ

func (m *LeaseGrantResponse) GetHeader() *ResponseHeader

func (*LeaseGrantResponse) GetID ΒΆ

func (m *LeaseGrantResponse) GetID() int64

func (*LeaseGrantResponse) GetTTL ΒΆ

func (m *LeaseGrantResponse) GetTTL() int64

func (*LeaseGrantResponse) Marshal ΒΆ

func (m *LeaseGrantResponse) Marshal() (dAtA []byte, err error)

func (*LeaseGrantResponse) MarshalTo ΒΆ

func (m *LeaseGrantResponse) MarshalTo(dAtA []byte) (int, error)

func (*LeaseGrantResponse) ProtoMessage ΒΆ

func (*LeaseGrantResponse) ProtoMessage()

func (*LeaseGrantResponse) Reset ΒΆ

func (m *LeaseGrantResponse) Reset()

func (*LeaseGrantResponse) Size ΒΆ

func (m *LeaseGrantResponse) Size() (n int)

func (*LeaseGrantResponse) String ΒΆ

func (m *LeaseGrantResponse) String() string

func (*LeaseGrantResponse) Unmarshal ΒΆ

func (m *LeaseGrantResponse) Unmarshal(dAtA []byte) error

type LeaseKeepAliveRequest ΒΆ

type LeaseKeepAliveRequest struct {
	// ID is the lease ID for the lease to keep alive.
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
}

func (*LeaseKeepAliveRequest) Descriptor ΒΆ

func (*LeaseKeepAliveRequest) Descriptor() ([]byte, []int)

func (*LeaseKeepAliveRequest) GetID ΒΆ

func (m *LeaseKeepAliveRequest) GetID() int64

func (*LeaseKeepAliveRequest) Marshal ΒΆ

func (m *LeaseKeepAliveRequest) Marshal() (dAtA []byte, err error)

func (*LeaseKeepAliveRequest) MarshalTo ΒΆ

func (m *LeaseKeepAliveRequest) MarshalTo(dAtA []byte) (int, error)

func (*LeaseKeepAliveRequest) ProtoMessage ΒΆ

func (*LeaseKeepAliveRequest) ProtoMessage()

func (*LeaseKeepAliveRequest) Reset ΒΆ

func (m *LeaseKeepAliveRequest) Reset()

func (*LeaseKeepAliveRequest) Size ΒΆ

func (m *LeaseKeepAliveRequest) Size() (n int)

func (*LeaseKeepAliveRequest) String ΒΆ

func (m *LeaseKeepAliveRequest) String() string

func (*LeaseKeepAliveRequest) Unmarshal ΒΆ

func (m *LeaseKeepAliveRequest) Unmarshal(dAtA []byte) error

type LeaseKeepAliveResponse ΒΆ

type LeaseKeepAliveResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// ID is the lease ID from the keep alive request.
	ID int64 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
	// TTL is the new time-to-live for the lease.
	TTL int64 `protobuf:"varint,3,opt,name=TTL,proto3" json:"TTL,omitempty"`
}

func (*LeaseKeepAliveResponse) Descriptor ΒΆ

func (*LeaseKeepAliveResponse) Descriptor() ([]byte, []int)

func (*LeaseKeepAliveResponse) GetHeader ΒΆ

func (m *LeaseKeepAliveResponse) GetHeader() *ResponseHeader

func (*LeaseKeepAliveResponse) GetID ΒΆ

func (m *LeaseKeepAliveResponse) GetID() int64

func (*LeaseKeepAliveResponse) GetTTL ΒΆ

func (m *LeaseKeepAliveResponse) GetTTL() int64

func (*LeaseKeepAliveResponse) Marshal ΒΆ

func (m *LeaseKeepAliveResponse) Marshal() (dAtA []byte, err error)

func (*LeaseKeepAliveResponse) MarshalTo ΒΆ

func (m *LeaseKeepAliveResponse) MarshalTo(dAtA []byte) (int, error)

func (*LeaseKeepAliveResponse) ProtoMessage ΒΆ

func (*LeaseKeepAliveResponse) ProtoMessage()

func (*LeaseKeepAliveResponse) Reset ΒΆ

func (m *LeaseKeepAliveResponse) Reset()

func (*LeaseKeepAliveResponse) Size ΒΆ

func (m *LeaseKeepAliveResponse) Size() (n int)

func (*LeaseKeepAliveResponse) String ΒΆ

func (m *LeaseKeepAliveResponse) String() string

func (*LeaseKeepAliveResponse) Unmarshal ΒΆ

func (m *LeaseKeepAliveResponse) Unmarshal(dAtA []byte) error

type LeaseLeasesRequest ΒΆ

type LeaseLeasesRequest struct {
}

func (*LeaseLeasesRequest) Descriptor ΒΆ

func (*LeaseLeasesRequest) Descriptor() ([]byte, []int)

func (*LeaseLeasesRequest) Marshal ΒΆ

func (m *LeaseLeasesRequest) Marshal() (dAtA []byte, err error)

func (*LeaseLeasesRequest) MarshalTo ΒΆ

func (m *LeaseLeasesRequest) MarshalTo(dAtA []byte) (int, error)

func (*LeaseLeasesRequest) ProtoMessage ΒΆ

func (*LeaseLeasesRequest) ProtoMessage()

func (*LeaseLeasesRequest) Reset ΒΆ

func (m *LeaseLeasesRequest) Reset()

func (*LeaseLeasesRequest) Size ΒΆ

func (m *LeaseLeasesRequest) Size() (n int)

func (*LeaseLeasesRequest) String ΒΆ

func (m *LeaseLeasesRequest) String() string

func (*LeaseLeasesRequest) Unmarshal ΒΆ

func (m *LeaseLeasesRequest) Unmarshal(dAtA []byte) error

type LeaseLeasesResponse ΒΆ

type LeaseLeasesResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Leases []*LeaseStatus  `protobuf:"bytes,2,rep,name=leases" json:"leases,omitempty"`
}

func (*LeaseLeasesResponse) Descriptor ΒΆ

func (*LeaseLeasesResponse) Descriptor() ([]byte, []int)

func (*LeaseLeasesResponse) GetHeader ΒΆ

func (m *LeaseLeasesResponse) GetHeader() *ResponseHeader

func (*LeaseLeasesResponse) GetLeases ΒΆ

func (m *LeaseLeasesResponse) GetLeases() []*LeaseStatus

func (*LeaseLeasesResponse) Marshal ΒΆ

func (m *LeaseLeasesResponse) Marshal() (dAtA []byte, err error)

func (*LeaseLeasesResponse) MarshalTo ΒΆ

func (m *LeaseLeasesResponse) MarshalTo(dAtA []byte) (int, error)

func (*LeaseLeasesResponse) ProtoMessage ΒΆ

func (*LeaseLeasesResponse) ProtoMessage()

func (*LeaseLeasesResponse) Reset ΒΆ

func (m *LeaseLeasesResponse) Reset()

func (*LeaseLeasesResponse) Size ΒΆ

func (m *LeaseLeasesResponse) Size() (n int)

func (*LeaseLeasesResponse) String ΒΆ

func (m *LeaseLeasesResponse) String() string

func (*LeaseLeasesResponse) Unmarshal ΒΆ

func (m *LeaseLeasesResponse) Unmarshal(dAtA []byte) error

type LeaseRevokeRequest ΒΆ

type LeaseRevokeRequest struct {
	// ID is the lease ID to revoke. When the ID is revoked, all associated keys will be deleted.
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
}

func (*LeaseRevokeRequest) Descriptor ΒΆ

func (*LeaseRevokeRequest) Descriptor() ([]byte, []int)

func (*LeaseRevokeRequest) GetID ΒΆ

func (m *LeaseRevokeRequest) GetID() int64

func (*LeaseRevokeRequest) Marshal ΒΆ

func (m *LeaseRevokeRequest) Marshal() (dAtA []byte, err error)

func (*LeaseRevokeRequest) MarshalTo ΒΆ

func (m *LeaseRevokeRequest) MarshalTo(dAtA []byte) (int, error)

func (*LeaseRevokeRequest) ProtoMessage ΒΆ

func (*LeaseRevokeRequest) ProtoMessage()

func (*LeaseRevokeRequest) Reset ΒΆ

func (m *LeaseRevokeRequest) Reset()

func (*LeaseRevokeRequest) Size ΒΆ

func (m *LeaseRevokeRequest) Size() (n int)

func (*LeaseRevokeRequest) String ΒΆ

func (m *LeaseRevokeRequest) String() string

func (*LeaseRevokeRequest) Unmarshal ΒΆ

func (m *LeaseRevokeRequest) Unmarshal(dAtA []byte) error

type LeaseRevokeResponse ΒΆ

type LeaseRevokeResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*LeaseRevokeResponse) Descriptor ΒΆ

func (*LeaseRevokeResponse) Descriptor() ([]byte, []int)

func (*LeaseRevokeResponse) GetHeader ΒΆ

func (m *LeaseRevokeResponse) GetHeader() *ResponseHeader

func (*LeaseRevokeResponse) Marshal ΒΆ

func (m *LeaseRevokeResponse) Marshal() (dAtA []byte, err error)

func (*LeaseRevokeResponse) MarshalTo ΒΆ

func (m *LeaseRevokeResponse) MarshalTo(dAtA []byte) (int, error)

func (*LeaseRevokeResponse) ProtoMessage ΒΆ

func (*LeaseRevokeResponse) ProtoMessage()

func (*LeaseRevokeResponse) Reset ΒΆ

func (m *LeaseRevokeResponse) Reset()

func (*LeaseRevokeResponse) Size ΒΆ

func (m *LeaseRevokeResponse) Size() (n int)

func (*LeaseRevokeResponse) String ΒΆ

func (m *LeaseRevokeResponse) String() string

func (*LeaseRevokeResponse) Unmarshal ΒΆ

func (m *LeaseRevokeResponse) Unmarshal(dAtA []byte) error

type LeaseServer ΒΆ

type LeaseServer interface {
	// LeaseGrant creates a lease which expires if the server does not receive a keepAlive
	// within a given time to live period. All keys attached to the lease will be expired and
	// deleted if the lease expires. Each expired key generates a delete event in the event history.
	LeaseGrant(context.Context, *LeaseGrantRequest) (*LeaseGrantResponse, error)
	// LeaseRevoke revokes a lease. All keys attached to the lease will expire and be deleted.
	LeaseRevoke(context.Context, *LeaseRevokeRequest) (*LeaseRevokeResponse, error)
	// LeaseKeepAlive keeps the lease alive by streaming keep alive requests from the client
	// to the server and streaming keep alive responses from the server to the client.
	LeaseKeepAlive(Lease_LeaseKeepAliveServer) error
	// LeaseTimeToLive retrieves lease information.
	LeaseTimeToLive(context.Context, *LeaseTimeToLiveRequest) (*LeaseTimeToLiveResponse, error)
	// LeaseLeases lists all existing leases.
	LeaseLeases(context.Context, *LeaseLeasesRequest) (*LeaseLeasesResponse, error)
}

type LeaseStatus ΒΆ

type LeaseStatus struct {
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
}

func (*LeaseStatus) Descriptor ΒΆ

func (*LeaseStatus) Descriptor() ([]byte, []int)

func (*LeaseStatus) GetID ΒΆ

func (m *LeaseStatus) GetID() int64

func (*LeaseStatus) Marshal ΒΆ

func (m *LeaseStatus) Marshal() (dAtA []byte, err error)

func (*LeaseStatus) MarshalTo ΒΆ

func (m *LeaseStatus) MarshalTo(dAtA []byte) (int, error)

func (*LeaseStatus) ProtoMessage ΒΆ

func (*LeaseStatus) ProtoMessage()

func (*LeaseStatus) Reset ΒΆ

func (m *LeaseStatus) Reset()

func (*LeaseStatus) Size ΒΆ

func (m *LeaseStatus) Size() (n int)

func (*LeaseStatus) String ΒΆ

func (m *LeaseStatus) String() string

func (*LeaseStatus) Unmarshal ΒΆ

func (m *LeaseStatus) Unmarshal(dAtA []byte) error

type LeaseTimeToLiveRequest ΒΆ

type LeaseTimeToLiveRequest struct {
	// ID is the lease ID for the lease.
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// keys is true to query all the keys attached to this lease.
	Keys bool `protobuf:"varint,2,opt,name=keys,proto3" json:"keys,omitempty"`
}

func (*LeaseTimeToLiveRequest) Descriptor ΒΆ

func (*LeaseTimeToLiveRequest) Descriptor() ([]byte, []int)

func (*LeaseTimeToLiveRequest) GetID ΒΆ

func (m *LeaseTimeToLiveRequest) GetID() int64

func (*LeaseTimeToLiveRequest) GetKeys ΒΆ

func (m *LeaseTimeToLiveRequest) GetKeys() bool

func (*LeaseTimeToLiveRequest) Marshal ΒΆ