*: update generated proto code
parent
59b479e59b
commit
13f44e4b79
|
@ -35,7 +35,7 @@ type Request struct {
|
||||||
Dir bool `protobuf:"varint,5,req" json:"Dir"`
|
Dir bool `protobuf:"varint,5,req" json:"Dir"`
|
||||||
PrevValue string `protobuf:"bytes,6,req" json:"PrevValue"`
|
PrevValue string `protobuf:"bytes,6,req" json:"PrevValue"`
|
||||||
PrevIndex uint64 `protobuf:"varint,7,req" json:"PrevIndex"`
|
PrevIndex uint64 `protobuf:"varint,7,req" json:"PrevIndex"`
|
||||||
PrevExist *bool `protobuf:"varint,8,req" json:"PrevExist,omitempty"`
|
PrevExist *bool `protobuf:"varint,8,opt" json:"PrevExist,omitempty"`
|
||||||
Expiration int64 `protobuf:"varint,9,req" json:"Expiration"`
|
Expiration int64 `protobuf:"varint,9,req" json:"Expiration"`
|
||||||
Wait bool `protobuf:"varint,10,req" json:"Wait"`
|
Wait bool `protobuf:"varint,10,req" json:"Wait"`
|
||||||
Since uint64 `protobuf:"varint,11,req" json:"Since"`
|
Since uint64 `protobuf:"varint,11,req" json:"Since"`
|
||||||
|
@ -64,16 +64,17 @@ func (*Metadata) ProtoMessage() {}
|
||||||
func init() {
|
func init() {
|
||||||
}
|
}
|
||||||
func (m *Request) Unmarshal(data []byte) error {
|
func (m *Request) Unmarshal(data []byte) error {
|
||||||
|
var hasFields [1]uint64
|
||||||
l := len(data)
|
l := len(data)
|
||||||
index := 0
|
iNdEx := 0
|
||||||
for index < l {
|
for iNdEx < l {
|
||||||
var wire uint64
|
var wire uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
wire |= (uint64(b) & 0x7F) << shift
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -87,147 +88,154 @@ func (m *Request) Unmarshal(data []byte) error {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.ID |= (uint64(b) & 0x7F) << shift
|
m.ID |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
hasFields[0] |= uint64(0x00000001)
|
||||||
case 2:
|
case 2:
|
||||||
if wireType != 2 {
|
if wireType != 2 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Method", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Method", wireType)
|
||||||
}
|
}
|
||||||
var stringLen uint64
|
var stringLen uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
stringLen |= (uint64(b) & 0x7F) << shift
|
stringLen |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
postIndex := index + int(stringLen)
|
postIndex := iNdEx + int(stringLen)
|
||||||
if postIndex > l {
|
if postIndex > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.Method = string(data[index:postIndex])
|
m.Method = string(data[iNdEx:postIndex])
|
||||||
index = postIndex
|
iNdEx = postIndex
|
||||||
|
hasFields[0] |= uint64(0x00000002)
|
||||||
case 3:
|
case 3:
|
||||||
if wireType != 2 {
|
if wireType != 2 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Path", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Path", wireType)
|
||||||
}
|
}
|
||||||
var stringLen uint64
|
var stringLen uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
stringLen |= (uint64(b) & 0x7F) << shift
|
stringLen |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
postIndex := index + int(stringLen)
|
postIndex := iNdEx + int(stringLen)
|
||||||
if postIndex > l {
|
if postIndex > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.Path = string(data[index:postIndex])
|
m.Path = string(data[iNdEx:postIndex])
|
||||||
index = postIndex
|
iNdEx = postIndex
|
||||||
|
hasFields[0] |= uint64(0x00000004)
|
||||||
case 4:
|
case 4:
|
||||||
if wireType != 2 {
|
if wireType != 2 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Val", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Val", wireType)
|
||||||
}
|
}
|
||||||
var stringLen uint64
|
var stringLen uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
stringLen |= (uint64(b) & 0x7F) << shift
|
stringLen |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
postIndex := index + int(stringLen)
|
postIndex := iNdEx + int(stringLen)
|
||||||
if postIndex > l {
|
if postIndex > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.Val = string(data[index:postIndex])
|
m.Val = string(data[iNdEx:postIndex])
|
||||||
index = postIndex
|
iNdEx = postIndex
|
||||||
|
hasFields[0] |= uint64(0x00000008)
|
||||||
case 5:
|
case 5:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Dir", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Dir", wireType)
|
||||||
}
|
}
|
||||||
var v int
|
var v int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
v |= (int(b) & 0x7F) << shift
|
v |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
m.Dir = bool(v != 0)
|
m.Dir = bool(v != 0)
|
||||||
|
hasFields[0] |= uint64(0x00000010)
|
||||||
case 6:
|
case 6:
|
||||||
if wireType != 2 {
|
if wireType != 2 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field PrevValue", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field PrevValue", wireType)
|
||||||
}
|
}
|
||||||
var stringLen uint64
|
var stringLen uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
stringLen |= (uint64(b) & 0x7F) << shift
|
stringLen |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
postIndex := index + int(stringLen)
|
postIndex := iNdEx + int(stringLen)
|
||||||
if postIndex > l {
|
if postIndex > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.PrevValue = string(data[index:postIndex])
|
m.PrevValue = string(data[iNdEx:postIndex])
|
||||||
index = postIndex
|
iNdEx = postIndex
|
||||||
|
hasFields[0] |= uint64(0x00000020)
|
||||||
case 7:
|
case 7:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field PrevIndex", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field PrevIndex", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.PrevIndex |= (uint64(b) & 0x7F) << shift
|
m.PrevIndex |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
hasFields[0] |= uint64(0x00000040)
|
||||||
case 8:
|
case 8:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field PrevExist", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field PrevExist", wireType)
|
||||||
}
|
}
|
||||||
var v int
|
var v int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
v |= (int(b) & 0x7F) << shift
|
v |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -240,131 +248,139 @@ func (m *Request) Unmarshal(data []byte) error {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Expiration", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Expiration", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.Expiration |= (int64(b) & 0x7F) << shift
|
m.Expiration |= (int64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
hasFields[0] |= uint64(0x00000080)
|
||||||
case 10:
|
case 10:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Wait", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Wait", wireType)
|
||||||
}
|
}
|
||||||
var v int
|
var v int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
v |= (int(b) & 0x7F) << shift
|
v |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
m.Wait = bool(v != 0)
|
m.Wait = bool(v != 0)
|
||||||
|
hasFields[0] |= uint64(0x00000100)
|
||||||
case 11:
|
case 11:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Since", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Since", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.Since |= (uint64(b) & 0x7F) << shift
|
m.Since |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
hasFields[0] |= uint64(0x00000200)
|
||||||
case 12:
|
case 12:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Recursive", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Recursive", wireType)
|
||||||
}
|
}
|
||||||
var v int
|
var v int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
v |= (int(b) & 0x7F) << shift
|
v |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
m.Recursive = bool(v != 0)
|
m.Recursive = bool(v != 0)
|
||||||
|
hasFields[0] |= uint64(0x00000400)
|
||||||
case 13:
|
case 13:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Sorted", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Sorted", wireType)
|
||||||
}
|
}
|
||||||
var v int
|
var v int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
v |= (int(b) & 0x7F) << shift
|
v |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
m.Sorted = bool(v != 0)
|
m.Sorted = bool(v != 0)
|
||||||
|
hasFields[0] |= uint64(0x00000800)
|
||||||
case 14:
|
case 14:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Quorum", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Quorum", wireType)
|
||||||
}
|
}
|
||||||
var v int
|
var v int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
v |= (int(b) & 0x7F) << shift
|
v |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
m.Quorum = bool(v != 0)
|
m.Quorum = bool(v != 0)
|
||||||
|
hasFields[0] |= uint64(0x00001000)
|
||||||
case 15:
|
case 15:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Time", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Time", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.Time |= (int64(b) & 0x7F) << shift
|
m.Time |= (int64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
hasFields[0] |= uint64(0x00002000)
|
||||||
case 16:
|
case 16:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Stream", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Stream", wireType)
|
||||||
}
|
}
|
||||||
var v int
|
var v int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
v |= (int(b) & 0x7F) << shift
|
v |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
m.Stream = bool(v != 0)
|
m.Stream = bool(v != 0)
|
||||||
|
hasFields[0] |= uint64(0x00004000)
|
||||||
default:
|
default:
|
||||||
var sizeOfWire int
|
var sizeOfWire int
|
||||||
for {
|
for {
|
||||||
|
@ -374,31 +390,78 @@ func (m *Request) Unmarshal(data []byte) error {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
index -= sizeOfWire
|
iNdEx -= sizeOfWire
|
||||||
skippy, err := github_com_gogo_protobuf_proto.Skip(data[index:])
|
skippy, err := skipEtcdserver(data[iNdEx:])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if (index + skippy) > l {
|
if (iNdEx + skippy) > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
|
m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
|
||||||
index += skippy
|
iNdEx += skippy
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000001) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("ID")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000002) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Method")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000004) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Path")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000008) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Val")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000010) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Dir")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000020) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("PrevValue")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000040) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("PrevIndex")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000080) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Expiration")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000100) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Wait")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000200) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Since")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000400) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Recursive")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000800) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Sorted")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00001000) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Quorum")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00002000) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Time")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00004000) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Stream")
|
||||||
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
func (m *Metadata) Unmarshal(data []byte) error {
|
func (m *Metadata) Unmarshal(data []byte) error {
|
||||||
|
var hasFields [1]uint64
|
||||||
l := len(data)
|
l := len(data)
|
||||||
index := 0
|
iNdEx := 0
|
||||||
for index < l {
|
for iNdEx < l {
|
||||||
var wire uint64
|
var wire uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
wire |= (uint64(b) & 0x7F) << shift
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -412,31 +475,33 @@ func (m *Metadata) Unmarshal(data []byte) error {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field NodeID", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field NodeID", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.NodeID |= (uint64(b) & 0x7F) << shift
|
m.NodeID |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
hasFields[0] |= uint64(0x00000001)
|
||||||
case 2:
|
case 2:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field ClusterID", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field ClusterID", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.ClusterID |= (uint64(b) & 0x7F) << shift
|
m.ClusterID |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
hasFields[0] |= uint64(0x00000002)
|
||||||
default:
|
default:
|
||||||
var sizeOfWire int
|
var sizeOfWire int
|
||||||
for {
|
for {
|
||||||
|
@ -446,20 +511,111 @@ func (m *Metadata) Unmarshal(data []byte) error {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
index -= sizeOfWire
|
iNdEx -= sizeOfWire
|
||||||
skippy, err := github_com_gogo_protobuf_proto.Skip(data[index:])
|
skippy, err := skipEtcdserver(data[iNdEx:])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if (index + skippy) > l {
|
if (iNdEx + skippy) > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
|
m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
|
||||||
index += skippy
|
iNdEx += skippy
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000001) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("NodeID")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000002) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("ClusterID")
|
||||||
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
func skipEtcdserver(data []byte) (n int, err error) {
|
||||||
|
l := len(data)
|
||||||
|
iNdEx := 0
|
||||||
|
for iNdEx < l {
|
||||||
|
var wire uint64
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
wireType := int(wire & 0x7)
|
||||||
|
switch wireType {
|
||||||
|
case 0:
|
||||||
|
for {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
iNdEx++
|
||||||
|
if data[iNdEx-1] < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return iNdEx, nil
|
||||||
|
case 1:
|
||||||
|
iNdEx += 8
|
||||||
|
return iNdEx, nil
|
||||||
|
case 2:
|
||||||
|
var length int
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
length |= (int(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
iNdEx += length
|
||||||
|
return iNdEx, nil
|
||||||
|
case 3:
|
||||||
|
for {
|
||||||
|
var innerWire uint64
|
||||||
|
var start int = iNdEx
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
innerWire |= (uint64(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
innerWireType := int(innerWire & 0x7)
|
||||||
|
if innerWireType == 4 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
next, err := skipEtcdserver(data[start:])
|
||||||
|
if err != nil {
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
|
iNdEx = start + next
|
||||||
|
}
|
||||||
|
return iNdEx, nil
|
||||||
|
case 4:
|
||||||
|
return iNdEx, nil
|
||||||
|
case 5:
|
||||||
|
iNdEx += 4
|
||||||
|
return iNdEx, nil
|
||||||
|
default:
|
||||||
|
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
panic("unreachable")
|
||||||
|
}
|
||||||
func (m *Request) Size() (n int) {
|
func (m *Request) Size() (n int) {
|
||||||
var l int
|
var l int
|
||||||
_ = l
|
_ = l
|
||||||
|
|
|
@ -8,25 +8,25 @@ option (gogoproto.unmarshaler_all) = true;
|
||||||
option (gogoproto.goproto_getters_all) = false;
|
option (gogoproto.goproto_getters_all) = false;
|
||||||
|
|
||||||
message Request {
|
message Request {
|
||||||
required uint64 ID = 1 [(gogoproto.nullable) = false];
|
optional uint64 ID = 1 [(gogoproto.nullable) = false];
|
||||||
required string Method = 2 [(gogoproto.nullable) = false];
|
optional string Method = 2 [(gogoproto.nullable) = false];
|
||||||
required string Path = 3 [(gogoproto.nullable) = false];
|
optional string Path = 3 [(gogoproto.nullable) = false];
|
||||||
required string Val = 4 [(gogoproto.nullable) = false];
|
optional string Val = 4 [(gogoproto.nullable) = false];
|
||||||
required bool Dir = 5 [(gogoproto.nullable) = false];
|
optional bool Dir = 5 [(gogoproto.nullable) = false];
|
||||||
required string PrevValue = 6 [(gogoproto.nullable) = false];
|
optional string PrevValue = 6 [(gogoproto.nullable) = false];
|
||||||
required uint64 PrevIndex = 7 [(gogoproto.nullable) = false];
|
optional uint64 PrevIndex = 7 [(gogoproto.nullable) = false];
|
||||||
required bool PrevExist = 8 [(gogoproto.nullable) = true];
|
optional bool PrevExist = 8 [(gogoproto.nullable) = true];
|
||||||
required int64 Expiration = 9 [(gogoproto.nullable) = false];
|
optional int64 Expiration = 9 [(gogoproto.nullable) = false];
|
||||||
required bool Wait = 10 [(gogoproto.nullable) = false];
|
optional bool Wait = 10 [(gogoproto.nullable) = false];
|
||||||
required uint64 Since = 11 [(gogoproto.nullable) = false];
|
optional uint64 Since = 11 [(gogoproto.nullable) = false];
|
||||||
required bool Recursive = 12 [(gogoproto.nullable) = false];
|
optional bool Recursive = 12 [(gogoproto.nullable) = false];
|
||||||
required bool Sorted = 13 [(gogoproto.nullable) = false];
|
optional bool Sorted = 13 [(gogoproto.nullable) = false];
|
||||||
required bool Quorum = 14 [(gogoproto.nullable) = false];
|
optional bool Quorum = 14 [(gogoproto.nullable) = false];
|
||||||
required int64 Time = 15 [(gogoproto.nullable) = false];
|
optional int64 Time = 15 [(gogoproto.nullable) = false];
|
||||||
required bool Stream = 16 [(gogoproto.nullable) = false];
|
optional bool Stream = 16 [(gogoproto.nullable) = false];
|
||||||
}
|
}
|
||||||
|
|
||||||
message Metadata {
|
message Metadata {
|
||||||
required uint64 NodeID = 1 [(gogoproto.nullable) = false];
|
optional uint64 NodeID = 1 [(gogoproto.nullable) = false];
|
||||||
required uint64 ClusterID = 2 [(gogoproto.nullable) = false];
|
optional uint64 ClusterID = 2 [(gogoproto.nullable) = false];
|
||||||
}
|
}
|
||||||
|
|
|
@ -76,16 +76,17 @@ func (m *LogEntry) GetCommand() []byte {
|
||||||
func init() {
|
func init() {
|
||||||
}
|
}
|
||||||
func (m *LogEntry) Unmarshal(data []byte) error {
|
func (m *LogEntry) Unmarshal(data []byte) error {
|
||||||
|
var hasFields [1]uint64
|
||||||
l := len(data)
|
l := len(data)
|
||||||
index := 0
|
iNdEx := 0
|
||||||
for index < l {
|
for iNdEx < l {
|
||||||
var wire uint64
|
var wire uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
wire |= (uint64(b) & 0x7F) << shift
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -100,79 +101,82 @@ func (m *LogEntry) Unmarshal(data []byte) error {
|
||||||
}
|
}
|
||||||
var v uint64
|
var v uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
v |= (uint64(b) & 0x7F) << shift
|
v |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
m.Index = &v
|
m.Index = &v
|
||||||
|
hasFields[0] |= uint64(0x00000001)
|
||||||
case 2:
|
case 2:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Term", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Term", wireType)
|
||||||
}
|
}
|
||||||
var v uint64
|
var v uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
v |= (uint64(b) & 0x7F) << shift
|
v |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
m.Term = &v
|
m.Term = &v
|
||||||
|
hasFields[0] |= uint64(0x00000002)
|
||||||
case 3:
|
case 3:
|
||||||
if wireType != 2 {
|
if wireType != 2 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field CommandName", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field CommandName", wireType)
|
||||||
}
|
}
|
||||||
var stringLen uint64
|
var stringLen uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
stringLen |= (uint64(b) & 0x7F) << shift
|
stringLen |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
postIndex := index + int(stringLen)
|
postIndex := iNdEx + int(stringLen)
|
||||||
if postIndex > l {
|
if postIndex > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
s := string(data[index:postIndex])
|
s := string(data[iNdEx:postIndex])
|
||||||
m.CommandName = &s
|
m.CommandName = &s
|
||||||
index = postIndex
|
iNdEx = postIndex
|
||||||
|
hasFields[0] |= uint64(0x00000004)
|
||||||
case 4:
|
case 4:
|
||||||
if wireType != 2 {
|
if wireType != 2 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Command", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Command", wireType)
|
||||||
}
|
}
|
||||||
var byteLen int
|
var byteLen int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
byteLen |= (int(b) & 0x7F) << shift
|
byteLen |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
postIndex := index + byteLen
|
postIndex := iNdEx + byteLen
|
||||||
if postIndex > l {
|
if postIndex > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.Command = append([]byte{}, data[index:postIndex]...)
|
m.Command = append([]byte{}, data[iNdEx:postIndex]...)
|
||||||
index = postIndex
|
iNdEx = postIndex
|
||||||
default:
|
default:
|
||||||
var sizeOfWire int
|
var sizeOfWire int
|
||||||
for {
|
for {
|
||||||
|
@ -182,20 +186,114 @@ func (m *LogEntry) Unmarshal(data []byte) error {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
index -= sizeOfWire
|
iNdEx -= sizeOfWire
|
||||||
skippy, err := github_com_gogo_protobuf_proto.Skip(data[index:])
|
skippy, err := skipLogEntry(data[iNdEx:])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if (index + skippy) > l {
|
if (iNdEx + skippy) > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
|
m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
|
||||||
index += skippy
|
iNdEx += skippy
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000001) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Index")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000002) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("Term")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000004) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("CommandName")
|
||||||
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
func skipLogEntry(data []byte) (n int, err error) {
|
||||||
|
l := len(data)
|
||||||
|
iNdEx := 0
|
||||||
|
for iNdEx < l {
|
||||||
|
var wire uint64
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
wireType := int(wire & 0x7)
|
||||||
|
switch wireType {
|
||||||
|
case 0:
|
||||||
|
for {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
iNdEx++
|
||||||
|
if data[iNdEx-1] < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return iNdEx, nil
|
||||||
|
case 1:
|
||||||
|
iNdEx += 8
|
||||||
|
return iNdEx, nil
|
||||||
|
case 2:
|
||||||
|
var length int
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
length |= (int(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
iNdEx += length
|
||||||
|
return iNdEx, nil
|
||||||
|
case 3:
|
||||||
|
for {
|
||||||
|
var innerWire uint64
|
||||||
|
var start int = iNdEx
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
innerWire |= (uint64(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
innerWireType := int(innerWire & 0x7)
|
||||||
|
if innerWireType == 4 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
next, err := skipLogEntry(data[start:])
|
||||||
|
if err != nil {
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
|
iNdEx = start + next
|
||||||
|
}
|
||||||
|
return iNdEx, nil
|
||||||
|
case 4:
|
||||||
|
return iNdEx, nil
|
||||||
|
case 5:
|
||||||
|
iNdEx += 4
|
||||||
|
return iNdEx, nil
|
||||||
|
default:
|
||||||
|
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
panic("unreachable")
|
||||||
|
}
|
||||||
func (this *LogEntry) String() string {
|
func (this *LogEntry) String() string {
|
||||||
if this == nil {
|
if this == nil {
|
||||||
return "nil"
|
return "nil"
|
||||||
|
@ -256,9 +354,9 @@ func sozLogEntry(x uint64) (n int) {
|
||||||
}
|
}
|
||||||
func NewPopulatedLogEntry(r randyLogEntry, easy bool) *LogEntry {
|
func NewPopulatedLogEntry(r randyLogEntry, easy bool) *LogEntry {
|
||||||
this := &LogEntry{}
|
this := &LogEntry{}
|
||||||
v1 := uint64(r.Uint32())
|
v1 := uint64(uint64(r.Uint32()))
|
||||||
this.Index = &v1
|
this.Index = &v1
|
||||||
v2 := uint64(r.Uint32())
|
v2 := uint64(uint64(r.Uint32()))
|
||||||
this.Term = &v2
|
this.Term = &v2
|
||||||
v3 := randStringLogEntry(r)
|
v3 := randStringLogEntry(r)
|
||||||
this.CommandName = &v3
|
this.CommandName = &v3
|
||||||
|
@ -285,7 +383,13 @@ type randyLogEntry interface {
|
||||||
}
|
}
|
||||||
|
|
||||||
func randUTF8RuneLogEntry(r randyLogEntry) rune {
|
func randUTF8RuneLogEntry(r randyLogEntry) rune {
|
||||||
return rune(r.Intn(126-43) + 43)
|
ru := r.Intn(62)
|
||||||
|
if ru < 10 {
|
||||||
|
return rune(ru + 48)
|
||||||
|
} else if ru < 36 {
|
||||||
|
return rune(ru + 55)
|
||||||
|
}
|
||||||
|
return rune(ru + 61)
|
||||||
}
|
}
|
||||||
func randStringLogEntry(r randyLogEntry) string {
|
func randStringLogEntry(r randyLogEntry) string {
|
||||||
v5 := r.Intn(100)
|
v5 := r.Intn(100)
|
||||||
|
@ -356,17 +460,23 @@ func (m *LogEntry) MarshalTo(data []byte) (n int, err error) {
|
||||||
_ = i
|
_ = i
|
||||||
var l int
|
var l int
|
||||||
_ = l
|
_ = l
|
||||||
if m.Index != nil {
|
if m.Index == nil {
|
||||||
|
return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("Index")
|
||||||
|
} else {
|
||||||
data[i] = 0x8
|
data[i] = 0x8
|
||||||
i++
|
i++
|
||||||
i = encodeVarintLogEntry(data, i, uint64(*m.Index))
|
i = encodeVarintLogEntry(data, i, uint64(*m.Index))
|
||||||
}
|
}
|
||||||
if m.Term != nil {
|
if m.Term == nil {
|
||||||
|
return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("Term")
|
||||||
|
} else {
|
||||||
data[i] = 0x10
|
data[i] = 0x10
|
||||||
i++
|
i++
|
||||||
i = encodeVarintLogEntry(data, i, uint64(*m.Term))
|
i = encodeVarintLogEntry(data, i, uint64(*m.Term))
|
||||||
}
|
}
|
||||||
if m.CommandName != nil {
|
if m.CommandName == nil {
|
||||||
|
return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("CommandName")
|
||||||
|
} else {
|
||||||
data[i] = 0x1a
|
data[i] = 0x1a
|
||||||
i++
|
i++
|
||||||
i = encodeVarintLogEntry(data, i, uint64(len(*m.CommandName)))
|
i = encodeVarintLogEntry(data, i, uint64(len(*m.CommandName)))
|
||||||
|
|
File diff suppressed because it is too large
Load Diff
|
@ -14,16 +14,16 @@ enum EntryType {
|
||||||
}
|
}
|
||||||
|
|
||||||
message Entry {
|
message Entry {
|
||||||
required EntryType Type = 1 [(gogoproto.nullable) = false];
|
optional EntryType Type = 1 [(gogoproto.nullable) = false];
|
||||||
required uint64 Term = 2 [(gogoproto.nullable) = false];
|
optional uint64 Term = 2 [(gogoproto.nullable) = false];
|
||||||
required uint64 Index = 3 [(gogoproto.nullable) = false];
|
optional uint64 Index = 3 [(gogoproto.nullable) = false];
|
||||||
optional bytes Data = 4 [(gogoproto.nullable) = false];
|
optional bytes Data = 4 [(gogoproto.nullable) = false];
|
||||||
}
|
}
|
||||||
|
|
||||||
message SnapshotMetadata {
|
message SnapshotMetadata {
|
||||||
required ConfState conf_state = 1 [(gogoproto.nullable) = false];
|
optional ConfState conf_state = 1 [(gogoproto.nullable) = false];
|
||||||
required uint64 index = 2 [(gogoproto.nullable) = false];
|
optional uint64 index = 2 [(gogoproto.nullable) = false];
|
||||||
required uint64 term = 3 [(gogoproto.nullable) = false];
|
optional uint64 term = 3 [(gogoproto.nullable) = false];
|
||||||
}
|
}
|
||||||
|
|
||||||
message Snapshot {
|
message Snapshot {
|
||||||
|
@ -47,23 +47,23 @@ enum MessageType {
|
||||||
}
|
}
|
||||||
|
|
||||||
message Message {
|
message Message {
|
||||||
required MessageType type = 1 [(gogoproto.nullable) = false];
|
optional MessageType type = 1 [(gogoproto.nullable) = false];
|
||||||
required uint64 to = 2 [(gogoproto.nullable) = false];
|
optional uint64 to = 2 [(gogoproto.nullable) = false];
|
||||||
required uint64 from = 3 [(gogoproto.nullable) = false];
|
optional uint64 from = 3 [(gogoproto.nullable) = false];
|
||||||
required uint64 term = 4 [(gogoproto.nullable) = false];
|
optional uint64 term = 4 [(gogoproto.nullable) = false];
|
||||||
required uint64 logTerm = 5 [(gogoproto.nullable) = false];
|
optional uint64 logTerm = 5 [(gogoproto.nullable) = false];
|
||||||
required uint64 index = 6 [(gogoproto.nullable) = false];
|
optional uint64 index = 6 [(gogoproto.nullable) = false];
|
||||||
repeated Entry entries = 7 [(gogoproto.nullable) = false];
|
repeated Entry entries = 7 [(gogoproto.nullable) = false];
|
||||||
required uint64 commit = 8 [(gogoproto.nullable) = false];
|
optional uint64 commit = 8 [(gogoproto.nullable) = false];
|
||||||
required Snapshot snapshot = 9 [(gogoproto.nullable) = false];
|
optional Snapshot snapshot = 9 [(gogoproto.nullable) = false];
|
||||||
required bool reject = 10 [(gogoproto.nullable) = false];
|
optional bool reject = 10 [(gogoproto.nullable) = false];
|
||||||
required uint64 rejectHint = 11 [(gogoproto.nullable) = false];
|
optional uint64 rejectHint = 11 [(gogoproto.nullable) = false];
|
||||||
}
|
}
|
||||||
|
|
||||||
message HardState {
|
message HardState {
|
||||||
required uint64 term = 1 [(gogoproto.nullable) = false];
|
optional uint64 term = 1 [(gogoproto.nullable) = false];
|
||||||
required uint64 vote = 2 [(gogoproto.nullable) = false];
|
optional uint64 vote = 2 [(gogoproto.nullable) = false];
|
||||||
required uint64 commit = 3 [(gogoproto.nullable) = false];
|
optional uint64 commit = 3 [(gogoproto.nullable) = false];
|
||||||
}
|
}
|
||||||
|
|
||||||
message ConfState {
|
message ConfState {
|
||||||
|
@ -77,8 +77,8 @@ enum ConfChangeType {
|
||||||
}
|
}
|
||||||
|
|
||||||
message ConfChange {
|
message ConfChange {
|
||||||
required uint64 ID = 1 [(gogoproto.nullable) = false];
|
optional uint64 ID = 1 [(gogoproto.nullable) = false];
|
||||||
required ConfChangeType Type = 2 [(gogoproto.nullable) = false];
|
optional ConfChangeType Type = 2 [(gogoproto.nullable) = false];
|
||||||
required uint64 NodeID = 3 [(gogoproto.nullable) = false];
|
optional uint64 NodeID = 3 [(gogoproto.nullable) = false];
|
||||||
optional bytes Context = 4 [(gogoproto.nullable) = false];
|
optional bytes Context = 4 [(gogoproto.nullable) = false];
|
||||||
}
|
}
|
||||||
|
|
|
@ -7,7 +7,7 @@
|
||||||
PREFIX="github.com/coreos/etcd/Godeps/_workspace/src"
|
PREFIX="github.com/coreos/etcd/Godeps/_workspace/src"
|
||||||
DIRS="./wal/walpb ./etcdserver/etcdserverpb ./snap/snappb ./raft/raftpb ./migrate/etcd4pb ./storage/storagepb"
|
DIRS="./wal/walpb ./etcdserver/etcdserverpb ./snap/snappb ./raft/raftpb ./migrate/etcd4pb ./storage/storagepb"
|
||||||
|
|
||||||
SHA="bc946d07d1016848dfd2507f90f0859c9471681e"
|
SHA="64f27bf06efee53589314a6e5a4af34cdd85adf6"
|
||||||
|
|
||||||
if ! protoc --version > /dev/null; then
|
if ! protoc --version > /dev/null; then
|
||||||
echo "could not find protoc, is it installed + in PATH?"
|
echo "could not find protoc, is it installed + in PATH?"
|
||||||
|
@ -28,7 +28,7 @@ export PATH="${GOBIN}:${PATH}"
|
||||||
|
|
||||||
for dir in ${DIRS}; do
|
for dir in ${DIRS}; do
|
||||||
pushd ${dir}
|
pushd ${dir}
|
||||||
protoc --gogo_out=. -I=.:${GOPATH}/src/github.com/gogo/protobuf/protobuf:${GOPATH}/src *.proto
|
protoc --gogofast_out=. -I=.:${GOPATH}/src/github.com/gogo/protobuf/protobuf:${GOPATH}/src *.proto
|
||||||
sed -i".bak" -e "s|github.com/gogo/protobuf/proto|${PREFIX}/github.com/gogo/protobuf/proto|" *.go
|
sed -i".bak" -e "s|github.com/gogo/protobuf/proto|${PREFIX}/github.com/gogo/protobuf/proto|" *.go
|
||||||
rm -f *.bak
|
rm -f *.bak
|
||||||
popd
|
popd
|
||||||
|
|
|
@ -39,16 +39,17 @@ func (*Snapshot) ProtoMessage() {}
|
||||||
func init() {
|
func init() {
|
||||||
}
|
}
|
||||||
func (m *Snapshot) Unmarshal(data []byte) error {
|
func (m *Snapshot) Unmarshal(data []byte) error {
|
||||||
|
var hasFields [1]uint64
|
||||||
l := len(data)
|
l := len(data)
|
||||||
index := 0
|
iNdEx := 0
|
||||||
for index < l {
|
for iNdEx < l {
|
||||||
var wire uint64
|
var wire uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
wire |= (uint64(b) & 0x7F) << shift
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -62,38 +63,39 @@ func (m *Snapshot) Unmarshal(data []byte) error {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Crc", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Crc", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.Crc |= (uint32(b) & 0x7F) << shift
|
m.Crc |= (uint32(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
hasFields[0] |= uint64(0x00000001)
|
||||||
case 2:
|
case 2:
|
||||||
if wireType != 2 {
|
if wireType != 2 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType)
|
||||||
}
|
}
|
||||||
var byteLen int
|
var byteLen int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
byteLen |= (int(b) & 0x7F) << shift
|
byteLen |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
postIndex := index + byteLen
|
postIndex := iNdEx + byteLen
|
||||||
if postIndex > l {
|
if postIndex > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.Data = append([]byte{}, data[index:postIndex]...)
|
m.Data = append([]byte{}, data[iNdEx:postIndex]...)
|
||||||
index = postIndex
|
iNdEx = postIndex
|
||||||
default:
|
default:
|
||||||
var sizeOfWire int
|
var sizeOfWire int
|
||||||
for {
|
for {
|
||||||
|
@ -103,20 +105,108 @@ func (m *Snapshot) Unmarshal(data []byte) error {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
index -= sizeOfWire
|
iNdEx -= sizeOfWire
|
||||||
skippy, err := github_com_gogo_protobuf_proto.Skip(data[index:])
|
skippy, err := skipSnap(data[iNdEx:])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if (index + skippy) > l {
|
if (iNdEx + skippy) > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
|
m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
|
||||||
index += skippy
|
iNdEx += skippy
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000001) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("crc")
|
||||||
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
func skipSnap(data []byte) (n int, err error) {
|
||||||
|
l := len(data)
|
||||||
|
iNdEx := 0
|
||||||
|
for iNdEx < l {
|
||||||
|
var wire uint64
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
wireType := int(wire & 0x7)
|
||||||
|
switch wireType {
|
||||||
|
case 0:
|
||||||
|
for {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
iNdEx++
|
||||||
|
if data[iNdEx-1] < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return iNdEx, nil
|
||||||
|
case 1:
|
||||||
|
iNdEx += 8
|
||||||
|
return iNdEx, nil
|
||||||
|
case 2:
|
||||||
|
var length int
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
length |= (int(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
iNdEx += length
|
||||||
|
return iNdEx, nil
|
||||||
|
case 3:
|
||||||
|
for {
|
||||||
|
var innerWire uint64
|
||||||
|
var start int = iNdEx
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
innerWire |= (uint64(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
innerWireType := int(innerWire & 0x7)
|
||||||
|
if innerWireType == 4 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
next, err := skipSnap(data[start:])
|
||||||
|
if err != nil {
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
|
iNdEx = start + next
|
||||||
|
}
|
||||||
|
return iNdEx, nil
|
||||||
|
case 4:
|
||||||
|
return iNdEx, nil
|
||||||
|
case 5:
|
||||||
|
iNdEx += 4
|
||||||
|
return iNdEx, nil
|
||||||
|
default:
|
||||||
|
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
panic("unreachable")
|
||||||
|
}
|
||||||
func (m *Snapshot) Size() (n int) {
|
func (m *Snapshot) Size() (n int) {
|
||||||
var l int
|
var l int
|
||||||
_ = l
|
_ = l
|
||||||
|
|
|
@ -8,6 +8,6 @@ option (gogoproto.unmarshaler_all) = true;
|
||||||
option (gogoproto.goproto_getters_all) = false;
|
option (gogoproto.goproto_getters_all) = false;
|
||||||
|
|
||||||
message snapshot {
|
message snapshot {
|
||||||
required uint32 crc = 1 [(gogoproto.nullable) = false];
|
optional uint32 crc = 1 [(gogoproto.nullable) = false];
|
||||||
optional bytes data = 2;
|
optional bytes data = 2;
|
||||||
}
|
}
|
||||||
|
|
|
@ -115,6 +115,11 @@ func Read(snapname string) (*raftpb.Snapshot, error) {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if len(b) == 0 {
|
||||||
|
plog.Errorf("unexpected empty snapshot")
|
||||||
|
return nil, ErrEmptySnapshot
|
||||||
|
}
|
||||||
|
|
||||||
var serializedSnap snappb.Snapshot
|
var serializedSnap snappb.Snapshot
|
||||||
if err = serializedSnap.Unmarshal(b); err != nil {
|
if err = serializedSnap.Unmarshal(b); err != nil {
|
||||||
plog.Errorf("corrupted snapshot file %v: %v", snapname, err)
|
plog.Errorf("corrupted snapshot file %v: %v", snapname, err)
|
||||||
|
|
|
@ -21,7 +21,6 @@ import math "math"
|
||||||
|
|
||||||
import io "io"
|
import io "io"
|
||||||
import fmt "fmt"
|
import fmt "fmt"
|
||||||
import github_com_gogo_protobuf_proto "github.com/coreos/etcd/Godeps/_workspace/src/github.com/gogo/protobuf/proto"
|
|
||||||
|
|
||||||
// Reference imports to suppress errors if they are not otherwise used.
|
// Reference imports to suppress errors if they are not otherwise used.
|
||||||
var _ = proto.Marshal
|
var _ = proto.Marshal
|
||||||
|
@ -98,15 +97,15 @@ func init() {
|
||||||
}
|
}
|
||||||
func (m *KeyValue) Unmarshal(data []byte) error {
|
func (m *KeyValue) Unmarshal(data []byte) error {
|
||||||
l := len(data)
|
l := len(data)
|
||||||
index := 0
|
iNdEx := 0
|
||||||
for index < l {
|
for iNdEx < l {
|
||||||
var wire uint64
|
var wire uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
wire |= (uint64(b) & 0x7F) << shift
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -121,32 +120,32 @@ func (m *KeyValue) Unmarshal(data []byte) error {
|
||||||
}
|
}
|
||||||
var byteLen int
|
var byteLen int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
byteLen |= (int(b) & 0x7F) << shift
|
byteLen |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
postIndex := index + byteLen
|
postIndex := iNdEx + byteLen
|
||||||
if postIndex > l {
|
if postIndex > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.Key = append([]byte{}, data[index:postIndex]...)
|
m.Key = append([]byte{}, data[iNdEx:postIndex]...)
|
||||||
index = postIndex
|
iNdEx = postIndex
|
||||||
case 2:
|
case 2:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field CreateIndex", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field CreateIndex", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.CreateIndex |= (int64(b) & 0x7F) << shift
|
m.CreateIndex |= (int64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -157,11 +156,11 @@ func (m *KeyValue) Unmarshal(data []byte) error {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field ModIndex", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field ModIndex", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.ModIndex |= (int64(b) & 0x7F) << shift
|
m.ModIndex |= (int64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -172,11 +171,11 @@ func (m *KeyValue) Unmarshal(data []byte) error {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Version", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Version", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.Version |= (int64(b) & 0x7F) << shift
|
m.Version |= (int64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -188,22 +187,22 @@ func (m *KeyValue) Unmarshal(data []byte) error {
|
||||||
}
|
}
|
||||||
var byteLen int
|
var byteLen int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
byteLen |= (int(b) & 0x7F) << shift
|
byteLen |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
postIndex := index + byteLen
|
postIndex := iNdEx + byteLen
|
||||||
if postIndex > l {
|
if postIndex > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.Value = append([]byte{}, data[index:postIndex]...)
|
m.Value = append([]byte{}, data[iNdEx:postIndex]...)
|
||||||
index = postIndex
|
iNdEx = postIndex
|
||||||
default:
|
default:
|
||||||
var sizeOfWire int
|
var sizeOfWire int
|
||||||
for {
|
for {
|
||||||
|
@ -213,31 +212,32 @@ func (m *KeyValue) Unmarshal(data []byte) error {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
index -= sizeOfWire
|
iNdEx -= sizeOfWire
|
||||||
skippy, err := github_com_gogo_protobuf_proto.Skip(data[index:])
|
skippy, err := skipKv(data[iNdEx:])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if (index + skippy) > l {
|
if (iNdEx + skippy) > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
|
m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
|
||||||
index += skippy
|
iNdEx += skippy
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
func (m *Event) Unmarshal(data []byte) error {
|
func (m *Event) Unmarshal(data []byte) error {
|
||||||
l := len(data)
|
l := len(data)
|
||||||
index := 0
|
iNdEx := 0
|
||||||
for index < l {
|
for iNdEx < l {
|
||||||
var wire uint64
|
var wire uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
wire |= (uint64(b) & 0x7F) << shift
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -251,11 +251,11 @@ func (m *Event) Unmarshal(data []byte) error {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.Type |= (Event_EventType(b) & 0x7F) << shift
|
m.Type |= (Event_EventType(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -267,24 +267,24 @@ func (m *Event) Unmarshal(data []byte) error {
|
||||||
}
|
}
|
||||||
var msglen int
|
var msglen int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
msglen |= (int(b) & 0x7F) << shift
|
msglen |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
postIndex := index + msglen
|
postIndex := iNdEx + msglen
|
||||||
if postIndex > l {
|
if postIndex > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
if err := m.Kv.Unmarshal(data[index:postIndex]); err != nil {
|
if err := m.Kv.Unmarshal(data[iNdEx:postIndex]); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
index = postIndex
|
iNdEx = postIndex
|
||||||
default:
|
default:
|
||||||
var sizeOfWire int
|
var sizeOfWire int
|
||||||
for {
|
for {
|
||||||
|
@ -294,20 +294,105 @@ func (m *Event) Unmarshal(data []byte) error {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
index -= sizeOfWire
|
iNdEx -= sizeOfWire
|
||||||
skippy, err := github_com_gogo_protobuf_proto.Skip(data[index:])
|
skippy, err := skipKv(data[iNdEx:])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if (index + skippy) > l {
|
if (iNdEx + skippy) > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
|
m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
|
||||||
index += skippy
|
iNdEx += skippy
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
func skipKv(data []byte) (n int, err error) {
|
||||||
|
l := len(data)
|
||||||
|
iNdEx := 0
|
||||||
|
for iNdEx < l {
|
||||||
|
var wire uint64
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
wireType := int(wire & 0x7)
|
||||||
|
switch wireType {
|
||||||
|
case 0:
|
||||||
|
for {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
iNdEx++
|
||||||
|
if data[iNdEx-1] < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return iNdEx, nil
|
||||||
|
case 1:
|
||||||
|
iNdEx += 8
|
||||||
|
return iNdEx, nil
|
||||||
|
case 2:
|
||||||
|
var length int
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
length |= (int(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
iNdEx += length
|
||||||
|
return iNdEx, nil
|
||||||
|
case 3:
|
||||||
|
for {
|
||||||
|
var innerWire uint64
|
||||||
|
var start int = iNdEx
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
innerWire |= (uint64(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
innerWireType := int(innerWire & 0x7)
|
||||||
|
if innerWireType == 4 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
next, err := skipKv(data[start:])
|
||||||
|
if err != nil {
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
|
iNdEx = start + next
|
||||||
|
}
|
||||||
|
return iNdEx, nil
|
||||||
|
case 4:
|
||||||
|
return iNdEx, nil
|
||||||
|
case 5:
|
||||||
|
iNdEx += 4
|
||||||
|
return iNdEx, nil
|
||||||
|
default:
|
||||||
|
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
panic("unreachable")
|
||||||
|
}
|
||||||
func (m *KeyValue) Size() (n int) {
|
func (m *KeyValue) Size() (n int) {
|
||||||
var l int
|
var l int
|
||||||
_ = l
|
_ = l
|
||||||
|
|
|
@ -51,16 +51,17 @@ func (*Snapshot) ProtoMessage() {}
|
||||||
func init() {
|
func init() {
|
||||||
}
|
}
|
||||||
func (m *Record) Unmarshal(data []byte) error {
|
func (m *Record) Unmarshal(data []byte) error {
|
||||||
|
var hasFields [1]uint64
|
||||||
l := len(data)
|
l := len(data)
|
||||||
index := 0
|
iNdEx := 0
|
||||||
for index < l {
|
for iNdEx < l {
|
||||||
var wire uint64
|
var wire uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
wire |= (uint64(b) & 0x7F) << shift
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -74,53 +75,55 @@ func (m *Record) Unmarshal(data []byte) error {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.Type |= (int64(b) & 0x7F) << shift
|
m.Type |= (int64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
hasFields[0] |= uint64(0x00000001)
|
||||||
case 2:
|
case 2:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Crc", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Crc", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.Crc |= (uint32(b) & 0x7F) << shift
|
m.Crc |= (uint32(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
hasFields[0] |= uint64(0x00000002)
|
||||||
case 3:
|
case 3:
|
||||||
if wireType != 2 {
|
if wireType != 2 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType)
|
||||||
}
|
}
|
||||||
var byteLen int
|
var byteLen int
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
byteLen |= (int(b) & 0x7F) << shift
|
byteLen |= (int(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
postIndex := index + byteLen
|
postIndex := iNdEx + byteLen
|
||||||
if postIndex > l {
|
if postIndex > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.Data = append([]byte{}, data[index:postIndex]...)
|
m.Data = append([]byte{}, data[iNdEx:postIndex]...)
|
||||||
index = postIndex
|
iNdEx = postIndex
|
||||||
default:
|
default:
|
||||||
var sizeOfWire int
|
var sizeOfWire int
|
||||||
for {
|
for {
|
||||||
|
@ -130,31 +133,39 @@ func (m *Record) Unmarshal(data []byte) error {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
index -= sizeOfWire
|
iNdEx -= sizeOfWire
|
||||||
skippy, err := github_com_gogo_protobuf_proto.Skip(data[index:])
|
skippy, err := skipRecord(data[iNdEx:])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if (index + skippy) > l {
|
if (iNdEx + skippy) > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
|
m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
|
||||||
index += skippy
|
iNdEx += skippy
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000001) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("type")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000002) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("crc")
|
||||||
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
func (m *Snapshot) Unmarshal(data []byte) error {
|
func (m *Snapshot) Unmarshal(data []byte) error {
|
||||||
|
var hasFields [1]uint64
|
||||||
l := len(data)
|
l := len(data)
|
||||||
index := 0
|
iNdEx := 0
|
||||||
for index < l {
|
for iNdEx < l {
|
||||||
var wire uint64
|
var wire uint64
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
wire |= (uint64(b) & 0x7F) << shift
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
|
@ -168,31 +179,33 @@ func (m *Snapshot) Unmarshal(data []byte) error {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Index", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Index", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.Index |= (uint64(b) & 0x7F) << shift
|
m.Index |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
hasFields[0] |= uint64(0x00000001)
|
||||||
case 2:
|
case 2:
|
||||||
if wireType != 0 {
|
if wireType != 0 {
|
||||||
return fmt.Errorf("proto: wrong wireType = %d for field Term", wireType)
|
return fmt.Errorf("proto: wrong wireType = %d for field Term", wireType)
|
||||||
}
|
}
|
||||||
for shift := uint(0); ; shift += 7 {
|
for shift := uint(0); ; shift += 7 {
|
||||||
if index >= l {
|
if iNdEx >= l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
b := data[index]
|
b := data[iNdEx]
|
||||||
index++
|
iNdEx++
|
||||||
m.Term |= (uint64(b) & 0x7F) << shift
|
m.Term |= (uint64(b) & 0x7F) << shift
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
hasFields[0] |= uint64(0x00000002)
|
||||||
default:
|
default:
|
||||||
var sizeOfWire int
|
var sizeOfWire int
|
||||||
for {
|
for {
|
||||||
|
@ -202,20 +215,111 @@ func (m *Snapshot) Unmarshal(data []byte) error {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
index -= sizeOfWire
|
iNdEx -= sizeOfWire
|
||||||
skippy, err := github_com_gogo_protobuf_proto.Skip(data[index:])
|
skippy, err := skipRecord(data[iNdEx:])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if (index + skippy) > l {
|
if (iNdEx + skippy) > l {
|
||||||
return io.ErrUnexpectedEOF
|
return io.ErrUnexpectedEOF
|
||||||
}
|
}
|
||||||
m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
|
m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...)
|
||||||
index += skippy
|
iNdEx += skippy
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000001) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("index")
|
||||||
|
}
|
||||||
|
if hasFields[0]&uint64(0x00000002) == 0 {
|
||||||
|
return github_com_gogo_protobuf_proto.NewRequiredNotSetError("term")
|
||||||
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
func skipRecord(data []byte) (n int, err error) {
|
||||||
|
l := len(data)
|
||||||
|
iNdEx := 0
|
||||||
|
for iNdEx < l {
|
||||||
|
var wire uint64
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
wire |= (uint64(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
wireType := int(wire & 0x7)
|
||||||
|
switch wireType {
|
||||||
|
case 0:
|
||||||
|
for {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
iNdEx++
|
||||||
|
if data[iNdEx-1] < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return iNdEx, nil
|
||||||
|
case 1:
|
||||||
|
iNdEx += 8
|
||||||
|
return iNdEx, nil
|
||||||
|
case 2:
|
||||||
|
var length int
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
length |= (int(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
iNdEx += length
|
||||||
|
return iNdEx, nil
|
||||||
|
case 3:
|
||||||
|
for {
|
||||||
|
var innerWire uint64
|
||||||
|
var start int = iNdEx
|
||||||
|
for shift := uint(0); ; shift += 7 {
|
||||||
|
if iNdEx >= l {
|
||||||
|
return 0, io.ErrUnexpectedEOF
|
||||||
|
}
|
||||||
|
b := data[iNdEx]
|
||||||
|
iNdEx++
|
||||||
|
innerWire |= (uint64(b) & 0x7F) << shift
|
||||||
|
if b < 0x80 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
innerWireType := int(innerWire & 0x7)
|
||||||
|
if innerWireType == 4 {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
next, err := skipRecord(data[start:])
|
||||||
|
if err != nil {
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
|
iNdEx = start + next
|
||||||
|
}
|
||||||
|
return iNdEx, nil
|
||||||
|
case 4:
|
||||||
|
return iNdEx, nil
|
||||||
|
case 5:
|
||||||
|
iNdEx += 4
|
||||||
|
return iNdEx, nil
|
||||||
|
default:
|
||||||
|
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
panic("unreachable")
|
||||||
|
}
|
||||||
func (m *Record) Size() (n int) {
|
func (m *Record) Size() (n int) {
|
||||||
var l int
|
var l int
|
||||||
_ = l
|
_ = l
|
||||||
|
|
|
@ -8,12 +8,12 @@ option (gogoproto.unmarshaler_all) = true;
|
||||||
option (gogoproto.goproto_getters_all) = false;
|
option (gogoproto.goproto_getters_all) = false;
|
||||||
|
|
||||||
message Record {
|
message Record {
|
||||||
required int64 type = 1 [(gogoproto.nullable) = false];
|
optional int64 type = 1 [(gogoproto.nullable) = false];
|
||||||
required uint32 crc = 2 [(gogoproto.nullable) = false];
|
optional uint32 crc = 2 [(gogoproto.nullable) = false];
|
||||||
optional bytes data = 3;
|
optional bytes data = 3;
|
||||||
}
|
}
|
||||||
|
|
||||||
message Snapshot {
|
message Snapshot {
|
||||||
required uint64 index = 1 [(gogoproto.nullable) = false];
|
optional uint64 index = 1 [(gogoproto.nullable) = false];
|
||||||
required uint64 term = 2 [(gogoproto.nullable) = false];
|
optional uint64 term = 2 [(gogoproto.nullable) = false];
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue