raft_serverpb

package
v0.0.0-...-8b85187 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 17, 2024 License: Apache-2.0 Imports: 11 Imported by: 66

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRaftServerpb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaftServerpb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRaftServerpb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ExtraMessageType_name = map[int32]string{
	0:  "MsgRegionWakeUp",
	1:  "MsgWantRollbackMerge",
	2:  "MsgCheckStalePeer",
	3:  "MsgCheckStalePeerResponse",
	4:  "MsgHibernateRequest",
	5:  "MsgHibernateResponse",
	6:  "MsgRejectRaftLogCausedByMemoryUsage",
	7:  "MsgAvailabilityRequest",
	8:  "MsgAvailabilityResponse",
	9:  "MsgVoterReplicatedIndexRequest",
	10: "MsgVoterReplicatedIndexResponse",
	11: "MsgGcPeerRequest",
	12: "MsgGcPeerResponse",
	13: "MsgFlushMemtable",
	14: "MsgRefreshBuckets",
	15: "MsgSnapGenPrecheckRequest",
	16: "MsgSnapGenPrecheckResponse",
	17: "MsgPreLoadRegionRequest",
	18: "MsgPreLoadRegionResponse",
}
View Source 
var ExtraMessageType_value = map[string]int32{
	"MsgRegionWakeUp":                     0,
	"MsgWantRollbackMerge":                1,
	"MsgCheckStalePeer":                   2,
	"MsgCheckStalePeerResponse":           3,
	"MsgHibernateRequest":                 4,
	"MsgHibernateResponse":                5,
	"MsgRejectRaftLogCausedByMemoryUsage": 6,
	"MsgAvailabilityRequest":              7,
	"MsgAvailabilityResponse":             8,
	"MsgVoterReplicatedIndexRequest":      9,
	"MsgVoterReplicatedIndexResponse":     10,
	"MsgGcPeerRequest":                    11,
	"MsgGcPeerResponse":                   12,
	"MsgFlushMemtable":                    13,
	"MsgRefreshBuckets":                   14,
	"MsgSnapGenPrecheckRequest":           15,
	"MsgSnapGenPrecheckResponse":          16,
	"MsgPreLoadRegionRequest":             17,
	"MsgPreLoadRegionResponse":            18,
}
View Source 
var PeerState_name = map[int32]string{
	0: "Normal",
	1: "Applying",
	2: "Tombstone",
	3: "Merging",
	4: "Unavailable",
}
View Source 
var PeerState_value = map[string]int32{
	"Normal":      0,
	"Applying":    1,
	"Tombstone":   2,
	"Merging":     3,
	"Unavailable": 4,
}

Functions

This section is empty.

Types

type AcceptedSnapshotFiles 

