raft_serverpb

package
Version: v0.0.0-...-ca78592 Latest Latest
Warning

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

Go to latest
Published: Nov 30, 2022 License: Apache-2.0 Imports: 9 Imported by: 74

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",
}
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,
}
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 Done

type Done struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	PremergeCommit uint64           `protobuf:"varint,2,opt,name=premerge_commit,json=premergeCommit,proto3" json:"premerge_commit,omitempty"`
	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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExtraMessage) Descriptor

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

func (*ExtraMessage) GetCheckPeers

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

func (*ExtraMessage) GetForcelyAwaken

func (m *ExtraMessage) GetForcelyAwaken() bool

func (*ExtraMessage) GetPremergeCommit

func (m *ExtraMessage) GetPremergeCommit() uint64

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
)

func (ExtraMessageType) EnumDescriptor

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

func (ExtraMessageType) String

func (x ExtraMessageType) String() string

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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 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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (m *RaftSnapshotData) GetMeta() *SnapshotMeta

func (*RaftSnapshotData) GetRegion

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegionLocalState) Descriptor

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

func (*RegionLocalState) GetMergeState

func (m *RegionLocalState) GetMergeState() *MergeState

func (*RegionLocalState) GetRegion

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

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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 (*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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SnapshotMeta) Descriptor

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

func (*SnapshotMeta) GetCfFiles

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

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) 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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL