Versions in this module Expand all Collapse all v1 v1.0.9 Apr 20, 2018 Changes in this version + var AlarmRequest_AlarmAction_name = map[int32]string + var AlarmRequest_AlarmAction_value = map[string]int32 + var AlarmType_name = map[int32]string + var AlarmType_value = map[string]int32 + var Compare_CompareResult_name = map[int32]string + var Compare_CompareResult_value = map[string]int32 + var Compare_CompareTarget_name = map[int32]string + var Compare_CompareTarget_value = map[string]int32 + var ErrIntOverflowEtcdserver = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowRaftInternal = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthEtcdserver = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthRaftInternal = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling") + var RangeRequest_SortOrder_name = map[int32]string + var RangeRequest_SortOrder_value = map[string]int32 + var RangeRequest_SortTarget_name = map[int32]string + var RangeRequest_SortTarget_value = map[string]int32 + var WatchCreateRequest_FilterType_name = map[int32]string + var WatchCreateRequest_FilterType_value = map[string]int32 + func RegisterAuthServer(s *grpc.Server, srv AuthServer) + func RegisterClusterServer(s *grpc.Server, srv ClusterServer) + func RegisterKVServer(s *grpc.Server, srv KVServer) + func RegisterLeaseServer(s *grpc.Server, srv LeaseServer) + func RegisterMaintenanceServer(s *grpc.Server, srv MaintenanceServer) + func RegisterWatchServer(s *grpc.Server, srv WatchServer) + type AlarmMember struct + Alarm AlarmType + MemberID uint64 + func (*AlarmMember) Descriptor() ([]byte, []int) + func (*AlarmMember) ProtoMessage() + func (m *AlarmMember) Marshal() (dAtA []byte, err error) + func (m *AlarmMember) MarshalTo(dAtA []byte) (int, error) + func (m *AlarmMember) Reset() + func (m *AlarmMember) Size() (n int) + func (m *AlarmMember) String() string + func (m *AlarmMember) Unmarshal(dAtA []byte) error + type AlarmRequest struct + Action AlarmRequest_AlarmAction + Alarm AlarmType + MemberID uint64 + func (*AlarmRequest) Descriptor() ([]byte, []int) + func (*AlarmRequest) ProtoMessage() + func (m *AlarmRequest) Marshal() (dAtA []byte, err error) + func (m *AlarmRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AlarmRequest) Reset() + func (m *AlarmRequest) Size() (n int) + func (m *AlarmRequest) String() string + func (m *AlarmRequest) Unmarshal(dAtA []byte) error + type AlarmRequest_AlarmAction int32 + const AlarmRequest_ACTIVATE + const AlarmRequest_DEACTIVATE + const AlarmRequest_GET + func (AlarmRequest_AlarmAction) EnumDescriptor() ([]byte, []int) + func (x AlarmRequest_AlarmAction) String() string + type AlarmResponse struct + Alarms []*AlarmMember + Header *ResponseHeader + func (*AlarmResponse) Descriptor() ([]byte, []int) + func (*AlarmResponse) ProtoMessage() + func (m *AlarmResponse) GetAlarms() []*AlarmMember + func (m *AlarmResponse) GetHeader() *ResponseHeader + func (m *AlarmResponse) Marshal() (dAtA []byte, err error) + func (m *AlarmResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AlarmResponse) Reset() + func (m *AlarmResponse) Size() (n int) + func (m *AlarmResponse) String() string + func (m *AlarmResponse) Unmarshal(dAtA []byte) error + type AlarmType int32 + const AlarmType_NONE + const AlarmType_NOSPACE + func (AlarmType) EnumDescriptor() ([]byte, []int) + func (x AlarmType) String() string + type AuthClient interface + AuthDisable func(ctx context.Context, in *AuthDisableRequest, opts ...grpc.CallOption) (*AuthDisableResponse, error) + AuthEnable func(ctx context.Context, in *AuthEnableRequest, opts ...grpc.CallOption) (*AuthEnableResponse, error) + Authenticate func(ctx context.Context, in *AuthenticateRequest, opts ...grpc.CallOption) (*AuthenticateResponse, error) + RoleAdd func(ctx context.Context, in *AuthRoleAddRequest, opts ...grpc.CallOption) (*AuthRoleAddResponse, error) + RoleDelete func(ctx context.Context, in *AuthRoleDeleteRequest, opts ...grpc.CallOption) (*AuthRoleDeleteResponse, error) + RoleGet func(ctx context.Context, in *AuthRoleGetRequest, opts ...grpc.CallOption) (*AuthRoleGetResponse, error) + RoleGrantPermission func(ctx context.Context, in *AuthRoleGrantPermissionRequest, ...) (*AuthRoleGrantPermissionResponse, error) + RoleList func(ctx context.Context, in *AuthRoleListRequest, opts ...grpc.CallOption) (*AuthRoleListResponse, error) + RoleRevokePermission func(ctx context.Context, in *AuthRoleRevokePermissionRequest, ...) (*AuthRoleRevokePermissionResponse, error) + UserAdd func(ctx context.Context, in *AuthUserAddRequest, opts ...grpc.CallOption) (*AuthUserAddResponse, error) + UserChangePassword func(ctx context.Context, in *AuthUserChangePasswordRequest, ...) (*AuthUserChangePasswordResponse, error) + UserDelete func(ctx context.Context, in *AuthUserDeleteRequest, opts ...grpc.CallOption) (*AuthUserDeleteResponse, error) + UserGet func(ctx context.Context, in *AuthUserGetRequest, opts ...grpc.CallOption) (*AuthUserGetResponse, error) + UserGrantRole func(ctx context.Context, in *AuthUserGrantRoleRequest, opts ...grpc.CallOption) (*AuthUserGrantRoleResponse, error) + UserList func(ctx context.Context, in *AuthUserListRequest, opts ...grpc.CallOption) (*AuthUserListResponse, error) + UserRevokeRole func(ctx context.Context, in *AuthUserRevokeRoleRequest, opts ...grpc.CallOption) (*AuthUserRevokeRoleResponse, error) + func NewAuthClient(cc *grpc.ClientConn) AuthClient + type AuthDisableRequest struct + func (*AuthDisableRequest) Descriptor() ([]byte, []int) + func (*AuthDisableRequest) ProtoMessage() + func (m *AuthDisableRequest) Marshal() (dAtA []byte, err error) + func (m *AuthDisableRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthDisableRequest) Reset() + func (m *AuthDisableRequest) Size() (n int) + func (m *AuthDisableRequest) String() string + func (m *AuthDisableRequest) Unmarshal(dAtA []byte) error + type AuthDisableResponse struct + Header *ResponseHeader + func (*AuthDisableResponse) Descriptor() ([]byte, []int) + func (*AuthDisableResponse) ProtoMessage() + func (m *AuthDisableResponse) GetHeader() *ResponseHeader + func (m *AuthDisableResponse) Marshal() (dAtA []byte, err error) + func (m *AuthDisableResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthDisableResponse) Reset() + func (m *AuthDisableResponse) Size() (n int) + func (m *AuthDisableResponse) String() string + func (m *AuthDisableResponse) Unmarshal(dAtA []byte) error + type AuthEnableRequest struct + func (*AuthEnableRequest) Descriptor() ([]byte, []int) + func (*AuthEnableRequest) ProtoMessage() + func (m *AuthEnableRequest) Marshal() (dAtA []byte, err error) + func (m *AuthEnableRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthEnableRequest) Reset() + func (m *AuthEnableRequest) Size() (n int) + func (m *AuthEnableRequest) String() string + func (m *AuthEnableRequest) Unmarshal(dAtA []byte) error + type AuthEnableResponse struct + Header *ResponseHeader + func (*AuthEnableResponse) Descriptor() ([]byte, []int) + func (*AuthEnableResponse) ProtoMessage() + func (m *AuthEnableResponse) GetHeader() *ResponseHeader + func (m *AuthEnableResponse) Marshal() (dAtA []byte, err error) + func (m *AuthEnableResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthEnableResponse) Reset() + func (m *AuthEnableResponse) Size() (n int) + func (m *AuthEnableResponse) String() string + func (m *AuthEnableResponse) Unmarshal(dAtA []byte) error + type AuthRoleAddRequest struct + Name string + func (*AuthRoleAddRequest) Descriptor() ([]byte, []int) + func (*AuthRoleAddRequest) ProtoMessage() + func (m *AuthRoleAddRequest) Marshal() (dAtA []byte, err error) + func (m *AuthRoleAddRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthRoleAddRequest) Reset() + func (m *AuthRoleAddRequest) Size() (n int) + func (m *AuthRoleAddRequest) String() string + func (m *AuthRoleAddRequest) Unmarshal(dAtA []byte) error + type AuthRoleAddResponse struct + Header *ResponseHeader + func (*AuthRoleAddResponse) Descriptor() ([]byte, []int) + func (*AuthRoleAddResponse) ProtoMessage() + func (m *AuthRoleAddResponse) GetHeader() *ResponseHeader + func (m *AuthRoleAddResponse) Marshal() (dAtA []byte, err error) + func (m *AuthRoleAddResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthRoleAddResponse) Reset() + func (m *AuthRoleAddResponse) Size() (n int) + func (m *AuthRoleAddResponse) String() string + func (m *AuthRoleAddResponse) Unmarshal(dAtA []byte) error + type AuthRoleDeleteRequest struct + Role string + func (*AuthRoleDeleteRequest) Descriptor() ([]byte, []int) + func (*AuthRoleDeleteRequest) ProtoMessage() + func (m *AuthRoleDeleteRequest) Marshal() (dAtA []byte, err error) + func (m *AuthRoleDeleteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthRoleDeleteRequest) Reset() + func (m *AuthRoleDeleteRequest) Size() (n int) + func (m *AuthRoleDeleteRequest) String() string + func (m *AuthRoleDeleteRequest) Unmarshal(dAtA []byte) error + type AuthRoleDeleteResponse struct + Header *ResponseHeader + func (*AuthRoleDeleteResponse) Descriptor() ([]byte, []int) + func (*AuthRoleDeleteResponse) ProtoMessage() + func (m *AuthRoleDeleteResponse) GetHeader() *ResponseHeader + func (m *AuthRoleDeleteResponse) Marshal() (dAtA []byte, err error) + func (m *AuthRoleDeleteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthRoleDeleteResponse) Reset() + func (m *AuthRoleDeleteResponse) Size() (n int) + func (m *AuthRoleDeleteResponse) String() string + func (m *AuthRoleDeleteResponse) Unmarshal(dAtA []byte) error + type AuthRoleGetRequest struct + Role string + func (*AuthRoleGetRequest) Descriptor() ([]byte, []int) + func (*AuthRoleGetRequest) ProtoMessage() + func (m *AuthRoleGetRequest) Marshal() (dAtA []byte, err error) + func (m *AuthRoleGetRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthRoleGetRequest) Reset() + func (m *AuthRoleGetRequest) Size() (n int) + func (m *AuthRoleGetRequest) String() string + func (m *AuthRoleGetRequest) Unmarshal(dAtA []byte) error + type AuthRoleGetResponse struct + Header *ResponseHeader + Perm []*authpb.Permission + func (*AuthRoleGetResponse) Descriptor() ([]byte, []int) + func (*AuthRoleGetResponse) ProtoMessage() + func (m *AuthRoleGetResponse) GetHeader() *ResponseHeader + func (m *AuthRoleGetResponse) GetPerm() []*authpb.Permission + func (m *AuthRoleGetResponse) Marshal() (dAtA []byte, err error) + func (m *AuthRoleGetResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthRoleGetResponse) Reset() + func (m *AuthRoleGetResponse) Size() (n int) + func (m *AuthRoleGetResponse) String() string + func (m *AuthRoleGetResponse) Unmarshal(dAtA []byte) error + type AuthRoleGrantPermissionRequest struct + Name string + Perm *authpb.Permission + func (*AuthRoleGrantPermissionRequest) Descriptor() ([]byte, []int) + func (*AuthRoleGrantPermissionRequest) ProtoMessage() + func (m *AuthRoleGrantPermissionRequest) GetPerm() *authpb.Permission + func (m *AuthRoleGrantPermissionRequest) Marshal() (dAtA []byte, err error) + func (m *AuthRoleGrantPermissionRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthRoleGrantPermissionRequest) Reset() + func (m *AuthRoleGrantPermissionRequest) Size() (n int) + func (m *AuthRoleGrantPermissionRequest) String() string + func (m *AuthRoleGrantPermissionRequest) Unmarshal(dAtA []byte) error + type AuthRoleGrantPermissionResponse struct + Header *ResponseHeader + func (*AuthRoleGrantPermissionResponse) Descriptor() ([]byte, []int) + func (*AuthRoleGrantPermissionResponse) ProtoMessage() + func (m *AuthRoleGrantPermissionResponse) GetHeader() *ResponseHeader + func (m *AuthRoleGrantPermissionResponse) Marshal() (dAtA []byte, err error) + func (m *AuthRoleGrantPermissionResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthRoleGrantPermissionResponse) Reset() + func (m *AuthRoleGrantPermissionResponse) Size() (n int) + func (m *AuthRoleGrantPermissionResponse) String() string + func (m *AuthRoleGrantPermissionResponse) Unmarshal(dAtA []byte) error + type AuthRoleListRequest struct + func (*AuthRoleListRequest) Descriptor() ([]byte, []int) + func (*AuthRoleListRequest) ProtoMessage() + func (m *AuthRoleListRequest) Marshal() (dAtA []byte, err error) + func (m *AuthRoleListRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthRoleListRequest) Reset() + func (m *AuthRoleListRequest) Size() (n int) + func (m *AuthRoleListRequest) String() string + func (m *AuthRoleListRequest) Unmarshal(dAtA []byte) error + type AuthRoleListResponse struct + Header *ResponseHeader + Roles []string + func (*AuthRoleListResponse) Descriptor() ([]byte, []int) + func (*AuthRoleListResponse) ProtoMessage() + func (m *AuthRoleListResponse) GetHeader() *ResponseHeader + func (m *AuthRoleListResponse) Marshal() (dAtA []byte, err error) + func (m *AuthRoleListResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthRoleListResponse) Reset() + func (m *AuthRoleListResponse) Size() (n int) + func (m *AuthRoleListResponse) String() string + func (m *AuthRoleListResponse) Unmarshal(dAtA []byte) error + type AuthRoleRevokePermissionRequest struct + Key string + RangeEnd string + Role string + func (*AuthRoleRevokePermissionRequest) Descriptor() ([]byte, []int) + func (*AuthRoleRevokePermissionRequest) ProtoMessage() + func (m *AuthRoleRevokePermissionRequest) Marshal() (dAtA []byte, err error) + func (m *AuthRoleRevokePermissionRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthRoleRevokePermissionRequest) Reset() + func (m *AuthRoleRevokePermissionRequest) Size() (n int) + func (m *AuthRoleRevokePermissionRequest) String() string + func (m *AuthRoleRevokePermissionRequest) Unmarshal(dAtA []byte) error + type AuthRoleRevokePermissionResponse struct + Header *ResponseHeader + func (*AuthRoleRevokePermissionResponse) Descriptor() ([]byte, []int) + func (*AuthRoleRevokePermissionResponse) ProtoMessage() + func (m *AuthRoleRevokePermissionResponse) GetHeader() *ResponseHeader + func (m *AuthRoleRevokePermissionResponse) Marshal() (dAtA []byte, err error) + func (m *AuthRoleRevokePermissionResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthRoleRevokePermissionResponse) Reset() + func (m *AuthRoleRevokePermissionResponse) Size() (n int) + func (m *AuthRoleRevokePermissionResponse) String() string + func (m *AuthRoleRevokePermissionResponse) Unmarshal(dAtA []byte) error + type AuthServer interface + AuthDisable func(context.Context, *AuthDisableRequest) (*AuthDisableResponse, error) + AuthEnable func(context.Context, *AuthEnableRequest) (*AuthEnableResponse, error) + Authenticate func(context.Context, *AuthenticateRequest) (*AuthenticateResponse, error) + RoleAdd func(context.Context, *AuthRoleAddRequest) (*AuthRoleAddResponse, error) + RoleDelete func(context.Context, *AuthRoleDeleteRequest) (*AuthRoleDeleteResponse, error) + RoleGet func(context.Context, *AuthRoleGetRequest) (*AuthRoleGetResponse, error) + RoleGrantPermission func(context.Context, *AuthRoleGrantPermissionRequest) (*AuthRoleGrantPermissionResponse, error) + RoleList func(context.Context, *AuthRoleListRequest) (*AuthRoleListResponse, error) + RoleRevokePermission func(context.Context, *AuthRoleRevokePermissionRequest) (*AuthRoleRevokePermissionResponse, error) + UserAdd func(context.Context, *AuthUserAddRequest) (*AuthUserAddResponse, error) + UserChangePassword func(context.Context, *AuthUserChangePasswordRequest) (*AuthUserChangePasswordResponse, error) + UserDelete func(context.Context, *AuthUserDeleteRequest) (*AuthUserDeleteResponse, error) + UserGet func(context.Context, *AuthUserGetRequest) (*AuthUserGetResponse, error) + UserGrantRole func(context.Context, *AuthUserGrantRoleRequest) (*AuthUserGrantRoleResponse, error) + UserList func(context.Context, *AuthUserListRequest) (*AuthUserListResponse, error) + UserRevokeRole func(context.Context, *AuthUserRevokeRoleRequest) (*AuthUserRevokeRoleResponse, error) + type AuthUserAddRequest struct + Name string + Password string + func (*AuthUserAddRequest) Descriptor() ([]byte, []int) + func (*AuthUserAddRequest) ProtoMessage() + func (m *AuthUserAddRequest) Marshal() (dAtA []byte, err error) + func (m *AuthUserAddRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserAddRequest) Reset() + func (m *AuthUserAddRequest) Size() (n int) + func (m *AuthUserAddRequest) String() string + func (m *AuthUserAddRequest) Unmarshal(dAtA []byte) error + type AuthUserAddResponse struct + Header *ResponseHeader + func (*AuthUserAddResponse) Descriptor() ([]byte, []int) + func (*AuthUserAddResponse) ProtoMessage() + func (m *AuthUserAddResponse) GetHeader() *ResponseHeader + func (m *AuthUserAddResponse) Marshal() (dAtA []byte, err error) + func (m *AuthUserAddResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserAddResponse) Reset() + func (m *AuthUserAddResponse) Size() (n int) + func (m *AuthUserAddResponse) String() string + func (m *AuthUserAddResponse) Unmarshal(dAtA []byte) error + type AuthUserChangePasswordRequest struct + Name string + Password string + func (*AuthUserChangePasswordRequest) Descriptor() ([]byte, []int) + func (*AuthUserChangePasswordRequest) ProtoMessage() + func (m *AuthUserChangePasswordRequest) Marshal() (dAtA []byte, err error) + func (m *AuthUserChangePasswordRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserChangePasswordRequest) Reset() + func (m *AuthUserChangePasswordRequest) Size() (n int) + func (m *AuthUserChangePasswordRequest) String() string + func (m *AuthUserChangePasswordRequest) Unmarshal(dAtA []byte) error + type AuthUserChangePasswordResponse struct + Header *ResponseHeader + func (*AuthUserChangePasswordResponse) Descriptor() ([]byte, []int) + func (*AuthUserChangePasswordResponse) ProtoMessage() + func (m *AuthUserChangePasswordResponse) GetHeader() *ResponseHeader + func (m *AuthUserChangePasswordResponse) Marshal() (dAtA []byte, err error) + func (m *AuthUserChangePasswordResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserChangePasswordResponse) Reset() + func (m *AuthUserChangePasswordResponse) Size() (n int) + func (m *AuthUserChangePasswordResponse) String() string + func (m *AuthUserChangePasswordResponse) Unmarshal(dAtA []byte) error + type AuthUserDeleteRequest struct + Name string + func (*AuthUserDeleteRequest) Descriptor() ([]byte, []int) + func (*AuthUserDeleteRequest) ProtoMessage() + func (m *AuthUserDeleteRequest) Marshal() (dAtA []byte, err error) + func (m *AuthUserDeleteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserDeleteRequest) Reset() + func (m *AuthUserDeleteRequest) Size() (n int) + func (m *AuthUserDeleteRequest) String() string + func (m *AuthUserDeleteRequest) Unmarshal(dAtA []byte) error + type AuthUserDeleteResponse struct + Header *ResponseHeader + func (*AuthUserDeleteResponse) Descriptor() ([]byte, []int) + func (*AuthUserDeleteResponse) ProtoMessage() + func (m *AuthUserDeleteResponse) GetHeader() *ResponseHeader + func (m *AuthUserDeleteResponse) Marshal() (dAtA []byte, err error) + func (m *AuthUserDeleteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserDeleteResponse) Reset() + func (m *AuthUserDeleteResponse) Size() (n int) + func (m *AuthUserDeleteResponse) String() string + func (m *AuthUserDeleteResponse) Unmarshal(dAtA []byte) error + type AuthUserGetRequest struct + Name string + func (*AuthUserGetRequest) Descriptor() ([]byte, []int) + func (*AuthUserGetRequest) ProtoMessage() + func (m *AuthUserGetRequest) Marshal() (dAtA []byte, err error) + func (m *AuthUserGetRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserGetRequest) Reset() + func (m *AuthUserGetRequest) Size() (n int) + func (m *AuthUserGetRequest) String() string + func (m *AuthUserGetRequest) Unmarshal(dAtA []byte) error + type AuthUserGetResponse struct + Header *ResponseHeader + Roles []string + func (*AuthUserGetResponse) Descriptor() ([]byte, []int) + func (*AuthUserGetResponse) ProtoMessage() + func (m *AuthUserGetResponse) GetHeader() *ResponseHeader + func (m *AuthUserGetResponse) Marshal() (dAtA []byte, err error) + func (m *AuthUserGetResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserGetResponse) Reset() + func (m *AuthUserGetResponse) Size() (n int) + func (m *AuthUserGetResponse) String() string + func (m *AuthUserGetResponse) Unmarshal(dAtA []byte) error + type AuthUserGrantRoleRequest struct + Role string + User string + func (*AuthUserGrantRoleRequest) Descriptor() ([]byte, []int) + func (*AuthUserGrantRoleRequest) ProtoMessage() + func (m *AuthUserGrantRoleRequest) Marshal() (dAtA []byte, err error) + func (m *AuthUserGrantRoleRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserGrantRoleRequest) Reset() + func (m *AuthUserGrantRoleRequest) Size() (n int) + func (m *AuthUserGrantRoleRequest) String() string + func (m *AuthUserGrantRoleRequest) Unmarshal(dAtA []byte) error + type AuthUserGrantRoleResponse struct + Header *ResponseHeader + func (*AuthUserGrantRoleResponse) Descriptor() ([]byte, []int) + func (*AuthUserGrantRoleResponse) ProtoMessage() + func (m *AuthUserGrantRoleResponse) GetHeader() *ResponseHeader + func (m *AuthUserGrantRoleResponse) Marshal() (dAtA []byte, err error) + func (m *AuthUserGrantRoleResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserGrantRoleResponse) Reset() + func (m *AuthUserGrantRoleResponse) Size() (n int) + func (m *AuthUserGrantRoleResponse) String() string + func (m *AuthUserGrantRoleResponse) Unmarshal(dAtA []byte) error + type AuthUserListRequest struct + func (*AuthUserListRequest) Descriptor() ([]byte, []int) + func (*AuthUserListRequest) ProtoMessage() + func (m *AuthUserListRequest) Marshal() (dAtA []byte, err error) + func (m *AuthUserListRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserListRequest) Reset() + func (m *AuthUserListRequest) Size() (n int) + func (m *AuthUserListRequest) String() string + func (m *AuthUserListRequest) Unmarshal(dAtA []byte) error + type AuthUserListResponse struct + Header *ResponseHeader + Users []string + func (*AuthUserListResponse) Descriptor() ([]byte, []int) + func (*AuthUserListResponse) ProtoMessage() + func (m *AuthUserListResponse) GetHeader() *ResponseHeader + func (m *AuthUserListResponse) Marshal() (dAtA []byte, err error) + func (m *AuthUserListResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserListResponse) Reset() + func (m *AuthUserListResponse) Size() (n int) + func (m *AuthUserListResponse) String() string + func (m *AuthUserListResponse) Unmarshal(dAtA []byte) error + type AuthUserRevokeRoleRequest struct + Name string + Role string + func (*AuthUserRevokeRoleRequest) Descriptor() ([]byte, []int) + func (*AuthUserRevokeRoleRequest) ProtoMessage() + func (m *AuthUserRevokeRoleRequest) Marshal() (dAtA []byte, err error) + func (m *AuthUserRevokeRoleRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserRevokeRoleRequest) Reset() + func (m *AuthUserRevokeRoleRequest) Size() (n int) + func (m *AuthUserRevokeRoleRequest) String() string + func (m *AuthUserRevokeRoleRequest) Unmarshal(dAtA []byte) error + type AuthUserRevokeRoleResponse struct + Header *ResponseHeader + func (*AuthUserRevokeRoleResponse) Descriptor() ([]byte, []int) + func (*AuthUserRevokeRoleResponse) ProtoMessage() + func (m *AuthUserRevokeRoleResponse) GetHeader() *ResponseHeader + func (m *AuthUserRevokeRoleResponse) Marshal() (dAtA []byte, err error) + func (m *AuthUserRevokeRoleResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthUserRevokeRoleResponse) Reset() + func (m *AuthUserRevokeRoleResponse) Size() (n int) + func (m *AuthUserRevokeRoleResponse) String() string + func (m *AuthUserRevokeRoleResponse) Unmarshal(dAtA []byte) error + type AuthenticateRequest struct + Name string + Password string + func (*AuthenticateRequest) Descriptor() ([]byte, []int) + func (*AuthenticateRequest) ProtoMessage() + func (m *AuthenticateRequest) Marshal() (dAtA []byte, err error) + func (m *AuthenticateRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AuthenticateRequest) Reset() + func (m *AuthenticateRequest) Size() (n int) + func (m *AuthenticateRequest) String() string + func (m *AuthenticateRequest) Unmarshal(dAtA []byte) error + type AuthenticateResponse struct + Header *ResponseHeader + Token string + func (*AuthenticateResponse) Descriptor() ([]byte, []int) + func (*AuthenticateResponse) ProtoMessage() + func (m *AuthenticateResponse) GetHeader() *ResponseHeader + func (m *AuthenticateResponse) Marshal() (dAtA []byte, err error) + func (m *AuthenticateResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AuthenticateResponse) Reset() + func (m *AuthenticateResponse) Size() (n int) + func (m *AuthenticateResponse) String() string + func (m *AuthenticateResponse) Unmarshal(dAtA []byte) error + type ClusterClient interface + MemberAdd func(ctx context.Context, in *MemberAddRequest, opts ...grpc.CallOption) (*MemberAddResponse, error) + MemberList func(ctx context.Context, in *MemberListRequest, opts ...grpc.CallOption) (*MemberListResponse, error) + MemberRemove func(ctx context.Context, in *MemberRemoveRequest, opts ...grpc.CallOption) (*MemberRemoveResponse, error) + MemberUpdate func(ctx context.Context, in *MemberUpdateRequest, opts ...grpc.CallOption) (*MemberUpdateResponse, error) + func NewClusterClient(cc *grpc.ClientConn) ClusterClient + type ClusterServer interface + MemberAdd func(context.Context, *MemberAddRequest) (*MemberAddResponse, error) + MemberList func(context.Context, *MemberListRequest) (*MemberListResponse, error) + MemberRemove func(context.Context, *MemberRemoveRequest) (*MemberRemoveResponse, error) + MemberUpdate func(context.Context, *MemberUpdateRequest) (*MemberUpdateResponse, error) + type CompactionRequest struct + Physical bool + Revision int64 + func (*CompactionRequest) Descriptor() ([]byte, []int) + func (*CompactionRequest) ProtoMessage() + func (m *CompactionRequest) Marshal() (dAtA []byte, err error) + func (m *CompactionRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CompactionRequest) Reset() + func (m *CompactionRequest) Size() (n int) + func (m *CompactionRequest) String() string + func (m *CompactionRequest) Unmarshal(dAtA []byte) error + type CompactionResponse struct + Header *ResponseHeader + func (*CompactionResponse) Descriptor() ([]byte, []int) + func (*CompactionResponse) ProtoMessage() + func (m *CompactionResponse) GetHeader() *ResponseHeader + func (m *CompactionResponse) Marshal() (dAtA []byte, err error) + func (m *CompactionResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CompactionResponse) Reset() + func (m *CompactionResponse) Size() (n int) + func (m *CompactionResponse) String() string + func (m *CompactionResponse) Unmarshal(dAtA []byte) error + type Compare struct + Key []byte + Result Compare_CompareResult + Target Compare_CompareTarget + TargetUnion isCompare_TargetUnion + func (*Compare) Descriptor() ([]byte, []int) + func (*Compare) ProtoMessage() + func (*Compare) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *Compare) GetCreateRevision() int64 + func (m *Compare) GetModRevision() int64 + func (m *Compare) GetTargetUnion() isCompare_TargetUnion + func (m *Compare) GetValue() []byte + func (m *Compare) GetVersion() int64 + func (m *Compare) Marshal() (dAtA []byte, err error) + func (m *Compare) MarshalTo(dAtA []byte) (int, error) + func (m *Compare) Reset() + func (m *Compare) Size() (n int) + func (m *Compare) String() string + func (m *Compare) Unmarshal(dAtA []byte) error + type Compare_CompareResult int32 + const Compare_EQUAL + const Compare_GREATER + const Compare_LESS + const Compare_NOT_EQUAL + func (Compare_CompareResult) EnumDescriptor() ([]byte, []int) + func (x Compare_CompareResult) String() string + type Compare_CompareTarget int32 + const Compare_CREATE + const Compare_MOD + const Compare_VALUE + const Compare_VERSION + func (Compare_CompareTarget) EnumDescriptor() ([]byte, []int) + func (x Compare_CompareTarget) String() string + type Compare_CreateRevision struct + CreateRevision int64 + func (m *Compare_CreateRevision) MarshalTo(dAtA []byte) (int, error) + func (m *Compare_CreateRevision) Size() (n int) + type Compare_ModRevision struct + ModRevision int64 + func (m *Compare_ModRevision) MarshalTo(dAtA []byte) (int, error) + func (m *Compare_ModRevision) Size() (n int) + type Compare_Value struct + Value []byte + func (m *Compare_Value) MarshalTo(dAtA []byte) (int, error) + func (m *Compare_Value) Size() (n int) + type Compare_Version struct + Version int64 + func (m *Compare_Version) MarshalTo(dAtA []byte) (int, error) + func (m *Compare_Version) Size() (n int) + type DefragmentRequest struct + func (*DefragmentRequest) Descriptor() ([]byte, []int) + func (*DefragmentRequest) ProtoMessage() + func (m *DefragmentRequest) Marshal() (dAtA []byte, err error) + func (m *DefragmentRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DefragmentRequest) Reset() + func (m *DefragmentRequest) Size() (n int) + func (m *DefragmentRequest) String() string + func (m *DefragmentRequest) Unmarshal(dAtA []byte) error + type DefragmentResponse struct + Header *ResponseHeader + func (*DefragmentResponse) Descriptor() ([]byte, []int) + func (*DefragmentResponse) ProtoMessage() + func (m *DefragmentResponse) GetHeader() *ResponseHeader + func (m *DefragmentResponse) Marshal() (dAtA []byte, err error) + func (m *DefragmentResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DefragmentResponse) Reset() + func (m *DefragmentResponse) Size() (n int) + func (m *DefragmentResponse) String() string + func (m *DefragmentResponse) Unmarshal(dAtA []byte) error + type DeleteRangeRequest struct + Key []byte + PrevKv bool + RangeEnd []byte + func (*DeleteRangeRequest) Descriptor() ([]byte, []int) + func (*DeleteRangeRequest) ProtoMessage() + func (m *DeleteRangeRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteRangeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRangeRequest) Reset() + func (m *DeleteRangeRequest) Size() (n int) + func (m *DeleteRangeRequest) String() string + func (m *DeleteRangeRequest) Unmarshal(dAtA []byte) error + type DeleteRangeResponse struct + Deleted int64 + Header *ResponseHeader + PrevKvs []*mvccpb.KeyValue + func (*DeleteRangeResponse) Descriptor() ([]byte, []int) + func (*DeleteRangeResponse) ProtoMessage() + func (m *DeleteRangeResponse) GetHeader() *ResponseHeader + func (m *DeleteRangeResponse) GetPrevKvs() []*mvccpb.KeyValue + func (m *DeleteRangeResponse) Marshal() (dAtA []byte, err error) + func (m *DeleteRangeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRangeResponse) Reset() + func (m *DeleteRangeResponse) Size() (n int) + func (m *DeleteRangeResponse) String() string + func (m *DeleteRangeResponse) Unmarshal(dAtA []byte) error + type EmptyResponse struct + func (*EmptyResponse) Descriptor() ([]byte, []int) + func (*EmptyResponse) ProtoMessage() + func (m *EmptyResponse) Marshal() (dAtA []byte, err error) + func (m *EmptyResponse) MarshalTo(dAtA []byte) (int, error) + func (m *EmptyResponse) Reset() + func (m *EmptyResponse) Size() (n int) + func (m *EmptyResponse) String() string + func (m *EmptyResponse) Unmarshal(dAtA []byte) error + type HashRequest struct + func (*HashRequest) Descriptor() ([]byte, []int) + func (*HashRequest) ProtoMessage() + func (m *HashRequest) Marshal() (dAtA []byte, err error) + func (m *HashRequest) MarshalTo(dAtA []byte) (int, error) + func (m *HashRequest) Reset() + func (m *HashRequest) Size() (n int) + func (m *HashRequest) String() string + func (m *HashRequest) Unmarshal(dAtA []byte) error + type HashResponse struct + Hash uint32 + Header *ResponseHeader + func (*HashResponse) Descriptor() ([]byte, []int) + func (*HashResponse) ProtoMessage() + func (m *HashResponse) GetHeader() *ResponseHeader + func (m *HashResponse) Marshal() (dAtA []byte, err error) + func (m *HashResponse) MarshalTo(dAtA []byte) (int, error) + func (m *HashResponse) Reset() + func (m *HashResponse) Size() (n int) + func (m *HashResponse) String() string + func (m *HashResponse) Unmarshal(dAtA []byte) error + type InternalAuthenticateRequest struct + Name string + Password string + SimpleToken string + func (*InternalAuthenticateRequest) Descriptor() ([]byte, []int) + func (*InternalAuthenticateRequest) ProtoMessage() + func (m *InternalAuthenticateRequest) Marshal() (dAtA []byte, err error) + func (m *InternalAuthenticateRequest) MarshalTo(dAtA []byte) (int, error) + func (m *InternalAuthenticateRequest) Reset() + func (m *InternalAuthenticateRequest) Size() (n int) + func (m *InternalAuthenticateRequest) String() string + func (m *InternalAuthenticateRequest) Unmarshal(dAtA []byte) error + type InternalRaftRequest struct + Alarm *AlarmRequest + AuthDisable *AuthDisableRequest + AuthEnable *AuthEnableRequest + AuthRoleAdd *AuthRoleAddRequest + AuthRoleDelete *AuthRoleDeleteRequest + AuthRoleGet *AuthRoleGetRequest + AuthRoleGrantPermission *AuthRoleGrantPermissionRequest + AuthRoleList *AuthRoleListRequest + AuthRoleRevokePermission *AuthRoleRevokePermissionRequest + AuthUserAdd *AuthUserAddRequest + AuthUserChangePassword *AuthUserChangePasswordRequest + AuthUserDelete *AuthUserDeleteRequest + AuthUserGet *AuthUserGetRequest + AuthUserGrantRole *AuthUserGrantRoleRequest + AuthUserList *AuthUserListRequest + AuthUserRevokeRole *AuthUserRevokeRoleRequest + Authenticate *InternalAuthenticateRequest + Compaction *CompactionRequest + DeleteRange *DeleteRangeRequest + Header *RequestHeader + ID uint64 + LeaseGrant *LeaseGrantRequest + LeaseRevoke *LeaseRevokeRequest + Put *PutRequest + Range *RangeRequest + Txn *TxnRequest + V2 *Request + func (*InternalRaftRequest) Descriptor() ([]byte, []int) + func (*InternalRaftRequest) ProtoMessage() + func (m *InternalRaftRequest) Marshal() (dAtA []byte, err error) + func (m *InternalRaftRequest) MarshalTo(dAtA []byte) (int, error) + func (m *InternalRaftRequest) Reset() + func (m *InternalRaftRequest) Size() (n int) + func (m *InternalRaftRequest) String() string + func (m *InternalRaftRequest) Unmarshal(dAtA []byte) error + type KVClient interface + Compact func(ctx context.Context, in *CompactionRequest, opts ...grpc.CallOption) (*CompactionResponse, error) + DeleteRange func(ctx context.Context, in *DeleteRangeRequest, opts ...grpc.CallOption) (*DeleteRangeResponse, error) + Put func(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error) + Range func(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error) + Txn func(ctx context.Context, in *TxnRequest, opts ...grpc.CallOption) (*TxnResponse, error) + func NewKVClient(cc *grpc.ClientConn) KVClient + type KVServer interface + Compact func(context.Context, *CompactionRequest) (*CompactionResponse, error) + DeleteRange func(context.Context, *DeleteRangeRequest) (*DeleteRangeResponse, error) + Put func(context.Context, *PutRequest) (*PutResponse, error) + Range func(context.Context, *RangeRequest) (*RangeResponse, error) + Txn func(context.Context, *TxnRequest) (*TxnResponse, error) + type LeaseClient interface + LeaseGrant func(ctx context.Context, in *LeaseGrantRequest, opts ...grpc.CallOption) (*LeaseGrantResponse, error) + LeaseKeepAlive func(ctx context.Context, opts ...grpc.CallOption) (Lease_LeaseKeepAliveClient, error) + LeaseRevoke func(ctx context.Context, in *LeaseRevokeRequest, opts ...grpc.CallOption) (*LeaseRevokeResponse, error) + LeaseTimeToLive func(ctx context.Context, in *LeaseTimeToLiveRequest, opts ...grpc.CallOption) (*LeaseTimeToLiveResponse, error) + func NewLeaseClient(cc *grpc.ClientConn) LeaseClient + type LeaseGrantRequest struct + ID int64 + TTL int64 + func (*LeaseGrantRequest) Descriptor() ([]byte, []int) + func (*LeaseGrantRequest) ProtoMessage() + func (m *LeaseGrantRequest) Marshal() (dAtA []byte, err error) + func (m *LeaseGrantRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LeaseGrantRequest) Reset() + func (m *LeaseGrantRequest) Size() (n int) + func (m *LeaseGrantRequest) String() string + func (m *LeaseGrantRequest) Unmarshal(dAtA []byte) error + type LeaseGrantResponse struct + Error string + Header *ResponseHeader + ID int64 + TTL int64 + func (*LeaseGrantResponse) Descriptor() ([]byte, []int) + func (*LeaseGrantResponse) ProtoMessage() + func (m *LeaseGrantResponse) GetHeader() *ResponseHeader + func (m *LeaseGrantResponse) Marshal() (dAtA []byte, err error) + func (m *LeaseGrantResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LeaseGrantResponse) Reset() + func (m *LeaseGrantResponse) Size() (n int) + func (m *LeaseGrantResponse) String() string + func (m *LeaseGrantResponse) Unmarshal(dAtA []byte) error + type LeaseKeepAliveRequest struct + ID int64 + func (*LeaseKeepAliveRequest) Descriptor() ([]byte, []int) + func (*LeaseKeepAliveRequest) ProtoMessage() + func (m *LeaseKeepAliveRequest) Marshal() (dAtA []byte, err error) + func (m *LeaseKeepAliveRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LeaseKeepAliveRequest) Reset() + func (m *LeaseKeepAliveRequest) Size() (n int) + func (m *LeaseKeepAliveRequest) String() string + func (m *LeaseKeepAliveRequest) Unmarshal(dAtA []byte) error + type LeaseKeepAliveResponse struct + Header *ResponseHeader + ID int64 + TTL int64 + func (*LeaseKeepAliveResponse) Descriptor() ([]byte, []int) + func (*LeaseKeepAliveResponse) ProtoMessage() + func (m *LeaseKeepAliveResponse) GetHeader() *ResponseHeader + func (m *LeaseKeepAliveResponse) Marshal() (dAtA []byte, err error) + func (m *LeaseKeepAliveResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LeaseKeepAliveResponse) Reset() + func (m *LeaseKeepAliveResponse) Size() (n int) + func (m *LeaseKeepAliveResponse) String() string + func (m *LeaseKeepAliveResponse) Unmarshal(dAtA []byte) error + type LeaseRevokeRequest struct + ID int64 + func (*LeaseRevokeRequest) Descriptor() ([]byte, []int) + func (*LeaseRevokeRequest) ProtoMessage() + func (m *LeaseRevokeRequest) Marshal() (dAtA []byte, err error) + func (m *LeaseRevokeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LeaseRevokeRequest) Reset() + func (m *LeaseRevokeRequest) Size() (n int) + func (m *LeaseRevokeRequest) String() string + func (m *LeaseRevokeRequest) Unmarshal(dAtA []byte) error + type LeaseRevokeResponse struct + Header *ResponseHeader + func (*LeaseRevokeResponse) Descriptor() ([]byte, []int) + func (*LeaseRevokeResponse) ProtoMessage() + func (m *LeaseRevokeResponse) GetHeader() *ResponseHeader + func (m *LeaseRevokeResponse) Marshal() (dAtA []byte, err error) + func (m *LeaseRevokeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LeaseRevokeResponse) Reset() + func (m *LeaseRevokeResponse) Size() (n int) + func (m *LeaseRevokeResponse) String() string + func (m *LeaseRevokeResponse) Unmarshal(dAtA []byte) error + type LeaseServer interface + LeaseGrant func(context.Context, *LeaseGrantRequest) (*LeaseGrantResponse, error) + LeaseKeepAlive func(Lease_LeaseKeepAliveServer) error + LeaseRevoke func(context.Context, *LeaseRevokeRequest) (*LeaseRevokeResponse, error) + LeaseTimeToLive func(context.Context, *LeaseTimeToLiveRequest) (*LeaseTimeToLiveResponse, error) + type LeaseTimeToLiveRequest struct + ID int64 + Keys bool + func (*LeaseTimeToLiveRequest) Descriptor() ([]byte, []int) + func (*LeaseTimeToLiveRequest) ProtoMessage() + func (m *LeaseTimeToLiveRequest) Marshal() (dAtA []byte, err error) + func (m *LeaseTimeToLiveRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LeaseTimeToLiveRequest) Reset() + func (m *LeaseTimeToLiveRequest) Size() (n int) + func (m *LeaseTimeToLiveRequest) String() string + func (m *LeaseTimeToLiveRequest) Unmarshal(dAtA []byte) error + type LeaseTimeToLiveResponse struct + GrantedTTL int64 + Header *ResponseHeader + ID int64 + Keys [][]byte + TTL int64 + func (*LeaseTimeToLiveResponse) Descriptor() ([]byte, []int) + func (*LeaseTimeToLiveResponse) ProtoMessage() + func (m *LeaseTimeToLiveResponse) GetHeader() *ResponseHeader + func (m *LeaseTimeToLiveResponse) Marshal() (dAtA []byte, err error) + func (m *LeaseTimeToLiveResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LeaseTimeToLiveResponse) Reset() + func (m *LeaseTimeToLiveResponse) Size() (n int) + func (m *LeaseTimeToLiveResponse) String() string + func (m *LeaseTimeToLiveResponse) Unmarshal(dAtA []byte) error + type Lease_LeaseKeepAliveClient interface + Recv func() (*LeaseKeepAliveResponse, error) + Send func(*LeaseKeepAliveRequest) error + type Lease_LeaseKeepAliveServer interface + Recv func() (*LeaseKeepAliveRequest, error) + Send func(*LeaseKeepAliveResponse) error + type MaintenanceClient interface + Alarm func(ctx context.Context, in *AlarmRequest, opts ...grpc.CallOption) (*AlarmResponse, error) + Defragment func(ctx context.Context, in *DefragmentRequest, opts ...grpc.CallOption) (*DefragmentResponse, error) + Hash func(ctx context.Context, in *HashRequest, opts ...grpc.CallOption) (*HashResponse, error) + Snapshot func(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (Maintenance_SnapshotClient, error) + Status func(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error) + func NewMaintenanceClient(cc *grpc.ClientConn) MaintenanceClient + type MaintenanceServer interface + Alarm func(context.Context, *AlarmRequest) (*AlarmResponse, error) + Defragment func(context.Context, *DefragmentRequest) (*DefragmentResponse, error) + Hash func(context.Context, *HashRequest) (*HashResponse, error) + Snapshot func(*SnapshotRequest, Maintenance_SnapshotServer) error + Status func(context.Context, *StatusRequest) (*StatusResponse, error) + type Maintenance_SnapshotClient interface + Recv func() (*SnapshotResponse, error) + type Maintenance_SnapshotServer interface + Send func(*SnapshotResponse) error + type Member struct + ClientURLs []string + ID uint64 + Name string + PeerURLs []string + func (*Member) Descriptor() ([]byte, []int) + func (*Member) ProtoMessage() + func (m *Member) Marshal() (dAtA []byte, err error) + func (m *Member) MarshalTo(dAtA []byte) (int, error) + func (m *Member) Reset() + func (m *Member) Size() (n int) + func (m *Member) String() string + func (m *Member) Unmarshal(dAtA []byte) error + type MemberAddRequest struct + PeerURLs []string + func (*MemberAddRequest) Descriptor() ([]byte, []int) + func (*MemberAddRequest) ProtoMessage() + func (m *MemberAddRequest) Marshal() (dAtA []byte, err error) + func (m *MemberAddRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MemberAddRequest) Reset() + func (m *MemberAddRequest) Size() (n int) + func (m *MemberAddRequest) String() string + func (m *MemberAddRequest) Unmarshal(dAtA []byte) error + type MemberAddResponse struct + Header *ResponseHeader + Member *Member + Members []*Member + func (*MemberAddResponse) Descriptor() ([]byte, []int) + func (*MemberAddResponse) ProtoMessage() + func (m *MemberAddResponse) GetHeader() *ResponseHeader + func (m *MemberAddResponse) GetMember() *Member + func (m *MemberAddResponse) GetMembers() []*Member + func (m *MemberAddResponse) Marshal() (dAtA []byte, err error) + func (m *MemberAddResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MemberAddResponse) Reset() + func (m *MemberAddResponse) Size() (n int) + func (m *MemberAddResponse) String() string + func (m *MemberAddResponse) Unmarshal(dAtA []byte) error + type MemberListRequest struct + func (*MemberListRequest) Descriptor() ([]byte, []int) + func (*MemberListRequest) ProtoMessage() + func (m *MemberListRequest) Marshal() (dAtA []byte, err error) + func (m *MemberListRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MemberListRequest) Reset() + func (m *MemberListRequest) Size() (n int) + func (m *MemberListRequest) String() string + func (m *MemberListRequest) Unmarshal(dAtA []byte) error + type MemberListResponse struct + Header *ResponseHeader + Members []*Member + func (*MemberListResponse) Descriptor() ([]byte, []int) + func (*MemberListResponse) ProtoMessage() + func (m *MemberListResponse) GetHeader() *ResponseHeader + func (m *MemberListResponse) GetMembers() []*Member + func (m *MemberListResponse) Marshal() (dAtA []byte, err error) + func (m *MemberListResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MemberListResponse) Reset() + func (m *MemberListResponse) Size() (n int) + func (m *MemberListResponse) String() string + func (m *MemberListResponse) Unmarshal(dAtA []byte) error + type MemberRemoveRequest struct + ID uint64 + func (*MemberRemoveRequest) Descriptor() ([]byte, []int) + func (*MemberRemoveRequest) ProtoMessage() + func (m *MemberRemoveRequest) Marshal() (dAtA []byte, err error) + func (m *MemberRemoveRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MemberRemoveRequest) Reset() + func (m *MemberRemoveRequest) Size() (n int) + func (m *MemberRemoveRequest) String() string + func (m *MemberRemoveRequest) Unmarshal(dAtA []byte) error + type MemberRemoveResponse struct + Header *ResponseHeader + Members []*Member + func (*MemberRemoveResponse) Descriptor() ([]byte, []int) + func (*MemberRemoveResponse) ProtoMessage() + func (m *MemberRemoveResponse) GetHeader() *ResponseHeader + func (m *MemberRemoveResponse) GetMembers() []*Member + func (m *MemberRemoveResponse) Marshal() (dAtA []byte, err error) + func (m *MemberRemoveResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MemberRemoveResponse) Reset() + func (m *MemberRemoveResponse) Size() (n int) + func (m *MemberRemoveResponse) String() string + func (m *MemberRemoveResponse) Unmarshal(dAtA []byte) error + type MemberUpdateRequest struct + ID uint64 + PeerURLs []string + func (*MemberUpdateRequest) Descriptor() ([]byte, []int) + func (*MemberUpdateRequest) ProtoMessage() + func (m *MemberUpdateRequest) Marshal() (dAtA []byte, err error) + func (m *MemberUpdateRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MemberUpdateRequest) Reset() + func (m *MemberUpdateRequest) Size() (n int) + func (m *MemberUpdateRequest) String() string + func (m *MemberUpdateRequest) Unmarshal(dAtA []byte) error + type MemberUpdateResponse struct + Header *ResponseHeader + Members []*Member + func (*MemberUpdateResponse) Descriptor() ([]byte, []int) + func (*MemberUpdateResponse) ProtoMessage() + func (m *MemberUpdateResponse) GetHeader() *ResponseHeader + func (m *MemberUpdateResponse) GetMembers() []*Member + func (m *MemberUpdateResponse) Marshal() (dAtA []byte, err error) + func (m *MemberUpdateResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MemberUpdateResponse) Reset() + func (m *MemberUpdateResponse) Size() (n int) + func (m *MemberUpdateResponse) String() string + func (m *MemberUpdateResponse) Unmarshal(dAtA []byte) error + type Metadata struct + ClusterID uint64 + NodeID uint64 + XXX_unrecognized []byte + func (*Metadata) Descriptor() ([]byte, []int) + func (*Metadata) ProtoMessage() + func (m *Metadata) Marshal() (dAtA []byte, err error) + func (m *Metadata) MarshalTo(dAtA []byte) (int, error) + func (m *Metadata) Reset() + func (m *Metadata) Size() (n int) + func (m *Metadata) String() string + func (m *Metadata) Unmarshal(dAtA []byte) error + type PutRequest struct + IgnoreLease bool + IgnoreValue bool + Key []byte + Lease int64 + PrevKv bool + Value []byte + func (*PutRequest) Descriptor() ([]byte, []int) + func (*PutRequest) ProtoMessage() + func (m *PutRequest) Marshal() (dAtA []byte, err error) + func (m *PutRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PutRequest) Reset() + func (m *PutRequest) Size() (n int) + func (m *PutRequest) String() string + func (m *PutRequest) Unmarshal(dAtA []byte) error + type PutResponse struct + Header *ResponseHeader + PrevKv *mvccpb.KeyValue + func (*PutResponse) Descriptor() ([]byte, []int) + func (*PutResponse) ProtoMessage() + func (m *PutResponse) GetHeader() *ResponseHeader + func (m *PutResponse) GetPrevKv() *mvccpb.KeyValue + func (m *PutResponse) Marshal() (dAtA []byte, err error) + func (m *PutResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PutResponse) Reset() + func (m *PutResponse) Size() (n int) + func (m *PutResponse) String() string + func (m *PutResponse) Unmarshal(dAtA []byte) error + type RangeRequest struct + CountOnly bool + Key []byte + KeysOnly bool + Limit int64 + MaxCreateRevision int64 + MaxModRevision int64 + MinCreateRevision int64 + MinModRevision int64 + RangeEnd []byte + Revision int64 + Serializable bool + SortOrder RangeRequest_SortOrder + SortTarget RangeRequest_SortTarget + func (*RangeRequest) Descriptor() ([]byte, []int) + func (*RangeRequest) ProtoMessage() + func (m *RangeRequest) Marshal() (dAtA []byte, err error) + func (m *RangeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RangeRequest) Reset() + func (m *RangeRequest) Size() (n int) + func (m *RangeRequest) String() string + func (m *RangeRequest) Unmarshal(dAtA []byte) error + type RangeRequest_SortOrder int32 + const RangeRequest_ASCEND + const RangeRequest_DESCEND + const RangeRequest_NONE + func (RangeRequest_SortOrder) EnumDescriptor() ([]byte, []int) + func (x RangeRequest_SortOrder) String() string + type RangeRequest_SortTarget int32 + const RangeRequest_CREATE + const RangeRequest_KEY + const RangeRequest_MOD + const RangeRequest_VALUE + const RangeRequest_VERSION + func (RangeRequest_SortTarget) EnumDescriptor() ([]byte, []int) + func (x RangeRequest_SortTarget) String() string + type RangeResponse struct + Count int64 + Header *ResponseHeader + Kvs []*mvccpb.KeyValue + More bool + func (*RangeResponse) Descriptor() ([]byte, []int) + func (*RangeResponse) ProtoMessage() + func (m *RangeResponse) GetHeader() *ResponseHeader + func (m *RangeResponse) GetKvs() []*mvccpb.KeyValue + func (m *RangeResponse) Marshal() (dAtA []byte, err error) + func (m *RangeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RangeResponse) Reset() + func (m *RangeResponse) Size() (n int) + func (m *RangeResponse) String() string + func (m *RangeResponse) Unmarshal(dAtA []byte) error + type Request struct + Dir bool + Expiration int64 + ID uint64 + Method string + Path string + PrevExist *bool + PrevIndex uint64 + PrevValue string + Quorum bool + Recursive bool + Refresh *bool + Since uint64 + Sorted bool + Stream bool + Time int64 + Val string + Wait bool + XXX_unrecognized []byte + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) Marshal() (dAtA []byte, err error) + func (m *Request) MarshalTo(dAtA []byte) (int, error) + func (m *Request) Reset() + func (m *Request) Size() (n int) + func (m *Request) String() string + func (m *Request) Unmarshal(dAtA []byte) error + type RequestHeader struct + AuthRevision uint64 + ID uint64 + Username string + func (*RequestHeader) Descriptor() ([]byte, []int) + func (*RequestHeader) ProtoMessage() + func (m *RequestHeader) Marshal() (dAtA []byte, err error) + func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error) + func (m *RequestHeader) Reset() + func (m *RequestHeader) Size() (n int) + func (m *RequestHeader) String() string + func (m *RequestHeader) Unmarshal(dAtA []byte) error + type RequestOp struct + Request isRequestOp_Request + func (*RequestOp) Descriptor() ([]byte, []int) + func (*RequestOp) ProtoMessage() + func (*RequestOp) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *RequestOp) GetRequest() isRequestOp_Request + func (m *RequestOp) GetRequestDeleteRange() *DeleteRangeRequest + func (m *RequestOp) GetRequestPut() *PutRequest + func (m *RequestOp) GetRequestRange() *RangeRequest + func (m *RequestOp) Marshal() (dAtA []byte, err error) + func (m *RequestOp) MarshalTo(dAtA []byte) (int, error) + func (m *RequestOp) Reset() + func (m *RequestOp) Size() (n int) + func (m *RequestOp) String() string + func (m *RequestOp) Unmarshal(dAtA []byte) error + type RequestOp_RequestDeleteRange struct + RequestDeleteRange *DeleteRangeRequest + func (m *RequestOp_RequestDeleteRange) MarshalTo(dAtA []byte) (int, error) + func (m *RequestOp_RequestDeleteRange) Size() (n int) + type RequestOp_RequestPut struct + RequestPut *PutRequest + func (m *RequestOp_RequestPut) MarshalTo(dAtA []byte) (int, error) + func (m *RequestOp_RequestPut) Size() (n int) + type RequestOp_RequestRange struct + RequestRange *RangeRequest + func (m *RequestOp_RequestRange) MarshalTo(dAtA []byte) (int, error) + func (m *RequestOp_RequestRange) Size() (n int) + type ResponseHeader struct + ClusterId uint64 + MemberId uint64 + RaftTerm uint64 + Revision int64 + func (*ResponseHeader) Descriptor() ([]byte, []int) + func (*ResponseHeader) ProtoMessage() + func (m *ResponseHeader) Marshal() (dAtA []byte, err error) + func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseHeader) Reset() + func (m *ResponseHeader) Size() (n int) + func (m *ResponseHeader) String() string + func (m *ResponseHeader) Unmarshal(dAtA []byte) error + type ResponseOp struct + Response isResponseOp_Response + func (*ResponseOp) Descriptor() ([]byte, []int) + func (*ResponseOp) ProtoMessage() + func (*ResponseOp) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *ResponseOp) GetResponse() isResponseOp_Response + func (m *ResponseOp) GetResponseDeleteRange() *DeleteRangeResponse + func (m *ResponseOp) GetResponsePut() *PutResponse + func (m *ResponseOp) GetResponseRange() *RangeResponse + func (m *ResponseOp) Marshal() (dAtA []byte, err error) + func (m *ResponseOp) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseOp) Reset() + func (m *ResponseOp) Size() (n int) + func (m *ResponseOp) String() string + func (m *ResponseOp) Unmarshal(dAtA []byte) error + type ResponseOp_ResponseDeleteRange struct + ResponseDeleteRange *DeleteRangeResponse + func (m *ResponseOp_ResponseDeleteRange) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseOp_ResponseDeleteRange) Size() (n int) + type ResponseOp_ResponsePut struct + ResponsePut *PutResponse + func (m *ResponseOp_ResponsePut) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseOp_ResponsePut) Size() (n int) + type ResponseOp_ResponseRange struct + ResponseRange *RangeResponse + func (m *ResponseOp_ResponseRange) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseOp_ResponseRange) Size() (n int) + type SnapshotRequest struct + func (*SnapshotRequest) Descriptor() ([]byte, []int) + func (*SnapshotRequest) ProtoMessage() + func (m *SnapshotRequest) Marshal() (dAtA []byte, err error) + func (m *SnapshotRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotRequest) Reset() + func (m *SnapshotRequest) Size() (n int) + func (m *SnapshotRequest) String() string + func (m *SnapshotRequest) Unmarshal(dAtA []byte) error + type SnapshotResponse struct + Blob []byte + Header *ResponseHeader + RemainingBytes uint64 + func (*SnapshotResponse) Descriptor() ([]byte, []int) + func (*SnapshotResponse) ProtoMessage() + func (m *SnapshotResponse) GetHeader() *ResponseHeader + func (m *SnapshotResponse) Marshal() (dAtA []byte, err error) + func (m *SnapshotResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotResponse) Reset() + func (m *SnapshotResponse) Size() (n int) + func (m *SnapshotResponse) String() string + func (m *SnapshotResponse) Unmarshal(dAtA []byte) error + type StatusRequest struct + func (*StatusRequest) Descriptor() ([]byte, []int) + func (*StatusRequest) ProtoMessage() + func (m *StatusRequest) Marshal() (dAtA []byte, err error) + func (m *StatusRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StatusRequest) Reset() + func (m *StatusRequest) Size() (n int) + func (m *StatusRequest) String() string + func (m *StatusRequest) Unmarshal(dAtA []byte) error + type StatusResponse struct + DbSize int64 + Header *ResponseHeader + Leader uint64 + RaftIndex uint64 + RaftTerm uint64 + Version string + func (*StatusResponse) Descriptor() ([]byte, []int) + func (*StatusResponse) ProtoMessage() + func (m *StatusResponse) GetHeader() *ResponseHeader + func (m *StatusResponse) Marshal() (dAtA []byte, err error) + func (m *StatusResponse) MarshalTo(dAtA []byte) (int, error) + func (m *StatusResponse) Reset() + func (m *StatusResponse) Size() (n int) + func (m *StatusResponse) String() string + func (m *StatusResponse) Unmarshal(dAtA []byte) error + type TxnRequest struct + Compare []*Compare + Failure []*RequestOp + Success []*RequestOp + func (*TxnRequest) Descriptor() ([]byte, []int) + func (*TxnRequest) ProtoMessage() + func (m *TxnRequest) GetCompare() []*Compare + func (m *TxnRequest) GetFailure() []*RequestOp + func (m *TxnRequest) GetSuccess() []*RequestOp + func (m *TxnRequest) Marshal() (dAtA []byte, err error) + func (m *TxnRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TxnRequest) Reset() + func (m *TxnRequest) Size() (n int) + func (m *TxnRequest) String() string + func (m *TxnRequest) Unmarshal(dAtA []byte) error + type TxnResponse struct + Header *ResponseHeader + Responses []*ResponseOp + Succeeded bool + func (*TxnResponse) Descriptor() ([]byte, []int) + func (*TxnResponse) ProtoMessage() + func (m *TxnResponse) GetHeader() *ResponseHeader + func (m *TxnResponse) GetResponses() []*ResponseOp + func (m *TxnResponse) Marshal() (dAtA []byte, err error) + func (m *TxnResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TxnResponse) Reset() + func (m *TxnResponse) Size() (n int) + func (m *TxnResponse) String() string + func (m *TxnResponse) Unmarshal(dAtA []byte) error + type WatchCancelRequest struct + WatchId int64 + func (*WatchCancelRequest) Descriptor() ([]byte, []int) + func (*WatchCancelRequest) ProtoMessage() + func (m *WatchCancelRequest) Marshal() (dAtA []byte, err error) + func (m *WatchCancelRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WatchCancelRequest) Reset() + func (m *WatchCancelRequest) Size() (n int) + func (m *WatchCancelRequest) String() string + func (m *WatchCancelRequest) Unmarshal(dAtA []byte) error + type WatchClient interface + Watch func(ctx context.Context, opts ...grpc.CallOption) (Watch_WatchClient, error) + func NewWatchClient(cc *grpc.ClientConn) WatchClient + type WatchCreateRequest struct + Filters []WatchCreateRequest_FilterType + Key []byte + PrevKv bool + ProgressNotify bool + RangeEnd []byte + StartRevision int64 + func (*WatchCreateRequest) Descriptor() ([]byte, []int) + func (*WatchCreateRequest) ProtoMessage() + func (m *WatchCreateRequest) Marshal() (dAtA []byte, err error) + func (m *WatchCreateRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WatchCreateRequest) Reset() + func (m *WatchCreateRequest) Size() (n int) + func (m *WatchCreateRequest) String() string + func (m *WatchCreateRequest) Unmarshal(dAtA []byte) error + type WatchCreateRequest_FilterType int32 + const WatchCreateRequest_NODELETE + const WatchCreateRequest_NOPUT + func (WatchCreateRequest_FilterType) EnumDescriptor() ([]byte, []int) + func (x WatchCreateRequest_FilterType) String() string + type WatchRequest struct + RequestUnion isWatchRequest_RequestUnion + func (*WatchRequest) Descriptor() ([]byte, []int) + func (*WatchRequest) ProtoMessage() + func (*WatchRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *WatchRequest) GetCancelRequest() *WatchCancelRequest + func (m *WatchRequest) GetCreateRequest() *WatchCreateRequest + func (m *WatchRequest) GetRequestUnion() isWatchRequest_RequestUnion + func (m *WatchRequest) Marshal() (dAtA []byte, err error) + func (m *WatchRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WatchRequest) Reset() + func (m *WatchRequest) Size() (n int) + func (m *WatchRequest) String() string + func (m *WatchRequest) Unmarshal(dAtA []byte) error + type WatchRequest_CancelRequest struct + CancelRequest *WatchCancelRequest + func (m *WatchRequest_CancelRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WatchRequest_CancelRequest) Size() (n int) + type WatchRequest_CreateRequest struct + CreateRequest *WatchCreateRequest + func (m *WatchRequest_CreateRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WatchRequest_CreateRequest) Size() (n int) + type WatchResponse struct + CancelReason string + Canceled bool + CompactRevision int64 + Created bool + Events []*mvccpb.Event + Header *ResponseHeader + WatchId int64 + func (*WatchResponse) Descriptor() ([]byte, []int) + func (*WatchResponse) ProtoMessage() + func (m *WatchResponse) GetEvents() []*mvccpb.Event + func (m *WatchResponse) GetHeader() *ResponseHeader + func (m *WatchResponse) Marshal() (dAtA []byte, err error) + func (m *WatchResponse) MarshalTo(dAtA []byte) (int, error) + func (m *WatchResponse) Reset() + func (m *WatchResponse) Size() (n int) + func (m *WatchResponse) String() string + func (m *WatchResponse) Unmarshal(dAtA []byte) error + type WatchServer interface + Watch func(Watch_WatchServer) error + type Watch_WatchClient interface + Recv func() (*WatchResponse, error) + Send func(*WatchRequest) error + type Watch_WatchServer interface + Recv func() (*WatchRequest, error) + Send func(*WatchResponse) error