Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowRaftServerpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthRaftServerpb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupRaftServerpb = fmt.Errorf("proto: unexpected end of group") + var ExtraMessageType_name = map[int32]string + var ExtraMessageType_value = map[string]int32 + var PeerState_name = map[int32]string + var PeerState_value = map[string]int32 + type AcceptedSnapshotFiles struct + FileName []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AcceptedSnapshotFiles) Descriptor() ([]byte, []int) + func (*AcceptedSnapshotFiles) ProtoMessage() + func (m *AcceptedSnapshotFiles) GetFileName() []string + func (m *AcceptedSnapshotFiles) Marshal() (dAtA []byte, err error) + func (m *AcceptedSnapshotFiles) MarshalTo(dAtA []byte) (int, error) + func (m *AcceptedSnapshotFiles) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AcceptedSnapshotFiles) Reset() + func (m *AcceptedSnapshotFiles) Size() (n int) + func (m *AcceptedSnapshotFiles) String() string + func (m *AcceptedSnapshotFiles) Unmarshal(dAtA []byte) error + func (m *AcceptedSnapshotFiles) XXX_DiscardUnknown() + func (m *AcceptedSnapshotFiles) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AcceptedSnapshotFiles) XXX_Merge(src proto.Message) + func (m *AcceptedSnapshotFiles) XXX_Size() int + func (m *AcceptedSnapshotFiles) XXX_Unmarshal(b []byte) error + type AvailabilityContext struct + FromRegionEpoch *metapb.RegionEpoch + FromRegionId uint64 + Trimmed bool + Unavailable bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AvailabilityContext) Descriptor() ([]byte, []int) + func (*AvailabilityContext) ProtoMessage() + func (m *AvailabilityContext) GetFromRegionEpoch() *metapb.RegionEpoch + func (m *AvailabilityContext) GetFromRegionId() uint64 + func (m *AvailabilityContext) GetTrimmed() bool + func (m *AvailabilityContext) GetUnavailable() bool + func (m *AvailabilityContext) Marshal() (dAtA []byte, err error) + func (m *AvailabilityContext) MarshalTo(dAtA []byte) (int, error) + func (m *AvailabilityContext) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AvailabilityContext) Reset() + func (m *AvailabilityContext) Size() (n int) + func (m *AvailabilityContext) String() string + func (m *AvailabilityContext) Unmarshal(dAtA []byte) error + func (m *AvailabilityContext) XXX_DiscardUnknown() + func (m *AvailabilityContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AvailabilityContext) XXX_Merge(src proto.Message) + func (m *AvailabilityContext) XXX_Size() int + func (m *AvailabilityContext) XXX_Unmarshal(b []byte) error + type CheckGcPeer struct + CheckPeer *metapb.Peer + CheckRegionEpoch *metapb.RegionEpoch + CheckRegionId uint64 + FromRegionId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CheckGcPeer) Descriptor() ([]byte, []int) + func (*CheckGcPeer) ProtoMessage() + func (m *CheckGcPeer) GetCheckPeer() *metapb.Peer + func (m *CheckGcPeer) GetCheckRegionEpoch() *metapb.RegionEpoch + func (m *CheckGcPeer) GetCheckRegionId() uint64 + func (m *CheckGcPeer) GetFromRegionId() uint64 + func (m *CheckGcPeer) Marshal() (dAtA []byte, err error) + func (m *CheckGcPeer) MarshalTo(dAtA []byte) (int, error) + func (m *CheckGcPeer) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CheckGcPeer) Reset() + func (m *CheckGcPeer) Size() (n int) + func (m *CheckGcPeer) String() string + func (m *CheckGcPeer) Unmarshal(dAtA []byte) error + func (m *CheckGcPeer) XXX_DiscardUnknown() + func (m *CheckGcPeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CheckGcPeer) XXX_Merge(src proto.Message) + func (m *CheckGcPeer) XXX_Size() int + func (m *CheckGcPeer) XXX_Unmarshal(b []byte) error + type Done struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Done) Descriptor() ([]byte, []int) + func (*Done) ProtoMessage() + func (m *Done) Marshal() (dAtA []byte, err error) + func (m *Done) MarshalTo(dAtA []byte) (int, error) + func (m *Done) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Done) Reset() + func (m *Done) Size() (n int) + func (m *Done) String() string + func (m *Done) Unmarshal(dAtA []byte) error + func (m *Done) XXX_DiscardUnknown() + func (m *Done) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Done) XXX_Merge(src proto.Message) + func (m *Done) XXX_Size() int + func (m *Done) XXX_Unmarshal(b []byte) error + type ExtraMessage struct + AvailabilityContext *AvailabilityContext + CheckGcPeer *CheckGcPeer + CheckPeers []*metapb.Peer + FlushMemtable *FlushMemtable + ForcelyAwaken bool + Index uint64 + Type ExtraMessageType + WaitData bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExtraMessage) Descriptor() ([]byte, []int) + func (*ExtraMessage) ProtoMessage() + func (m *ExtraMessage) GetAvailabilityContext() *AvailabilityContext + func (m *ExtraMessage) GetCheckGcPeer() *CheckGcPeer + func (m *ExtraMessage) GetCheckPeers() []*metapb.Peer + func (m *ExtraMessage) GetFlushMemtable() *FlushMemtable + func (m *ExtraMessage) GetForcelyAwaken() bool + func (m *ExtraMessage) GetIndex() uint64 + func (m *ExtraMessage) GetType() ExtraMessageType + func (m *ExtraMessage) GetWaitData() bool + func (m *ExtraMessage) Marshal() (dAtA []byte, err error) + func (m *ExtraMessage) MarshalTo(dAtA []byte) (int, error) + func (m *ExtraMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtraMessage) Reset() + func (m *ExtraMessage) Size() (n int) + func (m *ExtraMessage) String() string + func (m *ExtraMessage) Unmarshal(dAtA []byte) error + func (m *ExtraMessage) XXX_DiscardUnknown() + func (m *ExtraMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExtraMessage) XXX_Merge(src proto.Message) + func (m *ExtraMessage) XXX_Size() int + func (m *ExtraMessage) XXX_Unmarshal(b []byte) error + type ExtraMessageType int32 + const ExtraMessageType_MsgAvailabilityRequest + const ExtraMessageType_MsgAvailabilityResponse + const ExtraMessageType_MsgCheckStalePeer + const ExtraMessageType_MsgCheckStalePeerResponse + const ExtraMessageType_MsgFlushMemtable + const ExtraMessageType_MsgGcPeerRequest + const ExtraMessageType_MsgGcPeerResponse + const ExtraMessageType_MsgHibernateRequest + const ExtraMessageType_MsgHibernateResponse + const ExtraMessageType_MsgRegionWakeUp + const ExtraMessageType_MsgRejectRaftLogCausedByMemoryUsage + const ExtraMessageType_MsgVoterReplicatedIndexRequest + const ExtraMessageType_MsgVoterReplicatedIndexResponse + const ExtraMessageType_MsgWantRollbackMerge + func (ExtraMessageType) EnumDescriptor() ([]byte, []int) + func (x ExtraMessageType) String() string + type FlushMemtable struct + RegionId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FlushMemtable) Descriptor() ([]byte, []int) + func (*FlushMemtable) ProtoMessage() + func (m *FlushMemtable) GetRegionId() uint64 + func (m *FlushMemtable) Marshal() (dAtA []byte, err error) + func (m *FlushMemtable) MarshalTo(dAtA []byte) (int, error) + func (m *FlushMemtable) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FlushMemtable) Reset() + func (m *FlushMemtable) Size() (n int) + func (m *FlushMemtable) String() string + func (m *FlushMemtable) Unmarshal(dAtA []byte) error + func (m *FlushMemtable) XXX_DiscardUnknown() + func (m *FlushMemtable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FlushMemtable) XXX_Merge(src proto.Message) + func (m *FlushMemtable) XXX_Size() int + func (m *FlushMemtable) XXX_Unmarshal(b []byte) error + type KeyValue struct + Key []byte + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeyValue) Descriptor() ([]byte, []int) + func (*KeyValue) ProtoMessage() + func (m *KeyValue) GetKey() []byte + func (m *KeyValue) GetValue() []byte + func (m *KeyValue) Marshal() (dAtA []byte, err error) + func (m *KeyValue) MarshalTo(dAtA []byte) (int, error) + func (m *KeyValue) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KeyValue) Reset() + func (m *KeyValue) Size() (n int) + func (m *KeyValue) String() string + func (m *KeyValue) Unmarshal(dAtA []byte) error + func (m *KeyValue) XXX_DiscardUnknown() + func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyValue) XXX_Merge(src proto.Message) + func (m *KeyValue) XXX_Size() int + func (m *KeyValue) XXX_Unmarshal(b []byte) error + type MergeState struct + Commit uint64 + MinIndex uint64 + Target *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MergeState) Descriptor() ([]byte, []int) + func (*MergeState) ProtoMessage() + func (m *MergeState) GetCommit() uint64 + func (m *MergeState) GetMinIndex() uint64 + func (m *MergeState) GetTarget() *metapb.Region + func (m *MergeState) Marshal() (dAtA []byte, err error) + func (m *MergeState) MarshalTo(dAtA []byte) (int, error) + func (m *MergeState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MergeState) Reset() + func (m *MergeState) Size() (n int) + func (m *MergeState) String() string + func (m *MergeState) Unmarshal(dAtA []byte) error + func (m *MergeState) XXX_DiscardUnknown() + func (m *MergeState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MergeState) XXX_Merge(src proto.Message) + func (m *MergeState) XXX_Size() int + func (m *MergeState) XXX_Unmarshal(b []byte) error + type MergedRecord struct + Index uint64 + SourceEpoch *metapb.RegionEpoch + SourceIndex uint64 + SourcePeers []*metapb.Peer + SourceRegionId uint64 + TargetEpoch *metapb.RegionEpoch + TargetPeers []*metapb.Peer + TargetRegionId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MergedRecord) Descriptor() ([]byte, []int) + func (*MergedRecord) ProtoMessage() + func (m *MergedRecord) GetIndex() uint64 + func (m *MergedRecord) GetSourceEpoch() *metapb.RegionEpoch + func (m *MergedRecord) GetSourceIndex() uint64 + func (m *MergedRecord) GetSourcePeers() []*metapb.Peer + func (m *MergedRecord) GetSourceRegionId() uint64 + func (m *MergedRecord) GetTargetEpoch() *metapb.RegionEpoch + func (m *MergedRecord) GetTargetPeers() []*metapb.Peer + func (m *MergedRecord) GetTargetRegionId() uint64 + func (m *MergedRecord) Marshal() (dAtA []byte, err error) + func (m *MergedRecord) MarshalTo(dAtA []byte) (int, error) + func (m *MergedRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MergedRecord) Reset() + func (m *MergedRecord) Size() (n int) + func (m *MergedRecord) String() string + func (m *MergedRecord) Unmarshal(dAtA []byte) error + func (m *MergedRecord) XXX_DiscardUnknown() + func (m *MergedRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MergedRecord) XXX_Merge(src proto.Message) + func (m *MergedRecord) XXX_Size() int + func (m *MergedRecord) XXX_Unmarshal(b []byte) error + type PeerState int32 + const PeerState_Applying + const PeerState_Merging + const PeerState_Normal + const PeerState_Tombstone + const PeerState_Unavailable + func (PeerState) EnumDescriptor() ([]byte, []int) + func (x PeerState) String() string + type RaftApplyState struct + AppliedIndex uint64 + CommitIndex uint64 + CommitTerm uint64 + LastCommitIndex uint64 + TruncatedState *RaftTruncatedState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RaftApplyState) Descriptor() ([]byte, []int) + func (*RaftApplyState) ProtoMessage() + func (m *RaftApplyState) GetAppliedIndex() uint64 + func (m *RaftApplyState) GetCommitIndex() uint64 + func (m *RaftApplyState) GetCommitTerm() uint64 + func (m *RaftApplyState) GetLastCommitIndex() uint64 + func (m *RaftApplyState) GetTruncatedState() *RaftTruncatedState + func (m *RaftApplyState) Marshal() (dAtA []byte, err error) + func (m *RaftApplyState) MarshalTo(dAtA []byte) (int, error) + func (m *RaftApplyState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RaftApplyState) Reset() + func (m *RaftApplyState) Size() (n int) + func (m *RaftApplyState) String() string + func (m *RaftApplyState) Unmarshal(dAtA []byte) error + func (m *RaftApplyState) XXX_DiscardUnknown() + func (m *RaftApplyState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RaftApplyState) XXX_Merge(src proto.Message) + func (m *RaftApplyState) XXX_Size() int + func (m *RaftApplyState) XXX_Unmarshal(b []byte) error + type RaftLocalState struct + HardState *eraftpb.HardState + LastIndex uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RaftLocalState) Descriptor() ([]byte, []int) + func (*RaftLocalState) ProtoMessage() + func (m *RaftLocalState) GetHardState() *eraftpb.HardState + func (m *RaftLocalState) GetLastIndex() uint64 + func (m *RaftLocalState) Marshal() (dAtA []byte, err error) + func (m *RaftLocalState) MarshalTo(dAtA []byte) (int, error) + func (m *RaftLocalState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RaftLocalState) Reset() + func (m *RaftLocalState) Size() (n int) + func (m *RaftLocalState) String() string + func (m *RaftLocalState) Unmarshal(dAtA []byte) error + func (m *RaftLocalState) XXX_DiscardUnknown() + func (m *RaftLocalState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RaftLocalState) XXX_Merge(src proto.Message) + func (m *RaftLocalState) XXX_Size() int + func (m *RaftLocalState) XXX_Unmarshal(b []byte) error + type RaftMessage struct + DiskUsage disk_usage.DiskUsage + EndKey []byte + ExtraCtx []byte + ExtraMsg *ExtraMessage + FromPeer *metapb.Peer + IsTombstone bool + MergeTarget *metapb.Region + Message *eraftpb.Message + RegionEpoch *metapb.RegionEpoch + RegionId uint64 + StartKey []byte + ToPeer *metapb.Peer + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RaftMessage) Descriptor() ([]byte, []int) + func (*RaftMessage) ProtoMessage() + func (m *RaftMessage) GetDiskUsage() disk_usage.DiskUsage + func (m *RaftMessage) GetEndKey() []byte + func (m *RaftMessage) GetExtraCtx() []byte + func (m *RaftMessage) GetExtraMsg() *ExtraMessage + func (m *RaftMessage) GetFromPeer() *metapb.Peer + func (m *RaftMessage) GetIsTombstone() bool + func (m *RaftMessage) GetMergeTarget() *metapb.Region + func (m *RaftMessage) GetMessage() *eraftpb.Message + func (m *RaftMessage) GetRegionEpoch() *metapb.RegionEpoch + func (m *RaftMessage) GetRegionId() uint64 + func (m *RaftMessage) GetStartKey() []byte + func (m *RaftMessage) GetToPeer() *metapb.Peer + func (m *RaftMessage) Marshal() (dAtA []byte, err error) + func (m *RaftMessage) MarshalTo(dAtA []byte) (int, error) + func (m *RaftMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RaftMessage) Reset() + func (m *RaftMessage) Size() (n int) + func (m *RaftMessage) String() string + func (m *RaftMessage) Unmarshal(dAtA []byte) error + func (m *RaftMessage) XXX_DiscardUnknown() + func (m *RaftMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RaftMessage) XXX_Merge(src proto.Message) + func (m *RaftMessage) XXX_Size() int + func (m *RaftMessage) XXX_Unmarshal(b []byte) error + type RaftSnapshotData struct + Data []*KeyValue + FileSize uint64 + MergedRecords []*MergedRecord + Meta *SnapshotMeta + Region *metapb.Region + RemovedRecords []*metapb.Peer + Version uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RaftSnapshotData) Descriptor() ([]byte, []int) + func (*RaftSnapshotData) ProtoMessage() + func (m *RaftSnapshotData) GetData() []*KeyValue + func (m *RaftSnapshotData) GetFileSize() uint64 + func (m *RaftSnapshotData) GetMergedRecords() []*MergedRecord + func (m *RaftSnapshotData) GetMeta() *SnapshotMeta + func (m *RaftSnapshotData) GetRegion() *metapb.Region + func (m *RaftSnapshotData) GetRemovedRecords() []*metapb.Peer + func (m *RaftSnapshotData) GetVersion() uint64 + func (m *RaftSnapshotData) Marshal() (dAtA []byte, err error) + func (m *RaftSnapshotData) MarshalTo(dAtA []byte) (int, error) + func (m *RaftSnapshotData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RaftSnapshotData) Reset() + func (m *RaftSnapshotData) Size() (n int) + func (m *RaftSnapshotData) String() string + func (m *RaftSnapshotData) Unmarshal(dAtA []byte) error + func (m *RaftSnapshotData) XXX_DiscardUnknown() + func (m *RaftSnapshotData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RaftSnapshotData) XXX_Merge(src proto.Message) + func (m *RaftSnapshotData) XXX_Size() int + func (m *RaftSnapshotData) XXX_Unmarshal(b []byte) error + type RaftTruncatedState struct + Index uint64 + Term uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RaftTruncatedState) Descriptor() ([]byte, []int) + func (*RaftTruncatedState) ProtoMessage() + func (m *RaftTruncatedState) GetIndex() uint64 + func (m *RaftTruncatedState) GetTerm() uint64 + func (m *RaftTruncatedState) Marshal() (dAtA []byte, err error) + func (m *RaftTruncatedState) MarshalTo(dAtA []byte) (int, error) + func (m *RaftTruncatedState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RaftTruncatedState) Reset() + func (m *RaftTruncatedState) Size() (n int) + func (m *RaftTruncatedState) String() string + func (m *RaftTruncatedState) Unmarshal(dAtA []byte) error + func (m *RaftTruncatedState) XXX_DiscardUnknown() + func (m *RaftTruncatedState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RaftTruncatedState) XXX_Merge(src proto.Message) + func (m *RaftTruncatedState) XXX_Size() int + func (m *RaftTruncatedState) XXX_Unmarshal(b []byte) error + type RegionLocalState struct + MergeState *MergeState + MergedRecords []*MergedRecord + Region *metapb.Region + RemovedRecords []*metapb.Peer + State PeerState + TabletIndex uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionLocalState) Descriptor() ([]byte, []int) + func (*RegionLocalState) ProtoMessage() + func (m *RegionLocalState) GetMergeState() *MergeState + func (m *RegionLocalState) GetMergedRecords() []*MergedRecord + func (m *RegionLocalState) GetRegion() *metapb.Region + func (m *RegionLocalState) GetRemovedRecords() []*metapb.Peer + func (m *RegionLocalState) GetState() PeerState + func (m *RegionLocalState) GetTabletIndex() uint64 + func (m *RegionLocalState) Marshal() (dAtA []byte, err error) + func (m *RegionLocalState) MarshalTo(dAtA []byte) (int, error) + func (m *RegionLocalState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RegionLocalState) Reset() + func (m *RegionLocalState) Size() (n int) + func (m *RegionLocalState) String() string + func (m *RegionLocalState) Unmarshal(dAtA []byte) error + func (m *RegionLocalState) XXX_DiscardUnknown() + func (m *RegionLocalState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegionLocalState) XXX_Merge(src proto.Message) + func (m *RegionLocalState) XXX_Size() int + func (m *RegionLocalState) XXX_Unmarshal(b []byte) error + type RegionSequenceNumberRelation struct + ApplyState *RaftApplyState + RegionId uint64 + RegionState *RegionLocalState + SequenceNumber uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionSequenceNumberRelation) Descriptor() ([]byte, []int) + func (*RegionSequenceNumberRelation) ProtoMessage() + func (m *RegionSequenceNumberRelation) GetApplyState() *RaftApplyState + func (m *RegionSequenceNumberRelation) GetRegionId() uint64 + func (m *RegionSequenceNumberRelation) GetRegionState() *RegionLocalState + func (m *RegionSequenceNumberRelation) GetSequenceNumber() uint64 + func (m *RegionSequenceNumberRelation) Marshal() (dAtA []byte, err error) + func (m *RegionSequenceNumberRelation) MarshalTo(dAtA []byte) (int, error) + func (m *RegionSequenceNumberRelation) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RegionSequenceNumberRelation) Reset() + func (m *RegionSequenceNumberRelation) Size() (n int) + func (m *RegionSequenceNumberRelation) String() string + func (m *RegionSequenceNumberRelation) Unmarshal(dAtA []byte) error + func (m *RegionSequenceNumberRelation) XXX_DiscardUnknown() + func (m *RegionSequenceNumberRelation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegionSequenceNumberRelation) XXX_Merge(src proto.Message) + func (m *RegionSequenceNumberRelation) XXX_Size() int + func (m *RegionSequenceNumberRelation) XXX_Unmarshal(b []byte) error + type SnapshotCFFile struct + Cf string + Checksum uint32 + Size_ uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapshotCFFile) Descriptor() ([]byte, []int) + func (*SnapshotCFFile) ProtoMessage() + func (m *SnapshotCFFile) GetCf() string + func (m *SnapshotCFFile) GetChecksum() uint32 + func (m *SnapshotCFFile) GetSize_() uint64 + func (m *SnapshotCFFile) Marshal() (dAtA []byte, err error) + func (m *SnapshotCFFile) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotCFFile) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotCFFile) Reset() + func (m *SnapshotCFFile) Size() (n int) + func (m *SnapshotCFFile) String() string + func (m *SnapshotCFFile) Unmarshal(dAtA []byte) error + func (m *SnapshotCFFile) XXX_DiscardUnknown() + func (m *SnapshotCFFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotCFFile) XXX_Merge(src proto.Message) + func (m *SnapshotCFFile) XXX_Size() int + func (m *SnapshotCFFile) XXX_Unmarshal(b []byte) error + type SnapshotChunk struct + Data []byte + Message *RaftMessage + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapshotChunk) Descriptor() ([]byte, []int) + func (*SnapshotChunk) ProtoMessage() + func (m *SnapshotChunk) GetData() []byte + func (m *SnapshotChunk) GetMessage() *RaftMessage + func (m *SnapshotChunk) Marshal() (dAtA []byte, err error) + func (m *SnapshotChunk) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotChunk) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotChunk) Reset() + func (m *SnapshotChunk) Size() (n int) + func (m *SnapshotChunk) String() string + func (m *SnapshotChunk) Unmarshal(dAtA []byte) error + func (m *SnapshotChunk) XXX_DiscardUnknown() + func (m *SnapshotChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotChunk) XXX_Merge(src proto.Message) + func (m *SnapshotChunk) XXX_Size() int + func (m *SnapshotChunk) XXX_Unmarshal(b []byte) error + type SnapshotMeta struct + CfFiles []*SnapshotCFFile + ForBalance bool + ForWitness bool + GenerateDurationSec uint64 + Start uint64 + TabletSnapPath string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapshotMeta) Descriptor() ([]byte, []int) + func (*SnapshotMeta) ProtoMessage() + func (m *SnapshotMeta) GetCfFiles() []*SnapshotCFFile + func (m *SnapshotMeta) GetForBalance() bool + func (m *SnapshotMeta) GetForWitness() bool + func (m *SnapshotMeta) GetGenerateDurationSec() uint64 + func (m *SnapshotMeta) GetStart() uint64 + func (m *SnapshotMeta) GetTabletSnapPath() string + func (m *SnapshotMeta) Marshal() (dAtA []byte, err error) + func (m *SnapshotMeta) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotMeta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotMeta) Reset() + func (m *SnapshotMeta) Size() (n int) + func (m *SnapshotMeta) String() string + func (m *SnapshotMeta) Unmarshal(dAtA []byte) error + func (m *SnapshotMeta) XXX_DiscardUnknown() + func (m *SnapshotMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotMeta) XXX_Merge(src proto.Message) + func (m *SnapshotMeta) XXX_Size() int + func (m *SnapshotMeta) XXX_Unmarshal(b []byte) error + type StoreIdent struct + ApiVersion kvrpcpb.APIVersion + ClusterId uint64 + StoreId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StoreIdent) Descriptor() ([]byte, []int) + func (*StoreIdent) ProtoMessage() + func (m *StoreIdent) GetApiVersion() kvrpcpb.APIVersion + func (m *StoreIdent) GetClusterId() uint64 + func (m *StoreIdent) GetStoreId() uint64 + func (m *StoreIdent) Marshal() (dAtA []byte, err error) + func (m *StoreIdent) MarshalTo(dAtA []byte) (int, error) + func (m *StoreIdent) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StoreIdent) Reset() + func (m *StoreIdent) Size() (n int) + func (m *StoreIdent) String() string + func (m *StoreIdent) Unmarshal(dAtA []byte) error + func (m *StoreIdent) XXX_DiscardUnknown() + func (m *StoreIdent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StoreIdent) XXX_Merge(src proto.Message) + func (m *StoreIdent) XXX_Size() int + func (m *StoreIdent) XXX_Unmarshal(b []byte) error + type StoreRecoverState struct + Seqno uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StoreRecoverState) Descriptor() ([]byte, []int) + func (*StoreRecoverState) ProtoMessage() + func (m *StoreRecoverState) GetSeqno() uint64 + func (m *StoreRecoverState) Marshal() (dAtA []byte, err error) + func (m *StoreRecoverState) MarshalTo(dAtA []byte) (int, error) + func (m *StoreRecoverState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StoreRecoverState) Reset() + func (m *StoreRecoverState) Size() (n int) + func (m *StoreRecoverState) String() string + func (m *StoreRecoverState) Unmarshal(dAtA []byte) error + func (m *StoreRecoverState) XXX_DiscardUnknown() + func (m *StoreRecoverState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StoreRecoverState) XXX_Merge(src proto.Message) + func (m *StoreRecoverState) XXX_Size() int + func (m *StoreRecoverState) XXX_Unmarshal(b []byte) error + type TabletSnapshotEnd struct + Checksum uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TabletSnapshotEnd) Descriptor() ([]byte, []int) + func (*TabletSnapshotEnd) ProtoMessage() + func (m *TabletSnapshotEnd) GetChecksum() uint64 + func (m *TabletSnapshotEnd) Marshal() (dAtA []byte, err error) + func (m *TabletSnapshotEnd) MarshalTo(dAtA []byte) (int, error) + func (m *TabletSnapshotEnd) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TabletSnapshotEnd) Reset() + func (m *TabletSnapshotEnd) Size() (n int) + func (m *TabletSnapshotEnd) String() string + func (m *TabletSnapshotEnd) Unmarshal(dAtA []byte) error + func (m *TabletSnapshotEnd) XXX_DiscardUnknown() + func (m *TabletSnapshotEnd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TabletSnapshotEnd) XXX_Merge(src proto.Message) + func (m *TabletSnapshotEnd) XXX_Size() int + func (m *TabletSnapshotEnd) XXX_Unmarshal(b []byte) error + type TabletSnapshotFileChunk struct + Data []byte + FileName string + FileSize uint64 + Iv []byte + Key *encryptionpb.DataKey + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TabletSnapshotFileChunk) Descriptor() ([]byte, []int) + func (*TabletSnapshotFileChunk) ProtoMessage() + func (m *TabletSnapshotFileChunk) GetData() []byte + func (m *TabletSnapshotFileChunk) GetFileName() string + func (m *TabletSnapshotFileChunk) GetFileSize() uint64 + func (m *TabletSnapshotFileChunk) GetIv() []byte + func (m *TabletSnapshotFileChunk) GetKey() *encryptionpb.DataKey + func (m *TabletSnapshotFileChunk) Marshal() (dAtA []byte, err error) + func (m *TabletSnapshotFileChunk) MarshalTo(dAtA []byte) (int, error) + func (m *TabletSnapshotFileChunk) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TabletSnapshotFileChunk) Reset() + func (m *TabletSnapshotFileChunk) Size() (n int) + func (m *TabletSnapshotFileChunk) String() string + func (m *TabletSnapshotFileChunk) Unmarshal(dAtA []byte) error + func (m *TabletSnapshotFileChunk) XXX_DiscardUnknown() + func (m *TabletSnapshotFileChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TabletSnapshotFileChunk) XXX_Merge(src proto.Message) + func (m *TabletSnapshotFileChunk) XXX_Size() int + func (m *TabletSnapshotFileChunk) XXX_Unmarshal(b []byte) error + type TabletSnapshotFileMeta struct + FileName string + FileSize uint64 + HeadChunk []byte + TrailingChunk []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TabletSnapshotFileMeta) Descriptor() ([]byte, []int) + func (*TabletSnapshotFileMeta) ProtoMessage() + func (m *TabletSnapshotFileMeta) GetFileName() string + func (m *TabletSnapshotFileMeta) GetFileSize() uint64 + func (m *TabletSnapshotFileMeta) GetHeadChunk() []byte + func (m *TabletSnapshotFileMeta) GetTrailingChunk() []byte + func (m *TabletSnapshotFileMeta) Marshal() (dAtA []byte, err error) + func (m *TabletSnapshotFileMeta) MarshalTo(dAtA []byte) (int, error) + func (m *TabletSnapshotFileMeta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TabletSnapshotFileMeta) Reset() + func (m *TabletSnapshotFileMeta) Size() (n int) + func (m *TabletSnapshotFileMeta) String() string + func (m *TabletSnapshotFileMeta) Unmarshal(dAtA []byte) error + func (m *TabletSnapshotFileMeta) XXX_DiscardUnknown() + func (m *TabletSnapshotFileMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TabletSnapshotFileMeta) XXX_Merge(src proto.Message) + func (m *TabletSnapshotFileMeta) XXX_Size() int + func (m *TabletSnapshotFileMeta) XXX_Unmarshal(b []byte) error + type TabletSnapshotHead struct + Message *RaftMessage + UseCache bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TabletSnapshotHead) Descriptor() ([]byte, []int) + func (*TabletSnapshotHead) ProtoMessage() + func (m *TabletSnapshotHead) GetMessage() *RaftMessage + func (m *TabletSnapshotHead) GetUseCache() bool + func (m *TabletSnapshotHead) Marshal() (dAtA []byte, err error) + func (m *TabletSnapshotHead) MarshalTo(dAtA []byte) (int, error) + func (m *TabletSnapshotHead) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TabletSnapshotHead) Reset() + func (m *TabletSnapshotHead) Size() (n int) + func (m *TabletSnapshotHead) String() string + func (m *TabletSnapshotHead) Unmarshal(dAtA []byte) error + func (m *TabletSnapshotHead) XXX_DiscardUnknown() + func (m *TabletSnapshotHead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TabletSnapshotHead) XXX_Merge(src proto.Message) + func (m *TabletSnapshotHead) XXX_Size() int + func (m *TabletSnapshotHead) XXX_Unmarshal(b []byte) error + type TabletSnapshotPreview struct + End bool + Metas []*TabletSnapshotFileMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TabletSnapshotPreview) Descriptor() ([]byte, []int) + func (*TabletSnapshotPreview) ProtoMessage() + func (m *TabletSnapshotPreview) GetEnd() bool + func (m *TabletSnapshotPreview) GetMetas() []*TabletSnapshotFileMeta + func (m *TabletSnapshotPreview) Marshal() (dAtA []byte, err error) + func (m *TabletSnapshotPreview) MarshalTo(dAtA []byte) (int, error) + func (m *TabletSnapshotPreview) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TabletSnapshotPreview) Reset() + func (m *TabletSnapshotPreview) Size() (n int) + func (m *TabletSnapshotPreview) String() string + func (m *TabletSnapshotPreview) Unmarshal(dAtA []byte) error + func (m *TabletSnapshotPreview) XXX_DiscardUnknown() + func (m *TabletSnapshotPreview) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TabletSnapshotPreview) XXX_Merge(src proto.Message) + func (m *TabletSnapshotPreview) XXX_Size() int + func (m *TabletSnapshotPreview) XXX_Unmarshal(b []byte) error + type TabletSnapshotRequest struct + Payload isTabletSnapshotRequest_Payload + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TabletSnapshotRequest) Descriptor() ([]byte, []int) + func (*TabletSnapshotRequest) ProtoMessage() + func (*TabletSnapshotRequest) XXX_OneofWrappers() []interface{} + func (m *TabletSnapshotRequest) GetChunk() *TabletSnapshotFileChunk + func (m *TabletSnapshotRequest) GetEnd() *TabletSnapshotEnd + func (m *TabletSnapshotRequest) GetHead() *TabletSnapshotHead + func (m *TabletSnapshotRequest) GetPayload() isTabletSnapshotRequest_Payload + func (m *TabletSnapshotRequest) GetPreview() *TabletSnapshotPreview + func (m *TabletSnapshotRequest) Marshal() (dAtA []byte, err error) + func (m *TabletSnapshotRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TabletSnapshotRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TabletSnapshotRequest) Reset() + func (m *TabletSnapshotRequest) Size() (n int) + func (m *TabletSnapshotRequest) String() string + func (m *TabletSnapshotRequest) Unmarshal(dAtA []byte) error + func (m *TabletSnapshotRequest) XXX_DiscardUnknown() + func (m *TabletSnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TabletSnapshotRequest) XXX_Merge(src proto.Message) + func (m *TabletSnapshotRequest) XXX_Size() int + func (m *TabletSnapshotRequest) XXX_Unmarshal(b []byte) error + type TabletSnapshotRequest_Chunk struct + Chunk *TabletSnapshotFileChunk + func (m *TabletSnapshotRequest_Chunk) MarshalTo(dAtA []byte) (int, error) + func (m *TabletSnapshotRequest_Chunk) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TabletSnapshotRequest_Chunk) Size() (n int) + type TabletSnapshotRequest_End struct + End *TabletSnapshotEnd + func (m *TabletSnapshotRequest_End) MarshalTo(dAtA []byte) (int, error) + func (m *TabletSnapshotRequest_End) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TabletSnapshotRequest_End) Size() (n int) + type TabletSnapshotRequest_Head struct + Head *TabletSnapshotHead + func (m *TabletSnapshotRequest_Head) MarshalTo(dAtA []byte) (int, error) + func (m *TabletSnapshotRequest_Head) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TabletSnapshotRequest_Head) Size() (n int) + type TabletSnapshotRequest_Preview struct + Preview *TabletSnapshotPreview + func (m *TabletSnapshotRequest_Preview) MarshalTo(dAtA []byte) (int, error) + func (m *TabletSnapshotRequest_Preview) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TabletSnapshotRequest_Preview) Size() (n int) + type TabletSnapshotResponse struct + Files *AcceptedSnapshotFiles + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TabletSnapshotResponse) Descriptor() ([]byte, []int) + func (*TabletSnapshotResponse) ProtoMessage() + func (m *TabletSnapshotResponse) GetFiles() *AcceptedSnapshotFiles + func (m *TabletSnapshotResponse) Marshal() (dAtA []byte, err error) + func (m *TabletSnapshotResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TabletSnapshotResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TabletSnapshotResponse) Reset() + func (m *TabletSnapshotResponse) Size() (n int) + func (m *TabletSnapshotResponse) String() string + func (m *TabletSnapshotResponse) Unmarshal(dAtA []byte) error + func (m *TabletSnapshotResponse) XXX_DiscardUnknown() + func (m *TabletSnapshotResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TabletSnapshotResponse) XXX_Merge(src proto.Message) + func (m *TabletSnapshotResponse) XXX_Size() int + func (m *TabletSnapshotResponse) XXX_Unmarshal(b []byte) error