state.pb.go 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221
  1. // Code generated by protoc-gen-gogo.
  2. // source: state.proto
  3. // DO NOT EDIT!
  4. package raft
  5. import proto "code.google.com/p/gogoprotobuf/proto"
  6. import json "encoding/json"
  7. import math "math"
  8. // discarding unused import gogoproto "code.google.com/p/gogoprotobuf/gogoproto/gogo.pb"
  9. import io1 "io"
  10. import code_google_com_p_gogoprotobuf_proto1 "code.google.com/p/gogoprotobuf/proto"
  11. // Reference proto, json, and math imports to suppress error if they are not otherwise used.
  12. var _ = proto.Marshal
  13. var _ = &json.SyntaxError{}
  14. var _ = math.Inf
  15. type State struct {
  16. Term int64 `protobuf:"varint,1,req,name=term" json:"term"`
  17. Vote int64 `protobuf:"varint,2,req,name=vote" json:"vote"`
  18. Commit int64 `protobuf:"varint,3,req,name=commit" json:"commit"`
  19. LastIndex int64 `protobuf:"varint,4,req,name=lastIndex" json:"lastIndex"`
  20. XXX_unrecognized []byte `json:"-"`
  21. }
  22. func (m *State) Reset() { *m = State{} }
  23. func (m *State) String() string { return proto.CompactTextString(m) }
  24. func (*State) ProtoMessage() {}
  25. func init() {
  26. }
  27. func (m *State) Unmarshal(data []byte) error {
  28. l := len(data)
  29. index := 0
  30. for index < l {
  31. var wire uint64
  32. for shift := uint(0); ; shift += 7 {
  33. if index >= l {
  34. return io1.ErrUnexpectedEOF
  35. }
  36. b := data[index]
  37. index++
  38. wire |= (uint64(b) & 0x7F) << shift
  39. if b < 0x80 {
  40. break
  41. }
  42. }
  43. fieldNum := int32(wire >> 3)
  44. wireType := int(wire & 0x7)
  45. switch fieldNum {
  46. case 1:
  47. if wireType != 0 {
  48. return code_google_com_p_gogoprotobuf_proto1.ErrWrongType
  49. }
  50. for shift := uint(0); ; shift += 7 {
  51. if index >= l {
  52. return io1.ErrUnexpectedEOF
  53. }
  54. b := data[index]
  55. index++
  56. m.Term |= (int64(b) & 0x7F) << shift
  57. if b < 0x80 {
  58. break
  59. }
  60. }
  61. case 2:
  62. if wireType != 0 {
  63. return code_google_com_p_gogoprotobuf_proto1.ErrWrongType
  64. }
  65. for shift := uint(0); ; shift += 7 {
  66. if index >= l {
  67. return io1.ErrUnexpectedEOF
  68. }
  69. b := data[index]
  70. index++
  71. m.Vote |= (int64(b) & 0x7F) << shift
  72. if b < 0x80 {
  73. break
  74. }
  75. }
  76. case 3:
  77. if wireType != 0 {
  78. return code_google_com_p_gogoprotobuf_proto1.ErrWrongType
  79. }
  80. for shift := uint(0); ; shift += 7 {
  81. if index >= l {
  82. return io1.ErrUnexpectedEOF
  83. }
  84. b := data[index]
  85. index++
  86. m.Commit |= (int64(b) & 0x7F) << shift
  87. if b < 0x80 {
  88. break
  89. }
  90. }
  91. case 4:
  92. if wireType != 0 {
  93. return code_google_com_p_gogoprotobuf_proto1.ErrWrongType
  94. }
  95. for shift := uint(0); ; shift += 7 {
  96. if index >= l {
  97. return io1.ErrUnexpectedEOF
  98. }
  99. b := data[index]
  100. index++
  101. m.LastIndex |= (int64(b) & 0x7F) << shift
  102. if b < 0x80 {
  103. break
  104. }
  105. }
  106. default:
  107. var sizeOfWire int
  108. for {
  109. sizeOfWire++
  110. wire >>= 7
  111. if wire == 0 {
  112. break
  113. }
  114. }
  115. index -= sizeOfWire
  116. skippy, err := code_google_com_p_gogoprotobuf_proto1.Skip(data[index:])
  117. if err != nil {
  118. return err
  119. }
  120. if (index + skippy) > l {
  121. return io1.ErrUnexpectedEOF
  122. }
  123. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  124. index += skippy
  125. }
  126. }
  127. return nil
  128. }
  129. func (m *State) Size() (n int) {
  130. var l int
  131. _ = l
  132. n += 1 + sovState(uint64(m.Term))
  133. n += 1 + sovState(uint64(m.Vote))
  134. n += 1 + sovState(uint64(m.Commit))
  135. n += 1 + sovState(uint64(m.LastIndex))
  136. if m.XXX_unrecognized != nil {
  137. n += len(m.XXX_unrecognized)
  138. }
  139. return n
  140. }
  141. func sovState(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 sozState(x uint64) (n int) {
  152. return sovState(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  153. }
  154. func (m *State) 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 *State) 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 = encodeVarintState(data, i, uint64(m.Term))
  171. data[i] = 0x10
  172. i++
  173. i = encodeVarintState(data, i, uint64(m.Vote))
  174. data[i] = 0x18
  175. i++
  176. i = encodeVarintState(data, i, uint64(m.Commit))
  177. data[i] = 0x20
  178. i++
  179. i = encodeVarintState(data, i, uint64(m.LastIndex))
  180. if m.XXX_unrecognized != nil {
  181. i += copy(data[i:], m.XXX_unrecognized)
  182. }
  183. return i, nil
  184. }
  185. func encodeFixed64State(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 encodeFixed32State(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 encodeVarintState(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. }