etcdserverpb

Aug 19, 2019

Changes in this version

type AlarmMember

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AlarmMember) XXX_DiscardUnknown()

+ func (m *AlarmMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AlarmMember) XXX_Merge(src proto.Message)

+ func (m *AlarmMember) XXX_Size() int

+ func (m *AlarmMember) XXX_Unmarshal(b []byte) error

type AlarmRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AlarmRequest) XXX_DiscardUnknown()

+ func (m *AlarmRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AlarmRequest) XXX_Merge(src proto.Message)

+ func (m *AlarmRequest) XXX_Size() int

+ func (m *AlarmRequest) XXX_Unmarshal(b []byte) error

type AlarmResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AlarmResponse) XXX_DiscardUnknown()

+ func (m *AlarmResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AlarmResponse) XXX_Merge(src proto.Message)

+ func (m *AlarmResponse) XXX_Size() int

+ func (m *AlarmResponse) XXX_Unmarshal(b []byte) error

type AuthDisableRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthDisableRequest) XXX_DiscardUnknown()

+ func (m *AuthDisableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthDisableRequest) XXX_Merge(src proto.Message)

+ func (m *AuthDisableRequest) XXX_Size() int

+ func (m *AuthDisableRequest) XXX_Unmarshal(b []byte) error

type AuthDisableResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthDisableResponse) XXX_DiscardUnknown()

+ func (m *AuthDisableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthDisableResponse) XXX_Merge(src proto.Message)

+ func (m *AuthDisableResponse) XXX_Size() int

+ func (m *AuthDisableResponse) XXX_Unmarshal(b []byte) error

type AuthEnableRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthEnableRequest) XXX_DiscardUnknown()

+ func (m *AuthEnableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthEnableRequest) XXX_Merge(src proto.Message)

+ func (m *AuthEnableRequest) XXX_Size() int

+ func (m *AuthEnableRequest) XXX_Unmarshal(b []byte) error

type AuthEnableResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthEnableResponse) XXX_DiscardUnknown()

+ func (m *AuthEnableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthEnableResponse) XXX_Merge(src proto.Message)

+ func (m *AuthEnableResponse) XXX_Size() int

+ func (m *AuthEnableResponse) XXX_Unmarshal(b []byte) error

type AuthRoleAddRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthRoleAddRequest) XXX_DiscardUnknown()

+ func (m *AuthRoleAddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthRoleAddRequest) XXX_Merge(src proto.Message)

+ func (m *AuthRoleAddRequest) XXX_Size() int

+ func (m *AuthRoleAddRequest) XXX_Unmarshal(b []byte) error

type AuthRoleAddResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthRoleAddResponse) XXX_DiscardUnknown()

+ func (m *AuthRoleAddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthRoleAddResponse) XXX_Merge(src proto.Message)

+ func (m *AuthRoleAddResponse) XXX_Size() int

+ func (m *AuthRoleAddResponse) XXX_Unmarshal(b []byte) error

type AuthRoleDeleteRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthRoleDeleteRequest) XXX_DiscardUnknown()

+ func (m *AuthRoleDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthRoleDeleteRequest) XXX_Merge(src proto.Message)

+ func (m *AuthRoleDeleteRequest) XXX_Size() int

+ func (m *AuthRoleDeleteRequest) XXX_Unmarshal(b []byte) error

type AuthRoleDeleteResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthRoleDeleteResponse) XXX_DiscardUnknown()

+ func (m *AuthRoleDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthRoleDeleteResponse) XXX_Merge(src proto.Message)

+ func (m *AuthRoleDeleteResponse) XXX_Size() int

+ func (m *AuthRoleDeleteResponse) XXX_Unmarshal(b []byte) error

type AuthRoleGetRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthRoleGetRequest) XXX_DiscardUnknown()

+ func (m *AuthRoleGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthRoleGetRequest) XXX_Merge(src proto.Message)

+ func (m *AuthRoleGetRequest) XXX_Size() int

+ func (m *AuthRoleGetRequest) XXX_Unmarshal(b []byte) error

type AuthRoleGetResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthRoleGetResponse) XXX_DiscardUnknown()

+ func (m *AuthRoleGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthRoleGetResponse) XXX_Merge(src proto.Message)

+ func (m *AuthRoleGetResponse) XXX_Size() int

+ func (m *AuthRoleGetResponse) XXX_Unmarshal(b []byte) error

type AuthRoleGrantPermissionRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthRoleGrantPermissionRequest) XXX_DiscardUnknown()

+ func (m *AuthRoleGrantPermissionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthRoleGrantPermissionRequest) XXX_Merge(src proto.Message)

+ func (m *AuthRoleGrantPermissionRequest) XXX_Size() int

+ func (m *AuthRoleGrantPermissionRequest) XXX_Unmarshal(b []byte) error

type AuthRoleGrantPermissionResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthRoleGrantPermissionResponse) XXX_DiscardUnknown()

+ func (m *AuthRoleGrantPermissionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthRoleGrantPermissionResponse) XXX_Merge(src proto.Message)

+ func (m *AuthRoleGrantPermissionResponse) XXX_Size() int

+ func (m *AuthRoleGrantPermissionResponse) XXX_Unmarshal(b []byte) error

type AuthRoleListRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthRoleListRequest) XXX_DiscardUnknown()

+ func (m *AuthRoleListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthRoleListRequest) XXX_Merge(src proto.Message)

+ func (m *AuthRoleListRequest) XXX_Size() int

+ func (m *AuthRoleListRequest) XXX_Unmarshal(b []byte) error

type AuthRoleListResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthRoleListResponse) XXX_DiscardUnknown()

+ func (m *AuthRoleListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthRoleListResponse) XXX_Merge(src proto.Message)

+ func (m *AuthRoleListResponse) XXX_Size() int

+ func (m *AuthRoleListResponse) XXX_Unmarshal(b []byte) error

type AuthRoleRevokePermissionRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthRoleRevokePermissionRequest) XXX_DiscardUnknown()

+ func (m *AuthRoleRevokePermissionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthRoleRevokePermissionRequest) XXX_Merge(src proto.Message)

+ func (m *AuthRoleRevokePermissionRequest) XXX_Size() int

+ func (m *AuthRoleRevokePermissionRequest) XXX_Unmarshal(b []byte) error

type AuthRoleRevokePermissionResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthRoleRevokePermissionResponse) XXX_DiscardUnknown()

+ func (m *AuthRoleRevokePermissionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthRoleRevokePermissionResponse) XXX_Merge(src proto.Message)

+ func (m *AuthRoleRevokePermissionResponse) XXX_Size() int

+ func (m *AuthRoleRevokePermissionResponse) XXX_Unmarshal(b []byte) error

type AuthUserAddRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserAddRequest) XXX_DiscardUnknown()

+ func (m *AuthUserAddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserAddRequest) XXX_Merge(src proto.Message)