type AcceptedSnapshotFiles struct {
	FileName []string `protobuf:"bytes,1,rep,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
}

func (*AcceptedSnapshotFiles) Descriptor 

func (*AcceptedSnapshotFiles) Descriptor() ([]byte, []int)

func (*AcceptedSnapshotFiles) GetFileName 

func (m *AcceptedSnapshotFiles) GetFileName() []string

func (*AcceptedSnapshotFiles) Marshal 

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

func (*AcceptedSnapshotFiles) MarshalTo 

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

func (*AcceptedSnapshotFiles) MarshalToSizedBuffer 

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

func (*AcceptedSnapshotFiles) ProtoMessage 

func (*AcceptedSnapshotFiles) ProtoMessage()

func (*AcceptedSnapshotFiles) Reset 

func (m *AcceptedSnapshotFiles) Reset()

func (*AcceptedSnapshotFiles) Size 

func (m *AcceptedSnapshotFiles) Size() (n int)

func (*AcceptedSnapshotFiles) String 

func (m *AcceptedSnapshotFiles) String() string

func (*AcceptedSnapshotFiles) Unmarshal 

func (m *AcceptedSnapshotFiles) Unmarshal(dAtA []byte) error

func (*AcceptedSnapshotFiles) XXX_DiscardUnknown 

func (m *AcceptedSnapshotFiles) XXX_DiscardUnknown()

func (*AcceptedSnapshotFiles) XXX_Marshal 

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

func (*AcceptedSnapshotFiles) XXX_Merge 

func (m *AcceptedSnapshotFiles) XXX_Merge(src proto.Message)

func (*AcceptedSnapshotFiles) XXX_Size 

func (m *AcceptedSnapshotFiles) XXX_Size() int

func (*AcceptedSnapshotFiles) XXX_Unmarshal 

func (m *AcceptedSnapshotFiles) XXX_Unmarshal(b []byte) error

type AvailabilityContext 

type AvailabilityContext struct {
	FromRegionId    uint64              `protobuf:"varint,1,opt,name=from_region_id,json=fromRegionId,proto3" json:"from_region_id,omitempty"`
	FromRegionEpoch *metapb.RegionEpoch `protobuf:"bytes,2,opt,name=from_region_epoch,json=fromRegionEpoch,proto3" json:"from_region_epoch,omitempty"`
	Unavailable     bool                `protobuf:"varint,3,opt,name=unavailable,proto3" json:"unavailable,omitempty"`
	Trimmed         bool                `protobuf:"varint,4,opt,name=trimmed,proto3" json:"trimmed,omitempty"`
}

func (*AvailabilityContext) Descriptor 

func (*AvailabilityContext) Descriptor() ([]byte, []int)

func (*AvailabilityContext) GetFromRegionEpoch 

func (m *AvailabilityContext) GetFromRegionEpoch() *metapb.RegionEpoch

func (*AvailabilityContext) GetFromRegionId 

func (m *AvailabilityContext) GetFromRegionId() uint64

func (*AvailabilityContext) GetTrimmed 

func (m *AvailabilityContext) GetTrimmed() bool

func (*AvailabilityContext) GetUnavailable 

func (m *AvailabilityContext) GetUnavailable() bool

func (*AvailabilityContext) Marshal 

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

func (*AvailabilityContext) MarshalTo 

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

func (*AvailabilityContext) MarshalToSizedBuffer 

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

func (*AvailabilityContext) ProtoMessage 

func (*AvailabilityContext) ProtoMessage()

func (*AvailabilityContext) Reset 

func (m *AvailabilityContext) Reset()

func (*AvailabilityContext) Size 

func (m *AvailabilityContext) Size() (n int)

func (*AvailabilityContext) String 

func (m *AvailabilityContext) String() string

func (*AvailabilityContext) Unmarshal 

func (m *AvailabilityContext) Unmarshal(dAtA []byte) error

func (*AvailabilityContext) XXX_DiscardUnknown 

func (m *AvailabilityContext) XXX_DiscardUnknown()

func (*AvailabilityContext) XXX_Marshal 

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

func (*AvailabilityContext) XXX_Merge 

func (m *AvailabilityContext) XXX_Merge(src proto.Message)

func (*AvailabilityContext) XXX_Size 

func (m *AvailabilityContext) XXX_Size() int

func (*AvailabilityContext) XXX_Unmarshal 

func (m *AvailabilityContext) XXX_Unmarshal(b []byte) error

type CheckGcPeer 

type CheckGcPeer struct {
	// The region ID who triggers the check and wait for report. It should be
	// the ID of RaftMessage.from.
	FromRegionId uint64 `protobuf:"varint,1,opt,name=from_region_id,json=fromRegionId,proto3" json:"from_region_id,omitempty"`
	// The region ID to be checked if should be destroyed.
	CheckRegionId uint64 `protobuf:"varint,2,opt,name=check_region_id,json=checkRegionId,proto3" json:"check_region_id,omitempty"`
	// The epoch of the region to be checked.
	CheckRegionEpoch *metapb.RegionEpoch `protobuf:"bytes,3,opt,name=check_region_epoch,json=checkRegionEpoch,proto3" json:"check_region_epoch,omitempty"`
	// The peer to be checked.
	CheckPeer *metapb.Peer `protobuf:"bytes,4,opt,name=check_peer,json=checkPeer,proto3" json:"check_peer,omitempty"`
}

func (*CheckGcPeer) Descriptor 

func (*CheckGcPeer) Descriptor() ([]byte, []int)

func (*CheckGcPeer) GetCheckPeer 

func (m *CheckGcPeer) GetCheckPeer() *metapb.Peer

func (*CheckGcPeer) GetCheckRegionEpoch 

func (m *CheckGcPeer) GetCheckRegionEpoch() *metapb.RegionEpoch

func (*CheckGcPeer) GetCheckRegionId 

func (m *CheckGcPeer) GetCheckRegionId() uint64

func (*CheckGcPeer) GetFromRegionId 

func (m *CheckGcPeer) GetFromRegionId() uint64

func (*CheckGcPeer) Marshal 

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

func (*CheckGcPeer) MarshalTo 

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

func (*CheckGcPeer) MarshalToSizedBuffer 

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

func (*CheckGcPeer) ProtoMessage 

func (*CheckGcPeer) ProtoMessage()

func (*CheckGcPeer) Reset 

func (m *CheckGcPeer) Reset()

func (*CheckGcPeer) Size 

func (m *CheckGcPeer) Size() (n int)

func (*CheckGcPeer) String 

func (m *CheckGcPeer) String() string

func (*CheckGcPeer) Unmarshal 

func (m *CheckGcPeer) Unmarshal(dAtA []byte) error

func (*CheckGcPeer) XXX_DiscardUnknown 

func (m *CheckGcPeer) XXX_DiscardUnknown()

func (*CheckGcPeer) XXX_Marshal 

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

func (*CheckGcPeer) XXX_Merge 

func (m *CheckGcPeer) XXX_Merge(src proto.Message)

func (*CheckGcPeer) XXX_Size 

func (m *CheckGcPeer) XXX_Size() int

func (*CheckGcPeer) XXX_Unmarshal 

func (m *CheckGcPeer) XXX_Unmarshal(b []byte) error

type Done 

type Done struct {
}

func (*Done) Descriptor 

func (*Done) Descriptor() ([]byte, []int)

func (*Done) Marshal 

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

func (*Done) MarshalTo 

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

func (*Done) MarshalToSizedBuffer 

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

func (*Done) ProtoMessage 

func (*Done) ProtoMessage()

func (*Done) Reset 

func (m *Done) Reset()

func (*Done) Size 

func (m *Done) Size() (n int)

func (*Done) String 

func (m *Done) String() string

func (*Done) Unmarshal 

func (m *Done) Unmarshal(dAtA []byte) error

func (*Done) XXX_DiscardUnknown 

func (m *Done) XXX_DiscardUnknown()

func (*Done) XXX_Marshal 

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

func (*Done) XXX_Merge 

func (m *Done) XXX_Merge(src proto.Message)

func (*Done) XXX_Size 

func (m *Done) XXX_Size() int

func (*Done) XXX_Unmarshal 

func (m *Done) XXX_Unmarshal(b []byte) error

type ExtraMessage 

type ExtraMessage struct {
	Type ExtraMessageType `protobuf:"varint,1,opt,name=type,proto3,enum=raft_serverpb.ExtraMessageType" json:"type,omitempty"`
	// It's merge related index. In `WantRollbackMerge`, it's prepare merge index. In
	// `MsgGcPeerRequest`, it's the commit merge index. In `MsgVoterReplicatedIndexRequest`
	// it's the voter_replicated_index.
	Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	// In `MsgCheckStalePeerResponse`, it's the peers that receiver can continue to query.
	CheckPeers []*metapb.Peer `protobuf:"bytes,3,rep,name=check_peers,json=checkPeers,proto3" json:"check_peers,omitempty"`
	WaitData   bool           `protobuf:"varint,4,opt,name=wait_data,json=waitData,proto3" json:"wait_data,omitempty"`
	// Flag for forcely wake up hibernate regions if true.
	ForcelyAwaken bool           `protobuf:"varint,5,opt,name=forcely_awaken,json=forcelyAwaken,proto3" json:"forcely_awaken,omitempty"`
	CheckGcPeer   *CheckGcPeer   `protobuf:"bytes,6,opt,name=check_gc_peer,json=checkGcPeer,proto3" json:"check_gc_peer,omitempty"`
	FlushMemtable *FlushMemtable `protobuf:"bytes,7,opt,name=flush_memtable,json=flushMemtable,proto3" json:"flush_memtable,omitempty"`
	// Used by `MsgAvailabilityRequest` and `MsgAvailabilityResponse` in v2.
	AvailabilityContext *AvailabilityContext `protobuf:"bytes,8,opt,name=availability_context,json=availabilityContext,proto3" json:"availability_context,omitempty"`
	// notice the peer to refresh buckets version
	RefreshBuckets *RefreshBuckets `protobuf:"bytes,9,opt,name=refresh_buckets,json=refreshBuckets,proto3" json:"refresh_buckets,omitempty"`
	// snap_gen_precheck_passed is used to indicate the precheck result when
	// a follower responds to a leader's snapshot gen precheck request.
	SnapGenPrecheckPassed bool `` /* 130-byte string literal not displayed */
}

func (*ExtraMessage) Descriptor 

func (*ExtraMessage) Descriptor() ([]byte, []int)

func (*ExtraMessage) GetAvailabilityContext 

func (m *ExtraMessage) GetAvailabilityContext() *AvailabilityContext

func (*ExtraMessage) GetCheckGcPeer 

func (m *ExtraMessage) GetCheckGcPeer() *CheckGcPeer

func (*ExtraMessage) GetCheckPeers 

func (m *ExtraMessage) GetCheckPeers() []*metapb.Peer

func (*ExtraMessage) GetFlushMemtable 

func (m *ExtraMessage) GetFlushMemtable() *FlushMemtable

func (*ExtraMessage) GetForcelyAwaken 

func (m *ExtraMessage) GetForcelyAwaken() bool

func (*ExtraMessage) GetIndex 

func (m *ExtraMessage) GetIndex() uint64

func (*ExtraMessage) GetRefreshBuckets 

func (m *ExtraMessage) GetRefreshBuckets() *RefreshBuckets

func (*ExtraMessage) GetSnapGenPrecheckPassed 

func (m *ExtraMessage) GetSnapGenPrecheckPassed() bool

func (*ExtraMessage) GetType 

func (m *ExtraMessage) GetType() ExtraMessageType

func (*ExtraMessage) GetWaitData 

func (m *ExtraMessage) GetWaitData() bool

func (*ExtraMessage) Marshal 

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

func (*ExtraMessage) MarshalTo 

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

func (*ExtraMessage) MarshalToSizedBuffer 

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

func (*ExtraMessage) ProtoMessage 

func (*ExtraMessage) ProtoMessage()

func (*ExtraMessage) Reset 

func (m *ExtraMessage) Reset()

func (*ExtraMessage) Size 

func (m *ExtraMessage) Size() (n int)

func (*ExtraMessage) String 

func (m *ExtraMessage) String() string

func (*ExtraMessage) Unmarshal 

func (m *ExtraMessage) Unmarshal(dAtA []byte) error

func (*ExtraMessage) XXX_DiscardUnknown 

func (m *ExtraMessage) XXX_DiscardUnknown()

func (*ExtraMessage) XXX_Marshal 

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

func (*ExtraMessage) XXX_Merge 

func (m *ExtraMessage) XXX_Merge(src proto.Message)

func (*ExtraMessage) XXX_Size 

func (m *ExtraMessage) XXX_Size() int

func (*ExtraMessage) XXX_Unmarshal 

func (m *ExtraMessage) XXX_Unmarshal(b []byte) error

type ExtraMessageType 

type ExtraMessageType int32
const (
	ExtraMessageType_MsgRegionWakeUp           ExtraMessageType = 0
	ExtraMessageType_MsgWantRollbackMerge      ExtraMessageType = 1
	ExtraMessageType_MsgCheckStalePeer         ExtraMessageType = 2
	ExtraMessageType_MsgCheckStalePeerResponse ExtraMessageType = 3
	// If leader is going to sleep, it will send requests to all its followers
	// to make sure they all agree to sleep.
	ExtraMessageType_MsgHibernateRequest                 ExtraMessageType = 4
	ExtraMessageType_MsgHibernateResponse                ExtraMessageType = 5
	ExtraMessageType_MsgRejectRaftLogCausedByMemoryUsage ExtraMessageType = 6
	ExtraMessageType_MsgAvailabilityRequest              ExtraMessageType = 7
	ExtraMessageType_MsgAvailabilityResponse             ExtraMessageType = 8
	ExtraMessageType_MsgVoterReplicatedIndexRequest      ExtraMessageType = 9
	ExtraMessageType_MsgVoterReplicatedIndexResponse     ExtraMessageType = 10
	// Message means that `from` is tombstone. Leader can then update removed_records.
	ExtraMessageType_MsgGcPeerRequest  ExtraMessageType = 11
	ExtraMessageType_MsgGcPeerResponse ExtraMessageType = 12
	ExtraMessageType_MsgFlushMemtable  ExtraMessageType = 13
	ExtraMessageType_MsgRefreshBuckets ExtraMessageType = 14
	// Messages for the snapshot gen precheck process.
	ExtraMessageType_MsgSnapGenPrecheckRequest  ExtraMessageType = 15
	ExtraMessageType_MsgSnapGenPrecheckResponse ExtraMessageType = 16
	// Used in transfer leader process for leader to inform follower to load the
	// region into in-memory engine if the relevant region is cached.
	ExtraMessageType_MsgPreLoadRegionRequest ExtraMessageType = 17
	// Used in transfer leader process for follower to inform leader the completes
	// of the region cache
	ExtraMessageType_MsgPreLoadRegionResponse ExtraMessageType = 18
)

func (ExtraMessageType) EnumDescriptor 

func (ExtraMessageType) EnumDescriptor() ([]byte, []int)

func (ExtraMessageType) String 

func (x ExtraMessageType) String() string

type FlushMemtable 

type FlushMemtable struct {
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

func (*FlushMemtable) Descriptor 

func (*FlushMemtable) Descriptor() ([]byte, []int)

func (*FlushMemtable) GetRegionId 

func (m *FlushMemtable) GetRegionId() uint64

func (*FlushMemtable) Marshal 

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

func (*FlushMemtable) MarshalTo 

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

func (*FlushMemtable) MarshalToSizedBuffer 

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

func (*FlushMemtable) ProtoMessage 

func (*FlushMemtable) ProtoMessage()

func (*FlushMemtable) Reset 

func (m *FlushMemtable) Reset()

func (*FlushMemtable) Size 

func (m *FlushMemtable) Size() (n int)

func (*FlushMemtable) String 

func (m *FlushMemtable) String() string

func (*FlushMemtable) Unmarshal 

func (m *FlushMemtable) Unmarshal(dAtA []byte) error

func (*FlushMemtable) XXX_DiscardUnknown 

func (m *FlushMemtable) XXX_DiscardUnknown()

func (*FlushMemtable) XXX_Marshal 

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

func (*FlushMemtable) XXX_Merge 

func (m *FlushMemtable) XXX_Merge(src proto.Message)

func (*FlushMemtable) XXX_Size 

func (m *FlushMemtable) XXX_Size() int

func (*FlushMemtable) XXX_Unmarshal 

func (m *FlushMemtable) XXX_Unmarshal(b []byte) error

type KeyValue 

type KeyValue struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*KeyValue) Descriptor 

func (*KeyValue) Descriptor() ([]byte, []int)

func (*KeyValue) GetKey 

func (m *KeyValue) GetKey() []byte

func (*KeyValue) GetValue 

func (m *KeyValue) GetValue() []byte

func (*KeyValue) Marshal 

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

func (*KeyValue) MarshalTo 

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

func (*KeyValue) MarshalToSizedBuffer 

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

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) Size 

func (m *KeyValue) Size() (n int)

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) Unmarshal 

func (m *KeyValue) Unmarshal(dAtA []byte) error

func (*KeyValue) XXX_DiscardUnknown 

func (m *KeyValue) XXX_DiscardUnknown()

func (*KeyValue) XXX_Marshal 

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

func (*KeyValue) XXX_Merge 

func (m *KeyValue) XXX_Merge(src proto.Message)

func (*KeyValue) XXX_Size 

func (m *KeyValue) XXX_Size() int

func (*KeyValue) XXX_Unmarshal 

func (m *KeyValue) XXX_Unmarshal(b []byte) error

type MergeState 

type MergeState struct {
	MinIndex uint64         `protobuf:"varint,1,opt,name=min_index,json=minIndex,proto3" json:"min_index,omitempty"`
	Target   *metapb.Region `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Commit   uint64         `protobuf:"varint,3,opt,name=commit,proto3" json:"commit,omitempty"`
}

