database.pb.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856
  1. // Code generated by protoc-gen-gogo. DO NOT EDIT.
  2. // source: database.proto
  3. package main
  4. import (
  5. fmt "fmt"
  6. _ "github.com/gogo/protobuf/gogoproto"
  7. proto "github.com/gogo/protobuf/proto"
  8. io "io"
  9. math "math"
  10. math_bits "math/bits"
  11. )
  12. // Reference imports to suppress errors if they are not otherwise used.
  13. var _ = proto.Marshal
  14. var _ = fmt.Errorf
  15. var _ = math.Inf
  16. // This is a compile-time assertion to ensure that this generated file
  17. // is compatible with the proto package it is being compiled against.
  18. // A compilation error at this line likely means your copy of the
  19. // proto package needs to be updated.
  20. const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
  21. type DatabaseRecord struct {
  22. Addresses []DatabaseAddress `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses"`
  23. Misses int32 `protobuf:"varint,2,opt,name=misses,proto3" json:"misses,omitempty"`
  24. Seen int64 `protobuf:"varint,3,opt,name=seen,proto3" json:"seen,omitempty"`
  25. Missed int64 `protobuf:"varint,4,opt,name=missed,proto3" json:"missed,omitempty"`
  26. }
  27. func (m *DatabaseRecord) Reset() { *m = DatabaseRecord{} }
  28. func (m *DatabaseRecord) String() string { return proto.CompactTextString(m) }
  29. func (*DatabaseRecord) ProtoMessage() {}
  30. func (*DatabaseRecord) Descriptor() ([]byte, []int) {
  31. return fileDescriptor_b90fe3356ea5df07, []int{0}
  32. }
  33. func (m *DatabaseRecord) XXX_Unmarshal(b []byte) error {
  34. return m.Unmarshal(b)
  35. }
  36. func (m *DatabaseRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  37. if deterministic {
  38. return xxx_messageInfo_DatabaseRecord.Marshal(b, m, deterministic)
  39. } else {
  40. b = b[:cap(b)]
  41. n, err := m.MarshalToSizedBuffer(b)
  42. if err != nil {
  43. return nil, err
  44. }
  45. return b[:n], nil
  46. }
  47. }
  48. func (m *DatabaseRecord) XXX_Merge(src proto.Message) {
  49. xxx_messageInfo_DatabaseRecord.Merge(m, src)
  50. }
  51. func (m *DatabaseRecord) XXX_Size() int {
  52. return m.Size()
  53. }
  54. func (m *DatabaseRecord) XXX_DiscardUnknown() {
  55. xxx_messageInfo_DatabaseRecord.DiscardUnknown(m)
  56. }
  57. var xxx_messageInfo_DatabaseRecord proto.InternalMessageInfo
  58. type ReplicationRecord struct {
  59. Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
  60. Addresses []DatabaseAddress `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses"`
  61. Seen int64 `protobuf:"varint,3,opt,name=seen,proto3" json:"seen,omitempty"`
  62. }
  63. func (m *ReplicationRecord) Reset() { *m = ReplicationRecord{} }
  64. func (m *ReplicationRecord) String() string { return proto.CompactTextString(m) }
  65. func (*ReplicationRecord) ProtoMessage() {}
  66. func (*ReplicationRecord) Descriptor() ([]byte, []int) {
  67. return fileDescriptor_b90fe3356ea5df07, []int{1}
  68. }
  69. func (m *ReplicationRecord) XXX_Unmarshal(b []byte) error {
  70. return m.Unmarshal(b)
  71. }
  72. func (m *ReplicationRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  73. if deterministic {
  74. return xxx_messageInfo_ReplicationRecord.Marshal(b, m, deterministic)
  75. } else {
  76. b = b[:cap(b)]
  77. n, err := m.MarshalToSizedBuffer(b)
  78. if err != nil {
  79. return nil, err
  80. }
  81. return b[:n], nil
  82. }
  83. }
  84. func (m *ReplicationRecord) XXX_Merge(src proto.Message) {
  85. xxx_messageInfo_ReplicationRecord.Merge(m, src)
  86. }
  87. func (m *ReplicationRecord) XXX_Size() int {
  88. return m.Size()
  89. }
  90. func (m *ReplicationRecord) XXX_DiscardUnknown() {
  91. xxx_messageInfo_ReplicationRecord.DiscardUnknown(m)
  92. }
  93. var xxx_messageInfo_ReplicationRecord proto.InternalMessageInfo
  94. type DatabaseAddress struct {
  95. Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
  96. Expires int64 `protobuf:"varint,2,opt,name=expires,proto3" json:"expires,omitempty"`
  97. }
  98. func (m *DatabaseAddress) Reset() { *m = DatabaseAddress{} }
  99. func (m *DatabaseAddress) String() string { return proto.CompactTextString(m) }
  100. func (*DatabaseAddress) ProtoMessage() {}
  101. func (*DatabaseAddress) Descriptor() ([]byte, []int) {
  102. return fileDescriptor_b90fe3356ea5df07, []int{2}
  103. }
  104. func (m *DatabaseAddress) XXX_Unmarshal(b []byte) error {
  105. return m.Unmarshal(b)
  106. }
  107. func (m *DatabaseAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  108. if deterministic {
  109. return xxx_messageInfo_DatabaseAddress.Marshal(b, m, deterministic)
  110. } else {
  111. b = b[:cap(b)]
  112. n, err := m.MarshalToSizedBuffer(b)
  113. if err != nil {
  114. return nil, err
  115. }
  116. return b[:n], nil
  117. }
  118. }
  119. func (m *DatabaseAddress) XXX_Merge(src proto.Message) {
  120. xxx_messageInfo_DatabaseAddress.Merge(m, src)
  121. }
  122. func (m *DatabaseAddress) XXX_Size() int {
  123. return m.Size()
  124. }
  125. func (m *DatabaseAddress) XXX_DiscardUnknown() {
  126. xxx_messageInfo_DatabaseAddress.DiscardUnknown(m)
  127. }
  128. var xxx_messageInfo_DatabaseAddress proto.InternalMessageInfo
  129. func init() {
  130. proto.RegisterType((*DatabaseRecord)(nil), "main.DatabaseRecord")
  131. proto.RegisterType((*ReplicationRecord)(nil), "main.ReplicationRecord")
  132. proto.RegisterType((*DatabaseAddress)(nil), "main.DatabaseAddress")
  133. }
  134. func init() { proto.RegisterFile("database.proto", fileDescriptor_b90fe3356ea5df07) }
  135. var fileDescriptor_b90fe3356ea5df07 = []byte{
  136. // 270 bytes of a gzipped FileDescriptorProto
  137. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x90, 0x41, 0x4a, 0xc4, 0x30,
  138. 0x18, 0x85, 0x9b, 0x49, 0x1d, 0x99, 0x08, 0xa3, 0x06, 0x94, 0x20, 0x12, 0x4b, 0xdd, 0x74, 0xd5,
  139. 0x01, 0x5d, 0xb9, 0x74, 0xd0, 0x0b, 0xe4, 0x06, 0xe9, 0xe4, 0x77, 0x08, 0x3a, 0x4d, 0x49, 0x2a,
  140. 0xe8, 0x29, 0xf4, 0x58, 0x5d, 0xce, 0xd2, 0x95, 0x68, 0x7b, 0x11, 0x69, 0x26, 0x55, 0x14, 0x37,
  141. 0xb3, 0x7b, 0xdf, 0xff, 0xbf, 0x97, 0xbc, 0x84, 0x4c, 0x95, 0xac, 0x65, 0x21, 0x1d, 0xe4, 0x95,
  142. 0x35, 0xb5, 0xa1, 0xf1, 0x4a, 0xea, 0xf2, 0xe4, 0xdc, 0x42, 0x65, 0xdc, 0xcc, 0x8f, 0x8a, 0xc7,
  143. 0xbb, 0xd9, 0xd2, 0x2c, 0x8d, 0x07, 0xaf, 0x36, 0xd6, 0xf4, 0x05, 0x91, 0xe9, 0x4d, 0x48, 0x0b,
  144. 0x58, 0x18, 0xab, 0xe8, 0x15, 0x99, 0x48, 0xa5, 0x2c, 0x38, 0x07, 0x8e, 0xa1, 0x04, 0x67, 0x7b,
  145. 0x17, 0x47, 0x79, 0x7f, 0x62, 0x3e, 0x18, 0xaf, 0x37, 0xeb, 0x79, 0xdc, 0xbc, 0x9f, 0x45, 0xe2,
  146. 0xc7, 0x4d, 0x8f, 0xc9, 0x78, 0xa5, 0x7d, 0x6e, 0x94, 0xa0, 0x6c, 0x47, 0x04, 0xa2, 0x94, 0xc4,
  147. 0x0e, 0xa0, 0x64, 0x38, 0x41, 0x19, 0x16, 0x5e, 0x7f, 0x7b, 0x15, 0x8b, 0xfd, 0x34, 0x50, 0x5a,
  148. 0x93, 0x43, 0x01, 0xd5, 0x83, 0x5e, 0xc8, 0x5a, 0x9b, 0x32, 0x74, 0x3a, 0x20, 0xf8, 0x1e, 0x9e,
  149. 0x19, 0x4a, 0x50, 0x36, 0x11, 0xbd, 0xfc, 0xdd, 0x72, 0xb4, 0x55, 0xcb, 0x7f, 0xda, 0xa4, 0xb7,
  150. 0x64, 0xff, 0x4f, 0x8e, 0x32, 0xb2, 0x1b, 0x32, 0xe1, 0xde, 0x01, 0xfb, 0x0d, 0x3c, 0x55, 0xda,
  151. 0x86, 0x77, 0x62, 0x31, 0xe0, 0xfc, 0xb4, 0xf9, 0xe4, 0x51, 0xd3, 0x72, 0xb4, 0x6e, 0x39, 0xfa,
  152. 0x68, 0x39, 0x7a, 0xed, 0x78, 0xb4, 0xee, 0x78, 0xf4, 0xd6, 0xf1, 0xa8, 0x18, 0xfb, 0x3f, 0xbf,
  153. 0xfc, 0x0a, 0x00, 0x00, 0xff, 0xff, 0x7a, 0xa2, 0xf6, 0x1e, 0xb0, 0x01, 0x00, 0x00,
  154. }
  155. func (m *DatabaseRecord) Marshal() (dAtA []byte, err error) {
  156. size := m.Size()
  157. dAtA = make([]byte, size)
  158. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  159. if err != nil {
  160. return nil, err
  161. }
  162. return dAtA[:n], nil
  163. }
  164. func (m *DatabaseRecord) MarshalTo(dAtA []byte) (int, error) {
  165. size := m.Size()
  166. return m.MarshalToSizedBuffer(dAtA[:size])
  167. }
  168. func (m *DatabaseRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  169. i := len(dAtA)
  170. _ = i
  171. var l int
  172. _ = l
  173. if m.Missed != 0 {
  174. i = encodeVarintDatabase(dAtA, i, uint64(m.Missed))
  175. i--
  176. dAtA[i] = 0x20
  177. }
  178. if m.Seen != 0 {
  179. i = encodeVarintDatabase(dAtA, i, uint64(m.Seen))
  180. i--
  181. dAtA[i] = 0x18
  182. }
  183. if m.Misses != 0 {
  184. i = encodeVarintDatabase(dAtA, i, uint64(m.Misses))
  185. i--
  186. dAtA[i] = 0x10
  187. }
  188. if len(m.Addresses) > 0 {
  189. for iNdEx := len(m.Addresses) - 1; iNdEx >= 0; iNdEx-- {
  190. {
  191. size, err := m.Addresses[iNdEx].MarshalToSizedBuffer(dAtA[:i])
  192. if err != nil {
  193. return 0, err
  194. }
  195. i -= size
  196. i = encodeVarintDatabase(dAtA, i, uint64(size))
  197. }
  198. i--
  199. dAtA[i] = 0xa
  200. }
  201. }
  202. return len(dAtA) - i, nil
  203. }
  204. func (m *ReplicationRecord) Marshal() (dAtA []byte, err error) {
  205. size := m.Size()
  206. dAtA = make([]byte, size)
  207. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  208. if err != nil {
  209. return nil, err
  210. }
  211. return dAtA[:n], nil
  212. }
  213. func (m *ReplicationRecord) MarshalTo(dAtA []byte) (int, error) {
  214. size := m.Size()
  215. return m.MarshalToSizedBuffer(dAtA[:size])
  216. }
  217. func (m *ReplicationRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  218. i := len(dAtA)
  219. _ = i
  220. var l int
  221. _ = l
  222. if m.Seen != 0 {
  223. i = encodeVarintDatabase(dAtA, i, uint64(m.Seen))
  224. i--
  225. dAtA[i] = 0x18
  226. }
  227. if len(m.Addresses) > 0 {
  228. for iNdEx := len(m.Addresses) - 1; iNdEx >= 0; iNdEx-- {
  229. {
  230. size, err := m.Addresses[iNdEx].MarshalToSizedBuffer(dAtA[:i])
  231. if err != nil {
  232. return 0, err
  233. }
  234. i -= size
  235. i = encodeVarintDatabase(dAtA, i, uint64(size))
  236. }
  237. i--
  238. dAtA[i] = 0x12
  239. }
  240. }
  241. if len(m.Key) > 0 {
  242. i -= len(m.Key)
  243. copy(dAtA[i:], m.Key)
  244. i = encodeVarintDatabase(dAtA, i, uint64(len(m.Key)))
  245. i--
  246. dAtA[i] = 0xa
  247. }
  248. return len(dAtA) - i, nil
  249. }
  250. func (m *DatabaseAddress) Marshal() (dAtA []byte, err error) {
  251. size := m.Size()
  252. dAtA = make([]byte, size)
  253. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  254. if err != nil {
  255. return nil, err
  256. }
  257. return dAtA[:n], nil
  258. }
  259. func (m *DatabaseAddress) MarshalTo(dAtA []byte) (int, error) {
  260. size := m.Size()
  261. return m.MarshalToSizedBuffer(dAtA[:size])
  262. }
  263. func (m *DatabaseAddress) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  264. i := len(dAtA)
  265. _ = i
  266. var l int
  267. _ = l
  268. if m.Expires != 0 {
  269. i = encodeVarintDatabase(dAtA, i, uint64(m.Expires))
  270. i--
  271. dAtA[i] = 0x10
  272. }
  273. if len(m.Address) > 0 {
  274. i -= len(m.Address)
  275. copy(dAtA[i:], m.Address)
  276. i = encodeVarintDatabase(dAtA, i, uint64(len(m.Address)))
  277. i--
  278. dAtA[i] = 0xa
  279. }
  280. return len(dAtA) - i, nil
  281. }
  282. func encodeVarintDatabase(dAtA []byte, offset int, v uint64) int {
  283. offset -= sovDatabase(v)
  284. base := offset
  285. for v >= 1<<7 {
  286. dAtA[offset] = uint8(v&0x7f | 0x80)
  287. v >>= 7
  288. offset++
  289. }
  290. dAtA[offset] = uint8(v)
  291. return base
  292. }
  293. func (m *DatabaseRecord) Size() (n int) {
  294. if m == nil {
  295. return 0
  296. }
  297. var l int
  298. _ = l
  299. if len(m.Addresses) > 0 {
  300. for _, e := range m.Addresses {
  301. l = e.Size()
  302. n += 1 + l + sovDatabase(uint64(l))
  303. }
  304. }
  305. if m.Misses != 0 {
  306. n += 1 + sovDatabase(uint64(m.Misses))
  307. }
  308. if m.Seen != 0 {
  309. n += 1 + sovDatabase(uint64(m.Seen))
  310. }
  311. if m.Missed != 0 {
  312. n += 1 + sovDatabase(uint64(m.Missed))
  313. }
  314. return n
  315. }
  316. func (m *ReplicationRecord) Size() (n int) {
  317. if m == nil {
  318. return 0
  319. }
  320. var l int
  321. _ = l
  322. l = len(m.Key)
  323. if l > 0 {
  324. n += 1 + l + sovDatabase(uint64(l))
  325. }
  326. if len(m.Addresses) > 0 {
  327. for _, e := range m.Addresses {
  328. l = e.Size()
  329. n += 1 + l + sovDatabase(uint64(l))
  330. }
  331. }
  332. if m.Seen != 0 {
  333. n += 1 + sovDatabase(uint64(m.Seen))
  334. }
  335. return n
  336. }
  337. func (m *DatabaseAddress) Size() (n int) {
  338. if m == nil {
  339. return 0
  340. }
  341. var l int
  342. _ = l
  343. l = len(m.Address)
  344. if l > 0 {
  345. n += 1 + l + sovDatabase(uint64(l))
  346. }
  347. if m.Expires != 0 {
  348. n += 1 + sovDatabase(uint64(m.Expires))
  349. }
  350. return n
  351. }
  352. func sovDatabase(x uint64) (n int) {
  353. return (math_bits.Len64(x|1) + 6) / 7
  354. }
  355. func sozDatabase(x uint64) (n int) {
  356. return sovDatabase(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  357. }
  358. func (m *DatabaseRecord) Unmarshal(dAtA []byte) error {
  359. l := len(dAtA)
  360. iNdEx := 0
  361. for iNdEx < l {
  362. preIndex := iNdEx
  363. var wire uint64
  364. for shift := uint(0); ; shift += 7 {
  365. if shift >= 64 {
  366. return ErrIntOverflowDatabase
  367. }
  368. if iNdEx >= l {
  369. return io.ErrUnexpectedEOF
  370. }
  371. b := dAtA[iNdEx]
  372. iNdEx++
  373. wire |= uint64(b&0x7F) << shift
  374. if b < 0x80 {
  375. break
  376. }
  377. }
  378. fieldNum := int32(wire >> 3)
  379. wireType := int(wire & 0x7)
  380. if wireType == 4 {
  381. return fmt.Errorf("proto: DatabaseRecord: wiretype end group for non-group")
  382. }
  383. if fieldNum <= 0 {
  384. return fmt.Errorf("proto: DatabaseRecord: illegal tag %d (wire type %d)", fieldNum, wire)
  385. }
  386. switch fieldNum {
  387. case 1:
  388. if wireType != 2 {
  389. return fmt.Errorf("proto: wrong wireType = %d for field Addresses", wireType)
  390. }
  391. var msglen int
  392. for shift := uint(0); ; shift += 7 {
  393. if shift >= 64 {
  394. return ErrIntOverflowDatabase
  395. }
  396. if iNdEx >= l {
  397. return io.ErrUnexpectedEOF
  398. }
  399. b := dAtA[iNdEx]
  400. iNdEx++
  401. msglen |= int(b&0x7F) << shift
  402. if b < 0x80 {
  403. break
  404. }
  405. }
  406. if msglen < 0 {
  407. return ErrInvalidLengthDatabase
  408. }
  409. postIndex := iNdEx + msglen
  410. if postIndex < 0 {
  411. return ErrInvalidLengthDatabase
  412. }
  413. if postIndex > l {
  414. return io.ErrUnexpectedEOF
  415. }
  416. m.Addresses = append(m.Addresses, DatabaseAddress{})
  417. if err := m.Addresses[len(m.Addresses)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  418. return err
  419. }
  420. iNdEx = postIndex
  421. case 2:
  422. if wireType != 0 {
  423. return fmt.Errorf("proto: wrong wireType = %d for field Misses", wireType)
  424. }
  425. m.Misses = 0
  426. for shift := uint(0); ; shift += 7 {
  427. if shift >= 64 {
  428. return ErrIntOverflowDatabase
  429. }
  430. if iNdEx >= l {
  431. return io.ErrUnexpectedEOF
  432. }
  433. b := dAtA[iNdEx]
  434. iNdEx++
  435. m.Misses |= int32(b&0x7F) << shift
  436. if b < 0x80 {
  437. break
  438. }
  439. }
  440. case 3:
  441. if wireType != 0 {
  442. return fmt.Errorf("proto: wrong wireType = %d for field Seen", wireType)
  443. }
  444. m.Seen = 0
  445. for shift := uint(0); ; shift += 7 {
  446. if shift >= 64 {
  447. return ErrIntOverflowDatabase
  448. }
  449. if iNdEx >= l {
  450. return io.ErrUnexpectedEOF
  451. }
  452. b := dAtA[iNdEx]
  453. iNdEx++
  454. m.Seen |= int64(b&0x7F) << shift
  455. if b < 0x80 {
  456. break
  457. }
  458. }
  459. case 4:
  460. if wireType != 0 {
  461. return fmt.Errorf("proto: wrong wireType = %d for field Missed", wireType)
  462. }
  463. m.Missed = 0
  464. for shift := uint(0); ; shift += 7 {
  465. if shift >= 64 {
  466. return ErrIntOverflowDatabase
  467. }
  468. if iNdEx >= l {
  469. return io.ErrUnexpectedEOF
  470. }
  471. b := dAtA[iNdEx]
  472. iNdEx++
  473. m.Missed |= int64(b&0x7F) << shift
  474. if b < 0x80 {
  475. break
  476. }
  477. }
  478. default:
  479. iNdEx = preIndex
  480. skippy, err := skipDatabase(dAtA[iNdEx:])
  481. if err != nil {
  482. return err
  483. }
  484. if skippy < 0 {
  485. return ErrInvalidLengthDatabase
  486. }
  487. if (iNdEx + skippy) < 0 {
  488. return ErrInvalidLengthDatabase
  489. }
  490. if (iNdEx + skippy) > l {
  491. return io.ErrUnexpectedEOF
  492. }
  493. iNdEx += skippy
  494. }
  495. }
  496. if iNdEx > l {
  497. return io.ErrUnexpectedEOF
  498. }
  499. return nil
  500. }
  501. func (m *ReplicationRecord) Unmarshal(dAtA []byte) error {
  502. l := len(dAtA)
  503. iNdEx := 0
  504. for iNdEx < l {
  505. preIndex := iNdEx
  506. var wire uint64
  507. for shift := uint(0); ; shift += 7 {
  508. if shift >= 64 {
  509. return ErrIntOverflowDatabase
  510. }
  511. if iNdEx >= l {
  512. return io.ErrUnexpectedEOF
  513. }
  514. b := dAtA[iNdEx]
  515. iNdEx++
  516. wire |= uint64(b&0x7F) << shift
  517. if b < 0x80 {
  518. break
  519. }
  520. }
  521. fieldNum := int32(wire >> 3)
  522. wireType := int(wire & 0x7)
  523. if wireType == 4 {
  524. return fmt.Errorf("proto: ReplicationRecord: wiretype end group for non-group")
  525. }
  526. if fieldNum <= 0 {
  527. return fmt.Errorf("proto: ReplicationRecord: illegal tag %d (wire type %d)", fieldNum, wire)
  528. }
  529. switch fieldNum {
  530. case 1:
  531. if wireType != 2 {
  532. return fmt.Errorf("proto: wrong wireType = %d for field Key", wireType)
  533. }
  534. var stringLen uint64
  535. for shift := uint(0); ; shift += 7 {
  536. if shift >= 64 {
  537. return ErrIntOverflowDatabase
  538. }
  539. if iNdEx >= l {
  540. return io.ErrUnexpectedEOF
  541. }
  542. b := dAtA[iNdEx]
  543. iNdEx++
  544. stringLen |= uint64(b&0x7F) << shift
  545. if b < 0x80 {
  546. break
  547. }
  548. }
  549. intStringLen := int(stringLen)
  550. if intStringLen < 0 {
  551. return ErrInvalidLengthDatabase
  552. }
  553. postIndex := iNdEx + intStringLen
  554. if postIndex < 0 {
  555. return ErrInvalidLengthDatabase
  556. }
  557. if postIndex > l {
  558. return io.ErrUnexpectedEOF
  559. }
  560. m.Key = string(dAtA[iNdEx:postIndex])
  561. iNdEx = postIndex
  562. case 2:
  563. if wireType != 2 {
  564. return fmt.Errorf("proto: wrong wireType = %d for field Addresses", wireType)
  565. }
  566. var msglen int
  567. for shift := uint(0); ; shift += 7 {
  568. if shift >= 64 {
  569. return ErrIntOverflowDatabase
  570. }
  571. if iNdEx >= l {
  572. return io.ErrUnexpectedEOF
  573. }
  574. b := dAtA[iNdEx]
  575. iNdEx++
  576. msglen |= int(b&0x7F) << shift
  577. if b < 0x80 {
  578. break
  579. }
  580. }
  581. if msglen < 0 {
  582. return ErrInvalidLengthDatabase
  583. }
  584. postIndex := iNdEx + msglen
  585. if postIndex < 0 {
  586. return ErrInvalidLengthDatabase
  587. }
  588. if postIndex > l {
  589. return io.ErrUnexpectedEOF
  590. }
  591. m.Addresses = append(m.Addresses, DatabaseAddress{})
  592. if err := m.Addresses[len(m.Addresses)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  593. return err
  594. }
  595. iNdEx = postIndex
  596. case 3:
  597. if wireType != 0 {
  598. return fmt.Errorf("proto: wrong wireType = %d for field Seen", wireType)
  599. }
  600. m.Seen = 0
  601. for shift := uint(0); ; shift += 7 {
  602. if shift >= 64 {
  603. return ErrIntOverflowDatabase
  604. }
  605. if iNdEx >= l {
  606. return io.ErrUnexpectedEOF
  607. }
  608. b := dAtA[iNdEx]
  609. iNdEx++
  610. m.Seen |= int64(b&0x7F) << shift
  611. if b < 0x80 {
  612. break
  613. }
  614. }
  615. default:
  616. iNdEx = preIndex
  617. skippy, err := skipDatabase(dAtA[iNdEx:])
  618. if err != nil {
  619. return err
  620. }
  621. if skippy < 0 {
  622. return ErrInvalidLengthDatabase
  623. }
  624. if (iNdEx + skippy) < 0 {
  625. return ErrInvalidLengthDatabase
  626. }
  627. if (iNdEx + skippy) > l {
  628. return io.ErrUnexpectedEOF
  629. }
  630. iNdEx += skippy
  631. }
  632. }
  633. if iNdEx > l {
  634. return io.ErrUnexpectedEOF
  635. }
  636. return nil
  637. }
  638. func (m *DatabaseAddress) Unmarshal(dAtA []byte) error {
  639. l := len(dAtA)
  640. iNdEx := 0
  641. for iNdEx < l {
  642. preIndex := iNdEx
  643. var wire uint64
  644. for shift := uint(0); ; shift += 7 {
  645. if shift >= 64 {
  646. return ErrIntOverflowDatabase
  647. }
  648. if iNdEx >= l {
  649. return io.ErrUnexpectedEOF
  650. }
  651. b := dAtA[iNdEx]
  652. iNdEx++
  653. wire |= uint64(b&0x7F) << shift
  654. if b < 0x80 {
  655. break
  656. }
  657. }
  658. fieldNum := int32(wire >> 3)
  659. wireType := int(wire & 0x7)
  660. if wireType == 4 {
  661. return fmt.Errorf("proto: DatabaseAddress: wiretype end group for non-group")
  662. }
  663. if fieldNum <= 0 {
  664. return fmt.Errorf("proto: DatabaseAddress: illegal tag %d (wire type %d)", fieldNum, wire)
  665. }
  666. switch fieldNum {
  667. case 1:
  668. if wireType != 2 {
  669. return fmt.Errorf("proto: wrong wireType = %d for field Address", wireType)
  670. }
  671. var stringLen uint64
  672. for shift := uint(0); ; shift += 7 {
  673. if shift >= 64 {
  674. return ErrIntOverflowDatabase
  675. }
  676. if iNdEx >= l {
  677. return io.ErrUnexpectedEOF
  678. }
  679. b := dAtA[iNdEx]
  680. iNdEx++
  681. stringLen |= uint64(b&0x7F) << shift
  682. if b < 0x80 {
  683. break
  684. }
  685. }
  686. intStringLen := int(stringLen)
  687. if intStringLen < 0 {
  688. return ErrInvalidLengthDatabase
  689. }
  690. postIndex := iNdEx + intStringLen
  691. if postIndex < 0 {
  692. return ErrInvalidLengthDatabase
  693. }
  694. if postIndex > l {
  695. return io.ErrUnexpectedEOF
  696. }
  697. m.Address = string(dAtA[iNdEx:postIndex])
  698. iNdEx = postIndex
  699. case 2:
  700. if wireType != 0 {
  701. return fmt.Errorf("proto: wrong wireType = %d for field Expires", wireType)
  702. }
  703. m.Expires = 0
  704. for shift := uint(0); ; shift += 7 {
  705. if shift >= 64 {
  706. return ErrIntOverflowDatabase
  707. }
  708. if iNdEx >= l {
  709. return io.ErrUnexpectedEOF
  710. }
  711. b := dAtA[iNdEx]
  712. iNdEx++
  713. m.Expires |= int64(b&0x7F) << shift
  714. if b < 0x80 {
  715. break
  716. }
  717. }
  718. default:
  719. iNdEx = preIndex
  720. skippy, err := skipDatabase(dAtA[iNdEx:])
  721. if err != nil {
  722. return err
  723. }
  724. if skippy < 0 {
  725. return ErrInvalidLengthDatabase
  726. }
  727. if (iNdEx + skippy) < 0 {
  728. return ErrInvalidLengthDatabase
  729. }
  730. if (iNdEx + skippy) > l {
  731. return io.ErrUnexpectedEOF
  732. }
  733. iNdEx += skippy
  734. }
  735. }
  736. if iNdEx > l {
  737. return io.ErrUnexpectedEOF
  738. }
  739. return nil
  740. }
  741. func skipDatabase(dAtA []byte) (n int, err error) {
  742. l := len(dAtA)
  743. iNdEx := 0
  744. depth := 0
  745. for iNdEx < l {
  746. var wire uint64
  747. for shift := uint(0); ; shift += 7 {
  748. if shift >= 64 {
  749. return 0, ErrIntOverflowDatabase
  750. }
  751. if iNdEx >= l {
  752. return 0, io.ErrUnexpectedEOF
  753. }
  754. b := dAtA[iNdEx]
  755. iNdEx++
  756. wire |= (uint64(b) & 0x7F) << shift
  757. if b < 0x80 {
  758. break
  759. }
  760. }
  761. wireType := int(wire & 0x7)
  762. switch wireType {
  763. case 0:
  764. for shift := uint(0); ; shift += 7 {
  765. if shift >= 64 {
  766. return 0, ErrIntOverflowDatabase
  767. }
  768. if iNdEx >= l {
  769. return 0, io.ErrUnexpectedEOF
  770. }
  771. iNdEx++
  772. if dAtA[iNdEx-1] < 0x80 {
  773. break
  774. }
  775. }
  776. case 1:
  777. iNdEx += 8
  778. case 2:
  779. var length int
  780. for shift := uint(0); ; shift += 7 {
  781. if shift >= 64 {
  782. return 0, ErrIntOverflowDatabase
  783. }
  784. if iNdEx >= l {
  785. return 0, io.ErrUnexpectedEOF
  786. }
  787. b := dAtA[iNdEx]
  788. iNdEx++
  789. length |= (int(b) & 0x7F) << shift
  790. if b < 0x80 {
  791. break
  792. }
  793. }
  794. if length < 0 {
  795. return 0, ErrInvalidLengthDatabase
  796. }
  797. iNdEx += length
  798. case 3:
  799. depth++
  800. case 4:
  801. if depth == 0 {
  802. return 0, ErrUnexpectedEndOfGroupDatabase
  803. }
  804. depth--
  805. case 5:
  806. iNdEx += 4
  807. default:
  808. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  809. }
  810. if iNdEx < 0 {
  811. return 0, ErrInvalidLengthDatabase
  812. }
  813. if depth == 0 {
  814. return iNdEx, nil
  815. }
  816. }
  817. return 0, io.ErrUnexpectedEOF
  818. }
  819. var (
  820. ErrInvalidLengthDatabase = fmt.Errorf("proto: negative length found during unmarshaling")
  821. ErrIntOverflowDatabase = fmt.Errorf("proto: integer overflow")
  822. ErrUnexpectedEndOfGroupDatabase = fmt.Errorf("proto: unexpected end of group")
  823. )