+ func (m *AuthUserAddRequest) XXX_Size() int

+ func (m *AuthUserAddRequest) XXX_Unmarshal(b []byte) error

type AuthUserAddResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserAddResponse) XXX_DiscardUnknown()

+ func (m *AuthUserAddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserAddResponse) XXX_Merge(src proto.Message)

+ func (m *AuthUserAddResponse) XXX_Size() int

+ func (m *AuthUserAddResponse) XXX_Unmarshal(b []byte) error

type AuthUserChangePasswordRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserChangePasswordRequest) XXX_DiscardUnknown()

+ func (m *AuthUserChangePasswordRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserChangePasswordRequest) XXX_Merge(src proto.Message)

+ func (m *AuthUserChangePasswordRequest) XXX_Size() int

+ func (m *AuthUserChangePasswordRequest) XXX_Unmarshal(b []byte) error

type AuthUserChangePasswordResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserChangePasswordResponse) XXX_DiscardUnknown()

+ func (m *AuthUserChangePasswordResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserChangePasswordResponse) XXX_Merge(src proto.Message)

+ func (m *AuthUserChangePasswordResponse) XXX_Size() int

+ func (m *AuthUserChangePasswordResponse) XXX_Unmarshal(b []byte) error

type AuthUserDeleteRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserDeleteRequest) XXX_DiscardUnknown()

+ func (m *AuthUserDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserDeleteRequest) XXX_Merge(src proto.Message)

+ func (m *AuthUserDeleteRequest) XXX_Size() int

+ func (m *AuthUserDeleteRequest) XXX_Unmarshal(b []byte) error

type AuthUserDeleteResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserDeleteResponse) XXX_DiscardUnknown()

+ func (m *AuthUserDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserDeleteResponse) XXX_Merge(src proto.Message)

+ func (m *AuthUserDeleteResponse) XXX_Size() int

+ func (m *AuthUserDeleteResponse) XXX_Unmarshal(b []byte) error

type AuthUserGetRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserGetRequest) XXX_DiscardUnknown()

+ func (m *AuthUserGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserGetRequest) XXX_Merge(src proto.Message)

+ func (m *AuthUserGetRequest) XXX_Size() int

+ func (m *AuthUserGetRequest) XXX_Unmarshal(b []byte) error

type AuthUserGetResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserGetResponse) XXX_DiscardUnknown()

+ func (m *AuthUserGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserGetResponse) XXX_Merge(src proto.Message)

+ func (m *AuthUserGetResponse) XXX_Size() int

+ func (m *AuthUserGetResponse) XXX_Unmarshal(b []byte) error

type AuthUserGrantRoleRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserGrantRoleRequest) XXX_DiscardUnknown()

+ func (m *AuthUserGrantRoleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserGrantRoleRequest) XXX_Merge(src proto.Message)

+ func (m *AuthUserGrantRoleRequest) XXX_Size() int

+ func (m *AuthUserGrantRoleRequest) XXX_Unmarshal(b []byte) error

type AuthUserGrantRoleResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserGrantRoleResponse) XXX_DiscardUnknown()

+ func (m *AuthUserGrantRoleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserGrantRoleResponse) XXX_Merge(src proto.Message)

+ func (m *AuthUserGrantRoleResponse) XXX_Size() int

+ func (m *AuthUserGrantRoleResponse) XXX_Unmarshal(b []byte) error

type AuthUserListRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserListRequest) XXX_DiscardUnknown()

+ func (m *AuthUserListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserListRequest) XXX_Merge(src proto.Message)

+ func (m *AuthUserListRequest) XXX_Size() int

+ func (m *AuthUserListRequest) XXX_Unmarshal(b []byte) error

type AuthUserListResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserListResponse) XXX_DiscardUnknown()

+ func (m *AuthUserListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserListResponse) XXX_Merge(src proto.Message)

+ func (m *AuthUserListResponse) XXX_Size() int

+ func (m *AuthUserListResponse) XXX_Unmarshal(b []byte) error

type AuthUserRevokeRoleRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserRevokeRoleRequest) XXX_DiscardUnknown()

+ func (m *AuthUserRevokeRoleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserRevokeRoleRequest) XXX_Merge(src proto.Message)

+ func (m *AuthUserRevokeRoleRequest) XXX_Size() int

+ func (m *AuthUserRevokeRoleRequest) XXX_Unmarshal(b []byte) error

type AuthUserRevokeRoleResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthUserRevokeRoleResponse) XXX_DiscardUnknown()

+ func (m *AuthUserRevokeRoleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthUserRevokeRoleResponse) XXX_Merge(src proto.Message)

+ func (m *AuthUserRevokeRoleResponse) XXX_Size() int

+ func (m *AuthUserRevokeRoleResponse) XXX_Unmarshal(b []byte) error

type AuthenticateRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthenticateRequest) XXX_DiscardUnknown()

+ func (m *AuthenticateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthenticateRequest) XXX_Merge(src proto.Message)

+ func (m *AuthenticateRequest) XXX_Size() int

+ func (m *AuthenticateRequest) XXX_Unmarshal(b []byte) error

type AuthenticateResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AuthenticateResponse) XXX_DiscardUnknown()

+ func (m *AuthenticateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AuthenticateResponse) XXX_Merge(src proto.Message)

+ func (m *AuthenticateResponse) XXX_Size() int

+ func (m *AuthenticateResponse) XXX_Unmarshal(b []byte) error

type CompactionRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *CompactionRequest) XXX_DiscardUnknown()

+ func (m *CompactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CompactionRequest) XXX_Merge(src proto.Message)

+ func (m *CompactionRequest) XXX_Size() int

+ func (m *CompactionRequest) XXX_Unmarshal(b []byte) error

type CompactionResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *CompactionResponse) XXX_DiscardUnknown()

+ func (m *CompactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CompactionResponse) XXX_Merge(src proto.Message)

+ func (m *CompactionResponse) XXX_Size() int

+ func (m *CompactionResponse) XXX_Unmarshal(b []byte) error

type Compare

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *Compare) XXX_DiscardUnknown()

+ func (m *Compare) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Compare) XXX_Merge(src proto.Message)

+ func (m *Compare) XXX_Size() int

+ func (m *Compare) XXX_Unmarshal(b []byte) error

type Compare_CreateRevision

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

type Compare_Lease

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

type Compare_ModRevision

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

type Compare_Value

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

type Compare_Version

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

type DefragmentRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *DefragmentRequest) XXX_DiscardUnknown()

+ func (m *DefragmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DefragmentRequest) XXX_Merge(src proto.Message)

+ func (m *DefragmentRequest) XXX_Size() int

+ func (m *DefragmentRequest) XXX_Unmarshal(b []byte) error

type DefragmentResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *DefragmentResponse) XXX_DiscardUnknown()

