database.pb.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848
  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) || (iNdEx+skippy) < 0 {
  485. return ErrInvalidLengthDatabase
  486. }
  487. if (iNdEx + skippy) > l {
  488. return io.ErrUnexpectedEOF
  489. }
  490. iNdEx += skippy
  491. }
  492. }
  493. if iNdEx > l {
  494. return io.ErrUnexpectedEOF
  495. }
  496. return nil
  497. }
  498. func (m *ReplicationRecord) Unmarshal(dAtA []byte) error {
  499. l := len(dAtA)
  500. iNdEx := 0
  501. for iNdEx < l {
  502. preIndex := iNdEx
  503. var wire uint64
  504. for shift := uint(0); ; shift += 7 {
  505. if shift >= 64 {
  506. return ErrIntOverflowDatabase
  507. }
  508. if iNdEx >= l {
  509. return io.ErrUnexpectedEOF
  510. }
  511. b := dAtA[iNdEx]
  512. iNdEx++
  513. wire |= uint64(b&0x7F) << shift
  514. if b < 0x80 {
  515. break
  516. }
  517. }
  518. fieldNum := int32(wire >> 3)
  519. wireType := int(wire & 0x7)
  520. if wireType == 4 {
  521. return fmt.Errorf("proto: ReplicationRecord: wiretype end group for non-group")
  522. }
  523. if fieldNum <= 0 {
  524. return fmt.Errorf("proto: ReplicationRecord: illegal tag %d (wire type %d)", fieldNum, wire)
  525. }
  526. switch fieldNum {
  527. case 1:
  528. if wireType != 2 {
  529. return fmt.Errorf("proto: wrong wireType = %d for field Key", wireType)
  530. }
  531. var stringLen uint64
  532. for shift := uint(0); ; shift += 7 {
  533. if shift >= 64 {
  534. return ErrIntOverflowDatabase
  535. }
  536. if iNdEx >= l {
  537. return io.ErrUnexpectedEOF
  538. }
  539. b := dAtA[iNdEx]
  540. iNdEx++
  541. stringLen |= uint64(b&0x7F) << shift
  542. if b < 0x80 {
  543. break
  544. }
  545. }
  546. intStringLen := int(stringLen)
  547. if intStringLen < 0 {
  548. return ErrInvalidLengthDatabase
  549. }
  550. postIndex := iNdEx + intStringLen
  551. if postIndex < 0 {
  552. return ErrInvalidLengthDatabase
  553. }
  554. if postIndex > l {
  555. return io.ErrUnexpectedEOF
  556. }
  557. m.Key = string(dAtA[iNdEx:postIndex])
  558. iNdEx = postIndex
  559. case 2:
  560. if wireType != 2 {
  561. return fmt.Errorf("proto: wrong wireType = %d for field Addresses", wireType)
  562. }
  563. var msglen int
  564. for shift := uint(0); ; shift += 7 {
  565. if shift >= 64 {
  566. return ErrIntOverflowDatabase
  567. }
  568. if iNdEx >= l {
  569. return io.ErrUnexpectedEOF
  570. }
  571. b := dAtA[iNdEx]
  572. iNdEx++
  573. msglen |= int(b&0x7F) << shift
  574. if b < 0x80 {
  575. break
  576. }
  577. }
  578. if msglen < 0 {
  579. return ErrInvalidLengthDatabase
  580. }
  581. postIndex := iNdEx + msglen
  582. if postIndex < 0 {
  583. return ErrInvalidLengthDatabase
  584. }
  585. if postIndex > l {
  586. return io.ErrUnexpectedEOF
  587. }
  588. m.Addresses = append(m.Addresses, DatabaseAddress{})
  589. if err := m.Addresses[len(m.Addresses)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  590. return err
  591. }
  592. iNdEx = postIndex
  593. case 3:
  594. if wireType != 0 {
  595. return fmt.Errorf("proto: wrong wireType = %d for field Seen", wireType)
  596. }
  597. m.Seen = 0
  598. for shift := uint(0); ; shift += 7 {
  599. if shift >= 64 {
  600. return ErrIntOverflowDatabase
  601. }
  602. if iNdEx >= l {
  603. return io.ErrUnexpectedEOF
  604. }
  605. b := dAtA[iNdEx]
  606. iNdEx++
  607. m.Seen |= int64(b&0x7F) << shift
  608. if b < 0x80 {
  609. break
  610. }
  611. }
  612. default:
  613. iNdEx = preIndex
  614. skippy, err := skipDatabase(dAtA[iNdEx:])
  615. if err != nil {
  616. return err
  617. }
  618. if (skippy < 0) || (iNdEx+skippy) < 0 {
  619. return ErrInvalidLengthDatabase
  620. }
  621. if (iNdEx + skippy) > l {
  622. return io.ErrUnexpectedEOF
  623. }
  624. iNdEx += skippy
  625. }
  626. }
  627. if iNdEx > l {
  628. return io.ErrUnexpectedEOF
  629. }
  630. return nil
  631. }
  632. func (m *DatabaseAddress) Unmarshal(dAtA []byte) error {
  633. l := len(dAtA)
  634. iNdEx := 0
  635. for iNdEx < l {
  636. preIndex := iNdEx
  637. var wire uint64
  638. for shift := uint(0); ; shift += 7 {
  639. if shift >= 64 {
  640. return ErrIntOverflowDatabase
  641. }
  642. if iNdEx >= l {
  643. return io.ErrUnexpectedEOF
  644. }
  645. b := dAtA[iNdEx]
  646. iNdEx++
  647. wire |= uint64(b&0x7F) << shift
  648. if b < 0x80 {
  649. break
  650. }
  651. }
  652. fieldNum := int32(wire >> 3)
  653. wireType := int(wire & 0x7)
  654. if wireType == 4 {
  655. return fmt.Errorf("proto: DatabaseAddress: wiretype end group for non-group")
  656. }
  657. if fieldNum <= 0 {
  658. return fmt.Errorf("proto: DatabaseAddress: illegal tag %d (wire type %d)", fieldNum, wire)
  659. }
  660. switch fieldNum {
  661. case 1:
  662. if wireType != 2 {
  663. return fmt.Errorf("proto: wrong wireType = %d for field Address", wireType)
  664. }
  665. var stringLen uint64
  666. for shift := uint(0); ; shift += 7 {
  667. if shift >= 64 {
  668. return ErrIntOverflowDatabase
  669. }
  670. if iNdEx >= l {
  671. return io.ErrUnexpectedEOF
  672. }
  673. b := dAtA[iNdEx]
  674. iNdEx++
  675. stringLen |= uint64(b&0x7F) << shift
  676. if b < 0x80 {
  677. break
  678. }
  679. }
  680. intStringLen := int(stringLen)
  681. if intStringLen < 0 {
  682. return ErrInvalidLengthDatabase
  683. }
  684. postIndex := iNdEx + intStringLen
  685. if postIndex < 0 {
  686. return ErrInvalidLengthDatabase
  687. }
  688. if postIndex > l {
  689. return io.ErrUnexpectedEOF
  690. }
  691. m.Address = string(dAtA[iNdEx:postIndex])
  692. iNdEx = postIndex
  693. case 2:
  694. if wireType != 0 {
  695. return fmt.Errorf("proto: wrong wireType = %d for field Expires", wireType)
  696. }
  697. m.Expires = 0
  698. for shift := uint(0); ; shift += 7 {
  699. if shift >= 64 {
  700. return ErrIntOverflowDatabase
  701. }
  702. if iNdEx >= l {
  703. return io.ErrUnexpectedEOF
  704. }
  705. b := dAtA[iNdEx]
  706. iNdEx++
  707. m.Expires |= int64(b&0x7F) << shift
  708. if b < 0x80 {
  709. break
  710. }
  711. }
  712. default:
  713. iNdEx = preIndex
  714. skippy, err := skipDatabase(dAtA[iNdEx:])
  715. if err != nil {
  716. return err
  717. }
  718. if (skippy < 0) || (iNdEx+skippy) < 0 {
  719. return ErrInvalidLengthDatabase
  720. }
  721. if (iNdEx + skippy) > l {
  722. return io.ErrUnexpectedEOF
  723. }
  724. iNdEx += skippy
  725. }
  726. }
  727. if iNdEx > l {
  728. return io.ErrUnexpectedEOF
  729. }
  730. return nil
  731. }
  732. func skipDatabase(dAtA []byte) (n int, err error) {
  733. l := len(dAtA)
  734. iNdEx := 0
  735. depth := 0
  736. for iNdEx < l {
  737. var wire uint64
  738. for shift := uint(0); ; shift += 7 {
  739. if shift >= 64 {
  740. return 0, ErrIntOverflowDatabase
  741. }
  742. if iNdEx >= l {
  743. return 0, io.ErrUnexpectedEOF
  744. }
  745. b := dAtA[iNdEx]
  746. iNdEx++
  747. wire |= (uint64(b) & 0x7F) << shift
  748. if b < 0x80 {
  749. break
  750. }
  751. }
  752. wireType := int(wire & 0x7)
  753. switch wireType {
  754. case 0:
  755. for shift := uint(0); ; shift += 7 {
  756. if shift >= 64 {
  757. return 0, ErrIntOverflowDatabase
  758. }
  759. if iNdEx >= l {
  760. return 0, io.ErrUnexpectedEOF
  761. }
  762. iNdEx++
  763. if dAtA[iNdEx-1] < 0x80 {
  764. break
  765. }
  766. }
  767. case 1:
  768. iNdEx += 8
  769. case 2:
  770. var length int
  771. for shift := uint(0); ; shift += 7 {
  772. if shift >= 64 {
  773. return 0, ErrIntOverflowDatabase
  774. }
  775. if iNdEx >= l {
  776. return 0, io.ErrUnexpectedEOF
  777. }
  778. b := dAtA[iNdEx]
  779. iNdEx++
  780. length |= (int(b) & 0x7F) << shift
  781. if b < 0x80 {
  782. break
  783. }
  784. }
  785. if length < 0 {
  786. return 0, ErrInvalidLengthDatabase
  787. }
  788. iNdEx += length
  789. case 3:
  790. depth++
  791. case 4:
  792. if depth == 0 {
  793. return 0, ErrUnexpectedEndOfGroupDatabase
  794. }
  795. depth--
  796. case 5:
  797. iNdEx += 4
  798. default:
  799. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  800. }
  801. if iNdEx < 0 {
  802. return 0, ErrInvalidLengthDatabase
  803. }
  804. if depth == 0 {
  805. return iNdEx, nil
  806. }
  807. }
  808. return 0, io.ErrUnexpectedEOF
  809. }
  810. var (
  811. ErrInvalidLengthDatabase = fmt.Errorf("proto: negative length found during unmarshaling")
  812. ErrIntOverflowDatabase = fmt.Errorf("proto: integer overflow")
  813. ErrUnexpectedEndOfGroupDatabase = fmt.Errorf("proto: unexpected end of group")
  814. )