func (*MergeState) Descriptor 

func (*MergeState) Descriptor() ([]byte, []int)

func (*MergeState) GetCommit 

func (m *MergeState) GetCommit() uint64

func (*MergeState) GetMinIndex 

func (m *MergeState) GetMinIndex() uint64

func (*MergeState) GetTarget 

func (m *MergeState) GetTarget() *metapb.Region

func (*MergeState) Marshal 

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

func (*MergeState) MarshalTo 

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

func (*MergeState) MarshalToSizedBuffer 

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

func (*MergeState) ProtoMessage 

func (*MergeState) ProtoMessage()

func (*MergeState) Reset 

func (m *MergeState) Reset()

func (*MergeState) Size 

func (m *MergeState) Size() (n int)

func (*MergeState) String 

func (m *MergeState) String() string

func (*MergeState) Unmarshal 

func (m *MergeState) Unmarshal(dAtA []byte) error

func (*MergeState) XXX_DiscardUnknown 

func (m *MergeState) XXX_DiscardUnknown()

func (*MergeState) XXX_Marshal 

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

func (*MergeState) XXX_Merge 

func (m *MergeState) XXX_Merge(src proto.Message)

func (*MergeState) XXX_Size 

func (m *MergeState) XXX_Size() int

func (*MergeState) XXX_Unmarshal 

func (m *MergeState) XXX_Unmarshal(b []byte) error

type MergedRecord 

type MergedRecord struct {
	SourceRegionId uint64              `protobuf:"varint,1,opt,name=source_region_id,json=sourceRegionId,proto3" json:"source_region_id,omitempty"`
	SourceEpoch    *metapb.RegionEpoch `protobuf:"bytes,2,opt,name=source_epoch,json=sourceEpoch,proto3" json:"source_epoch,omitempty"`
	// Peers of source region when merge is committed.
	SourcePeers []*metapb.Peer `protobuf:"bytes,3,rep,name=source_peers,json=sourcePeers,proto3" json:"source_peers,omitempty"`
	// Removed peers (by confchange) of source region when merge is committed.
	SourceRemovedRecords []*metapb.Peer      `protobuf:"bytes,9,rep,name=source_removed_records,json=sourceRemovedRecords,proto3" json:"source_removed_records,omitempty"`
	TargetRegionId       uint64              `protobuf:"varint,4,opt,name=target_region_id,json=targetRegionId,proto3" json:"target_region_id,omitempty"`
	TargetEpoch          *metapb.RegionEpoch `protobuf:"bytes,5,opt,name=target_epoch,json=targetEpoch,proto3" json:"target_epoch,omitempty"`
	TargetPeers          []*metapb.Peer      `protobuf:"bytes,6,rep,name=target_peers,json=targetPeers,proto3" json:"target_peers,omitempty"`
	// Commit merge index.
	Index uint64 `protobuf:"varint,7,opt,name=index,proto3" json:"index,omitempty"`
	// Prepare merge index.
	SourceIndex uint64 `protobuf:"varint,8,opt,name=source_index,json=sourceIndex,proto3" json:"source_index,omitempty"`
}

func (*MergedRecord) Descriptor 

func (*MergedRecord) Descriptor() ([]byte, []int)

func (*MergedRecord) GetIndex 

func (m *MergedRecord) GetIndex() uint64

func (*MergedRecord) GetSourceEpoch 

func (m *MergedRecord) GetSourceEpoch() *metapb.RegionEpoch

func (*MergedRecord) GetSourceIndex 

func (m *MergedRecord) GetSourceIndex() uint64

func (*MergedRecord) GetSourcePeers 

func (m *MergedRecord) GetSourcePeers() []*metapb.Peer

func (*MergedRecord) GetSourceRegionId 

func (m *MergedRecord) GetSourceRegionId() uint64

func (*MergedRecord) GetSourceRemovedRecords 

func (m *MergedRecord) GetSourceRemovedRecords() []*metapb.Peer

func (*MergedRecord) GetTargetEpoch 

func (m *MergedRecord) GetTargetEpoch() *metapb.RegionEpoch

func (*MergedRecord) GetTargetPeers 

func (m *MergedRecord) GetTargetPeers() []*metapb.Peer

func (*MergedRecord) GetTargetRegionId 

func (m *MergedRecord) GetTargetRegionId() uint64

func (*MergedRecord) Marshal 

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

func (*MergedRecord) MarshalTo 

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

func (*MergedRecord) MarshalToSizedBuffer 

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

func (*MergedRecord) ProtoMessage 

func (*MergedRecord) ProtoMessage()

func (*MergedRecord) Reset 

func (m *MergedRecord) Reset()

func (*MergedRecord) Size 

func (m *MergedRecord) Size() (n int)

func (*MergedRecord) String 

func (m *MergedRecord) String() string

func (*MergedRecord) Unmarshal 

func (m *MergedRecord) Unmarshal(dAtA []byte) error

func (*MergedRecord) XXX_DiscardUnknown 

func (m *MergedRecord) XXX_DiscardUnknown()

func (*MergedRecord) XXX_Marshal 

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

func (*MergedRecord) XXX_Merge 

func (m *MergedRecord) XXX_Merge(src proto.Message)

func (*MergedRecord) XXX_Size 

func (m *MergedRecord) XXX_Size() int

func (*MergedRecord) XXX_Unmarshal 

func (m *MergedRecord) XXX_Unmarshal(b []byte) error

type PeerState 

type PeerState int32
const (
	PeerState_Normal    PeerState = 0
	PeerState_Applying  PeerState = 1
	PeerState_Tombstone PeerState = 2
	PeerState_Merging   PeerState = 3
	// Currently used for witness to non-witness conversion: When a witness
	// has just become a non-witness, we need to set and persist this state,
	// so that when the service restarts before applying snapshot, we can
	// actively request snapshot when initializing this peer.
	PeerState_Unavailable PeerState = 4
)

func (PeerState) EnumDescriptor 

func (PeerState) EnumDescriptor() ([]byte, []int)

func (PeerState) String 

func (x PeerState) String() string

type RaftApplyState 

type RaftApplyState struct {
	AppliedIndex    uint64              `protobuf:"varint,1,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	LastCommitIndex uint64              `protobuf:"varint,3,opt,name=last_commit_index,json=lastCommitIndex,proto3" json:"last_commit_index,omitempty"`
	CommitIndex     uint64              `protobuf:"varint,4,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	CommitTerm      uint64              `protobuf:"varint,5,opt,name=commit_term,json=commitTerm,proto3" json:"commit_term,omitempty"`
	TruncatedState  *RaftTruncatedState `protobuf:"bytes,2,opt,name=truncated_state,json=truncatedState,proto3" json:"truncated_state,omitempty"`
}

func (*RaftApplyState) Descriptor 

func (*RaftApplyState) Descriptor() ([]byte, []int)

func (*RaftApplyState) GetAppliedIndex 

func (m *RaftApplyState) GetAppliedIndex() uint64

func (*RaftApplyState) GetCommitIndex 

func (m *RaftApplyState) GetCommitIndex() uint64

func (*RaftApplyState) GetCommitTerm 

func (m *RaftApplyState) GetCommitTerm() uint64

func (*RaftApplyState) GetLastCommitIndex 

func (m *RaftApplyState) GetLastCommitIndex() uint64

func (*RaftApplyState) GetTruncatedState 

func (m *RaftApplyState) GetTruncatedState() *RaftTruncatedState

func (*RaftApplyState) Marshal 

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

func (*RaftApplyState) MarshalTo 

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

func (*RaftApplyState) MarshalToSizedBuffer 

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

func (*RaftApplyState) ProtoMessage 

func (*RaftApplyState) ProtoMessage()

func (*RaftApplyState) Reset 

func (m *RaftApplyState) Reset()

func (*RaftApplyState) Size 

func (m *RaftApplyState) Size() (n int)

func (*RaftApplyState) String 

func (m *RaftApplyState) String() string

func (*RaftApplyState) Unmarshal 

func (m *RaftApplyState) Unmarshal(dAtA []byte) error

func (*RaftApplyState) XXX_DiscardUnknown 

func (m *RaftApplyState) XXX_DiscardUnknown()

func (*RaftApplyState) XXX_Marshal 

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