+ func (m *DefragmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DefragmentResponse) XXX_Merge(src proto.Message)

+ func (m *DefragmentResponse) XXX_Size() int

+ func (m *DefragmentResponse) XXX_Unmarshal(b []byte) error

type DeleteRangeRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *DeleteRangeRequest) XXX_DiscardUnknown()

+ func (m *DeleteRangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeleteRangeRequest) XXX_Merge(src proto.Message)

+ func (m *DeleteRangeRequest) XXX_Size() int

+ func (m *DeleteRangeRequest) XXX_Unmarshal(b []byte) error

type DeleteRangeResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *DeleteRangeResponse) XXX_DiscardUnknown()

+ func (m *DeleteRangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeleteRangeResponse) XXX_Merge(src proto.Message)

+ func (m *DeleteRangeResponse) XXX_Size() int

+ func (m *DeleteRangeResponse) XXX_Unmarshal(b []byte) error

type EmptyResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *EmptyResponse) XXX_DiscardUnknown()

+ func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EmptyResponse) XXX_Merge(src proto.Message)

+ func (m *EmptyResponse) XXX_Size() int

+ func (m *EmptyResponse) XXX_Unmarshal(b []byte) error

type HashKVRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *HashKVRequest) XXX_DiscardUnknown()

+ func (m *HashKVRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HashKVRequest) XXX_Merge(src proto.Message)

+ func (m *HashKVRequest) XXX_Size() int

+ func (m *HashKVRequest) XXX_Unmarshal(b []byte) error

type HashKVResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *HashKVResponse) XXX_DiscardUnknown()

+ func (m *HashKVResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HashKVResponse) XXX_Merge(src proto.Message)

+ func (m *HashKVResponse) XXX_Size() int

+ func (m *HashKVResponse) XXX_Unmarshal(b []byte) error

type HashRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *HashRequest) XXX_DiscardUnknown()

+ func (m *HashRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HashRequest) XXX_Merge(src proto.Message)

+ func (m *HashRequest) XXX_Size() int

+ func (m *HashRequest) XXX_Unmarshal(b []byte) error

type HashResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *HashResponse) XXX_DiscardUnknown()

+ func (m *HashResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HashResponse) XXX_Merge(src proto.Message)

+ func (m *HashResponse) XXX_Size() int

+ func (m *HashResponse) XXX_Unmarshal(b []byte) error

type InternalAuthenticateRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *InternalAuthenticateRequest) XXX_DiscardUnknown()

+ func (m *InternalAuthenticateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *InternalAuthenticateRequest) XXX_Merge(src proto.Message)

+ func (m *InternalAuthenticateRequest) XXX_Size() int

+ func (m *InternalAuthenticateRequest) XXX_Unmarshal(b []byte) error

type InternalRaftRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *InternalRaftRequest) XXX_DiscardUnknown()

+ func (m *InternalRaftRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *InternalRaftRequest) XXX_Merge(src proto.Message)

+ func (m *InternalRaftRequest) XXX_Size() int

+ func (m *InternalRaftRequest) XXX_Unmarshal(b []byte) error

type LeaseGrantRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *LeaseGrantRequest) XXX_DiscardUnknown()

+ func (m *LeaseGrantRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaseGrantRequest) XXX_Merge(src proto.Message)

+ func (m *LeaseGrantRequest) XXX_Size() int

+ func (m *LeaseGrantRequest) XXX_Unmarshal(b []byte) error

type LeaseGrantResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *LeaseGrantResponse) XXX_DiscardUnknown()

+ func (m *LeaseGrantResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaseGrantResponse) XXX_Merge(src proto.Message)

+ func (m *LeaseGrantResponse) XXX_Size() int

+ func (m *LeaseGrantResponse) XXX_Unmarshal(b []byte) error

type LeaseKeepAliveRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *LeaseKeepAliveRequest) XXX_DiscardUnknown()

+ func (m *LeaseKeepAliveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaseKeepAliveRequest) XXX_Merge(src proto.Message)

+ func (m *LeaseKeepAliveRequest) XXX_Size() int

+ func (m *LeaseKeepAliveRequest) XXX_Unmarshal(b []byte) error

type LeaseKeepAliveResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *LeaseKeepAliveResponse) XXX_DiscardUnknown()

+ func (m *LeaseKeepAliveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaseKeepAliveResponse) XXX_Merge(src proto.Message)

+ func (m *LeaseKeepAliveResponse) XXX_Size() int

+ func (m *LeaseKeepAliveResponse) XXX_Unmarshal(b []byte) error

type LeaseLeasesRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *LeaseLeasesRequest) XXX_DiscardUnknown()

+ func (m *LeaseLeasesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaseLeasesRequest) XXX_Merge(src proto.Message)

+ func (m *LeaseLeasesRequest) XXX_Size() int

+ func (m *LeaseLeasesRequest) XXX_Unmarshal(b []byte) error

type LeaseLeasesResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *LeaseLeasesResponse) XXX_DiscardUnknown()

+ func (m *LeaseLeasesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaseLeasesResponse) XXX_Merge(src proto.Message)

+ func (m *LeaseLeasesResponse) XXX_Size() int

+ func (m *LeaseLeasesResponse) XXX_Unmarshal(b []byte) error

type LeaseRevokeRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *LeaseRevokeRequest) XXX_DiscardUnknown()

+ func (m *LeaseRevokeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaseRevokeRequest) XXX_Merge(src proto.Message)

+ func (m *LeaseRevokeRequest) XXX_Size() int

+ func (m *LeaseRevokeRequest) XXX_Unmarshal(b []byte) error

type LeaseRevokeResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *LeaseRevokeResponse) XXX_DiscardUnknown()

+ func (m *LeaseRevokeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaseRevokeResponse) XXX_Merge(src proto.Message)

+ func (m *LeaseRevokeResponse) XXX_Size() int

+ func (m *LeaseRevokeResponse) XXX_Unmarshal(b []byte) error

type LeaseStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *LeaseStatus) XXX_DiscardUnknown()

+ func (m *LeaseStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaseStatus) XXX_Merge(src proto.Message)

+ func (m *LeaseStatus) XXX_Size() int

+ func (m *LeaseStatus) XXX_Unmarshal(b []byte) error

type LeaseTimeToLiveRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *LeaseTimeToLiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LeaseTimeToLiveRequest) XXX_DiscardUnknown()

+ func (m *LeaseTimeToLiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaseTimeToLiveRequest) XXX_Merge(src proto.Message)

+ func (m *LeaseTimeToLiveRequest) XXX_Size() int

+ func (m *LeaseTimeToLiveRequest) XXX_Unmarshal(b []byte) error

type LeaseTimeToLiveResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *LeaseTimeToLiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LeaseTimeToLiveResponse) XXX_DiscardUnknown()

