Documentation ¶
Overview ¶
Package raft_serverpb is a generated protocol buffer package.
It is generated from these files:
raft_serverpb.proto
It has these top-level messages:
RaftMessage RaftTruncatedState KeyValue RaftSnapshotData StoreIdent RaftLocalState RaftApplyState RegionLocalState
Index ¶
- Variables
- type KeyValue
- func (*KeyValue) Descriptor() ([]byte, []int)
- func (m *KeyValue) GetKey() []byte
- func (m *KeyValue) GetValue() []byte
- func (m *KeyValue) Marshal() (data []byte, err error)
- func (m *KeyValue) MarshalTo(data []byte) (int, error)
- func (*KeyValue) ProtoMessage()
- func (m *KeyValue) Reset()
- func (m *KeyValue) Size() (n int)
- func (m *KeyValue) String() string
- func (m *KeyValue) Unmarshal(data []byte) error
- type PeerState
- type RaftApplyState
- func (*RaftApplyState) Descriptor() ([]byte, []int)
- func (m *RaftApplyState) GetAppliedIndex() uint64
- func (m *RaftApplyState) GetTruncatedState() *RaftTruncatedState
- func (m *RaftApplyState) Marshal() (data []byte, err error)
- func (m *RaftApplyState) MarshalTo(data []byte) (int, error)
- func (*RaftApplyState) ProtoMessage()
- func (m *RaftApplyState) Reset()
- func (m *RaftApplyState) Size() (n int)
- func (m *RaftApplyState) String() string
- func (m *RaftApplyState) Unmarshal(data []byte) error
- type RaftLocalState
- func (*RaftLocalState) Descriptor() ([]byte, []int)
- func (m *RaftLocalState) GetHardState() *eraftpb.HardState
- func (m *RaftLocalState) GetLastIndex() uint64
- func (m *RaftLocalState) Marshal() (data []byte, err error)
- func (m *RaftLocalState) MarshalTo(data []byte) (int, error)
- func (*RaftLocalState) ProtoMessage()
- func (m *RaftLocalState) Reset()
- func (m *RaftLocalState) Size() (n int)
- func (m *RaftLocalState) String() string
- func (m *RaftLocalState) Unmarshal(data []byte) error
- type RaftMessage
- func (*RaftMessage) Descriptor() ([]byte, []int)
- func (m *RaftMessage) GetFromPeer() *metapb.Peer
- func (m *RaftMessage) GetIsTombstone() bool
- func (m *RaftMessage) GetMessage() *eraftpb.Message
- func (m *RaftMessage) GetRegionEpoch() *metapb.RegionEpoch
- func (m *RaftMessage) GetRegionId() uint64
- func (m *RaftMessage) GetToPeer() *metapb.Peer
- func (m *RaftMessage) Marshal() (data []byte, err error)
- func (m *RaftMessage) MarshalTo(data []byte) (int, error)
- func (*RaftMessage) ProtoMessage()
- func (m *RaftMessage) Reset()
- func (m *RaftMessage) Size() (n int)
- func (m *RaftMessage) String() string
- func (m *RaftMessage) Unmarshal(data []byte) error
- type RaftSnapshotData
- func (*RaftSnapshotData) Descriptor() ([]byte, []int)
- func (m *RaftSnapshotData) GetData() []*KeyValue
- func (m *RaftSnapshotData) GetFileSize() uint64
- func (m *RaftSnapshotData) GetRegion() *metapb.Region
- func (m *RaftSnapshotData) Marshal() (data []byte, err error)
- func (m *RaftSnapshotData) MarshalTo(data []byte) (int, error)
- func (*RaftSnapshotData) ProtoMessage()
- func (m *RaftSnapshotData) Reset()
- func (m *RaftSnapshotData) Size() (n int)
- func (m *RaftSnapshotData) String() string
- func (m *RaftSnapshotData) Unmarshal(data []byte) error
- type RaftTruncatedState
- func (*RaftTruncatedState) Descriptor() ([]byte, []int)
- func (m *RaftTruncatedState) GetIndex() uint64
- func (m *RaftTruncatedState) GetTerm() uint64
- func (m *RaftTruncatedState) Marshal() (data []byte, err error)
- func (m *RaftTruncatedState) MarshalTo(data []byte) (int, error)
- func (*RaftTruncatedState) ProtoMessage()
- func (m *RaftTruncatedState) Reset()
- func (m *RaftTruncatedState) Size() (n int)
- func (m *RaftTruncatedState) String() string
- func (m *RaftTruncatedState) Unmarshal(data []byte) error
- type RegionLocalState
- func (*RegionLocalState) Descriptor() ([]byte, []int)
- func (m *RegionLocalState) GetRegion() *metapb.Region
- func (m *RegionLocalState) GetState() PeerState
- func (m *RegionLocalState) Marshal() (data []byte, err error)
- func (m *RegionLocalState) MarshalTo(data []byte) (int, error)
- func (*RegionLocalState) ProtoMessage()
- func (m *RegionLocalState) Reset()
- func (m *RegionLocalState) Size() (n int)
- func (m *RegionLocalState) String() string
- func (m *RegionLocalState) Unmarshal(data []byte) error
- type StoreIdent
- func (*StoreIdent) Descriptor() ([]byte, []int)
- func (m *StoreIdent) GetClusterId() uint64
- func (m *StoreIdent) GetStoreId() uint64
- func (m *StoreIdent) Marshal() (data []byte, err error)
- func (m *StoreIdent) MarshalTo(data []byte) (int, error)
- func (*StoreIdent) ProtoMessage()
- func (m *StoreIdent) Reset()
- func (m *StoreIdent) Size() (n int)
- func (m *StoreIdent) String() string
- func (m *StoreIdent) Unmarshal(data []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthRaftServerpb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRaftServerpb = fmt.Errorf("proto: integer overflow") )
View Source
var PeerState_name = map[int32]string{
0: "Normal",
1: "Applying",
2: "Tombstone",
}
View Source
var PeerState_value = map[string]int32{
"Normal": 0,
"Applying": 1,
"Tombstone": 2,
}
Functions ¶
This section is empty.
Types ¶
type KeyValue ¶
type KeyValue struct { Key []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*KeyValue) Descriptor ¶
func (*KeyValue) ProtoMessage ¶
func (*KeyValue) ProtoMessage()
type PeerState ¶
type PeerState int32
func (PeerState) EnumDescriptor ¶
func (*PeerState) UnmarshalJSON ¶
type RaftApplyState ¶
type RaftApplyState struct { AppliedIndex *uint64 `protobuf:"varint,1,opt,name=applied_index" json:"applied_index,omitempty"` TruncatedState *RaftTruncatedState `protobuf:"bytes,2,opt,name=truncated_state" json:"truncated_state,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RaftApplyState) Descriptor ¶
func (*RaftApplyState) Descriptor() ([]byte, []int)
func (*RaftApplyState) GetAppliedIndex ¶
func (m *RaftApplyState) GetAppliedIndex() uint64
func (*RaftApplyState) GetTruncatedState ¶
func (m *RaftApplyState) GetTruncatedState() *RaftTruncatedState
func (*RaftApplyState) Marshal ¶
func (m *RaftApplyState) Marshal() (data []byte, err 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
type RaftLocalState ¶
type RaftLocalState struct { HardState *eraftpb.HardState `protobuf:"bytes,1,opt,name=hard_state" json:"hard_state,omitempty"` LastIndex *uint64 `protobuf:"varint,2,opt,name=last_index" json:"last_index,omitempty"` XXX_unrecognized []byte `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) 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
type RaftMessage ¶
type RaftMessage struct { RegionId *uint64 `protobuf:"varint,1,opt,name=region_id" json:"region_id,omitempty"` FromPeer *metapb.Peer `protobuf:"bytes,2,opt,name=from_peer" json:"from_peer,omitempty"` ToPeer *metapb.Peer `protobuf:"bytes,3,opt,name=to_peer" json:"to_peer,omitempty"` Message *eraftpb.Message `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"` RegionEpoch *metapb.RegionEpoch `protobuf:"bytes,5,opt,name=region_epoch" 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:"is_tombstone,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RaftMessage) Descriptor ¶
func (*RaftMessage) Descriptor() ([]byte, []int)
func (*RaftMessage) GetFromPeer ¶
func (m *RaftMessage) GetFromPeer() *metapb.Peer
func (*RaftMessage) GetIsTombstone ¶
func (m *RaftMessage) GetIsTombstone() bool
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) GetToPeer ¶
func (m *RaftMessage) GetToPeer() *metapb.Peer
func (*RaftMessage) Marshal ¶
func (m *RaftMessage) Marshal() (data []byte, err 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
type RaftSnapshotData ¶
type RaftSnapshotData struct { Region *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"` FileSize *uint64 `protobuf:"varint,2,opt,name=file_size" json:"file_size,omitempty"` Data []*KeyValue `protobuf:"bytes,3,rep,name=data" json:"data,omitempty"` XXX_unrecognized []byte `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) GetRegion ¶
func (m *RaftSnapshotData) GetRegion() *metapb.Region
func (*RaftSnapshotData) Marshal ¶
func (m *RaftSnapshotData) Marshal() (data []byte, err 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
type RaftTruncatedState ¶
type RaftTruncatedState struct { Index *uint64 `protobuf:"varint,1,opt,name=index" json:"index,omitempty"` Term *uint64 `protobuf:"varint,2,opt,name=term" json:"term,omitempty"` XXX_unrecognized []byte `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) 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
type RegionLocalState ¶
type RegionLocalState struct { State *PeerState `protobuf:"varint,1,opt,name=state,enum=raft_serverpb.PeerState" json:"state,omitempty"` Region *metapb.Region `protobuf:"bytes,2,opt,name=region" json:"region,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RegionLocalState) Descriptor ¶
func (*RegionLocalState) Descriptor() ([]byte, []int)
func (*RegionLocalState) GetRegion ¶
func (m *RegionLocalState) GetRegion() *metapb.Region
func (*RegionLocalState) GetState ¶
func (m *RegionLocalState) GetState() PeerState
func (*RegionLocalState) Marshal ¶
func (m *RegionLocalState) Marshal() (data []byte, err 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
type StoreIdent ¶
type StoreIdent struct { ClusterId *uint64 `protobuf:"varint,1,opt,name=cluster_id" json:"cluster_id,omitempty"` StoreId *uint64 `protobuf:"varint,2,opt,name=store_id" json:"store_id,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*StoreIdent) Descriptor ¶
func (*StoreIdent) Descriptor() ([]byte, []int)
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) 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
Click to show internal directories.
Click to hide internal directories.