func (*RaftApplyState) XXX_Merge 

func (m *RaftApplyState) XXX_Merge(src proto.Message)

func (*RaftApplyState) XXX_Size 

func (m *RaftApplyState) XXX_Size() int

func (*RaftApplyState) XXX_Unmarshal 

func (m *RaftApplyState) XXX_Unmarshal(b []byte) error

type RaftLocalState 

type RaftLocalState struct {
	HardState *eraftpb.HardState `protobuf:"bytes,1,opt,name=hard_state,json=hardState,proto3" json:"hard_state,omitempty"`
	LastIndex uint64             `protobuf:"varint,2,opt,name=last_index,json=lastIndex,proto3" json:"last_index,omitempty"`
}

func (*RaftLocalState) Descriptor 

func (*RaftLocalState) Descriptor() ([]byte, []int)

func (*RaftLocalState) GetHardState 

func (m *RaftLocalState) GetHardState() *eraftpb.HardState

func (*RaftLocalState) GetLastIndex 

func (m *RaftLocalState) GetLastIndex() uint64

func (*RaftLocalState) Marshal 

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

func (*RaftLocalState) MarshalTo 

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

func (*RaftLocalState) MarshalToSizedBuffer 

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

func (*RaftLocalState) ProtoMessage 

func (*RaftLocalState) ProtoMessage()

func (*RaftLocalState) Reset 

func (m *RaftLocalState) Reset()

func (*RaftLocalState) Size 

func (m *RaftLocalState) Size() (n int)

func (*RaftLocalState) String 

func (m *RaftLocalState) String() string

func (*RaftLocalState) Unmarshal 

func (m *RaftLocalState) Unmarshal(dAtA []byte) error

func (*RaftLocalState) XXX_DiscardUnknown 

func (m *RaftLocalState) XXX_DiscardUnknown()

func (*RaftLocalState) XXX_Marshal 

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

func (*RaftLocalState) XXX_Merge 

func (m *RaftLocalState) XXX_Merge(src proto.Message)

func (*RaftLocalState) XXX_Size 

func (m *RaftLocalState) XXX_Size() int

func (*RaftLocalState) XXX_Unmarshal 

func (m *RaftLocalState) XXX_Unmarshal(b []byte) error

type RaftMessage 

type RaftMessage struct {
	RegionId    uint64              `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	FromPeer    *metapb.Peer        `protobuf:"bytes,2,opt,name=from_peer,json=fromPeer,proto3" json:"from_peer,omitempty"`
	ToPeer      *metapb.Peer        `protobuf:"bytes,3,opt,name=to_peer,json=toPeer,proto3" json:"to_peer,omitempty"`
	Message     *eraftpb.Message    `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	RegionEpoch *metapb.RegionEpoch `protobuf:"bytes,5,opt,name=region_epoch,json=regionEpoch,proto3" json:"region_epoch,omitempty"`
	// true means to_peer is a tombstone peer and it should remove itself.
	IsTombstone bool `protobuf:"varint,6,opt,name=is_tombstone,json=isTombstone,proto3" json:"is_tombstone,omitempty"`
	// Region key range [start_key, end_key).
	StartKey []byte `protobuf:"bytes,7,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   []byte `protobuf:"bytes,8,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	// If it has value, to_peer should be removed if merge is never going to complete.
	MergeTarget *metapb.Region       `protobuf:"bytes,9,opt,name=merge_target,json=mergeTarget,proto3" json:"merge_target,omitempty"`
	ExtraMsg    *ExtraMessage        `protobuf:"bytes,10,opt,name=extra_msg,json=extraMsg,proto3" json:"extra_msg,omitempty"`
	ExtraCtx    []byte               `protobuf:"bytes,11,opt,name=extra_ctx,json=extraCtx,proto3" json:"extra_ctx,omitempty"`
	DiskUsage   disk_usage.DiskUsage `protobuf:"varint,12,opt,name=disk_usage,json=diskUsage,proto3,enum=disk_usage.DiskUsage" json:"disk_usage,omitempty"`
}

func (*RaftMessage) Descriptor 

func (*RaftMessage) Descriptor() ([]byte, []int)

func (*RaftMessage) GetDiskUsage 

func (m *RaftMessage) GetDiskUsage() disk_usage.DiskUsage

func (*RaftMessage) GetEndKey 

func (m *RaftMessage) GetEndKey() []byte

func (*RaftMessage) GetExtraCtx 

func (m *RaftMessage) GetExtraCtx() []byte

func (*RaftMessage) GetExtraMsg 

func (m *RaftMessage) GetExtraMsg() *ExtraMessage

func (*RaftMessage) GetFromPeer 

func (m *RaftMessage) GetFromPeer() *metapb.Peer

func (*RaftMessage) GetIsTombstone 

func (m *RaftMessage) GetIsTombstone() bool

func (*RaftMessage) GetMergeTarget 

func (m *RaftMessage) GetMergeTarget() *metapb.Region

func (*RaftMessage) GetMessage 

func (m *RaftMessage) GetMessage() *eraftpb.Message

func (*RaftMessage) GetRegionEpoch 

func (m *RaftMessage) GetRegionEpoch() *metapb.RegionEpoch

func (*RaftMessage) GetRegionId 

func (m *RaftMessage) GetRegionId() uint64

func (*RaftMessage) GetStartKey 

func (m *RaftMessage) GetStartKey() []byte

func (*RaftMessage) GetToPeer 

func (m *RaftMessage) GetToPeer() *metapb.Peer

func (*RaftMessage) Marshal 

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

func (*RaftMessage) MarshalTo 

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

func (*RaftMessage) MarshalToSizedBuffer 

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

func (*RaftMessage) ProtoMessage 

func (*RaftMessage) ProtoMessage()

func (*RaftMessage) Reset 

func (m *RaftMessage) Reset()

func (*RaftMessage) Size 

func (m *RaftMessage) Size() (n int)

func (*RaftMessage) String 

func (m *RaftMessage) String() string

func (*RaftMessage) Unmarshal 

func (m *RaftMessage) Unmarshal(dAtA []byte) error

func (*RaftMessage) XXX_DiscardUnknown 

func (m *RaftMessage) XXX_DiscardUnknown()

func (*RaftMessage) XXX_Marshal 

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

func (*RaftMessage) XXX_Merge 

func (m *RaftMessage) XXX_Merge(src proto.Message)

func (*RaftMessage) XXX_Size 

func (m *RaftMessage) XXX_Size() int

func (*RaftMessage) XXX_Unmarshal 

func (m *RaftMessage) XXX_Unmarshal(b []byte) error

type RaftSnapshotData 

type RaftSnapshotData struct {
	Region         *metapb.Region  `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	FileSize       uint64          `protobuf:"varint,2,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	Data           []*KeyValue     `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"`
	Version        uint64          `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	Meta           *SnapshotMeta   `protobuf:"bytes,5,opt,name=meta,proto3" json:"meta,omitempty"`
	RemovedRecords []*metapb.Peer  `protobuf:"bytes,6,rep,name=removed_records,json=removedRecords,proto3" json:"removed_records,omitempty"`
	MergedRecords  []*MergedRecord `protobuf:"bytes,7,rep,name=merged_records,json=mergedRecords,proto3" json:"merged_records,omitempty"`
}

func (*RaftSnapshotData) Descriptor 

func (*RaftSnapshotData) Descriptor() ([]byte, []int)

func (*RaftSnapshotData) GetData 

func (m *RaftSnapshotData) GetData() []*KeyValue

func (*RaftSnapshotData) GetFileSize 

func (m *RaftSnapshotData) GetFileSize() uint64

func (*RaftSnapshotData) GetMergedRecords 

func (m *RaftSnapshotData) GetMergedRecords() []*MergedRecord

func (*RaftSnapshotData) GetMeta 

func (m *RaftSnapshotData) GetMeta() *SnapshotMeta

func (*RaftSnapshotData) GetRegion 

func (m *RaftSnapshotData) GetRegion() *metapb.Region

func (*RaftSnapshotData) GetRemovedRecords 

func (m *RaftSnapshotData) GetRemovedRecords() []*metapb.Peer

func (*RaftSnapshotData) GetVersion 

func (m *RaftSnapshotData) GetVersion() uint64

func (*RaftSnapshotData) Marshal 

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

func (*RaftSnapshotData) MarshalTo 

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

func (*RaftSnapshotData) MarshalToSizedBuffer 

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

func (*RaftSnapshotData) ProtoMessage 

func (*RaftSnapshotData) ProtoMessage()

func (*RaftSnapshotData) Reset 

func (m *RaftSnapshotData) Reset()

func (*RaftSnapshotData) Size 

func (m *RaftSnapshotData) Size() (n int)

func (*RaftSnapshotData) String 

func (m *RaftSnapshotData) String() string

func (*RaftSnapshotData) Unmarshal 

func (m *RaftSnapshotData) Unmarshal(dAtA []byte) error

func (*RaftSnapshotData) XXX_DiscardUnknown 

func (m *RaftSnapshotData) XXX_DiscardUnknown()

func (*RaftSnapshotData) XXX_Marshal 

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

func (*RaftSnapshotData) XXX_Merge 

func (m *RaftSnapshotData) XXX_Merge(src proto.Message)

func (*RaftSnapshotData) XXX_Size 

func (m *RaftSnapshotData) XXX_Size() int

func (*RaftSnapshotData) XXX_Unmarshal 

func (m *RaftSnapshotData) XXX_Unmarshal(b []byte) error

type RaftTruncatedState 