+ func (m *LeaseTimeToLiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaseTimeToLiveResponse) XXX_Merge(src proto.Message)

+ func (m *LeaseTimeToLiveResponse) XXX_Size() int

+ func (m *LeaseTimeToLiveResponse) XXX_Unmarshal(b []byte) error

type Member

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Member) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Member) XXX_DiscardUnknown()

+ func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Member) XXX_Merge(src proto.Message)

+ func (m *Member) XXX_Size() int

+ func (m *Member) XXX_Unmarshal(b []byte) error

type MemberAddRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *MemberAddRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MemberAddRequest) XXX_DiscardUnknown()

+ func (m *MemberAddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MemberAddRequest) XXX_Merge(src proto.Message)

+ func (m *MemberAddRequest) XXX_Size() int

+ func (m *MemberAddRequest) XXX_Unmarshal(b []byte) error

type MemberAddResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *MemberAddResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MemberAddResponse) XXX_DiscardUnknown()

+ func (m *MemberAddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MemberAddResponse) XXX_Merge(src proto.Message)

+ func (m *MemberAddResponse) XXX_Size() int

+ func (m *MemberAddResponse) XXX_Unmarshal(b []byte) error

type MemberListRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *MemberListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MemberListRequest) XXX_DiscardUnknown()

+ func (m *MemberListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MemberListRequest) XXX_Merge(src proto.Message)

+ func (m *MemberListRequest) XXX_Size() int

+ func (m *MemberListRequest) XXX_Unmarshal(b []byte) error

type MemberListResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *MemberListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MemberListResponse) XXX_DiscardUnknown()

+ func (m *MemberListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MemberListResponse) XXX_Merge(src proto.Message)

+ func (m *MemberListResponse) XXX_Size() int

+ func (m *MemberListResponse) XXX_Unmarshal(b []byte) error

type MemberRemoveRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *MemberRemoveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MemberRemoveRequest) XXX_DiscardUnknown()

+ func (m *MemberRemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MemberRemoveRequest) XXX_Merge(src proto.Message)

+ func (m *MemberRemoveRequest) XXX_Size() int

+ func (m *MemberRemoveRequest) XXX_Unmarshal(b []byte) error

type MemberRemoveResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *MemberRemoveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MemberRemoveResponse) XXX_DiscardUnknown()

+ func (m *MemberRemoveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MemberRemoveResponse) XXX_Merge(src proto.Message)

+ func (m *MemberRemoveResponse) XXX_Size() int

+ func (m *MemberRemoveResponse) XXX_Unmarshal(b []byte) error

type MemberUpdateRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *MemberUpdateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MemberUpdateRequest) XXX_DiscardUnknown()

+ func (m *MemberUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MemberUpdateRequest) XXX_Merge(src proto.Message)

+ func (m *MemberUpdateRequest) XXX_Size() int

+ func (m *MemberUpdateRequest) XXX_Unmarshal(b []byte) error

type MemberUpdateResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *MemberUpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MemberUpdateResponse) XXX_DiscardUnknown()

+ func (m *MemberUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MemberUpdateResponse) XXX_Merge(src proto.Message)

+ func (m *MemberUpdateResponse) XXX_Size() int

+ func (m *MemberUpdateResponse) XXX_Unmarshal(b []byte) error

type Metadata

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Metadata) XXX_DiscardUnknown()

+ func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Metadata) XXX_Merge(src proto.Message)

+ func (m *Metadata) XXX_Size() int

+ func (m *Metadata) XXX_Unmarshal(b []byte) error

type MoveLeaderRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *MoveLeaderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MoveLeaderRequest) XXX_DiscardUnknown()

+ func (m *MoveLeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MoveLeaderRequest) XXX_Merge(src proto.Message)

+ func (m *MoveLeaderRequest) XXX_Size() int

+ func (m *MoveLeaderRequest) XXX_Unmarshal(b []byte) error

type MoveLeaderResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *MoveLeaderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MoveLeaderResponse) XXX_DiscardUnknown()

+ func (m *MoveLeaderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MoveLeaderResponse) XXX_Merge(src proto.Message)

+ func (m *MoveLeaderResponse) XXX_Size() int

+ func (m *MoveLeaderResponse) XXX_Unmarshal(b []byte) error

type PutRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PutRequest) XXX_DiscardUnknown()

+ func (m *PutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PutRequest) XXX_Merge(src proto.Message)

+ func (m *PutRequest) XXX_Size() int

+ func (m *PutRequest) XXX_Unmarshal(b []byte) error

type PutResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PutResponse) XXX_DiscardUnknown()

+ func (m *PutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PutResponse) XXX_Merge(src proto.Message)

+ func (m *PutResponse) XXX_Size() int

+ func (m *PutResponse) XXX_Unmarshal(b []byte) error

type RangeRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RangeRequest) XXX_DiscardUnknown()

+ func (m *RangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RangeRequest) XXX_Merge(src proto.Message)

+ func (m *RangeRequest) XXX_Size() int

+ func (m *RangeRequest) XXX_Unmarshal(b []byte) error

type RangeResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RangeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RangeResponse) XXX_DiscardUnknown()

+ func (m *RangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RangeResponse) XXX_Merge(src proto.Message)

+ func (m *RangeResponse) XXX_Size() int

+ func (m *RangeResponse) XXX_Unmarshal(b []byte) error

type Request

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Request) XXX_DiscardUnknown()

+ func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Request) XXX_Merge(src proto.Message)

+ func (m *Request) XXX_Size() int

+ func (m *Request) XXX_Unmarshal(b []byte) error

type RequestHeader

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RequestHeader) XXX_DiscardUnknown()

+ func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RequestHeader) XXX_Merge(src proto.Message)

+ func (m *RequestHeader) XXX_Size() int

+ func (m *RequestHeader) XXX_Unmarshal(b []byte) error

type RequestOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RequestOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RequestOp) XXX_DiscardUnknown()

+ func (m *RequestOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RequestOp) XXX_Merge(src proto.Message)

+ func (m *RequestOp) XXX_Size() int

+ func (m *RequestOp) XXX_Unmarshal(b []byte) error

type RequestOp_RequestDeleteRange

+ func (m *RequestOp_RequestDeleteRange) MarshalToSizedBuffer(dAtA []byte) (int, error)

type RequestOp_RequestPut

+ func (m *RequestOp_RequestPut) MarshalToSizedBuffer(dAtA []byte) (int, error)

type RequestOp_RequestRange

+ func (m *RequestOp_RequestRange) MarshalToSizedBuffer(dAtA []byte) (int, error)

type RequestOp_RequestTxn

+ func (m *RequestOp_RequestTxn) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ResponseHeader

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResponseHeader) XXX_DiscardUnknown()

+ func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResponseHeader) XXX_Merge(src proto.Message)

+ func (m *ResponseHeader) XXX_Size() int

