Versions in this module Expand all Collapse all v1 v1.1.0-alpha Oct 31, 2017 v1.0.9 Apr 20, 2018 v1.0.8 Feb 11, 2018 v1.0.7 Jan 19, 2018 v1.0.6 Jan 8, 2018 v1.0.5 Dec 26, 2017 v1.0.4 Dec 11, 2017 v1.0.3 Nov 25, 2017 v1.0.2 Nov 13, 2017 v1.0.1 Oct 31, 2017 v1.0.0 Oct 16, 2017 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