type RaftTruncatedState struct {
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Term  uint64 `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
}

func (*RaftTruncatedState) Descriptor 

func (*RaftTruncatedState) Descriptor() ([]byte, []int)

func (*RaftTruncatedState) GetIndex 

func (m *RaftTruncatedState) GetIndex() uint64

func (*RaftTruncatedState) GetTerm 

func (m *RaftTruncatedState) GetTerm() uint64

func (*RaftTruncatedState) Marshal 

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

func (*RaftTruncatedState) MarshalTo 

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

func (*RaftTruncatedState) MarshalToSizedBuffer 

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

func (*RaftTruncatedState) ProtoMessage 

func (*RaftTruncatedState) ProtoMessage()

func (*RaftTruncatedState) Reset 

func (m *RaftTruncatedState) Reset()

func (*RaftTruncatedState) Size 

func (m *RaftTruncatedState) Size() (n int)

func (*RaftTruncatedState) String 

func (m *RaftTruncatedState) String() string

func (*RaftTruncatedState) Unmarshal 

func (m *RaftTruncatedState) Unmarshal(dAtA []byte) error

func (*RaftTruncatedState) XXX_DiscardUnknown 

func (m *RaftTruncatedState) XXX_DiscardUnknown()

func (*RaftTruncatedState) XXX_Marshal 

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

func (*RaftTruncatedState) XXX_Merge 

func (m *RaftTruncatedState) XXX_Merge(src proto.Message)

func (*RaftTruncatedState) XXX_Size 

func (m *RaftTruncatedState) XXX_Size() int

func (*RaftTruncatedState) XXX_Unmarshal 

func (m *RaftTruncatedState) XXX_Unmarshal(b []byte) error

type RefreshBuckets 

type RefreshBuckets struct {
	Version uint64   `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Keys    [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	Sizes   []uint64 `protobuf:"varint,3,rep,packed,name=sizes,proto3" json:"sizes,omitempty"`
}

func (*RefreshBuckets) Descriptor 

func (*RefreshBuckets) Descriptor() ([]byte, []int)

func (*RefreshBuckets) GetKeys 

func (m *RefreshBuckets) GetKeys() [][]byte

func (*RefreshBuckets) GetSizes 

func (m *RefreshBuckets) GetSizes() []uint64

func (*RefreshBuckets) GetVersion 

func (m *RefreshBuckets) GetVersion() uint64

func (*RefreshBuckets) Marshal 

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

func (*RefreshBuckets) MarshalTo 

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

func (*RefreshBuckets) MarshalToSizedBuffer 

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

func (*RefreshBuckets) ProtoMessage 

func (*RefreshBuckets) ProtoMessage()

func (*RefreshBuckets) Reset 

func (m *RefreshBuckets) Reset()

func (*RefreshBuckets) Size 

func (m *RefreshBuckets) Size() (n int)

func (*RefreshBuckets) String 

func (m *RefreshBuckets) String() string

func (*RefreshBuckets) Unmarshal 

func (m *RefreshBuckets) Unmarshal(dAtA []byte) error

func (*RefreshBuckets) XXX_DiscardUnknown 

func (m *RefreshBuckets) XXX_DiscardUnknown()

func (*RefreshBuckets) XXX_Marshal 

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

func (*RefreshBuckets) XXX_Merge 

func (m *RefreshBuckets) XXX_Merge(src proto.Message)

func (*RefreshBuckets) XXX_Size 

func (m *RefreshBuckets) XXX_Size() int

func (*RefreshBuckets) XXX_Unmarshal 

func (m *RefreshBuckets) XXX_Unmarshal(b []byte) error

type RegionLocalState 

type RegionLocalState struct {
	State      PeerState      `protobuf:"varint,1,opt,name=state,proto3,enum=raft_serverpb.PeerState" json:"state,omitempty"`
	Region     *metapb.Region `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	MergeState *MergeState    `protobuf:"bytes,3,opt,name=merge_state,json=mergeState,proto3" json:"merge_state,omitempty"`
	// The apply index corresponding to the storage when it's initialized.
	TabletIndex uint64 `protobuf:"varint,4,opt,name=tablet_index,json=tabletIndex,proto3" json:"tablet_index,omitempty"`
	// Raft doesn't guarantee peer will be removed in the end. In v1, peer finds
	// out its destiny by logs or broadcast; in v2, leader is responsible to
	// ensure removed peers are destroyed.
	// Note: only peers who has been part of this region can be in this list.
	RemovedRecords []*metapb.Peer `protobuf:"bytes,5,rep,name=removed_records,json=removedRecords,proto3" json:"removed_records,omitempty"`
	// Merged peer can't be deleted like gc peers. Instead, leader needs to
	// query target peer to decide whether source peer can be destroyed.
	MergedRecords []*MergedRecord `protobuf:"bytes,6,rep,name=merged_records,json=mergedRecords,proto3" json:"merged_records,omitempty"`
}

func (*RegionLocalState) Descriptor 

func (*RegionLocalState) Descriptor() ([]byte, []int)

func (*RegionLocalState) GetMergeState 

func (m *RegionLocalState) GetMergeState() *MergeState

func (*RegionLocalState) GetMergedRecords 

func (m *RegionLocalState) GetMergedRecords() []*MergedRecord

func (*RegionLocalState) GetRegion 

func (m *RegionLocalState) GetRegion() *metapb.Region

func (*RegionLocalState) GetRemovedRecords 

func (m *RegionLocalState) GetRemovedRecords() []*metapb.Peer

func (*RegionLocalState) GetState 

func (m *RegionLocalState) GetState() PeerState

func (*RegionLocalState) GetTabletIndex 

func (m *RegionLocalState) GetTabletIndex() uint64

func (*RegionLocalState) Marshal 

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

func (*RegionLocalState) MarshalTo 

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

func (*RegionLocalState) MarshalToSizedBuffer 

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

func (*RegionLocalState) ProtoMessage 

func (*RegionLocalState) ProtoMessage()

func (*RegionLocalState) Reset 

func (m *RegionLocalState) Reset()

func (*RegionLocalState) Size 

func (m *RegionLocalState) Size() (n int)

func (*RegionLocalState) String 

func (m *RegionLocalState) String() string

func (*RegionLocalState) Unmarshal 

func (m *RegionLocalState) Unmarshal(dAtA []byte) error

func (*RegionLocalState) XXX_DiscardUnknown 

func (m *RegionLocalState) XXX_DiscardUnknown()

func (*RegionLocalState) XXX_Marshal 

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

func (*RegionLocalState) XXX_Merge 

func (m *RegionLocalState) XXX_Merge(src proto.Message)

func (*RegionLocalState) XXX_Size 

func (m *RegionLocalState) XXX_Size() int

func (*RegionLocalState) XXX_Unmarshal 

func (m *RegionLocalState) XXX_Unmarshal(b []byte) error

type RegionSequenceNumberRelation 

type RegionSequenceNumberRelation struct {
	RegionId       uint64            `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	SequenceNumber uint64            `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	ApplyState     *RaftApplyState   `protobuf:"bytes,3,opt,name=apply_state,json=applyState,proto3" json:"apply_state,omitempty"`
	RegionState    *RegionLocalState `protobuf:"bytes,4,opt,name=region_state,json=regionState,proto3" json:"region_state,omitempty"`
}

func (*RegionSequenceNumberRelation) Descriptor 

func (*RegionSequenceNumberRelation) Descriptor() ([]byte, []int)

func (*RegionSequenceNumberRelation) GetApplyState 

func (m *RegionSequenceNumberRelation) GetApplyState() *RaftApplyState

func (*RegionSequenceNumberRelation) GetRegionId 

func (m *RegionSequenceNumberRelation) GetRegionId() uint64

func (*RegionSequenceNumberRelation) GetRegionState 

func (m *RegionSequenceNumberRelation) GetRegionState() *RegionLocalState

func (*RegionSequenceNumberRelation) GetSequenceNumber 

func (m *RegionSequenceNumberRelation) GetSequenceNumber() uint64

func (*RegionSequenceNumberRelation) Marshal 

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

func (*RegionSequenceNumberRelation) MarshalTo 

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

func (*RegionSequenceNumberRelation) MarshalToSizedBuffer 

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

func (*RegionSequenceNumberRelation) ProtoMessage 

func (*RegionSequenceNumberRelation) ProtoMessage()

func (*RegionSequenceNumberRelation) Reset 

func (m *RegionSequenceNumberRelation) Reset()

func (*RegionSequenceNumberRelation) Size 

func (m *RegionSequenceNumberRelation) Size() (n int)

func (*RegionSequenceNumberRelation) String 

func (m *RegionSequenceNumberRelation) String() string

func (*RegionSequenceNumberRelation) Unmarshal 

func (m *RegionSequenceNumberRelation) Unmarshal(dAtA []byte) error

func (*RegionSequenceNumberRelation) XXX_DiscardUnknown 

func (m *RegionSequenceNumberRelation) XXX_DiscardUnknown()

func (*RegionSequenceNumberRelation) XXX_Marshal 

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

func (*RegionSequenceNumberRelation) XXX_Merge 

func (m *RegionSequenceNumberRelation) XXX_Merge(src proto.Message)

func (*RegionSequenceNumberRelation) XXX_Size 

func (m *RegionSequenceNumberRelation) XXX_Size() int

func (*RegionSequenceNumberRelation) XXX_Unmarshal 

func (m *RegionSequenceNumberRelation) XXX_Unmarshal(b []byte) error

type SnapshotCFFile 

type SnapshotCFFile struct {
	Cf       string `protobuf:"bytes,1,opt,name=cf,proto3" json:"cf,omitempty"`
	Size_    uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Checksum uint32 `protobuf:"varint,3,opt,name=checksum,proto3" json:"checksum,omitempty"`
}

func (*SnapshotCFFile) Descriptor 

func (*SnapshotCFFile) Descriptor() ([]byte, []int)

func (*SnapshotCFFile) GetCf 

func (m *SnapshotCFFile) GetCf() string

func (*SnapshotCFFile) GetChecksum 

func (m *SnapshotCFFile) GetChecksum() uint32

func (*SnapshotCFFile) GetSize_ 

func (m *SnapshotCFFile) GetSize_() uint64

func (*SnapshotCFFile) Marshal 

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

func (*SnapshotCFFile) MarshalTo 

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

func (*SnapshotCFFile) MarshalToSizedBuffer 

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

func (*SnapshotCFFile) ProtoMessage 

func (*SnapshotCFFile) ProtoMessage()

func (*SnapshotCFFile) Reset 

func (m *SnapshotCFFile) Reset()

func (*SnapshotCFFile) Size 

func (m *SnapshotCFFile) Size() (n int)

func (*SnapshotCFFile) String 

func (m *SnapshotCFFile) String() string

func (*SnapshotCFFile) Unmarshal 

func (m *SnapshotCFFile) Unmarshal(dAtA []byte) error

func (*SnapshotCFFile) XXX_DiscardUnknown 

func (m *SnapshotCFFile) XXX_DiscardUnknown()

func (*SnapshotCFFile) XXX_Marshal 

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

func (*SnapshotCFFile) XXX_Merge 

func (m *SnapshotCFFile) XXX_Merge(src proto.Message)

func (*SnapshotCFFile) XXX_Size 

func (m *SnapshotCFFile) XXX_Size() int

func (*SnapshotCFFile) XXX_Unmarshal 

func (m *SnapshotCFFile) XXX_Unmarshal(b []byte) error

type SnapshotChunk 

type SnapshotChunk struct {
	Message *RaftMessage `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Data    []byte       `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*SnapshotChunk) Descriptor 

func (*SnapshotChunk) Descriptor() ([]byte, []int)

func (*SnapshotChunk) GetData 

func (m *SnapshotChunk) GetData() []byte

func (*SnapshotChunk) GetMessage 

func (m *SnapshotChunk) GetMessage() *RaftMessage

func (*SnapshotChunk) Marshal 

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

func (*SnapshotChunk) MarshalTo 

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

func (*SnapshotChunk) MarshalToSizedBuffer 

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

func (*SnapshotChunk) ProtoMessage 

func (*SnapshotChunk) ProtoMessage()

func (*SnapshotChunk) Reset 

func (m *SnapshotChunk) Reset()

func (*SnapshotChunk) Size 

func (m *SnapshotChunk) Size() (n int)

func (*SnapshotChunk) String 

func (m *SnapshotChunk) String() string

func (*SnapshotChunk) Unmarshal 

func (m *SnapshotChunk) Unmarshal(dAtA []byte) error

func (*SnapshotChunk) XXX_DiscardUnknown 

func (m *SnapshotChunk) XXX_DiscardUnknown()

func (*SnapshotChunk) XXX_Marshal 

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

func (*SnapshotChunk) XXX_Merge 

func (m *SnapshotChunk) XXX_Merge(src proto.Message)

func (*SnapshotChunk) XXX_Size 

func (m *SnapshotChunk) XXX_Size() int

func (*SnapshotChunk) XXX_Unmarshal 

func (m *SnapshotChunk) XXX_Unmarshal(b []byte) error

type SnapshotMeta 

type SnapshotMeta struct {
	CfFiles []*SnapshotCFFile `protobuf:"bytes,1,rep,name=cf_files,json=cfFiles,proto3" json:"cf_files,omitempty"`
	// true means this snapshot is triggered for load balance
	ForBalance bool `protobuf:"varint,2,opt,name=for_balance,json=forBalance,proto3" json:"for_balance,omitempty"`
	// true means this is an empty snapshot for witness
	ForWitness bool `protobuf:"varint,3,opt,name=for_witness,json=forWitness,proto3" json:"for_witness,omitempty"`
	// the timestamp second to generate snapshot
	Start uint64 `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty"`
	// the duration of generating snapshot
	GenerateDurationSec uint64 `protobuf:"varint,5,opt,name=generate_duration_sec,json=generateDurationSec,proto3" json:"generate_duration_sec,omitempty"`
	// the path of the tablet snapshot, it should only be used for v1 to receive
	// snapshot from v2
	TabletSnapPath string `protobuf:"bytes,6,opt,name=tablet_snap_path,json=tabletSnapPath,proto3" json:"tablet_snap_path,omitempty"`
	// A hint of the latest commit index on leader when sending snapshot.
	// It should only be used for v2 to send snapshot to v1.
	// See https://github.com/pingcap/tiflash/issues/7568
	CommitIndexHint uint64 `protobuf:"varint,7,opt,name=commit_index_hint,json=commitIndexHint,proto3" json:"commit_index_hint,omitempty"`
}

func (*SnapshotMeta) Descriptor 

func (*SnapshotMeta) Descriptor() ([]byte, []int)

func (*SnapshotMeta) GetCfFiles 

func (m *SnapshotMeta) GetCfFiles() []*SnapshotCFFile

func (*SnapshotMeta) GetCommitIndexHint 

func (m *SnapshotMeta) GetCommitIndexHint() uint64

func (*SnapshotMeta) GetForBalance 

func (m *SnapshotMeta) GetForBalance() bool

func (*SnapshotMeta) GetForWitness 

func (m *SnapshotMeta) GetForWitness() bool

func (*SnapshotMeta) GetGenerateDurationSec 

func (m *SnapshotMeta) GetGenerateDurationSec() uint64

func (*SnapshotMeta) GetStart 

func (m *SnapshotMeta) GetStart() uint64

func (*SnapshotMeta) GetTabletSnapPath 

func (m *SnapshotMeta) GetTabletSnapPath() string

func (*SnapshotMeta) Marshal 

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

func (*SnapshotMeta) MarshalTo 

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

func (*SnapshotMeta) MarshalToSizedBuffer 

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

func (*SnapshotMeta) ProtoMessage 

func (*SnapshotMeta) ProtoMessage()

func (*SnapshotMeta) Reset 

func (m *SnapshotMeta) Reset()

func (*SnapshotMeta) Size 

func (m *SnapshotMeta) Size() (n int)

func (*SnapshotMeta) String 

func (m *SnapshotMeta) String() string

func (*SnapshotMeta) Unmarshal 

func (m *SnapshotMeta) Unmarshal(dAtA []byte) error

func (*SnapshotMeta) XXX_DiscardUnknown 

func (m *SnapshotMeta) XXX_DiscardUnknown()

func (*SnapshotMeta) XXX_Marshal 

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

func (*SnapshotMeta) XXX_Merge 

func (m *SnapshotMeta) XXX_Merge(src proto.Message)

func (*SnapshotMeta) XXX_Size 

func (m *SnapshotMeta) XXX_Size() int

func (*SnapshotMeta) XXX_Unmarshal 

func (m *SnapshotMeta) XXX_Unmarshal(b []byte) error

type StoreIdent 

type StoreIdent struct {
	ClusterId  uint64             `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	StoreId    uint64             `protobuf:"varint,2,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	ApiVersion kvrpcpb.APIVersion `protobuf:"varint,3,opt,name=api_version,json=apiVersion,proto3,enum=kvrpcpb.APIVersion" json:"api_version,omitempty"`
}

func (*StoreIdent) Descriptor 

func (*StoreIdent) Descriptor() ([]byte, []int)

func (*StoreIdent) GetApiVersion 

func (m *StoreIdent) GetApiVersion() kvrpcpb.APIVersion

func (*StoreIdent) GetClusterId 

func (m *StoreIdent) GetClusterId() uint64

func (*StoreIdent) GetStoreId 

func (m *StoreIdent) GetStoreId() uint64

func (*StoreIdent) Marshal 

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

func (*StoreIdent) MarshalTo 

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

func (*StoreIdent) MarshalToSizedBuffer 

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

func (*StoreIdent) ProtoMessage 

func (*StoreIdent) ProtoMessage()

func (*StoreIdent) Reset 

func (m *StoreIdent) Reset()

func (*StoreIdent) Size 

func (m *StoreIdent) Size() (n int)

func (*StoreIdent) String 

func (m *StoreIdent) String() string

func (*StoreIdent) Unmarshal 

func (m *StoreIdent) Unmarshal(dAtA []byte) error

func (*StoreIdent) XXX_DiscardUnknown 

func (m *StoreIdent) XXX_DiscardUnknown()

func (*StoreIdent) XXX_Marshal 

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

func (*StoreIdent) XXX_Merge 

func (m *StoreIdent) XXX_Merge(src proto.Message)

func (*StoreIdent) XXX_Size 

func (m *StoreIdent) XXX_Size() int

func (*StoreIdent) XXX_Unmarshal 

func (m *StoreIdent) XXX_Unmarshal(b []byte) error

type StoreRecoverState 

type StoreRecoverState struct {
	// Used for TiKV start recovery when WAL of KVDB was disabled.
	// TiKV may read all relations between seqno and raft log index, and replay
	// all raft logs which corresponding seqno smaller than the seqno here.
	// After TiKV replays all raft logs and flushed KV data, the seqno here must
	// be updated.
	Seqno uint64 `protobuf:"varint,1,opt,name=seqno,proto3" json:"seqno,omitempty"`
}

func (*StoreRecoverState) Descriptor 

func (*StoreRecoverState) Descriptor() ([]byte, []int)

func (*StoreRecoverState) GetSeqno 

func (m *StoreRecoverState) GetSeqno() uint64

func (*StoreRecoverState) Marshal 

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

func (*StoreRecoverState) MarshalTo 

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

func (*StoreRecoverState) MarshalToSizedBuffer 

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

func (*StoreRecoverState) ProtoMessage 

func (*StoreRecoverState) ProtoMessage()

func (*StoreRecoverState) Reset 

func (m *StoreRecoverState) Reset()

func (*StoreRecoverState) Size 

func (m *StoreRecoverState) Size() (n int)

func (*StoreRecoverState) String 

func (m *StoreRecoverState) String() string

func (*StoreRecoverState) Unmarshal 

func (m *StoreRecoverState) Unmarshal(dAtA []byte) error

func (*StoreRecoverState) XXX_DiscardUnknown 

func (m *StoreRecoverState) XXX_DiscardUnknown()

func (*StoreRecoverState) XXX_Marshal 

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

func (*StoreRecoverState) XXX_Merge 

func (m *StoreRecoverState) XXX_Merge(src proto.Message)

func (*StoreRecoverState) XXX_Size 

func (m *StoreRecoverState) XXX_Size() int

func (*StoreRecoverState) XXX_Unmarshal 

func (m *StoreRecoverState) XXX_Unmarshal(b []byte) error

type TabletSnapshotEnd 

type TabletSnapshotEnd struct {
	// Checksum of all data sent in `TabletSnapshotFileChunk.data` and
	// `TabletSnapshotFileChunk.file_name`.
	Checksum uint64 `protobuf:"varint,1,opt,name=checksum,proto3" json:"checksum,omitempty"`
}

func (*TabletSnapshotEnd) Descriptor 

func (*TabletSnapshotEnd) Descriptor() ([]byte, []int)

func (*TabletSnapshotEnd) GetChecksum 

func (m *TabletSnapshotEnd) GetChecksum() uint64

func (*TabletSnapshotEnd) Marshal 

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

func (*TabletSnapshotEnd) MarshalTo 

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

func (*TabletSnapshotEnd) MarshalToSizedBuffer 

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

func (*TabletSnapshotEnd) ProtoMessage 

func (*TabletSnapshotEnd) ProtoMessage()

func (*TabletSnapshotEnd) Reset 

func (m *TabletSnapshotEnd) Reset()

func (*TabletSnapshotEnd) Size 

func (m *TabletSnapshotEnd) Size() (n int)

func (*TabletSnapshotEnd) String 

func (m *TabletSnapshotEnd) String() string

func (*TabletSnapshotEnd) Unmarshal 

func (m *TabletSnapshotEnd) Unmarshal(dAtA []byte) error

func (*TabletSnapshotEnd) XXX_DiscardUnknown 

func (m *TabletSnapshotEnd) XXX_DiscardUnknown()

func (*TabletSnapshotEnd) XXX_Marshal 

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

func (*TabletSnapshotEnd) XXX_Merge 

func (m *TabletSnapshotEnd) XXX_Merge(src proto.Message)

func (*TabletSnapshotEnd) XXX_Size 

func (m *TabletSnapshotEnd) XXX_Size() int

func (*TabletSnapshotEnd) XXX_Unmarshal 

func (m *TabletSnapshotEnd) XXX_Unmarshal(b []byte) error

type TabletSnapshotFileChunk 

type TabletSnapshotFileChunk struct {
	FileSize uint64 `protobuf:"varint,1,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	FileName string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// Encrypted.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// Initial vector if encryption is enabled.
	Iv  []byte                `protobuf:"bytes,4,opt,name=iv,proto3" json:"iv,omitempty"`
	Key *encryptionpb.DataKey `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
}

func (*TabletSnapshotFileChunk) Descriptor 

func (*TabletSnapshotFileChunk) Descriptor() ([]byte, []int)

func (*TabletSnapshotFileChunk) GetData 

func (m *TabletSnapshotFileChunk) GetData() []byte

func (*TabletSnapshotFileChunk) GetFileName 

func (m *TabletSnapshotFileChunk) GetFileName() string

func (*TabletSnapshotFileChunk) GetFileSize 

func (m *TabletSnapshotFileChunk) GetFileSize() uint64

func (*TabletSnapshotFileChunk) GetIv 

func (m *TabletSnapshotFileChunk) GetIv() []byte

func (*TabletSnapshotFileChunk) GetKey 

func (m *TabletSnapshotFileChunk) GetKey() *encryptionpb.DataKey

func (*TabletSnapshotFileChunk) Marshal 

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

func (*TabletSnapshotFileChunk) MarshalTo 

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

func (*TabletSnapshotFileChunk) MarshalToSizedBuffer 

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

func (*TabletSnapshotFileChunk) ProtoMessage 

func (*TabletSnapshotFileChunk) ProtoMessage()

func (*TabletSnapshotFileChunk) Reset 

func (m *TabletSnapshotFileChunk) Reset()

func (*TabletSnapshotFileChunk) Size 

func (m *TabletSnapshotFileChunk) Size() (n int)

func (*TabletSnapshotFileChunk) String 

func (m *TabletSnapshotFileChunk) String() string

func (*TabletSnapshotFileChunk) Unmarshal 

func (m *TabletSnapshotFileChunk) Unmarshal(dAtA []byte) error

func (*TabletSnapshotFileChunk) XXX_DiscardUnknown 

func (m *TabletSnapshotFileChunk) XXX_DiscardUnknown()

func (*TabletSnapshotFileChunk) XXX_Marshal 

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

func (*TabletSnapshotFileChunk) XXX_Merge 

func (m *TabletSnapshotFileChunk) XXX_Merge(src proto.Message)

func (*TabletSnapshotFileChunk) XXX_Size 

func (m *TabletSnapshotFileChunk) XXX_Size() int

func (*TabletSnapshotFileChunk) XXX_Unmarshal 

func (m *TabletSnapshotFileChunk) XXX_Unmarshal(b []byte) error

type TabletSnapshotFileMeta 

type TabletSnapshotFileMeta struct {
	FileSize uint64 `protobuf:"varint,1,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	FileName string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// Some block data. Unencrypted.
	HeadChunk []byte `protobuf:"bytes,3,opt,name=head_chunk,json=headChunk,proto3" json:"head_chunk,omitempty"`
	// trailing data including checksum. Unencrypted.
	TrailingChunk []byte `protobuf:"bytes,4,opt,name=trailing_chunk,json=trailingChunk,proto3" json:"trailing_chunk,omitempty"`
}

func (*TabletSnapshotFileMeta) Descriptor 

func (*TabletSnapshotFileMeta) Descriptor() ([]byte, []int)

func (*TabletSnapshotFileMeta) GetFileName 

func (m *TabletSnapshotFileMeta) GetFileName() string

func (*TabletSnapshotFileMeta) GetFileSize 

func (m *TabletSnapshotFileMeta) GetFileSize() uint64

func (*TabletSnapshotFileMeta) GetHeadChunk 

func (m *TabletSnapshotFileMeta) GetHeadChunk() []byte

func (*TabletSnapshotFileMeta) GetTrailingChunk 

func (m *TabletSnapshotFileMeta) GetTrailingChunk() []byte

func (*TabletSnapshotFileMeta) Marshal 

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

func (*TabletSnapshotFileMeta) MarshalTo 

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

func (*TabletSnapshotFileMeta) MarshalToSizedBuffer 

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

func (*TabletSnapshotFileMeta) ProtoMessage 

func (*TabletSnapshotFileMeta) ProtoMessage()

func (*TabletSnapshotFileMeta) Reset 

func (m *TabletSnapshotFileMeta) Reset()

func (*TabletSnapshotFileMeta) Size 

func (m *TabletSnapshotFileMeta) Size() (n int)

func (*TabletSnapshotFileMeta) String 

func (m *TabletSnapshotFileMeta) String() string

func (*TabletSnapshotFileMeta) Unmarshal 

func (m *TabletSnapshotFileMeta) Unmarshal(dAtA []byte) error

func (*TabletSnapshotFileMeta) XXX_DiscardUnknown 

func (m *TabletSnapshotFileMeta) XXX_DiscardUnknown()

func (*TabletSnapshotFileMeta) XXX_Marshal 

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

func (*TabletSnapshotFileMeta) XXX_Merge 

func (m *TabletSnapshotFileMeta) XXX_Merge(src proto.Message)

func (*TabletSnapshotFileMeta) XXX_Size 

func (m *TabletSnapshotFileMeta) XXX_Size() int

func (*TabletSnapshotFileMeta) XXX_Unmarshal 

func (m *TabletSnapshotFileMeta) XXX_Unmarshal(b []byte) error

type TabletSnapshotHead 

type TabletSnapshotHead struct {
	Message  *RaftMessage `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	UseCache bool         `protobuf:"varint,2,opt,name=use_cache,json=useCache,proto3" json:"use_cache,omitempty"`
}

func (*TabletSnapshotHead) Descriptor 

func (*TabletSnapshotHead) Descriptor() ([]byte, []int)

func (*TabletSnapshotHead) GetMessage 

func (m *TabletSnapshotHead) GetMessage() *RaftMessage

func (*TabletSnapshotHead) GetUseCache 

func (m *TabletSnapshotHead) GetUseCache() bool

func (*TabletSnapshotHead) Marshal 

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

func (*TabletSnapshotHead) MarshalTo 

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

func (*TabletSnapshotHead) MarshalToSizedBuffer 

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

func (*TabletSnapshotHead) ProtoMessage 

func (*TabletSnapshotHead) ProtoMessage()

func (*TabletSnapshotHead) Reset 

func (m *TabletSnapshotHead) Reset()

func (*TabletSnapshotHead) Size 

func (m *TabletSnapshotHead) Size() (n int)

func (*TabletSnapshotHead) String 

func (m *TabletSnapshotHead) String() string

func (*TabletSnapshotHead) Unmarshal 

func (m *TabletSnapshotHead) Unmarshal(dAtA []byte) error

func (*TabletSnapshotHead) XXX_DiscardUnknown 

func (m *TabletSnapshotHead) XXX_DiscardUnknown()

func (*TabletSnapshotHead) XXX_Marshal 

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

func (*TabletSnapshotHead) XXX_Merge 

func (m *TabletSnapshotHead) XXX_Merge(src proto.Message)

func (*TabletSnapshotHead) XXX_Size 

func (m *TabletSnapshotHead) XXX_Size() int

func (*TabletSnapshotHead) XXX_Unmarshal 

func (m *TabletSnapshotHead) XXX_Unmarshal(b []byte) error

type TabletSnapshotPreview 

type TabletSnapshotPreview struct {
	Metas []*TabletSnapshotFileMeta `protobuf:"bytes,1,rep,name=metas,proto3" json:"metas,omitempty"`
	// There may be too many metas, use a flag to indicate all metas
	// are sent.
	End bool `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
}

Snapshot preview for server to decide whether skip some files. Server should send back an `AcceptedSnapshotFile` to let client keep sending specified files. Only SST files can be skipped, all other files should always be sent.

func (*TabletSnapshotPreview) Descriptor 

func (*TabletSnapshotPreview) Descriptor() ([]byte, []int)

func (*TabletSnapshotPreview) GetEnd 

func (m *TabletSnapshotPreview) GetEnd() bool

func (*TabletSnapshotPreview) GetMetas 

func (m *TabletSnapshotPreview) GetMetas() []*TabletSnapshotFileMeta

func (*TabletSnapshotPreview) Marshal 

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

func (*TabletSnapshotPreview) MarshalTo 

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

func (*TabletSnapshotPreview) MarshalToSizedBuffer 

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

func (*TabletSnapshotPreview) ProtoMessage 

func (*TabletSnapshotPreview) ProtoMessage()

func (*TabletSnapshotPreview) Reset 

func (m *TabletSnapshotPreview) Reset()

func (*TabletSnapshotPreview) Size 

func (m *TabletSnapshotPreview) Size() (n int)

func (*TabletSnapshotPreview) String 

func (m *TabletSnapshotPreview) String() string

func (*TabletSnapshotPreview) Unmarshal 

func (m *TabletSnapshotPreview) Unmarshal(dAtA []byte) error

func (*TabletSnapshotPreview) XXX_DiscardUnknown 

func (m *TabletSnapshotPreview) XXX_DiscardUnknown()

func (*TabletSnapshotPreview) XXX_Marshal 

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

func (*TabletSnapshotPreview) XXX_Merge 

func (m *TabletSnapshotPreview) XXX_Merge(src proto.Message)

func (*TabletSnapshotPreview) XXX_Size 

func (m *TabletSnapshotPreview) XXX_Size() int

func (*TabletSnapshotPreview) XXX_Unmarshal 

func (m *TabletSnapshotPreview) XXX_Unmarshal(b []byte) error

type TabletSnapshotRequest 

type TabletSnapshotRequest struct {
	// Types that are valid to be assigned to Payload:
	//	*TabletSnapshotRequest_Head
	//	*TabletSnapshotRequest_Preview
	//	*TabletSnapshotRequest_Chunk
	//	*TabletSnapshotRequest_End
	Payload isTabletSnapshotRequest_Payload `protobuf_oneof:"payload"`
}

func (*TabletSnapshotRequest) Descriptor 

func (*TabletSnapshotRequest) Descriptor() ([]byte, []int)

func (*TabletSnapshotRequest) GetChunk 

func (m *TabletSnapshotRequest) GetChunk() *TabletSnapshotFileChunk

func (*TabletSnapshotRequest) GetEnd 

func (m *TabletSnapshotRequest) GetEnd() *TabletSnapshotEnd

func (*TabletSnapshotRequest) GetHead 

func (m *TabletSnapshotRequest) GetHead() *TabletSnapshotHead

func (*TabletSnapshotRequest) GetPayload 

func (m *TabletSnapshotRequest) GetPayload() isTabletSnapshotRequest_Payload

func (*TabletSnapshotRequest) GetPreview 

func (m *TabletSnapshotRequest) GetPreview() *TabletSnapshotPreview

func (*TabletSnapshotRequest) Marshal 

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

func (*TabletSnapshotRequest) MarshalTo 

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

func (*TabletSnapshotRequest) MarshalToSizedBuffer 

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

func (*TabletSnapshotRequest) ProtoMessage 

func (*TabletSnapshotRequest) ProtoMessage()

func (*TabletSnapshotRequest) Reset 

func (m *TabletSnapshotRequest) Reset()

func (*TabletSnapshotRequest) Size 

func (m *TabletSnapshotRequest) Size() (n int)

func (*TabletSnapshotRequest) String 

func (m *TabletSnapshotRequest) String() string

func (*TabletSnapshotRequest) Unmarshal 

func (m *TabletSnapshotRequest) Unmarshal(dAtA []byte) error

func (*TabletSnapshotRequest) XXX_DiscardUnknown 

func (m *TabletSnapshotRequest) XXX_DiscardUnknown()

func (*TabletSnapshotRequest) XXX_Marshal 

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

func (*TabletSnapshotRequest) XXX_Merge 

func (m *TabletSnapshotRequest) XXX_Merge(src proto.Message)

func (*TabletSnapshotRequest) XXX_OneofWrappers 

func (*TabletSnapshotRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TabletSnapshotRequest) XXX_Size 

func (m *TabletSnapshotRequest) XXX_Size() int

func (*TabletSnapshotRequest) XXX_Unmarshal 

func (m *TabletSnapshotRequest) XXX_Unmarshal(b []byte) error

type TabletSnapshotRequest_Chunk 

type TabletSnapshotRequest_Chunk struct {
	Chunk *TabletSnapshotFileChunk `protobuf:"bytes,3,opt,name=chunk,proto3,oneof" json:"chunk,omitempty"`
}

func (*TabletSnapshotRequest_Chunk) MarshalTo 

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

func (*TabletSnapshotRequest_Chunk) MarshalToSizedBuffer 

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

func (*TabletSnapshotRequest_Chunk) Size 

func (m *TabletSnapshotRequest_Chunk) Size() (n int)

type TabletSnapshotRequest_End 

type TabletSnapshotRequest_End struct {
	End *TabletSnapshotEnd `protobuf:"bytes,4,opt,name=end,proto3,oneof" json:"end,omitempty"`
}

func (*TabletSnapshotRequest_End) MarshalTo 

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

func (*TabletSnapshotRequest_End) MarshalToSizedBuffer 

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

func (*TabletSnapshotRequest_End) Size 

func (m *TabletSnapshotRequest_End) Size() (n int)

type TabletSnapshotRequest_Head 

type TabletSnapshotRequest_Head struct {
	Head *TabletSnapshotHead `protobuf:"bytes,1,opt,name=head,proto3,oneof" json:"head,omitempty"`
}

func (*TabletSnapshotRequest_Head) MarshalTo 

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

func (*TabletSnapshotRequest_Head) MarshalToSizedBuffer 

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

func (*TabletSnapshotRequest_Head) Size 

func (m *TabletSnapshotRequest_Head) Size() (n int)

type TabletSnapshotRequest_Preview 

type TabletSnapshotRequest_Preview struct {
	Preview *TabletSnapshotPreview `protobuf:"bytes,2,opt,name=preview,proto3,oneof" json:"preview,omitempty"`
}

func (*TabletSnapshotRequest_Preview) MarshalTo 

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

func (*TabletSnapshotRequest_Preview) MarshalToSizedBuffer 

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

func (*TabletSnapshotRequest_Preview) Size 

func (m *TabletSnapshotRequest_Preview) Size() (n int)

type TabletSnapshotResponse 

type TabletSnapshotResponse struct {
	Files *AcceptedSnapshotFiles `protobuf:"bytes,1,opt,name=files,proto3" json:"files,omitempty"`
}

func (*TabletSnapshotResponse) Descriptor 

func (*TabletSnapshotResponse) Descriptor() ([]byte, []int)

func (*TabletSnapshotResponse) GetFiles 

func (m *TabletSnapshotResponse) GetFiles() *AcceptedSnapshotFiles

func (*TabletSnapshotResponse) Marshal 

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

func (*TabletSnapshotResponse) MarshalTo 

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

func (*TabletSnapshotResponse) MarshalToSizedBuffer 

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

func (*TabletSnapshotResponse) ProtoMessage 

func (*TabletSnapshotResponse) ProtoMessage()

func (*TabletSnapshotResponse) Reset 

func (m *TabletSnapshotResponse) Reset()

func (*TabletSnapshotResponse) Size 

func (m *TabletSnapshotResponse) Size() (n int)

func (*TabletSnapshotResponse) String 

func (m *TabletSnapshotResponse) String() string

func (*TabletSnapshotResponse) Unmarshal 

func (m *TabletSnapshotResponse) Unmarshal(dAtA []byte) error

func (*TabletSnapshotResponse) XXX_DiscardUnknown 

func (m *TabletSnapshotResponse) XXX_DiscardUnknown()

func (*TabletSnapshotResponse) XXX_Marshal 

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

func (*TabletSnapshotResponse) XXX_Merge 

func (m *TabletSnapshotResponse) XXX_Merge(src proto.Message)

func (*TabletSnapshotResponse) XXX_Size 

func (m *TabletSnapshotResponse) XXX_Size() int

func (*TabletSnapshotResponse) XXX_Unmarshal 

func (m *TabletSnapshotResponse) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.