+ func (m *ResponseHeader) XXX_Unmarshal(b []byte) error

type ResponseOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ResponseOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResponseOp) XXX_DiscardUnknown()

+ func (m *ResponseOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResponseOp) XXX_Merge(src proto.Message)

+ func (m *ResponseOp) XXX_Size() int

+ func (m *ResponseOp) XXX_Unmarshal(b []byte) error

type ResponseOp_ResponseDeleteRange

+ func (m *ResponseOp_ResponseDeleteRange) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ResponseOp_ResponsePut

+ func (m *ResponseOp_ResponsePut) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ResponseOp_ResponseRange

+ func (m *ResponseOp_ResponseRange) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ResponseOp_ResponseTxn

+ func (m *ResponseOp_ResponseTxn) MarshalToSizedBuffer(dAtA []byte) (int, error)

type SnapshotRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SnapshotRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SnapshotRequest) XXX_DiscardUnknown()

+ func (m *SnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SnapshotRequest) XXX_Merge(src proto.Message)

+ func (m *SnapshotRequest) XXX_Size() int

+ func (m *SnapshotRequest) XXX_Unmarshal(b []byte) error

type SnapshotResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SnapshotResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SnapshotResponse) XXX_DiscardUnknown()

+ func (m *SnapshotResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SnapshotResponse) XXX_Merge(src proto.Message)

+ func (m *SnapshotResponse) XXX_Size() int

+ func (m *SnapshotResponse) XXX_Unmarshal(b []byte) error

type StatusRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *StatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StatusRequest) XXX_DiscardUnknown()

+ func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StatusRequest) XXX_Merge(src proto.Message)

+ func (m *StatusRequest) XXX_Size() int

+ func (m *StatusRequest) XXX_Unmarshal(b []byte) error

type StatusResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *StatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StatusResponse) XXX_DiscardUnknown()

+ func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StatusResponse) XXX_Merge(src proto.Message)

+ func (m *StatusResponse) XXX_Size() int

+ func (m *StatusResponse) XXX_Unmarshal(b []byte) error

type TxnRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *TxnRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TxnRequest) XXX_DiscardUnknown()

+ func (m *TxnRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TxnRequest) XXX_Merge(src proto.Message)

+ func (m *TxnRequest) XXX_Size() int

+ func (m *TxnRequest) XXX_Unmarshal(b []byte) error

type TxnResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *TxnResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TxnResponse) XXX_DiscardUnknown()

+ func (m *TxnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TxnResponse) XXX_Merge(src proto.Message)

+ func (m *TxnResponse) XXX_Size() int

+ func (m *TxnResponse) XXX_Unmarshal(b []byte) error

+ type UnimplementedAuthServer struct

+ func (*UnimplementedAuthServer) AuthDisable(ctx context.Context, req *AuthDisableRequest) (*AuthDisableResponse, error)

+ func (*UnimplementedAuthServer) AuthEnable(ctx context.Context, req *AuthEnableRequest) (*AuthEnableResponse, error)

+ func (*UnimplementedAuthServer) Authenticate(ctx context.Context, req *AuthenticateRequest) (*AuthenticateResponse, error)

+ func (*UnimplementedAuthServer) RoleAdd(ctx context.Context, req *AuthRoleAddRequest) (*AuthRoleAddResponse, error)

+ func (*UnimplementedAuthServer) RoleDelete(ctx context.Context, req *AuthRoleDeleteRequest) (*AuthRoleDeleteResponse, error)

+ func (*UnimplementedAuthServer) RoleGet(ctx context.Context, req *AuthRoleGetRequest) (*AuthRoleGetResponse, error)

+ func (*UnimplementedAuthServer) RoleGrantPermission(ctx context.Context, req *AuthRoleGrantPermissionRequest) (*AuthRoleGrantPermissionResponse, error)

+ func (*UnimplementedAuthServer) RoleList(ctx context.Context, req *AuthRoleListRequest) (*AuthRoleListResponse, error)

+ func (*UnimplementedAuthServer) RoleRevokePermission(ctx context.Context, req *AuthRoleRevokePermissionRequest) (*AuthRoleRevokePermissionResponse, error)

+ func (*UnimplementedAuthServer) UserAdd(ctx context.Context, req *AuthUserAddRequest) (*AuthUserAddResponse, error)

+ func (*UnimplementedAuthServer) UserChangePassword(ctx context.Context, req *AuthUserChangePasswordRequest) (*AuthUserChangePasswordResponse, error)

+ func (*UnimplementedAuthServer) UserDelete(ctx context.Context, req *AuthUserDeleteRequest) (*AuthUserDeleteResponse, error)

+ func (*UnimplementedAuthServer) UserGet(ctx context.Context, req *AuthUserGetRequest) (*AuthUserGetResponse, error)

+ func (*UnimplementedAuthServer) UserGrantRole(ctx context.Context, req *AuthUserGrantRoleRequest) (*AuthUserGrantRoleResponse, error)

+ func (*UnimplementedAuthServer) UserList(ctx context.Context, req *AuthUserListRequest) (*AuthUserListResponse, error)

+ func (*UnimplementedAuthServer) UserRevokeRole(ctx context.Context, req *AuthUserRevokeRoleRequest) (*AuthUserRevokeRoleResponse, error)

+ type UnimplementedClusterServer struct

+ func (*UnimplementedClusterServer) MemberAdd(ctx context.Context, req *MemberAddRequest) (*MemberAddResponse, error)

+ func (*UnimplementedClusterServer) MemberList(ctx context.Context, req *MemberListRequest) (*MemberListResponse, error)

+ func (*UnimplementedClusterServer) MemberRemove(ctx context.Context, req *MemberRemoveRequest) (*MemberRemoveResponse, error)

+ func (*UnimplementedClusterServer) MemberUpdate(ctx context.Context, req *MemberUpdateRequest) (*MemberUpdateResponse, error)

+ type UnimplementedKVServer struct

+ func (*UnimplementedKVServer) Compact(ctx context.Context, req *CompactionRequest) (*CompactionResponse, error)

+ func (*UnimplementedKVServer) DeleteRange(ctx context.Context, req *DeleteRangeRequest) (*DeleteRangeResponse, error)

+ func (*UnimplementedKVServer) Put(ctx context.Context, req *PutRequest) (*PutResponse, error)

+ func (*UnimplementedKVServer) Range(ctx context.Context, req *RangeRequest) (*RangeResponse, error)

+ func (*UnimplementedKVServer) Txn(ctx context.Context, req *TxnRequest) (*TxnResponse, error)

+ type UnimplementedLeaseServer struct

+ func (*UnimplementedLeaseServer) LeaseGrant(ctx context.Context, req *LeaseGrantRequest) (*LeaseGrantResponse, error)

+ func (*UnimplementedLeaseServer) LeaseKeepAlive(srv Lease_LeaseKeepAliveServer) error

