distributed/talent-plan-tinykv
1
0
Fork 0
mirror of https://github.com/talent-plan/tinykv.git synced 2025-03-23 16:20:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

remove reject hint

Browse Source 
Signed-off-by: Connor1996 <zbk602423539@gmail.com>
This commit is contained in:
Connor1996 2020-03-30 13:45:52 +08:00 committed by Connor
parent bb9739ae6e
commit 612724328b
2 changed files with 70 additions and 110 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

175
proto/pkg/eraftpb/eraftpb.pb.go
View File

@ -42,7 +42,7 @@ func (x EntryType) String() string {
return proto.EnumName(EntryType_name, int32(x))
}
func (EntryType) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_eraftpb_5a4d1f1b47871789, []int{0}
return fileDescriptor_eraftpb_6ff387e2d76c3034, []int{0}
}
// Some MessageType defined here are local messages which not come from the network, but should
@ -112,7 +112,7 @@ func (x MessageType) String() string {
return proto.EnumName(MessageType_name, int32(x))
}
func (MessageType) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_eraftpb_5a4d1f1b47871789, []int{1}
return fileDescriptor_eraftpb_6ff387e2d76c3034, []int{1}
}
type ConfChangeType int32
@ -135,7 +135,7 @@ func (x ConfChangeType) String() string {
return proto.EnumName(ConfChangeType_name, int32(x))
}
func (ConfChangeType) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_eraftpb_5a4d1f1b47871789, []int{2}
return fileDescriptor_eraftpb_6ff387e2d76c3034, []int{2}
}
// The entry is a type of change that needs to be applied. It contains two data fields.
@ -162,7 +162,7 @@ func (m *Entry) Reset() { *m = Entry{} }
func (m *Entry) String() string { return proto.CompactTextString(m) }
func (*Entry) ProtoMessage() {}
func (*Entry) Descriptor() ([]byte, []int) {
return fileDescriptor_eraftpb_5a4d1f1b47871789, []int{0}
return fileDescriptor_eraftpb_6ff387e2d76c3034, []int{0}
}
func (m *Entry) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -234,7 +234,7 @@ func (m *SnapshotMetadata) Reset() { *m = SnapshotMetadata{} }
func (m *SnapshotMetadata) String() string { return proto.CompactTextString(m) }
func (*SnapshotMetadata) ProtoMessage() {}
func (*SnapshotMetadata) Descriptor() ([]byte, []int) {
return fileDescriptor_eraftpb_5a4d1f1b47871789, []int{1}
return fileDescriptor_eraftpb_6ff387e2d76c3034, []int{1}
}
func (m *SnapshotMetadata) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -296,7 +296,7 @@ func (m *Snapshot) Reset() { *m = Snapshot{} }
func (m *Snapshot) String() string { return proto.CompactTextString(m) }
func (*Snapshot) ProtoMessage() {}
func (*Snapshot) Descriptor() ([]byte, []int) {
return fileDescriptor_eraftpb_5a4d1f1b47871789, []int{2}
return fileDescriptor_eraftpb_6ff387e2d76c3034, []int{2}
}
func (m *Snapshot) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -340,28 +340,26 @@ func (m *Snapshot) GetMetadata() *SnapshotMetadata {
}
type Message struct {
MsgType MessageType `protobuf:"varint,1,opt,name=msg_type,json=msgType,proto3,enum=eraftpb.MessageType" json:"msg_type,omitempty"`
To uint64 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
From uint64 `protobuf:"varint,3,opt,name=from,proto3" json:"from,omitempty"`
Term uint64 `protobuf:"varint,4,opt,name=term,proto3" json:"term,omitempty"`
LogTerm uint64 `protobuf:"varint,5,opt,name=log_term,json=logTerm,proto3" json:"log_term,omitempty"`
Index uint64 `protobuf:"varint,6,opt,name=index,proto3" json:"index,omitempty"`
Entries []*Entry `protobuf:"bytes,7,rep,name=entries" json:"entries,omitempty"`
Commit uint64 `protobuf:"varint,8,opt,name=commit,proto3" json:"commit,omitempty"`
Snapshot *Snapshot `protobuf:"bytes,9,opt,name=snapshot" json:"snapshot,omitempty"`
Reject bool `protobuf:"varint,10,opt,name=reject,proto3" json:"reject,omitempty"`
// TODO: Delete Start
RejectHint uint64 `protobuf:"varint,11,opt,name=reject_hint,json=rejectHint,proto3" json:"reject_hint,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
MsgType MessageType `protobuf:"varint,1,opt,name=msg_type,json=msgType,proto3,enum=eraftpb.MessageType" json:"msg_type,omitempty"`
To uint64 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
From uint64 `protobuf:"varint,3,opt,name=from,proto3" json:"from,omitempty"`
Term uint64 `protobuf:"varint,4,opt,name=term,proto3" json:"term,omitempty"`
LogTerm uint64 `protobuf:"varint,5,opt,name=log_term,json=logTerm,proto3" json:"log_term,omitempty"`
Index uint64 `protobuf:"varint,6,opt,name=index,proto3" json:"index,omitempty"`
Entries []*Entry `protobuf:"bytes,7,rep,name=entries" json:"entries,omitempty"`
Commit uint64 `protobuf:"varint,8,opt,name=commit,proto3" json:"commit,omitempty"`
Snapshot *Snapshot `protobuf:"bytes,9,opt,name=snapshot" json:"snapshot,omitempty"`
Reject bool `protobuf:"varint,10,opt,name=reject,proto3" json:"reject,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Message) Reset() { *m = Message{} }
func (m *Message) String() string { return proto.CompactTextString(m) }
func (*Message) ProtoMessage() {}
func (*Message) Descriptor() ([]byte, []int) {
return fileDescriptor_eraftpb_5a4d1f1b47871789, []int{3}
return fileDescriptor_eraftpb_6ff387e2d76c3034, []int{3}
}
func (m *Message) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -460,14 +458,7 @@ func (m *Message) GetReject() bool {
return false
}
func (m *Message) GetRejectHint() uint64 {
if m != nil {
return m.RejectHint
}
return 0
}
// HardState contains the state of a node, including the current term, commit index
// HardState contains the state of a node need to be peristed, including the current term, commit index
// and the vote record
type HardState struct {
Term uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
@ -482,7 +473,7 @@ func (m *HardState) Reset() { *m = HardState{} }
func (m *HardState) String() string { return proto.CompactTextString(m) }
func (*HardState) ProtoMessage() {}
func (*HardState) Descriptor() ([]byte, []int) {
return fileDescriptor_eraftpb_5a4d1f1b47871789, []int{4}
return fileDescriptor_eraftpb_6ff387e2d76c3034, []int{4}
}
func (m *HardState) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -545,7 +536,7 @@ func (m *ConfState) Reset() { *m = ConfState{} }
func (m *ConfState) String() string { return proto.CompactTextString(m) }
func (*ConfState) ProtoMessage() {}
func (*ConfState) Descriptor() ([]byte, []int) {
return fileDescriptor_eraftpb_5a4d1f1b47871789, []int{5}
return fileDescriptor_eraftpb_6ff387e2d76c3034, []int{5}
}
func (m *ConfState) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -596,7 +587,7 @@ func (m *ConfChange) Reset() { *m = ConfChange{} }
func (m *ConfChange) String() string { return proto.CompactTextString(m) }
func (*ConfChange) ProtoMessage() {}
func (*ConfChange) Descriptor() ([]byte, []int) {
return fileDescriptor_eraftpb_5a4d1f1b47871789, []int{6}
return fileDescriptor_eraftpb_6ff387e2d76c3034, []int{6}
}
func (m *ConfChange) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -860,11 +851,6 @@ func (m *Message) MarshalTo(dAtA []byte) (int, error) {
}
i++
}
if m.RejectHint != 0 {
dAtA[i] = 0x58
i++
i = encodeVarintEraftpb(dAtA, i, uint64(m.RejectHint))
}
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
@ -1086,9 +1072,6 @@ func (m *Message) Size() (n int) {
if m.Reject {
n += 2
}
if m.RejectHint != 0 {
n += 1 + sovEraftpb(uint64(m.RejectHint))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
@ -1783,25 +1766,6 @@ func (m *Message) Unmarshal(dAtA []byte) error {
}
}
m.Reject = bool(v != 0)
case 11:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field RejectHint", wireType)
}
m.RejectHint = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowEraftpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.RejectHint |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipEraftpb(dAtA[iNdEx:])
@ -2270,51 +2234,50 @@ var (
ErrIntOverflowEraftpb = fmt.Errorf("proto: integer overflow")
)
func init() { proto.RegisterFile("eraftpb.proto", fileDescriptor_eraftpb_5a4d1f1b47871789) }
func init() { proto.RegisterFile("eraftpb.proto", fileDescriptor_eraftpb_6ff387e2d76c3034) }
var fileDescriptor_eraftpb_5a4d1f1b47871789 = []byte{
// 683 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x64, 0x94, 0xdf, 0x4e, 0xdb, 0x4a,
0x10, 0xc6, 0xb3, 0xf9, 0x67, 0x7b, 0x1c, 0xc2, 0x32, 0x87, 0x03, 0xe6, 0x5c, 0xe4, 0xa4, 0xb9,
0x8a, 0x90, 0xa0, 0x82, 0xaa, 0x52, 0x6f, 0x01, 0x55, 0xa2, 0x6a, 0x8d, 0x2a, 0x43, 0x7b, 0x1b,
0x99, 0x78, 0x62, 0x52, 0x61, 0xaf, 0xeb, 0x5d, 0x28, 0x79, 0x93, 0x3e, 0x52, 0x6f, 0x2a, 0xf5,
0x11, 0x2a, 0xfa, 0x08, 0x7d, 0x81, 0x6a, 0x37, 0xb6, 0xe3, 0xd0, 0xbb, 0xf9, 0xc6, 0xb3, 0x3b,
0xbf, 0xf9, 0x66, 0x13, 0xd8, 0xa0, 0x3c, 0x9c, 0xa9, 0xec, 0xfa, 0x30, 0xcb, 0x85, 0x12, 0x68,
0x15, 0x72, 0xf4, 0x00, 0x9d, 0xd7, 0xa9, 0xca, 0x17, 0x78, 0x04, 0x40, 0x3a, 0x98, 0xa8, 0x45,
0x46, 0x1e, 0x1b, 0xb2, 0x71, 0xff, 0x18, 0x0f, 0xcb, 0x53, 0xa6, 0xe6, 0x6a, 0x91, 0x51, 0xe0,
0x50, 0x19, 0x22, 0x42, 0x5b, 0x51, 0x9e, 0x78, 0xcd, 0x21, 0x1b, 0xb7, 0x03, 0x13, 0xe3, 0x36,
0x74, 0xe6, 0x69, 0x44, 0x0f, 0x5e, 0xcb, 0x24, 0x97, 0x42, 0x57, 0x46, 0xa1, 0x0a, 0xbd, 0xf6,
0x90, 0x8d, 0x7b, 0x81, 0x89, 0x47, 0x02, 0xf8, 0x65, 0x1a, 0x66, 0xf2, 0x46, 0x28, 0x9f, 0x54,
0xa8, 0x73, 0x1a, 0x62, 0x2a, 0xd2, 0xd9, 0x44, 0xaa, 0x50, 0x2d, 0x21, 0xdc, 0x1a, 0xc4, 0x99,
0x48, 0x67, 0x97, 0xfa, 0x4b, 0xe0, 0x4c, 0xcb, 0x70, 0xd5, 0xb0, 0xf9, 0xa4, 0xa1, 0x41, 0x6b,
0xad, 0xd0, 0x46, 0x1f, 0xc0, 0x2e, 0x1b, 0x56, 0x40, 0x6c, 0x05, 0x84, 0x2f, 0xc1, 0x4e, 0x0a,
0x10, 0x73, 0x99, 0x7b, 0xbc, 0x57, 0xb5, 0x7e, 0x4a, 0x1a, 0x54, 0xa5, 0xa3, 0xef, 0x4d, 0xb0,
0x7c, 0x92, 0x32, 0x8c, 0x09, 0x9f, 0x83, 0x9d, 0xc8, 0xb8, 0x6e, 0xe1, 0x76, 0x75, 0x45, 0x51,
0x63, 0x4c, 0xb4, 0x12, 0x19, 0x1b, 0x0b, 0xfb, 0xd0, 0x54, 0xa2, 0x40, 0x6f, 0x2a, 0xa1, 0xb9,
0x66, 0xb9, 0xa8, 0xb8, 0x75, 0x5c, 0xcd, 0xd2, 0xae, 0xd9, 0xbc, 0x07, 0xf6, 0xad, 0x88, 0x27,
0x26, 0xdf, 0x31, 0x79, 0xeb, 0x56, 0xc4, 0x57, 0x6b, 0x1b, 0xe8, 0xd6, 0x0d, 0x19, 0x83, 0xa5,
0x17, 0x37, 0x27, 0xe9, 0x59, 0xc3, 0xd6, 0xd8, 0x3d, 0xee, 0xaf, 0xef, 0x36, 0x28, 0x3f, 0xe3,
0x0e, 0x74, 0xa7, 0x22, 0x49, 0xe6, 0xca, 0xb3, 0xcd, 0x05, 0x85, 0xc2, 0x03, 0xb0, 0x65, 0xe1,
0x82, 0xe7, 0x18, 0x7b, 0xb6, 0xfe, 0xb2, 0x27, 0xa8, 0x4a, 0xf4, 0x35, 0x39, 0x7d, 0xa2, 0xa9,
0xf2, 0x60, 0xc8, 0xc6, 0x76, 0x50, 0x28, 0xfc, 0x1f, 0xdc, 0x65, 0x34, 0xb9, 0x99, 0xa7, 0xca,
0x73, 0x4d, 0x0f, 0x58, 0xa6, 0xce, 0xe7, 0xa9, 0x1a, 0xbd, 0x05, 0xe7, 0x3c, 0xcc, 0xa3, 0xe5,
0x76, 0xcb, 0xd9, 0x59, 0x6d, 0x76, 0x84, 0xf6, 0xbd, 0x50, 0x54, 0x3e, 0x3b, 0x1d, 0xd7, 0xa0,
0x5b, 0x75, 0xe8, 0xd1, 0x33, 0x70, 0xce, 0xea, 0x4f, 0x25, 0x15, 0x11, 0x49, 0x8f, 0x0d, 0x5b,
0xda, 0x19, 0x23, 0x46, 0x0b, 0x00, 0x5d, 0x72, 0x76, 0x13, 0xa6, 0x31, 0xe1, 0x2b, 0x70, 0xa7,
0x26, 0xaa, 0x2f, 0x71, 0x77, 0xed, 0x09, 0x2e, 0x2b, 0xcd, 0x1e, 0x61, 0x5a, 0xc5, 0xb8, 0x0b,
0x96, 0xbe, 0x70, 0x32, 0x8f, 0x0a, 0xb2, 0xae, 0x96, 0x6f, 0x22, 0xf4, 0xc0, 0x9a, 0x8a, 0x54,
0xd1, 0xc3, 0x12, 0xae, 0x17, 0x94, 0x72, 0xff, 0x08, 0x9c, 0xea, 0x87, 0x85, 0x9b, 0xe0, 0x1a,
0x71, 0x21, 0xf2, 0x24, 0xbc, 0xe5, 0x0d, 0xfc, 0x07, 0x36, 0x4d, 0x62, 0xd5, 0x93, 0xb3, 0xfd,
0xdf, 0x0c, 0xdc, 0xda, 0x4b, 0x42, 0x80, 0xae, 0x2f, 0xe3, 0xf3, 0xbb, 0x8c, 0x37, 0xd0, 0x05,
0xcb, 0x97, 0xf1, 0x29, 0x85, 0x8a, 0x33, 0xec, 0x03, 0xf8, 0x32, 0x7e, 0x9f, 0x8b, 0x4c, 0x48,
0xe2, 0x4d, 0xdc, 0x00, 0xc7, 0x97, 0xf1, 0x49, 0x96, 0x51, 0x1a, 0xf1, 0x16, 0xfe, 0x0b, 0x5b,
0x95, 0x0c, 0x48, 0x66, 0x22, 0x95, 0xc4, 0xdb, 0x88, 0xd0, 0xf7, 0x65, 0x1c, 0xd0, 0xe7, 0x3b,
0x92, 0xea, 0xa3, 0x50, 0xc4, 0x3b, 0xf8, 0x1f, 0xec, 0xac, 0xe7, 0xaa, 0xfa, 0xae, 0x86, 0xf6,
0x65, 0x5c, 0xae, 0x9f, 0x5b, 0xc8, 0xa1, 0xa7, 0x79, 0x28, 0xcc, 0xd5, 0xb5, 0x06, 0xb1, 0xd1,
0x83, 0xed, 0x7a, 0xa6, 0x3a, 0xec, 0x14, 0x0c, 0x57, 0x79, 0x98, 0xca, 0x19, 0xe5, 0xef, 0x28,
0x8c, 0x28, 0xe7, 0x2e, 0x6e, 0xc1, 0x86, 0x4e, 0xcf, 0x13, 0x12, 0x77, 0xea, 0x42, 0x7c, 0xe1,
0xbd, 0xfd, 0x03, 0xe8, 0xaf, 0x3b, 0xaf, 0x67, 0x3d, 0x89, 0xa2, 0x0b, 0x11, 0x11, 0x6f, 0xe8,
0x59, 0x03, 0x4a, 0xc4, 0x3d, 0x19, 0xcd, 0x4e, 0xf9, 0xb7, 0xc7, 0x01, 0xfb, 0xf1, 0x38, 0x60,
0x3f, 0x1f, 0x07, 0xec, 0xeb, 0xaf, 0x41, 0xe3, 0xba, 0x6b, 0xfe, 0xf6, 0x5e, 0xfc, 0x09, 0x00,
0x00, 0xff, 0xff, 0x2a, 0xa4, 0xbc, 0x39, 0x07, 0x05, 0x00, 0x00,
var fileDescriptor_eraftpb_6ff387e2d76c3034 = []byte{
// 666 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x64, 0x94, 0x5f, 0x4e, 0xdb, 0x4e,
0x10, 0xc7, 0xb3, 0xf9, 0x67, 0x7b, 0x1c, 0xc2, 0xb2, 0x3f, 0x7e, 0x60, 0xfa, 0x10, 0xa5, 0x7e,
0x8a, 0x90, 0xa0, 0x82, 0xaa, 0x52, 0x5f, 0x01, 0x55, 0xa2, 0x6a, 0x8d, 0x2a, 0x43, 0xfb, 0x1a,
0x2d, 0xf6, 0xc4, 0xa4, 0xc2, 0x5e, 0xd7, 0xbb, 0x50, 0x72, 0x93, 0x1e, 0xa2, 0x07, 0xe9, 0x63,
0x8f, 0x50, 0xd1, 0x23, 0xf4, 0x02, 0xd5, 0x6e, 0x6c, 0xc7, 0xa1, 0x6f, 0xf3, 0x1d, 0xcf, 0xee,
0x7c, 0xe6, 0x3b, 0x9b, 0xc0, 0x06, 0x16, 0x7c, 0xa6, 0xf2, 0xeb, 0xc3, 0xbc, 0x10, 0x4a, 0x30,
0xab, 0x94, 0xfe, 0x03, 0xf4, 0xde, 0x64, 0xaa, 0x58, 0xb0, 0x23, 0x00, 0xd4, 0xc1, 0x54, 0x2d,
0x72, 0xf4, 0xc8, 0x98, 0x4c, 0x86, 0xc7, 0xec, 0xb0, 0x3a, 0x65, 0x6a, 0xae, 0x16, 0x39, 0x86,
0x0e, 0x56, 0x21, 0x63, 0xd0, 0x55, 0x58, 0xa4, 0x5e, 0x7b, 0x4c, 0x26, 0xdd, 0xd0, 0xc4, 0x6c,
0x1b, 0x7a, 0xf3, 0x2c, 0xc6, 0x07, 0xaf, 0x63, 0x92, 0x4b, 0xa1, 0x2b, 0x63, 0xae, 0xb8, 0xd7,
0x1d, 0x93, 0xc9, 0x20, 0x34, 0xb1, 0x2f, 0x80, 0x5e, 0x66, 0x3c, 0x97, 0x37, 0x42, 0x05, 0xa8,
0xb8, 0xce, 0x69, 0x88, 0x48, 0x64, 0xb3, 0xa9, 0x54, 0x5c, 0x2d, 0x21, 0xdc, 0x06, 0xc4, 0x99,
0xc8, 0x66, 0x97, 0xfa, 0x4b, 0xe8, 0x44, 0x55, 0xb8, 0x6a, 0xd8, 0x7e, 0xd2, 0xd0, 0xa0, 0x75,
0x56, 0x68, 0xfe, 0x47, 0xb0, 0xab, 0x86, 0x35, 0x10, 0x59, 0x01, 0xb1, 0x57, 0x60, 0xa7, 0x25,
0x88, 0xb9, 0xcc, 0x3d, 0xde, 0xab, 0x5b, 0x3f, 0x25, 0x0d, 0xeb, 0x52, 0xff, 0x7b, 0x1b, 0xac,
0x00, 0xa5, 0xe4, 0x09, 0xb2, 0x17, 0x60, 0xa7, 0x32, 0x69, 0x5a, 0xb8, 0x5d, 0x5f, 0x51, 0xd6,
0x18, 0x13, 0xad, 0x54, 0x26, 0xc6, 0xc2, 0x21, 0xb4, 0x95, 0x28, 0xd1, 0xdb, 0x4a, 0x68, 0xae,
0x59, 0x21, 0x6a, 0x6e, 0x1d, 0xd7, 0xb3, 0x74, 0x1b, 0x36, 0xef, 0x81, 0x7d, 0x2b, 0x92, 0xa9,
0xc9, 0xf7, 0x4c, 0xde, 0xba, 0x15, 0xc9, 0xd5, 0xda, 0x06, 0xfa, 0x4d, 0x43, 0x26, 0x60, 0xe9,
0xc5, 0xcd, 0x51, 0x7a, 0xd6, 0xb8, 0x33, 0x71, 0x8f, 0x87, 0xeb, 0xbb, 0x0d, 0xab, 0xcf, 0x6c,
0x07, 0xfa, 0x91, 0x48, 0xd3, 0xb9, 0xf2, 0x6c, 0x73, 0x41, 0xa9, 0xd8, 0x01, 0xd8, 0xb2, 0x74,
0xc1, 0x73, 0x8c, 0x3d, 0x5b, 0xff, 0xd8, 0x13, 0xd6, 0x25, 0xfa, 0x9a, 0x02, 0x3f, 0x63, 0xa4,
0x3c, 0x18, 0x93, 0x89, 0x1d, 0x96, 0xca, 0x7f, 0x07, 0xce, 0x39, 0x2f, 0xe2, 0xe5, 0xf2, 0xaa,
0xd1, 0x48, 0x63, 0x34, 0x06, 0xdd, 0x7b, 0xa1, 0xb0, 0x7a, 0x55, 0x3a, 0x6e, 0x30, 0x75, 0x9a,
0x4c, 0xfe, 0x73, 0x70, 0xce, 0x9a, 0x2f, 0x21, 0x13, 0x31, 0x4a, 0x8f, 0x8c, 0x3b, 0x7a, 0x70,
0x23, 0xfc, 0x05, 0x80, 0x2e, 0x39, 0xbb, 0xe1, 0x59, 0x82, 0xec, 0x35, 0xb8, 0x91, 0x89, 0x9a,
0x3b, 0xda, 0x5d, 0x7b, 0x61, 0xcb, 0x4a, 0xb3, 0x26, 0x88, 0xea, 0x98, 0xed, 0x82, 0xa5, 0x2f,
0x9c, 0xce, 0xe3, 0x92, 0xac, 0xaf, 0xe5, 0xdb, 0x98, 0x79, 0x60, 0x45, 0x22, 0x53, 0xf8, 0xb0,
0x84, 0x1b, 0x84, 0x95, 0xdc, 0x3f, 0x02, 0xa7, 0xfe, 0xdd, 0xb0, 0x4d, 0x70, 0x8d, 0xb8, 0x10,
0x45, 0xca, 0x6f, 0x69, 0x8b, 0xfd, 0x07, 0x9b, 0x26, 0xb1, 0xea, 0x49, 0xc9, 0xfe, 0x1f, 0x02,
0x6e, 0xe3, 0xa1, 0x30, 0x80, 0x7e, 0x20, 0x93, 0xf3, 0xbb, 0x9c, 0xb6, 0x98, 0x0b, 0x56, 0x20,
0x93, 0x53, 0xe4, 0x8a, 0x12, 0x36, 0x04, 0x08, 0x64, 0xf2, 0xa1, 0x10, 0xb9, 0x90, 0x48, 0xdb,
0x6c, 0x03, 0x9c, 0x40, 0x26, 0x27, 0x79, 0x8e, 0x59, 0x4c, 0x3b, 0xec, 0x7f, 0xd8, 0xaa, 0x65,
0x88, 0x32, 0x17, 0x99, 0x44, 0xda, 0x65, 0x0c, 0x86, 0x81, 0x4c, 0x42, 0xfc, 0x72, 0x87, 0x52,
0x7d, 0x12, 0x0a, 0x69, 0x8f, 0x3d, 0x83, 0x9d, 0xf5, 0x5c, 0x5d, 0xdf, 0xd7, 0xd0, 0x81, 0x4c,
0xaa, 0xed, 0x52, 0x8b, 0x51, 0x18, 0x68, 0x1e, 0xe4, 0x85, 0xba, 0xd6, 0x20, 0x36, 0xf3, 0x60,
0xbb, 0x99, 0xa9, 0x0f, 0x3b, 0x25, 0xc3, 0x55, 0xc1, 0x33, 0x39, 0xc3, 0xe2, 0x3d, 0xf2, 0x18,
0x0b, 0xea, 0xb2, 0x2d, 0xd8, 0xd0, 0xe9, 0x79, 0x8a, 0xe2, 0x4e, 0x5d, 0x88, 0xaf, 0x74, 0xb0,
0x7f, 0x00, 0xc3, 0x75, 0xe7, 0xf5, 0xac, 0x27, 0x71, 0x7c, 0x21, 0x62, 0xa4, 0x2d, 0x3d, 0x6b,
0x88, 0xa9, 0xb8, 0x47, 0xa3, 0xc9, 0x29, 0xfd, 0xf1, 0x38, 0x22, 0x3f, 0x1f, 0x47, 0xe4, 0xd7,
0xe3, 0x88, 0x7c, 0xfb, 0x3d, 0x6a, 0x5d, 0xf7, 0xcd, 0xbf, 0xda, 0xcb, 0xbf, 0x01, 0x00, 0x00,
0xff, 0xff, 0x2c, 0x70, 0xc6, 0xf6, 0xe6, 0x04, 0x00, 0x00,
}

5
proto/proto/eraftpb.proto
View File

@ -79,12 +79,9 @@ message Message {
uint64 commit = 8;
Snapshot snapshot = 9;
bool reject = 10;
// TODO: Delete Start
uint64 reject_hint = 11;
// TODO: Delete End
}
// HardState contains the state of a node, including the current term, commit index
// HardState contains the state of a node need to be peristed, including the current term, commit index
// and the vote record
message HardState {
uint64 term = 1;