Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowRecoverdatapb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthRecoverdatapb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupRecoverdatapb = fmt.Errorf("proto: unexpected end of group") + func RegisterRecoverDataServer(s *grpc.Server, srv RecoverDataServer) + type Error struct + Msg string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) GetMsg() string + func (m *Error) Marshal() (dAtA []byte, err error) + func (m *Error) MarshalTo(dAtA []byte) (int, error) + func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Error) Reset() + func (m *Error) Size() (n int) + func (m *Error) String() string + func (m *Error) Unmarshal(dAtA []byte) error + func (m *Error) XXX_DiscardUnknown() + func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error) XXX_Merge(src proto.Message) + func (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type ReadRegionMetaRequest struct + StoreId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadRegionMetaRequest) Descriptor() ([]byte, []int) + func (*ReadRegionMetaRequest) ProtoMessage() + func (m *ReadRegionMetaRequest) GetStoreId() uint64 + func (m *ReadRegionMetaRequest) Marshal() (dAtA []byte, err error) + func (m *ReadRegionMetaRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ReadRegionMetaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ReadRegionMetaRequest) Reset() + func (m *ReadRegionMetaRequest) Size() (n int) + func (m *ReadRegionMetaRequest) String() string + func (m *ReadRegionMetaRequest) Unmarshal(dAtA []byte) error + func (m *ReadRegionMetaRequest) XXX_DiscardUnknown() + func (m *ReadRegionMetaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadRegionMetaRequest) XXX_Merge(src proto.Message) + func (m *ReadRegionMetaRequest) XXX_Size() int + func (m *ReadRegionMetaRequest) XXX_Unmarshal(b []byte) error + type RecoverDataClient interface + ReadRegionMeta func(ctx context.Context, in *ReadRegionMetaRequest, opts ...grpc.CallOption) (RecoverData_ReadRegionMetaClient, error) + RecoverRegion func(ctx context.Context, opts ...grpc.CallOption) (RecoverData_RecoverRegionClient, error) + ResolveKvData func(ctx context.Context, in *ResolveKvDataRequest, opts ...grpc.CallOption) (RecoverData_ResolveKvDataClient, error) + WaitApply func(ctx context.Context, in *WaitApplyRequest, opts ...grpc.CallOption) (*WaitApplyResponse, error) + func NewRecoverDataClient(cc *grpc.ClientConn) RecoverDataClient + type RecoverDataServer interface + ReadRegionMeta func(*ReadRegionMetaRequest, RecoverData_ReadRegionMetaServer) error + RecoverRegion func(RecoverData_RecoverRegionServer) error + ResolveKvData func(*ResolveKvDataRequest, RecoverData_ResolveKvDataServer) error + WaitApply func(context.Context, *WaitApplyRequest) (*WaitApplyResponse, error) + type RecoverData_ReadRegionMetaClient interface + Recv func() (*RegionMeta, error) + type RecoverData_ReadRegionMetaServer interface + Send func(*RegionMeta) error + type RecoverData_RecoverRegionClient interface + CloseAndRecv func() (*RecoverRegionResponse, error) + Send func(*RecoverRegionRequest) error + type RecoverData_RecoverRegionServer interface + Recv func() (*RecoverRegionRequest, error) + SendAndClose func(*RecoverRegionResponse) error + type RecoverData_ResolveKvDataClient interface + Recv func() (*ResolveKvDataResponse, error) + type RecoverData_ResolveKvDataServer interface + Send func(*ResolveKvDataResponse) error + type RecoverRegionRequest struct + AsLeader bool + RegionId uint64 + Tombstone bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RecoverRegionRequest) Descriptor() ([]byte, []int) + func (*RecoverRegionRequest) ProtoMessage() + func (m *RecoverRegionRequest) GetAsLeader() bool + func (m *RecoverRegionRequest) GetRegionId() uint64 + func (m *RecoverRegionRequest) GetTombstone() bool + func (m *RecoverRegionRequest) Marshal() (dAtA []byte, err error) + func (m *RecoverRegionRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RecoverRegionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RecoverRegionRequest) Reset() + func (m *RecoverRegionRequest) Size() (n int) + func (m *RecoverRegionRequest) String() string + func (m *RecoverRegionRequest) Unmarshal(dAtA []byte) error + func (m *RecoverRegionRequest) XXX_DiscardUnknown() + func (m *RecoverRegionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RecoverRegionRequest) XXX_Merge(src proto.Message) + func (m *RecoverRegionRequest) XXX_Size() int + func (m *RecoverRegionRequest) XXX_Unmarshal(b []byte) error + type RecoverRegionResponse struct + Error *Error + StoreId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RecoverRegionResponse) Descriptor() ([]byte, []int) + func (*RecoverRegionResponse) ProtoMessage() + func (m *RecoverRegionResponse) GetError() *Error + func (m *RecoverRegionResponse) GetStoreId() uint64 + func (m *RecoverRegionResponse) Marshal() (dAtA []byte, err error) + func (m *RecoverRegionResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RecoverRegionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RecoverRegionResponse) Reset() + func (m *RecoverRegionResponse) Size() (n int) + func (m *RecoverRegionResponse) String() string + func (m *RecoverRegionResponse) Unmarshal(dAtA []byte) error + func (m *RecoverRegionResponse) XXX_DiscardUnknown() + func (m *RecoverRegionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RecoverRegionResponse) XXX_Merge(src proto.Message) + func (m *RecoverRegionResponse) XXX_Size() int + func (m *RecoverRegionResponse) XXX_Unmarshal(b []byte) error + type RegionMeta struct + CommitIndex uint64 + EndKey []byte + LastIndex uint64 + LastLogTerm uint64 + PeerId uint64 + RegionId uint64 + StartKey []byte + Tombstone bool + Version uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionMeta) Descriptor() ([]byte, []int) + func (*RegionMeta) ProtoMessage() + func (m *RegionMeta) GetCommitIndex() uint64 + func (m *RegionMeta) GetEndKey() []byte + func (m *RegionMeta) GetLastIndex() uint64 + func (m *RegionMeta) GetLastLogTerm() uint64 + func (m *RegionMeta) GetPeerId() uint64 + func (m *RegionMeta) GetRegionId() uint64 + func (m *RegionMeta) GetStartKey() []byte + func (m *RegionMeta) GetTombstone() bool + func (m *RegionMeta) GetVersion() uint64 + func (m *RegionMeta) Marshal() (dAtA []byte, err error) + func (m *RegionMeta) MarshalTo(dAtA []byte) (int, error) + func (m *RegionMeta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RegionMeta) Reset() + func (m *RegionMeta) Size() (n int) + func (m *RegionMeta) String() string + func (m *RegionMeta) Unmarshal(dAtA []byte) error + func (m *RegionMeta) XXX_DiscardUnknown() + func (m *RegionMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegionMeta) XXX_Merge(src proto.Message) + func (m *RegionMeta) XXX_Size() int + func (m *RegionMeta) XXX_Unmarshal(b []byte) error + type ResolveKvDataRequest struct + ResolvedTs uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResolveKvDataRequest) Descriptor() ([]byte, []int) + func (*ResolveKvDataRequest) ProtoMessage() + func (m *ResolveKvDataRequest) GetResolvedTs() uint64 + func (m *ResolveKvDataRequest) Marshal() (dAtA []byte, err error) + func (m *ResolveKvDataRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ResolveKvDataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResolveKvDataRequest) Reset() + func (m *ResolveKvDataRequest) Size() (n int) + func (m *ResolveKvDataRequest) String() string + func (m *ResolveKvDataRequest) Unmarshal(dAtA []byte) error + func (m *ResolveKvDataRequest) XXX_DiscardUnknown() + func (m *ResolveKvDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResolveKvDataRequest) XXX_Merge(src proto.Message) + func (m *ResolveKvDataRequest) XXX_Size() int + func (m *ResolveKvDataRequest) XXX_Unmarshal(b []byte) error + type ResolveKvDataResponse struct + CurrentCommitTs uint64 + Error *Error + ResolvedKeyCount uint64 + StoreId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResolveKvDataResponse) Descriptor() ([]byte, []int) + func (*ResolveKvDataResponse) ProtoMessage() + func (m *ResolveKvDataResponse) GetCurrentCommitTs() uint64 + func (m *ResolveKvDataResponse) GetError() *Error + func (m *ResolveKvDataResponse) GetResolvedKeyCount() uint64 + func (m *ResolveKvDataResponse) GetStoreId() uint64 + func (m *ResolveKvDataResponse) Marshal() (dAtA []byte, err error) + func (m *ResolveKvDataResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ResolveKvDataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResolveKvDataResponse) Reset() + func (m *ResolveKvDataResponse) Size() (n int) + func (m *ResolveKvDataResponse) String() string + func (m *ResolveKvDataResponse) Unmarshal(dAtA []byte) error + func (m *ResolveKvDataResponse) XXX_DiscardUnknown() + func (m *ResolveKvDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResolveKvDataResponse) XXX_Merge(src proto.Message) + func (m *ResolveKvDataResponse) XXX_Size() int + func (m *ResolveKvDataResponse) XXX_Unmarshal(b []byte) error + type UnimplementedRecoverDataServer struct + func (*UnimplementedRecoverDataServer) ReadRegionMeta(req *ReadRegionMetaRequest, srv RecoverData_ReadRegionMetaServer) error + func (*UnimplementedRecoverDataServer) RecoverRegion(srv RecoverData_RecoverRegionServer) error + func (*UnimplementedRecoverDataServer) ResolveKvData(req *ResolveKvDataRequest, srv RecoverData_ResolveKvDataServer) error + func (*UnimplementedRecoverDataServer) WaitApply(ctx context.Context, req *WaitApplyRequest) (*WaitApplyResponse, error) + type WaitApplyRequest struct + StoreId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WaitApplyRequest) Descriptor() ([]byte, []int) + func (*WaitApplyRequest) ProtoMessage() + func (m *WaitApplyRequest) GetStoreId() uint64 + func (m *WaitApplyRequest) Marshal() (dAtA []byte, err error) + func (m *WaitApplyRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WaitApplyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WaitApplyRequest) Reset() + func (m *WaitApplyRequest) Size() (n int) + func (m *WaitApplyRequest) String() string + func (m *WaitApplyRequest) Unmarshal(dAtA []byte) error + func (m *WaitApplyRequest) XXX_DiscardUnknown() + func (m *WaitApplyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WaitApplyRequest) XXX_Merge(src proto.Message) + func (m *WaitApplyRequest) XXX_Size() int + func (m *WaitApplyRequest) XXX_Unmarshal(b []byte) error + type WaitApplyResponse struct + Error *Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WaitApplyResponse) Descriptor() ([]byte, []int) + func (*WaitApplyResponse) ProtoMessage() + func (m *WaitApplyResponse) GetError() *Error + func (m *WaitApplyResponse) Marshal() (dAtA []byte, err error) + func (m *WaitApplyResponse) MarshalTo(dAtA []byte) (int, error) + func (m *WaitApplyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WaitApplyResponse) Reset() + func (m *WaitApplyResponse) Size() (n int) + func (m *WaitApplyResponse) String() string + func (m *WaitApplyResponse) Unmarshal(dAtA []byte) error + func (m *WaitApplyResponse) XXX_DiscardUnknown() + func (m *WaitApplyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WaitApplyResponse) XXX_Merge(src proto.Message) + func (m *WaitApplyResponse) XXX_Size() int + func (m *WaitApplyResponse) XXX_Unmarshal(b []byte) error