+ func (*UnimplementedLeaseServer) LeaseLeases(ctx context.Context, req *LeaseLeasesRequest) (*LeaseLeasesResponse, error)

+ func (*UnimplementedLeaseServer) LeaseRevoke(ctx context.Context, req *LeaseRevokeRequest) (*LeaseRevokeResponse, error)

+ func (*UnimplementedLeaseServer) LeaseTimeToLive(ctx context.Context, req *LeaseTimeToLiveRequest) (*LeaseTimeToLiveResponse, error)

+ type UnimplementedMaintenanceServer struct

+ func (*UnimplementedMaintenanceServer) Alarm(ctx context.Context, req *AlarmRequest) (*AlarmResponse, error)

+ func (*UnimplementedMaintenanceServer) Defragment(ctx context.Context, req *DefragmentRequest) (*DefragmentResponse, error)

+ func (*UnimplementedMaintenanceServer) Hash(ctx context.Context, req *HashRequest) (*HashResponse, error)

+ func (*UnimplementedMaintenanceServer) HashKV(ctx context.Context, req *HashKVRequest) (*HashKVResponse, error)

+ func (*UnimplementedMaintenanceServer) MoveLeader(ctx context.Context, req *MoveLeaderRequest) (*MoveLeaderResponse, error)

+ func (*UnimplementedMaintenanceServer) Snapshot(req *SnapshotRequest, srv Maintenance_SnapshotServer) error

+ func (*UnimplementedMaintenanceServer) Status(ctx context.Context, req *StatusRequest) (*StatusResponse, error)

+ type UnimplementedWatchServer struct

+ func (*UnimplementedWatchServer) Watch(srv Watch_WatchServer) error

type WatchCancelRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *WatchCancelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WatchCancelRequest) XXX_DiscardUnknown()

+ func (m *WatchCancelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WatchCancelRequest) XXX_Merge(src proto.Message)

+ func (m *WatchCancelRequest) XXX_Size() int

+ func (m *WatchCancelRequest) XXX_Unmarshal(b []byte) error

type WatchCreateRequest

+ Fragment bool

+ WatchId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *WatchCreateRequest) GetFragment() bool

+ func (m *WatchCreateRequest) GetWatchId() int64

+ func (m *WatchCreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WatchCreateRequest) XXX_DiscardUnknown()

+ func (m *WatchCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WatchCreateRequest) XXX_Merge(src proto.Message)

+ func (m *WatchCreateRequest) XXX_Size() int

+ func (m *WatchCreateRequest) XXX_Unmarshal(b []byte) error

+ type WatchProgressRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WatchProgressRequest) Descriptor() ([]byte, []int)

+ func (*WatchProgressRequest) ProtoMessage()

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

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

+ func (m *WatchProgressRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WatchProgressRequest) Reset()

+ func (m *WatchProgressRequest) Size() (n int)

+ func (m *WatchProgressRequest) String() string

+ func (m *WatchProgressRequest) Unmarshal(dAtA []byte) error

+ func (m *WatchProgressRequest) XXX_DiscardUnknown()

+ func (m *WatchProgressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WatchProgressRequest) XXX_Merge(src proto.Message)

+ func (m *WatchProgressRequest) XXX_Size() int

+ func (m *WatchProgressRequest) XXX_Unmarshal(b []byte) error

type WatchRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *WatchRequest) GetProgressRequest() *WatchProgressRequest

+ func (m *WatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WatchRequest) XXX_DiscardUnknown()

+ func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WatchRequest) XXX_Merge(src proto.Message)

+ func (m *WatchRequest) XXX_Size() int

+ func (m *WatchRequest) XXX_Unmarshal(b []byte) error

type WatchRequest_CancelRequest

