entry.pb.go 5.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243
  1. // Code generated by protoc-gen-gogo.
  2. // source: entry.proto
  3. // DO NOT EDIT!
  4. /*
  5. Package raft is a generated protocol buffer package.
  6. It is generated from these files:
  7. entry.proto
  8. It has these top-level messages:
  9. Entry
  10. */
  11. package raft
  12. import proto "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 "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 Entry struct {
  23. Type int64 `protobuf:"varint,1,req,name=type" json:"type"`
  24. Term int64 `protobuf:"varint,2,req,name=term" json:"term"`
  25. Index int64 `protobuf:"varint,3,req,name=index" json:"index"`
  26. Data []byte `protobuf:"bytes,4,opt,name=data" json:"data,omitempty"`
  27. XXX_unrecognized []byte `json:"-"`
  28. }
  29. func (m *Entry) Reset() { *m = Entry{} }
  30. func (m *Entry) String() string { return proto.CompactTextString(m) }
  31. func (*Entry) ProtoMessage() {}
  32. func init() {
  33. }
  34. func (m *Entry) Unmarshal(data []byte) error {
  35. l := len(data)
  36. index := 0
  37. for index < l {
  38. var wire uint64
  39. for shift := uint(0); ; shift += 7 {
  40. if index >= l {
  41. return io.ErrUnexpectedEOF
  42. }
  43. b := data[index]
  44. index++
  45. wire |= (uint64(b) & 0x7F) << shift
  46. if b < 0x80 {
  47. break
  48. }
  49. }
  50. fieldNum := int32(wire >> 3)
  51. wireType := int(wire & 0x7)
  52. switch fieldNum {
  53. case 1:
  54. if wireType != 0 {
  55. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  56. }
  57. for shift := uint(0); ; shift += 7 {
  58. if index >= l {
  59. return io.ErrUnexpectedEOF
  60. }
  61. b := data[index]
  62. index++
  63. m.Type |= (int64(b) & 0x7F) << shift
  64. if b < 0x80 {
  65. break
  66. }
  67. }
  68. case 2:
  69. if wireType != 0 {
  70. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  71. }
  72. for shift := uint(0); ; shift += 7 {
  73. if index >= l {
  74. return io.ErrUnexpectedEOF
  75. }
  76. b := data[index]
  77. index++
  78. m.Term |= (int64(b) & 0x7F) << shift
  79. if b < 0x80 {
  80. break
  81. }
  82. }
  83. case 3:
  84. if wireType != 0 {
  85. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  86. }
  87. for shift := uint(0); ; shift += 7 {
  88. if index >= l {
  89. return io.ErrUnexpectedEOF
  90. }
  91. b := data[index]
  92. index++
  93. m.Index |= (int64(b) & 0x7F) << shift
  94. if b < 0x80 {
  95. break
  96. }
  97. }
  98. case 4:
  99. if wireType != 2 {
  100. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  101. }
  102. var byteLen int
  103. for shift := uint(0); ; shift += 7 {
  104. if index >= l {
  105. return io.ErrUnexpectedEOF
  106. }
  107. b := data[index]
  108. index++
  109. byteLen |= (int(b) & 0x7F) << shift
  110. if b < 0x80 {
  111. break
  112. }
  113. }
  114. postIndex := index + byteLen
  115. if postIndex > l {
  116. return io.ErrUnexpectedEOF
  117. }
  118. m.Data = append(m.Data, data[index:postIndex]...)
  119. index = postIndex
  120. default:
  121. var sizeOfWire int
  122. for {
  123. sizeOfWire++
  124. wire >>= 7
  125. if wire == 0 {
  126. break
  127. }
  128. }
  129. index -= sizeOfWire
  130. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  131. if err != nil {
  132. return err
  133. }
  134. if (index + skippy) > l {
  135. return io.ErrUnexpectedEOF
  136. }
  137. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  138. index += skippy
  139. }
  140. }
  141. return nil
  142. }
  143. func (m *Entry) Size() (n int) {
  144. var l int
  145. _ = l
  146. n += 1 + sovEntry(uint64(m.Type))
  147. n += 1 + sovEntry(uint64(m.Term))
  148. n += 1 + sovEntry(uint64(m.Index))
  149. if m.Data != nil {
  150. l = len(m.Data)
  151. n += 1 + l + sovEntry(uint64(l))
  152. }
  153. if m.XXX_unrecognized != nil {
  154. n += len(m.XXX_unrecognized)
  155. }
  156. return n
  157. }
  158. func sovEntry(x uint64) (n int) {
  159. for {
  160. n++
  161. x >>= 7
  162. if x == 0 {
  163. break
  164. }
  165. }
  166. return n
  167. }
  168. func sozEntry(x uint64) (n int) {
  169. return sovEntry(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  170. }
  171. func (m *Entry) Marshal() (data []byte, err error) {
  172. size := m.Size()
  173. data = make([]byte, size)
  174. n, err := m.MarshalTo(data)
  175. if err != nil {
  176. return nil, err
  177. }
  178. return data[:n], nil
  179. }
  180. func (m *Entry) MarshalTo(data []byte) (n int, err error) {
  181. var i int
  182. _ = i
  183. var l int
  184. _ = l
  185. data[i] = 0x8
  186. i++
  187. i = encodeVarintEntry(data, i, uint64(m.Type))
  188. data[i] = 0x10
  189. i++
  190. i = encodeVarintEntry(data, i, uint64(m.Term))
  191. data[i] = 0x18
  192. i++
  193. i = encodeVarintEntry(data, i, uint64(m.Index))
  194. if m.Data != nil {
  195. data[i] = 0x22
  196. i++
  197. i = encodeVarintEntry(data, i, uint64(len(m.Data)))
  198. i += copy(data[i:], m.Data)
  199. }
  200. if m.XXX_unrecognized != nil {
  201. i += copy(data[i:], m.XXX_unrecognized)
  202. }
  203. return i, nil
  204. }
  205. func encodeFixed64Entry(data []byte, offset int, v uint64) int {
  206. data[offset] = uint8(v)
  207. data[offset+1] = uint8(v >> 8)
  208. data[offset+2] = uint8(v >> 16)
  209. data[offset+3] = uint8(v >> 24)
  210. data[offset+4] = uint8(v >> 32)
  211. data[offset+5] = uint8(v >> 40)
  212. data[offset+6] = uint8(v >> 48)
  213. data[offset+7] = uint8(v >> 56)
  214. return offset + 8
  215. }
  216. func encodeFixed32Entry(data []byte, offset int, v uint32) int {
  217. data[offset] = uint8(v)
  218. data[offset+1] = uint8(v >> 8)
  219. data[offset+2] = uint8(v >> 16)
  220. data[offset+3] = uint8(v >> 24)
  221. return offset + 4
  222. }
  223. func encodeVarintEntry(data []byte, offset int, v uint64) int {
  224. for v >= 1<<7 {
  225. data[offset] = uint8(v&0x7f | 0x80)
  226. v >>= 7
  227. offset++
  228. }
  229. data[offset] = uint8(v)
  230. return offset + 1
  231. }