| // Code generated by protoc-gen-gogo. |
| // source: record.proto |
| // DO NOT EDIT! |
| |
| /* |
| Package walpb is a generated protocol buffer package. |
| |
| It is generated from these files: |
| record.proto |
| |
| It has these top-level messages: |
| Record |
| Snapshot |
| */ |
| package walpb |
| |
| import proto "github.com/gogo/protobuf/proto" |
| import math "math" |
| |
| // discarding unused import gogoproto "github.com/coreos/etcd/Godeps/_workspace/src/gogoproto" |
| |
| import io "io" |
| import fmt "fmt" |
| |
| // Reference imports to suppress errors if they are not otherwise used. |
| var _ = proto.Marshal |
| var _ = math.Inf |
| |
| type Record struct { |
| Type int64 `protobuf:"varint,1,opt,name=type" json:"type"` |
| Crc uint32 `protobuf:"varint,2,opt,name=crc" json:"crc"` |
| Data []byte `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"` |
| XXX_unrecognized []byte `json:"-"` |
| } |
| |
| func (m *Record) Reset() { *m = Record{} } |
| func (m *Record) String() string { return proto.CompactTextString(m) } |
| func (*Record) ProtoMessage() {} |
| |
| type Snapshot struct { |
| Index uint64 `protobuf:"varint,1,opt,name=index" json:"index"` |
| Term uint64 `protobuf:"varint,2,opt,name=term" json:"term"` |
| XXX_unrecognized []byte `json:"-"` |
| } |
| |
| func (m *Snapshot) Reset() { *m = Snapshot{} } |
| func (m *Snapshot) String() string { return proto.CompactTextString(m) } |
| func (*Snapshot) ProtoMessage() {} |
| |
| func (m *Record) Marshal() (data []byte, err error) { |
| size := m.Size() |
| data = make([]byte, size) |
| n, err := m.MarshalTo(data) |
| if err != nil { |
| return nil, err |
| } |
| return data[:n], nil |
| } |
| |
| func (m *Record) MarshalTo(data []byte) (int, error) { |
| var i int |
| _ = i |
| var l int |
| _ = l |
| data[i] = 0x8 |
| i++ |
| i = encodeVarintRecord(data, i, uint64(m.Type)) |
| data[i] = 0x10 |
| i++ |
| i = encodeVarintRecord(data, i, uint64(m.Crc)) |
| if m.Data != nil { |
| data[i] = 0x1a |
| i++ |
| i = encodeVarintRecord(data, i, uint64(len(m.Data))) |
| i += copy(data[i:], m.Data) |
| } |
| if m.XXX_unrecognized != nil { |
| i += copy(data[i:], m.XXX_unrecognized) |
| } |
| return i, nil |
| } |
| |
| func (m *Snapshot) Marshal() (data []byte, err error) { |
| size := m.Size() |
| data = make([]byte, size) |
| n, err := m.MarshalTo(data) |
| if err != nil { |
| return nil, err |
| } |
| return data[:n], nil |
| } |
| |
| func (m *Snapshot) MarshalTo(data []byte) (int, error) { |
| var i int |
| _ = i |
| var l int |
| _ = l |
| data[i] = 0x8 |
| i++ |
| i = encodeVarintRecord(data, i, uint64(m.Index)) |
| data[i] = 0x10 |
| i++ |
| i = encodeVarintRecord(data, i, uint64(m.Term)) |
| if m.XXX_unrecognized != nil { |
| i += copy(data[i:], m.XXX_unrecognized) |
| } |
| return i, nil |
| } |
| |
| func encodeFixed64Record(data []byte, offset int, v uint64) int { |
| data[offset] = uint8(v) |
| data[offset+1] = uint8(v >> 8) |
| data[offset+2] = uint8(v >> 16) |
| data[offset+3] = uint8(v >> 24) |
| data[offset+4] = uint8(v >> 32) |
| data[offset+5] = uint8(v >> 40) |
| data[offset+6] = uint8(v >> 48) |
| data[offset+7] = uint8(v >> 56) |
| return offset + 8 |
| } |
| func encodeFixed32Record(data []byte, offset int, v uint32) int { |
| data[offset] = uint8(v) |
| data[offset+1] = uint8(v >> 8) |
| data[offset+2] = uint8(v >> 16) |
| data[offset+3] = uint8(v >> 24) |
| return offset + 4 |
| } |
| func encodeVarintRecord(data []byte, offset int, v uint64) int { |
| for v >= 1<<7 { |
| data[offset] = uint8(v&0x7f | 0x80) |
| v >>= 7 |
| offset++ |
| } |
| data[offset] = uint8(v) |
| return offset + 1 |
| } |
| func (m *Record) Size() (n int) { |
| var l int |
| _ = l |
| n += 1 + sovRecord(uint64(m.Type)) |
| n += 1 + sovRecord(uint64(m.Crc)) |
| if m.Data != nil { |
| l = len(m.Data) |
| n += 1 + l + sovRecord(uint64(l)) |
| } |
| if m.XXX_unrecognized != nil { |
| n += len(m.XXX_unrecognized) |
| } |
| return n |
| } |
| |
| func (m *Snapshot) Size() (n int) { |
| var l int |
| _ = l |
| n += 1 + sovRecord(uint64(m.Index)) |
| n += 1 + sovRecord(uint64(m.Term)) |
| if m.XXX_unrecognized != nil { |
| n += len(m.XXX_unrecognized) |
| } |
| return n |
| } |
| |
| func sovRecord(x uint64) (n int) { |
| for { |
| n++ |
| x >>= 7 |
| if x == 0 { |
| break |
| } |
| } |
| return n |
| } |
| func sozRecord(x uint64) (n int) { |
| return sovRecord(uint64((x << 1) ^ uint64((int64(x) >> 63)))) |
| } |
| func (m *Record) Unmarshal(data []byte) error { |
| l := len(data) |
| iNdEx := 0 |
| for iNdEx < l { |
| var wire uint64 |
| for shift := uint(0); ; shift += 7 { |
| if iNdEx >= l { |
| return io.ErrUnexpectedEOF |
| } |
| b := data[iNdEx] |
| iNdEx++ |
| wire |= (uint64(b) & 0x7F) << shift |
| if b < 0x80 { |
| break |
| } |
| } |
| fieldNum := int32(wire >> 3) |
| wireType := int(wire & 0x7) |
| switch fieldNum { |
| case 1: |
| if wireType != 0 { |
| return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType) |
| } |
| m.Type = 0 |
| for shift := uint(0); ; shift += 7 { |
| if iNdEx >= l { |
| return io.ErrUnexpectedEOF |
| } |
| b := data[iNdEx] |
| iNdEx++ |
| m.Type |= (int64(b) & 0x7F) << shift |
| if b < 0x80 { |
| break |
| } |
| } |
| case 2: |
| if wireType != 0 { |
| return fmt.Errorf("proto: wrong wireType = %d for field Crc", wireType) |
| } |
| m.Crc = 0 |
| for shift := uint(0); ; shift += 7 { |
| if iNdEx >= l { |
| return io.ErrUnexpectedEOF |
| } |
| b := data[iNdEx] |
| iNdEx++ |
| m.Crc |= (uint32(b) & 0x7F) << shift |
| if b < 0x80 { |
| break |
| } |
| } |
| case 3: |
| if wireType != 2 { |
| return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType) |
| } |
| var byteLen int |
| for shift := uint(0); ; shift += 7 { |
| if iNdEx >= l { |
| return io.ErrUnexpectedEOF |
| } |
| b := data[iNdEx] |
| iNdEx++ |
| byteLen |= (int(b) & 0x7F) << shift |
| if b < 0x80 { |
| break |
| } |
| } |
| if byteLen < 0 { |
| return ErrInvalidLengthRecord |
| } |
| postIndex := iNdEx + byteLen |
| if postIndex > l { |
| return io.ErrUnexpectedEOF |
| } |
| m.Data = append([]byte{}, data[iNdEx:postIndex]...) |
| iNdEx = postIndex |
| default: |
| var sizeOfWire int |
| for { |
| sizeOfWire++ |
| wire >>= 7 |
| if wire == 0 { |
| break |
| } |
| } |
| iNdEx -= sizeOfWire |
| skippy, err := skipRecord(data[iNdEx:]) |
| if err != nil { |
| return err |
| } |
| if skippy < 0 { |
| return ErrInvalidLengthRecord |
| } |
| if (iNdEx + skippy) > l { |
| return io.ErrUnexpectedEOF |
| } |
| m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...) |
| iNdEx += skippy |
| } |
| } |
| |
| return nil |
| } |
| func (m *Snapshot) Unmarshal(data []byte) error { |
| l := len(data) |
| iNdEx := 0 |
| for iNdEx < l { |
| var wire uint64 |
| for shift := uint(0); ; shift += 7 { |
| if iNdEx >= l { |
| return io.ErrUnexpectedEOF |
| } |
| b := data[iNdEx] |
| iNdEx++ |
| wire |= (uint64(b) & 0x7F) << shift |
| if b < 0x80 { |
| break |
| } |
| } |
| fieldNum := int32(wire >> 3) |
| wireType := int(wire & 0x7) |
| switch fieldNum { |
| case 1: |
| if wireType != 0 { |
| return fmt.Errorf("proto: wrong wireType = %d for field Index", wireType) |
| } |
| m.Index = 0 |
| for shift := uint(0); ; shift += 7 { |
| if iNdEx >= l { |
| return io.ErrUnexpectedEOF |
| } |
| b := data[iNdEx] |
| iNdEx++ |
| m.Index |= (uint64(b) & 0x7F) << shift |
| if b < 0x80 { |
| break |
| } |
| } |
| case 2: |
| if wireType != 0 { |
| return fmt.Errorf("proto: wrong wireType = %d for field Term", wireType) |
| } |
| m.Term = 0 |
| for shift := uint(0); ; shift += 7 { |
| if iNdEx >= l { |
| return io.ErrUnexpectedEOF |
| } |
| b := data[iNdEx] |
| iNdEx++ |
| m.Term |= (uint64(b) & 0x7F) << shift |
| if b < 0x80 { |
| break |
| } |
| } |
| default: |
| var sizeOfWire int |
| for { |
| sizeOfWire++ |
| wire >>= 7 |
| if wire == 0 { |
| break |
| } |
| } |
| iNdEx -= sizeOfWire |
| skippy, err := skipRecord(data[iNdEx:]) |
| if err != nil { |
| return err |
| } |
| if skippy < 0 { |
| return ErrInvalidLengthRecord |
| } |
| if (iNdEx + skippy) > l { |
| return io.ErrUnexpectedEOF |
| } |
| m.XXX_unrecognized = append(m.XXX_unrecognized, data[iNdEx:iNdEx+skippy]...) |
| iNdEx += skippy |
| } |
| } |
| |
| 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 |
| if length < 0 { |
| return 0, ErrInvalidLengthRecord |
| } |
| 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") |
| } |
| |
| var ( |
| ErrInvalidLengthRecord = fmt.Errorf("proto: negative length found during unmarshaling") |
| ) |