+ func (m *WatchRequest_CancelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type WatchRequest_CreateRequest

+ func (m *WatchRequest_CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ type WatchRequest_ProgressRequest struct

+ ProgressRequest *WatchProgressRequest

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

+ func (m *WatchRequest_ProgressRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WatchRequest_ProgressRequest) Size() (n int)

type WatchResponse

+ Fragment bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *WatchResponse) GetFragment() bool

+ func (m *WatchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WatchResponse) XXX_DiscardUnknown()

+ func (m *WatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WatchResponse) XXX_Merge(src proto.Message)

+ func (m *WatchResponse) XXX_Size() int

+ func (m *WatchResponse) XXX_Unmarshal(b []byte) error

Feb 1, 2018

Changes in this version

type AlarmType

+ const AlarmType_CORRUPT

type Compare

+ RangeEnd []byte

+ func (m *Compare) GetLease() int64

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

type Compare_CompareTarget

+ const Compare_LEASE

+ type Compare_Lease struct

+ Lease int64

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

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

+ type HashKVRequest struct

+ Revision int64

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

+ func (*HashKVRequest) ProtoMessage()

+ func (m *HashKVRequest) GetRevision() int64

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

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

+ func (m *HashKVRequest) Reset()

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

+ func (m *HashKVRequest) String() string

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

+ type HashKVResponse struct

+ CompactRevision int64

+ Hash uint32

+ Header *ResponseHeader

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

+ func (*HashKVResponse) ProtoMessage()

+ func (m *HashKVResponse) GetCompactRevision() int64

+ func (m *HashKVResponse) GetHash() uint32

+ func (m *HashKVResponse) GetHeader() *ResponseHeader

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

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

+ func (m *HashKVResponse) Reset()

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

+ func (m *HashKVResponse) String() string

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

type LeaseClient

+ LeaseLeases func(ctx context.Context, in *LeaseLeasesRequest, opts ...grpc.CallOption) (*LeaseLeasesResponse, error)

+ type LeaseLeasesRequest struct

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

+ func (*LeaseLeasesRequest) ProtoMessage()

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

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

+ func (m *LeaseLeasesRequest) Reset()

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

+ func (m *LeaseLeasesRequest) String() string

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

+ type LeaseLeasesResponse struct

+ Header *ResponseHeader

+ Leases []*LeaseStatus

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

+ func (*LeaseLeasesResponse) ProtoMessage()

+ func (m *LeaseLeasesResponse) GetHeader() *ResponseHeader

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

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

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

+ func (m *LeaseLeasesResponse) Reset()

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

+ func (m *LeaseLeasesResponse) String() string

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

type LeaseServer

+ LeaseLeases func(context.Context, *LeaseLeasesRequest) (*LeaseLeasesResponse, error)

+ type LeaseStatus struct

+ ID int64

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

+ func (*LeaseStatus) ProtoMessage()

+ func (m *LeaseStatus) GetID() int64

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

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

+ func (m *LeaseStatus) Reset()

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

+ func (m *LeaseStatus) String() string

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

type MaintenanceClient

+ HashKV func(ctx context.Context, in *HashKVRequest, opts ...grpc.CallOption) (*HashKVResponse, error)

+ MoveLeader func(ctx context.Context, in *MoveLeaderRequest, opts ...grpc.CallOption) (*MoveLeaderResponse, error)

type MaintenanceServer

+ HashKV func(context.Context, *HashKVRequest) (*HashKVResponse, error)

+ MoveLeader func(context.Context, *MoveLeaderRequest) (*MoveLeaderResponse, error)

+ type MoveLeaderRequest struct

+ TargetID uint64

+ func (*MoveLeaderRequest) Descriptor() ([]byte, []int)

+ func (*MoveLeaderRequest) ProtoMessage()

+ func (m *MoveLeaderRequest) GetTargetID() uint64

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

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

+ func (m *MoveLeaderRequest) Reset()

+ func (m *MoveLeaderRequest) Size() (n int)

+ func (m *MoveLeaderRequest) String() string

+ func (m *MoveLeaderRequest) Unmarshal(dAtA []byte) error

+ type MoveLeaderResponse struct

+ Header *ResponseHeader

+ func (*MoveLeaderResponse) Descriptor() ([]byte, []int)

+ func (*MoveLeaderResponse) ProtoMessage()

+ func (m *MoveLeaderResponse) GetHeader() *ResponseHeader

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

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

+ func (m *MoveLeaderResponse) Reset()

+ func (m *MoveLeaderResponse) Size() (n int)

+ func (m *MoveLeaderResponse) String() string

+ func (m *MoveLeaderResponse) Unmarshal(dAtA []byte) error

type RequestOp

+ func (m *RequestOp) GetRequestTxn() *TxnRequest

+ type RequestOp_RequestTxn struct

+ RequestTxn *TxnRequest

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

+ func (m *RequestOp_RequestTxn) Size() (n int)

type ResponseOp

+ func (m *ResponseOp) GetResponseTxn() *TxnResponse

+ type ResponseOp_ResponseTxn struct

+ ResponseTxn *TxnResponse

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

+ func (m *ResponseOp_ResponseTxn) Size() (n int)

Nov 16, 2017

Changes in this version

type AlarmMember

+ func (m *AlarmMember) GetAlarm() AlarmType

+ func (m *AlarmMember) GetMemberID() uint64

type AlarmRequest

+ func (m *AlarmRequest) GetAction() AlarmRequest_AlarmAction

+ func (m *AlarmRequest) GetAlarm() AlarmType

+ func (m *AlarmRequest) GetMemberID() uint64

type AuthRoleAddRequest

+ func (m *AuthRoleAddRequest) GetName() string

type AuthRoleDeleteRequest

+ func (m *AuthRoleDeleteRequest) GetRole() string

type AuthRoleGetRequest

+ func (m *AuthRoleGetRequest) GetRole() string

type AuthRoleGrantPermissionRequest

+ func (m *AuthRoleGrantPermissionRequest) GetName() string

type AuthRoleListResponse

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

type AuthRoleRevokePermissionRequest

+ func (m *AuthRoleRevokePermissionRequest) GetKey() string

+ func (m *AuthRoleRevokePermissionRequest) GetRangeEnd() string

+ func (m *AuthRoleRevokePermissionRequest) GetRole() string

type AuthUserAddRequest

+ func (m *AuthUserAddRequest) GetName() string

+ func (m *AuthUserAddRequest) GetPassword() string

type AuthUserChangePasswordRequest

+ func (m *AuthUserChangePasswordRequest) GetName() string

+ func (m *AuthUserChangePasswordRequest) GetPassword() string

type AuthUserDeleteRequest

+ func (m *AuthUserDeleteRequest) GetName() string

type AuthUserGetRequest

+ func (m *AuthUserGetRequest) GetName() string

type AuthUserGetResponse

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

type AuthUserGrantRoleRequest

+ func (m *AuthUserGrantRoleRequest) GetRole() string

+ func (m *AuthUserGrantRoleRequest) GetUser() string

type AuthUserListResponse

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

type AuthUserRevokeRoleRequest

+ func (m *AuthUserRevokeRoleRequest) GetName() string

+ func (m *AuthUserRevokeRoleRequest) GetRole() string

type AuthenticateRequest

+ func (m *AuthenticateRequest) GetName() string

+ func (m *AuthenticateRequest) GetPassword() string

type AuthenticateResponse

+ func (m *AuthenticateResponse) GetToken() string

type CompactionRequest

+ func (m *CompactionRequest) GetPhysical() bool

+ func (m *CompactionRequest) GetRevision() int64

type Compare

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

+ func (m *Compare) GetResult() Compare_CompareResult

+ func (m *Compare) GetTarget() Compare_CompareTarget

type DeleteRangeRequest

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

+ func (m *DeleteRangeRequest) GetPrevKv() bool

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

type DeleteRangeResponse

+ func (m *DeleteRangeResponse) GetDeleted() int64

type HashResponse

+ func (m *HashResponse) GetHash() uint32

type LeaseGrantRequest

+ func (m *LeaseGrantRequest) GetID() int64

+ func (m *LeaseGrantRequest) GetTTL() int64

type LeaseGrantResponse

+ func (m *LeaseGrantResponse) GetError() string

+ func (m *LeaseGrantResponse) GetID() int64

+ func (m *LeaseGrantResponse) GetTTL() int64

type LeaseKeepAliveRequest

+ func (m *LeaseKeepAliveRequest) GetID() int64

type LeaseKeepAliveResponse

+ func (m *LeaseKeepAliveResponse) GetID() int64

+ func (m *LeaseKeepAliveResponse) GetTTL() int64

type LeaseRevokeRequest

+ func (m *LeaseRevokeRequest) GetID() int64

type LeaseTimeToLiveRequest

+ func (m *LeaseTimeToLiveRequest) GetID() int64

+ func (m *LeaseTimeToLiveRequest) GetKeys() bool

type LeaseTimeToLiveResponse

+ func (m *LeaseTimeToLiveResponse) GetGrantedTTL() int64

+ func (m *LeaseTimeToLiveResponse) GetID() int64

+ func (m *LeaseTimeToLiveResponse) GetKeys() [][]byte

+ func (m *LeaseTimeToLiveResponse) GetTTL() int64

type Member

+ func (m *Member) GetClientURLs() []string

+ func (m *Member) GetID() uint64

+ func (m *Member) GetName() string

+ func (m *Member) GetPeerURLs() []string

type MemberAddRequest

+ func (m *MemberAddRequest) GetPeerURLs() []string

type MemberRemoveRequest

+ func (m *MemberRemoveRequest) GetID() uint64

type MemberUpdateRequest

+ func (m *MemberUpdateRequest) GetID() uint64

+ func (m *MemberUpdateRequest) GetPeerURLs() []string

type PutRequest

+ func (m *PutRequest) GetIgnoreLease() bool

+ func (m *PutRequest) GetIgnoreValue() bool

+ func (m *PutRequest) GetKey() []byte

+ func (m *PutRequest) GetLease() int64

+ func (m *PutRequest) GetPrevKv() bool

+ func (m *PutRequest) GetValue() []byte

type RangeRequest

+ func (m *RangeRequest) GetCountOnly() bool

+ func (m *RangeRequest) GetKey() []byte

+ func (m *RangeRequest) GetKeysOnly() bool

+ func (m *RangeRequest) GetLimit() int64

+ func (m *RangeRequest) GetMaxCreateRevision() int64

+ func (m *RangeRequest) GetMaxModRevision() int64

+ func (m *RangeRequest) GetMinCreateRevision() int64

+ func (m *RangeRequest) GetMinModRevision() int64

+ func (m *RangeRequest) GetRangeEnd() []byte

+ func (m *RangeRequest) GetRevision() int64

+ func (m *RangeRequest) GetSerializable() bool

+ func (m *RangeRequest) GetSortOrder() RangeRequest_SortOrder

+ func (m *RangeRequest) GetSortTarget() RangeRequest_SortTarget

type RangeResponse

+ func (m *RangeResponse) GetCount() int64

+ func (m *RangeResponse) GetMore() bool

type ResponseHeader

+ func (m *ResponseHeader) GetClusterId() uint64

+ func (m *ResponseHeader) GetMemberId() uint64

+ func (m *ResponseHeader) GetRaftTerm() uint64

+ func (m *ResponseHeader) GetRevision() int64

type SnapshotResponse

+ func (m *SnapshotResponse) GetBlob() []byte

+ func (m *SnapshotResponse) GetRemainingBytes() uint64

type StatusResponse

+ func (m *StatusResponse) GetDbSize() int64

+ func (m *StatusResponse) GetLeader() uint64

+ func (m *StatusResponse) GetRaftIndex() uint64

+ func (m *StatusResponse) GetRaftTerm() uint64

+ func (m *StatusResponse) GetVersion() string

type TxnResponse

+ func (m *TxnResponse) GetSucceeded() bool

type WatchCancelRequest

+ func (m *WatchCancelRequest) GetWatchId() int64

type WatchCreateRequest

+ func (m *WatchCreateRequest) GetFilters() []WatchCreateRequest_FilterType

+ func (m *WatchCreateRequest) GetKey() []byte

+ func (m *WatchCreateRequest) GetPrevKv() bool

+ func (m *WatchCreateRequest) GetProgressNotify() bool

+ func (m *WatchCreateRequest) GetRangeEnd() []byte

+ func (m *WatchCreateRequest) GetStartRevision() int64

type WatchResponse

+ func (m *WatchResponse) GetCancelReason() string

+ func (m *WatchResponse) GetCanceled() bool

+ func (m *WatchResponse) GetCompactRevision() int64

+ func (m *WatchResponse) GetCreated() bool

+ func (m *WatchResponse) GetWatchId() int64

Jun 9, 2017

Changes in this version

type MemberAddResponse

+ Members []*Member

+ func (m *MemberAddResponse) GetMembers() []*Member

type MemberRemoveResponse

+ Members []*Member

+ func (m *MemberRemoveResponse) GetMembers() []*Member

type MemberUpdateResponse

+ Members []*Member

+ func (m *MemberUpdateResponse) GetMembers() []*Member

type PutRequest

+ IgnoreLease bool

+ IgnoreValue bool

type WatchResponse

+ CancelReason string

Oct 10, 2018

Changes in this version

+ func NewLoggablePutRequest(request *PutRequest) *loggablePutRequest

Jun 15, 2018

Changes in this version

+ func NewLoggableTxnRequest(request *TxnRequest) *txnRequestStringer

+ type InternalRaftStringer struct

+ Request *InternalRaftRequest

+ func (as *InternalRaftStringer) String() string

Jan 20, 2017

Changes in this version

+ var WatchCreateRequest_FilterType_name = map[int32]string

+ var WatchCreateRequest_FilterType_value = map[string]int32

type Compare_CompareResult

+ const Compare_NOT_EQUAL

type LeaseClient

+ LeaseTimeToLive func(ctx context.Context, in *LeaseTimeToLiveRequest, opts ...grpc.CallOption) (*LeaseTimeToLiveResponse, error)

type LeaseServer

+ 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 RangeRequest

+ MaxCreateRevision int64

+ MaxModRevision int64

+ MinCreateRevision int64

+ MinModRevision int64

type RequestHeader

+ AuthRevision uint64

type WatchCreateRequest

+ Filters []WatchCreateRequest_FilterType

+ type WatchCreateRequest_FilterType int32

+ const WatchCreateRequest_NODELETE

+ const WatchCreateRequest_NOPUT

+ func (WatchCreateRequest_FilterType) EnumDescriptor() ([]byte, []int)

+ func (x WatchCreateRequest_FilterType) String() string

Oct 7, 2016

Changes in this version

type WatchCreateRequest

+ PrevKv bool

Oct 7, 2016

Changes in this version

type DeleteRangeRequest

+ PrevKv bool

type DeleteRangeResponse

+ PrevKvs []*mvccpb.KeyValue

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

type PutRequest

+ PrevKv bool

type PutResponse

+ PrevKv *mvccpb.KeyValue

+ func (m *PutResponse) GetPrevKv() *mvccpb.KeyValue

Jun 30, 2016

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

+ func RegisterAuthHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterAuthHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterClusterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterClusterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterKVHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterKVHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterLeaseHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterLeaseHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterMaintenanceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterMaintenanceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterWatchHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterWatchHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ 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

+ 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

+ 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

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

+ func (*DeleteRangeResponse) ProtoMessage()

+ func (m *DeleteRangeResponse) GetHeader() *ResponseHeader

+ 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)

+ 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)

+ 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

+ func (*MemberAddResponse) Descriptor() ([]byte, []int)

+ func (*MemberAddResponse) ProtoMessage()

+ func (m *MemberAddResponse) GetHeader() *ResponseHeader

+ func (m *MemberAddResponse) GetMember() *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

+ func (*MemberRemoveResponse) Descriptor() ([]byte, []int)

+ func (*MemberRemoveResponse) ProtoMessage()

+ func (m *MemberRemoveResponse) GetHeader() *ResponseHeader

+ 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

+ func (*MemberUpdateResponse) Descriptor() ([]byte, []int)

+ func (*MemberUpdateResponse) ProtoMessage()

+ func (m *MemberUpdateResponse) GetHeader() *ResponseHeader

+ 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

+ Key []byte

+ Lease int64

+ 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

+ func (*PutResponse) Descriptor() ([]byte, []int)

+ func (*PutResponse) ProtoMessage()

+ func (m *PutResponse) GetHeader() *ResponseHeader

+ 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

+ 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

+ 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

+ Key []byte

+ 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 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

+ 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