state.pb.go 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210
  1. // Code generated by protoc-gen-gogo.
  2. // source: state.proto
  3. // DO NOT EDIT!
  4. /*
  5. Package raft is a generated protocol buffer package.
  6. It is generated from these files:
  7. state.proto
  8. It has these top-level messages:
  9. State
  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 State struct {
  23. Term int64 `protobuf:"varint,1,req,name=term" json:"term"`
  24. Vote int64 `protobuf:"varint,2,req,name=vote" json:"vote"`
  25. Commit int64 `protobuf:"varint,3,req,name=commit" json:"commit"`
  26. XXX_unrecognized []byte `json:"-"`
  27. }
  28. func (m *State) Reset() { *m = State{} }
  29. func (m *State) String() string { return proto.CompactTextString(m) }
  30. func (*State) ProtoMessage() {}
  31. func init() {
  32. }
  33. func (m *State) 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.Term |= (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.Vote |= (int64(b) & 0x7F) << shift
  78. if b < 0x80 {
  79. break
  80. }
  81. }
  82. case 3:
  83. if wireType != 0 {
  84. return code_google_com_p_gogoprotobuf_proto.ErrWrongType
  85. }
  86. for shift := uint(0); ; shift += 7 {
  87. if index >= l {
  88. return io.ErrUnexpectedEOF
  89. }
  90. b := data[index]
  91. index++
  92. m.Commit |= (int64(b) & 0x7F) << shift
  93. if b < 0x80 {
  94. break
  95. }
  96. }
  97. default:
  98. var sizeOfWire int
  99. for {
  100. sizeOfWire++
  101. wire >>= 7
  102. if wire == 0 {
  103. break
  104. }
  105. }
  106. index -= sizeOfWire
  107. skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
  108. if err != nil {
  109. return err
  110. }
  111. if (index + skippy) > l {
  112. return io.ErrUnexpectedEOF
  113. }
  114. m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
  115. index += skippy
  116. }
  117. }
  118. return nil
  119. }
  120. func (m *State) Size() (n int) {
  121. var l int
  122. _ = l
  123. n += 1 + sovState(uint64(m.Term))
  124. n += 1 + sovState(uint64(m.Vote))
  125. n += 1 + sovState(uint64(m.Commit))
  126. if m.XXX_unrecognized != nil {
  127. n += len(m.XXX_unrecognized)
  128. }
  129. return n
  130. }
  131. func sovState(x uint64) (n int) {
  132. for {
  133. n++
  134. x >>= 7
  135. if x == 0 {
  136. break
  137. }
  138. }
  139. return n
  140. }
  141. func sozState(x uint64) (n int) {
  142. return sovState(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  143. }
  144. func (m *State) Marshal() (data []byte, err error) {
  145. size := m.Size()
  146. data = make([]byte, size)
  147. n, err := m.MarshalTo(data)
  148. if err != nil {
  149. return nil, err
  150. }
  151. return data[:n], nil
  152. }
  153. func (m *State) MarshalTo(data []byte) (n int, err error) {
  154. var i int
  155. _ = i
  156. var l int
  157. _ = l
  158. data[i] = 0x8
  159. i++
  160. i = encodeVarintState(data, i, uint64(m.Term))
  161. data[i] = 0x10
  162. i++
  163. i = encodeVarintState(data, i, uint64(m.Vote))
  164. data[i] = 0x18
  165. i++
  166. i = encodeVarintState(data, i, uint64(m.Commit))
  167. if m.XXX_unrecognized != nil {
  168. i += copy(data[i:], m.XXX_unrecognized)
  169. }
  170. return i, nil
  171. }
  172. func encodeFixed64State(data []byte, offset int, v uint64) int {
  173. data[offset] = uint8(v)
  174. data[offset+1] = uint8(v >> 8)
  175. data[offset+2] = uint8(v >> 16)
  176. data[offset+3] = uint8(v >> 24)
  177. data[offset+4] = uint8(v >> 32)
  178. data[offset+5] = uint8(v >> 40)
  179. data[offset+6] = uint8(v >> 48)
  180. data[offset+7] = uint8(v >> 56)
  181. return offset + 8
  182. }
  183. func encodeFixed32State(data []byte, offset int, v uint32) int {
  184. data[offset] = uint8(v)
  185. data[offset+1] = uint8(v >> 8)
  186. data[offset+2] = uint8(v >> 16)
  187. data[offset+3] = uint8(v >> 24)
  188. return offset + 4
  189. }
  190. func encodeVarintState(data []byte, offset int, v uint64) int {
  191. for v >= 1<<7 {
  192. data[offset] = uint8(v&0x7f | 0x80)
  193. v >>= 7
  194. offset++
  195. }
  196. data[offset] = uint8(v)
  197. return offset + 1
  198. }