entry.pb.go 5.8 KB

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