record.pb.go 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223
  1. // Code generated by protoc-gen-gogo.
  2. // source: record.proto
  3. // DO NOT EDIT!
  4. /*
  5. Package walpb is a generated protocol buffer package.
  6. It is generated from these files:
  7. record.proto
  8. It has these top-level messages:
  9. Record
  10. */
  11. package walpb
  12. import proto "github.com/coreos/etcd/Godeps/_workspace/src/code.google.com/p/gogoprotobuf/proto"
  13. import json "encoding/json"
  14. import math "math"
  15. // discarding unused import gogoproto "code.google.com/p/gogoprotobuf/gogoproto/gogo.pb"
  16. import io "io"
  17. import code_google_com_p_gogoprotobuf_proto "github.com/coreos/etcd/Godeps/_workspace/src/code.google.com/p/gogoprotobuf/proto"
  18. // Reference proto, json, and math imports to suppress error if they are not otherwise used.
  19. var _ = proto.Marshal
  20. var _ = &json.SyntaxError{}
  21. var _ = math.Inf
  22. type Record struct {
  23. Type int64 `protobuf:"varint,1,req,name=type" json:"type"`
  24. Crc uint32 `protobuf:"varint,2,req,name=crc" json:"crc"`
  25. Data []byte `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
  26. XXX_unrecognized []byte `json:"-"`
  27. }
  28. func (m *Record) Reset() { *m = Record{} }
  29. func (m *Record) String() string { return proto.CompactTextString(m) }
  30. func (*Record) ProtoMessage() {}
  31. func init() {
  32. }
  33. func (m *Record) Unmarshal(data []byte) error {
  34. l := len(data)
  35. index := 0
  36. for index < l {
  37. var wire uint64
  38. for shift := uint(0); ; shift += 7 {
  39. if index >= l {
  40. return io.ErrUnexpectedEOF
  41. }
  42. b := data[index]
  43. index++
  44. wire |= (uint64(b) & 0x7F) << shift
  45. if b < 0x80 {
  46. break
  47. }
  48. }
  49. fieldNum := int32(wire >> 3)
  50. wireType := int(wire & 0x7)
  51. switch fieldNum {
  52. case 1:
  53. if wireType != 0 {
  54. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  55. }
  56. for shift := uint(0); ; shift += 7 {
  57. if index >= l {
  58. return io.ErrUnexpectedEOF
  59. }
  60. b := data[index]
  61. index++
  62. m.Type |= (int64(b) & 0x7F) << shift
  63. if b < 0x80 {
  64. break
  65. }
  66. }
  67. case 2:
  68. if wireType != 0 {
  69. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  70. }
  71. for shift := uint(0); ; shift += 7 {
  72. if index >= l {
  73. return io.ErrUnexpectedEOF
  74. }
  75. b := data[index]
  76. index++
  77. m.Crc |= (uint32(b) & 0x7F) << shift
  78. if b < 0x80 {
  79. break
  80. }
  81. }
  82. case 3:
  83. if wireType != 2 {
  84. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  85. }
  86. var byteLen int
  87. for shift := uint(0); ; shift += 7 {
  88. if index >= l {
  89. return io.ErrUnexpectedEOF
  90. }
  91. b := data[index]
  92. index++
  93. byteLen |= (int(b) & 0x7F) << shift
  94. if b < 0x80 {
  95. break
  96. }
  97. }
  98. postIndex := index + byteLen
  99. if postIndex > l {
  100. return io.ErrUnexpectedEOF
  101. }
  102. m.Data = append(m.Data, data[index:postIndex]...)
  103. index = postIndex
  104. default:
  105. var sizeOfWire int
  106. for {
  107. sizeOfWire++
  108. wire >>= 7
  109. if wire == 0 {
  110. break
  111. }
  112. }
  113. index -= sizeOfWire
  114. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  115. if err != nil {
  116. return err
  117. }
  118. if (index + skippy) > l {
  119. return io.ErrUnexpectedEOF
  120. }
  121. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  122. index += skippy
  123. }
  124. }
  125. return nil
  126. }
  127. func (m *Record) Size() (n int) {
  128. var l int
  129. _ = l
  130. n += 1 + sovRecord(uint64(m.Type))
  131. n += 1 + sovRecord(uint64(m.Crc))
  132. if m.Data != nil {
  133. l = len(m.Data)
  134. n += 1 + l + sovRecord(uint64(l))
  135. }
  136. if m.XXX_unrecognized != nil {
  137. n += len(m.XXX_unrecognized)
  138. }
  139. return n
  140. }
  141. func sovRecord(x uint64) (n int) {
  142. for {
  143. n++
  144. x >>= 7
  145. if x == 0 {
  146. break
  147. }
  148. }
  149. return n
  150. }
  151. func sozRecord(x uint64) (n int) {
  152. return sovRecord(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  153. }
  154. func (m *Record) Marshal() (data []byte, err error) {
  155. size := m.Size()
  156. data = make([]byte, size)
  157. n, err := m.MarshalTo(data)
  158. if err != nil {
  159. return nil, err
  160. }
  161. return data[:n], nil
  162. }
  163. func (m *Record) MarshalTo(data []byte) (n int, err error) {
  164. var i int
  165. _ = i
  166. var l int
  167. _ = l
  168. data[i] = 0x8
  169. i++
  170. i = encodeVarintRecord(data, i, uint64(m.Type))
  171. data[i] = 0x10
  172. i++
  173. i = encodeVarintRecord(data, i, uint64(m.Crc))
  174. if m.Data != nil {
  175. data[i] = 0x1a
  176. i++
  177. i = encodeVarintRecord(data, i, uint64(len(m.Data)))
  178. i += copy(data[i:], m.Data)
  179. }
  180. if m.XXX_unrecognized != nil {
  181. i += copy(data[i:], m.XXX_unrecognized)
  182. }
  183. return i, nil
  184. }
  185. func encodeFixed64Record(data []byte, offset int, v uint64) int {
  186. data[offset] = uint8(v)
  187. data[offset+1] = uint8(v >> 8)
  188. data[offset+2] = uint8(v >> 16)
  189. data[offset+3] = uint8(v >> 24)
  190. data[offset+4] = uint8(v >> 32)
  191. data[offset+5] = uint8(v >> 40)
  192. data[offset+6] = uint8(v >> 48)
  193. data[offset+7] = uint8(v >> 56)
  194. return offset + 8
  195. }
  196. func encodeFixed32Record(data []byte, offset int, v uint32) int {
  197. data[offset] = uint8(v)
  198. data[offset+1] = uint8(v >> 8)
  199. data[offset+2] = uint8(v >> 16)
  200. data[offset+3] = uint8(v >> 24)
  201. return offset + 4
  202. }
  203. func encodeVarintRecord(data []byte, offset int, v uint64) int {
  204. for v >= 1<<7 {
  205. data[offset] = uint8(v&0x7f | 0x80)
  206. v >>= 7
  207. offset++
  208. }
  209. data[offset] = uint8(v)
  210. return offset + 1
  211. }