database.pb.go 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793
  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. Seen int64 `protobuf:"varint,3,opt,name=seen,proto3" json:"seen,omitempty"`
  24. }
  25. func (m *DatabaseRecord) Reset() { *m = DatabaseRecord{} }
  26. func (m *DatabaseRecord) String() string { return proto.CompactTextString(m) }
  27. func (*DatabaseRecord) ProtoMessage() {}
  28. func (*DatabaseRecord) Descriptor() ([]byte, []int) {
  29. return fileDescriptor_b90fe3356ea5df07, []int{0}
  30. }
  31. func (m *DatabaseRecord) XXX_Unmarshal(b []byte) error {
  32. return m.Unmarshal(b)
  33. }
  34. func (m *DatabaseRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  35. if deterministic {
  36. return xxx_messageInfo_DatabaseRecord.Marshal(b, m, deterministic)
  37. } else {
  38. b = b[:cap(b)]
  39. n, err := m.MarshalToSizedBuffer(b)
  40. if err != nil {
  41. return nil, err
  42. }
  43. return b[:n], nil
  44. }
  45. }
  46. func (m *DatabaseRecord) XXX_Merge(src proto.Message) {
  47. xxx_messageInfo_DatabaseRecord.Merge(m, src)
  48. }
  49. func (m *DatabaseRecord) XXX_Size() int {
  50. return m.Size()
  51. }
  52. func (m *DatabaseRecord) XXX_DiscardUnknown() {
  53. xxx_messageInfo_DatabaseRecord.DiscardUnknown(m)
  54. }
  55. var xxx_messageInfo_DatabaseRecord proto.InternalMessageInfo
  56. type ReplicationRecord struct {
  57. Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
  58. Addresses []DatabaseAddress `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses"`
  59. Seen int64 `protobuf:"varint,3,opt,name=seen,proto3" json:"seen,omitempty"`
  60. }
  61. func (m *ReplicationRecord) Reset() { *m = ReplicationRecord{} }
  62. func (m *ReplicationRecord) String() string { return proto.CompactTextString(m) }
  63. func (*ReplicationRecord) ProtoMessage() {}
  64. func (*ReplicationRecord) Descriptor() ([]byte, []int) {
  65. return fileDescriptor_b90fe3356ea5df07, []int{1}
  66. }
  67. func (m *ReplicationRecord) XXX_Unmarshal(b []byte) error {
  68. return m.Unmarshal(b)
  69. }
  70. func (m *ReplicationRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  71. if deterministic {
  72. return xxx_messageInfo_ReplicationRecord.Marshal(b, m, deterministic)
  73. } else {
  74. b = b[:cap(b)]
  75. n, err := m.MarshalToSizedBuffer(b)
  76. if err != nil {
  77. return nil, err
  78. }
  79. return b[:n], nil
  80. }
  81. }
  82. func (m *ReplicationRecord) XXX_Merge(src proto.Message) {
  83. xxx_messageInfo_ReplicationRecord.Merge(m, src)
  84. }
  85. func (m *ReplicationRecord) XXX_Size() int {
  86. return m.Size()
  87. }
  88. func (m *ReplicationRecord) XXX_DiscardUnknown() {
  89. xxx_messageInfo_ReplicationRecord.DiscardUnknown(m)
  90. }
  91. var xxx_messageInfo_ReplicationRecord proto.InternalMessageInfo
  92. type DatabaseAddress struct {
  93. Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
  94. Expires int64 `protobuf:"varint,2,opt,name=expires,proto3" json:"expires,omitempty"`
  95. }
  96. func (m *DatabaseAddress) Reset() { *m = DatabaseAddress{} }
  97. func (m *DatabaseAddress) String() string { return proto.CompactTextString(m) }
  98. func (*DatabaseAddress) ProtoMessage() {}
  99. func (*DatabaseAddress) Descriptor() ([]byte, []int) {
  100. return fileDescriptor_b90fe3356ea5df07, []int{2}
  101. }
  102. func (m *DatabaseAddress) XXX_Unmarshal(b []byte) error {
  103. return m.Unmarshal(b)
  104. }
  105. func (m *DatabaseAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  106. if deterministic {
  107. return xxx_messageInfo_DatabaseAddress.Marshal(b, m, deterministic)
  108. } else {
  109. b = b[:cap(b)]
  110. n, err := m.MarshalToSizedBuffer(b)
  111. if err != nil {
  112. return nil, err
  113. }
  114. return b[:n], nil
  115. }
  116. }
  117. func (m *DatabaseAddress) XXX_Merge(src proto.Message) {
  118. xxx_messageInfo_DatabaseAddress.Merge(m, src)
  119. }
  120. func (m *DatabaseAddress) XXX_Size() int {
  121. return m.Size()
  122. }
  123. func (m *DatabaseAddress) XXX_DiscardUnknown() {
  124. xxx_messageInfo_DatabaseAddress.DiscardUnknown(m)
  125. }
  126. var xxx_messageInfo_DatabaseAddress proto.InternalMessageInfo
  127. func init() {
  128. proto.RegisterType((*DatabaseRecord)(nil), "main.DatabaseRecord")
  129. proto.RegisterType((*ReplicationRecord)(nil), "main.ReplicationRecord")
  130. proto.RegisterType((*DatabaseAddress)(nil), "main.DatabaseAddress")
  131. }
  132. func init() { proto.RegisterFile("database.proto", fileDescriptor_b90fe3356ea5df07) }
  133. var fileDescriptor_b90fe3356ea5df07 = []byte{
  134. // 243 bytes of a gzipped FileDescriptorProto
  135. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0x4b, 0x49, 0x2c, 0x49,
  136. 0x4c, 0x4a, 0x2c, 0x4e, 0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0xc9, 0x4d, 0xcc, 0xcc,
  137. 0x93, 0x52, 0x2e, 0x4a, 0x2d, 0xc8, 0x2f, 0xd6, 0x07, 0x0b, 0x25, 0x95, 0xa6, 0xe9, 0xa7, 0xe7,
  138. 0xa7, 0xe7, 0x83, 0x39, 0x60, 0x16, 0x44, 0xa9, 0x52, 0x3c, 0x17, 0x9f, 0x0b, 0x54, 0x73, 0x50,
  139. 0x6a, 0x72, 0x7e, 0x51, 0x8a, 0x90, 0x25, 0x17, 0x67, 0x62, 0x4a, 0x4a, 0x51, 0x6a, 0x71, 0x71,
  140. 0x6a, 0xb1, 0x04, 0xa3, 0x02, 0xb3, 0x06, 0xb7, 0x91, 0xa8, 0x1e, 0xc8, 0x40, 0x3d, 0x98, 0x42,
  141. 0x47, 0x88, 0xb4, 0x13, 0xcb, 0x89, 0x7b, 0xf2, 0x0c, 0x41, 0x08, 0xd5, 0x42, 0x42, 0x5c, 0x2c,
  142. 0xc5, 0xa9, 0xa9, 0x79, 0x12, 0xcc, 0x0a, 0x8c, 0x1a, 0xcc, 0x41, 0x60, 0xb6, 0x52, 0x09, 0x97,
  143. 0x60, 0x50, 0x6a, 0x41, 0x4e, 0x66, 0x72, 0x62, 0x49, 0x66, 0x7e, 0x1e, 0xd4, 0x0e, 0x01, 0x2e,
  144. 0xe6, 0xec, 0xd4, 0x4a, 0x09, 0x46, 0x05, 0x46, 0x0d, 0x9e, 0x20, 0x10, 0x13, 0xd5, 0x56, 0x26,
  145. 0x8a, 0x6d, 0x75, 0xe5, 0xe2, 0x47, 0xd3, 0x27, 0x24, 0xc1, 0xc5, 0x0e, 0xd5, 0x03, 0xb6, 0x97,
  146. 0x33, 0x08, 0xc6, 0x05, 0xc9, 0xa4, 0x56, 0x14, 0x64, 0x16, 0x81, 0x6d, 0x06, 0x99, 0x01, 0xe3,
  147. 0x3a, 0xc9, 0x9c, 0x78, 0x28, 0xc7, 0x70, 0xe2, 0x91, 0x1c, 0xe3, 0x85, 0x47, 0x72, 0x8c, 0x0f,
  148. 0x1e, 0xc9, 0x31, 0x4e, 0x78, 0x2c, 0xc7, 0x70, 0xe1, 0xb1, 0x1c, 0xc3, 0x8d, 0xc7, 0x72, 0x0c,
  149. 0x49, 0x6c, 0xe0, 0x20, 0x34, 0x06, 0x04, 0x00, 0x00, 0xff, 0xff, 0xc6, 0x0b, 0x9b, 0x77, 0x7f,
  150. 0x01, 0x00, 0x00,
  151. }
  152. func (m *DatabaseRecord) Marshal() (dAtA []byte, err error) {
  153. size := m.Size()
  154. dAtA = make([]byte, size)
  155. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  156. if err != nil {
  157. return nil, err
  158. }
  159. return dAtA[:n], nil
  160. }
  161. func (m *DatabaseRecord) MarshalTo(dAtA []byte) (int, error) {
  162. size := m.Size()
  163. return m.MarshalToSizedBuffer(dAtA[:size])
  164. }
  165. func (m *DatabaseRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  166. i := len(dAtA)
  167. _ = i
  168. var l int
  169. _ = l
  170. if m.Seen != 0 {
  171. i = encodeVarintDatabase(dAtA, i, uint64(m.Seen))
  172. i--
  173. dAtA[i] = 0x18
  174. }
  175. if len(m.Addresses) > 0 {
  176. for iNdEx := len(m.Addresses) - 1; iNdEx >= 0; iNdEx-- {
  177. {
  178. size, err := m.Addresses[iNdEx].MarshalToSizedBuffer(dAtA[:i])
  179. if err != nil {
  180. return 0, err
  181. }
  182. i -= size
  183. i = encodeVarintDatabase(dAtA, i, uint64(size))
  184. }
  185. i--
  186. dAtA[i] = 0xa
  187. }
  188. }
  189. return len(dAtA) - i, nil
  190. }
  191. func (m *ReplicationRecord) Marshal() (dAtA []byte, err error) {
  192. size := m.Size()
  193. dAtA = make([]byte, size)
  194. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  195. if err != nil {
  196. return nil, err
  197. }
  198. return dAtA[:n], nil
  199. }
  200. func (m *ReplicationRecord) MarshalTo(dAtA []byte) (int, error) {
  201. size := m.Size()
  202. return m.MarshalToSizedBuffer(dAtA[:size])
  203. }
  204. func (m *ReplicationRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  205. i := len(dAtA)
  206. _ = i
  207. var l int
  208. _ = l
  209. if m.Seen != 0 {
  210. i = encodeVarintDatabase(dAtA, i, uint64(m.Seen))
  211. i--
  212. dAtA[i] = 0x18
  213. }
  214. if len(m.Addresses) > 0 {
  215. for iNdEx := len(m.Addresses) - 1; iNdEx >= 0; iNdEx-- {
  216. {
  217. size, err := m.Addresses[iNdEx].MarshalToSizedBuffer(dAtA[:i])
  218. if err != nil {
  219. return 0, err
  220. }
  221. i -= size
  222. i = encodeVarintDatabase(dAtA, i, uint64(size))
  223. }
  224. i--
  225. dAtA[i] = 0x12
  226. }
  227. }
  228. if len(m.Key) > 0 {
  229. i -= len(m.Key)
  230. copy(dAtA[i:], m.Key)
  231. i = encodeVarintDatabase(dAtA, i, uint64(len(m.Key)))
  232. i--
  233. dAtA[i] = 0xa
  234. }
  235. return len(dAtA) - i, nil
  236. }
  237. func (m *DatabaseAddress) Marshal() (dAtA []byte, err error) {
  238. size := m.Size()
  239. dAtA = make([]byte, size)
  240. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  241. if err != nil {
  242. return nil, err
  243. }
  244. return dAtA[:n], nil
  245. }
  246. func (m *DatabaseAddress) MarshalTo(dAtA []byte) (int, error) {
  247. size := m.Size()
  248. return m.MarshalToSizedBuffer(dAtA[:size])
  249. }
  250. func (m *DatabaseAddress) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  251. i := len(dAtA)
  252. _ = i
  253. var l int
  254. _ = l
  255. if m.Expires != 0 {
  256. i = encodeVarintDatabase(dAtA, i, uint64(m.Expires))
  257. i--
  258. dAtA[i] = 0x10
  259. }
  260. if len(m.Address) > 0 {
  261. i -= len(m.Address)
  262. copy(dAtA[i:], m.Address)
  263. i = encodeVarintDatabase(dAtA, i, uint64(len(m.Address)))
  264. i--
  265. dAtA[i] = 0xa
  266. }
  267. return len(dAtA) - i, nil
  268. }
  269. func encodeVarintDatabase(dAtA []byte, offset int, v uint64) int {
  270. offset -= sovDatabase(v)
  271. base := offset
  272. for v >= 1<<7 {
  273. dAtA[offset] = uint8(v&0x7f | 0x80)
  274. v >>= 7
  275. offset++
  276. }
  277. dAtA[offset] = uint8(v)
  278. return base
  279. }
  280. func (m *DatabaseRecord) Size() (n int) {
  281. if m == nil {
  282. return 0
  283. }
  284. var l int
  285. _ = l
  286. if len(m.Addresses) > 0 {
  287. for _, e := range m.Addresses {
  288. l = e.Size()
  289. n += 1 + l + sovDatabase(uint64(l))
  290. }
  291. }
  292. if m.Seen != 0 {
  293. n += 1 + sovDatabase(uint64(m.Seen))
  294. }
  295. return n
  296. }
  297. func (m *ReplicationRecord) Size() (n int) {
  298. if m == nil {
  299. return 0
  300. }
  301. var l int
  302. _ = l
  303. l = len(m.Key)
  304. if l > 0 {
  305. n += 1 + l + sovDatabase(uint64(l))
  306. }
  307. if len(m.Addresses) > 0 {
  308. for _, e := range m.Addresses {
  309. l = e.Size()
  310. n += 1 + l + sovDatabase(uint64(l))
  311. }
  312. }
  313. if m.Seen != 0 {
  314. n += 1 + sovDatabase(uint64(m.Seen))
  315. }
  316. return n
  317. }
  318. func (m *DatabaseAddress) Size() (n int) {
  319. if m == nil {
  320. return 0
  321. }
  322. var l int
  323. _ = l
  324. l = len(m.Address)
  325. if l > 0 {
  326. n += 1 + l + sovDatabase(uint64(l))
  327. }
  328. if m.Expires != 0 {
  329. n += 1 + sovDatabase(uint64(m.Expires))
  330. }
  331. return n
  332. }
  333. func sovDatabase(x uint64) (n int) {
  334. return (math_bits.Len64(x|1) + 6) / 7
  335. }
  336. func sozDatabase(x uint64) (n int) {
  337. return sovDatabase(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  338. }
  339. func (m *DatabaseRecord) Unmarshal(dAtA []byte) error {
  340. l := len(dAtA)
  341. iNdEx := 0
  342. for iNdEx < l {
  343. preIndex := iNdEx
  344. var wire uint64
  345. for shift := uint(0); ; shift += 7 {
  346. if shift >= 64 {
  347. return ErrIntOverflowDatabase
  348. }
  349. if iNdEx >= l {
  350. return io.ErrUnexpectedEOF
  351. }
  352. b := dAtA[iNdEx]
  353. iNdEx++
  354. wire |= uint64(b&0x7F) << shift
  355. if b < 0x80 {
  356. break
  357. }
  358. }
  359. fieldNum := int32(wire >> 3)
  360. wireType := int(wire & 0x7)
  361. if wireType == 4 {
  362. return fmt.Errorf("proto: DatabaseRecord: wiretype end group for non-group")
  363. }
  364. if fieldNum <= 0 {
  365. return fmt.Errorf("proto: DatabaseRecord: illegal tag %d (wire type %d)", fieldNum, wire)
  366. }
  367. switch fieldNum {
  368. case 1:
  369. if wireType != 2 {
  370. return fmt.Errorf("proto: wrong wireType = %d for field Addresses", wireType)
  371. }
  372. var msglen int
  373. for shift := uint(0); ; shift += 7 {
  374. if shift >= 64 {
  375. return ErrIntOverflowDatabase
  376. }
  377. if iNdEx >= l {
  378. return io.ErrUnexpectedEOF
  379. }
  380. b := dAtA[iNdEx]
  381. iNdEx++
  382. msglen |= int(b&0x7F) << shift
  383. if b < 0x80 {
  384. break
  385. }
  386. }
  387. if msglen < 0 {
  388. return ErrInvalidLengthDatabase
  389. }
  390. postIndex := iNdEx + msglen
  391. if postIndex < 0 {
  392. return ErrInvalidLengthDatabase
  393. }
  394. if postIndex > l {
  395. return io.ErrUnexpectedEOF
  396. }
  397. m.Addresses = append(m.Addresses, DatabaseAddress{})
  398. if err := m.Addresses[len(m.Addresses)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  399. return err
  400. }
  401. iNdEx = postIndex
  402. case 3:
  403. if wireType != 0 {
  404. return fmt.Errorf("proto: wrong wireType = %d for field Seen", wireType)
  405. }
  406. m.Seen = 0
  407. for shift := uint(0); ; shift += 7 {
  408. if shift >= 64 {
  409. return ErrIntOverflowDatabase
  410. }
  411. if iNdEx >= l {
  412. return io.ErrUnexpectedEOF
  413. }
  414. b := dAtA[iNdEx]
  415. iNdEx++
  416. m.Seen |= int64(b&0x7F) << shift
  417. if b < 0x80 {
  418. break
  419. }
  420. }
  421. default:
  422. iNdEx = preIndex
  423. skippy, err := skipDatabase(dAtA[iNdEx:])
  424. if err != nil {
  425. return err
  426. }
  427. if (skippy < 0) || (iNdEx+skippy) < 0 {
  428. return ErrInvalidLengthDatabase
  429. }
  430. if (iNdEx + skippy) > l {
  431. return io.ErrUnexpectedEOF
  432. }
  433. iNdEx += skippy
  434. }
  435. }
  436. if iNdEx > l {
  437. return io.ErrUnexpectedEOF
  438. }
  439. return nil
  440. }
  441. func (m *ReplicationRecord) Unmarshal(dAtA []byte) error {
  442. l := len(dAtA)
  443. iNdEx := 0
  444. for iNdEx < l {
  445. preIndex := iNdEx
  446. var wire uint64
  447. for shift := uint(0); ; shift += 7 {
  448. if shift >= 64 {
  449. return ErrIntOverflowDatabase
  450. }
  451. if iNdEx >= l {
  452. return io.ErrUnexpectedEOF
  453. }
  454. b := dAtA[iNdEx]
  455. iNdEx++
  456. wire |= uint64(b&0x7F) << shift
  457. if b < 0x80 {
  458. break
  459. }
  460. }
  461. fieldNum := int32(wire >> 3)
  462. wireType := int(wire & 0x7)
  463. if wireType == 4 {
  464. return fmt.Errorf("proto: ReplicationRecord: wiretype end group for non-group")
  465. }
  466. if fieldNum <= 0 {
  467. return fmt.Errorf("proto: ReplicationRecord: illegal tag %d (wire type %d)", fieldNum, wire)
  468. }
  469. switch fieldNum {
  470. case 1:
  471. if wireType != 2 {
  472. return fmt.Errorf("proto: wrong wireType = %d for field Key", wireType)
  473. }
  474. var byteLen int
  475. for shift := uint(0); ; shift += 7 {
  476. if shift >= 64 {
  477. return ErrIntOverflowDatabase
  478. }
  479. if iNdEx >= l {
  480. return io.ErrUnexpectedEOF
  481. }
  482. b := dAtA[iNdEx]
  483. iNdEx++
  484. byteLen |= int(b&0x7F) << shift
  485. if b < 0x80 {
  486. break
  487. }
  488. }
  489. if byteLen < 0 {
  490. return ErrInvalidLengthDatabase
  491. }
  492. postIndex := iNdEx + byteLen
  493. if postIndex < 0 {
  494. return ErrInvalidLengthDatabase
  495. }
  496. if postIndex > l {
  497. return io.ErrUnexpectedEOF
  498. }
  499. m.Key = append(m.Key[:0], dAtA[iNdEx:postIndex]...)
  500. if m.Key == nil {
  501. m.Key = []byte{}
  502. }
  503. iNdEx = postIndex
  504. case 2:
  505. if wireType != 2 {
  506. return fmt.Errorf("proto: wrong wireType = %d for field Addresses", wireType)
  507. }
  508. var msglen int
  509. for shift := uint(0); ; shift += 7 {
  510. if shift >= 64 {
  511. return ErrIntOverflowDatabase
  512. }
  513. if iNdEx >= l {
  514. return io.ErrUnexpectedEOF
  515. }
  516. b := dAtA[iNdEx]
  517. iNdEx++
  518. msglen |= int(b&0x7F) << shift
  519. if b < 0x80 {
  520. break
  521. }
  522. }
  523. if msglen < 0 {
  524. return ErrInvalidLengthDatabase
  525. }
  526. postIndex := iNdEx + msglen
  527. if postIndex < 0 {
  528. return ErrInvalidLengthDatabase
  529. }
  530. if postIndex > l {
  531. return io.ErrUnexpectedEOF
  532. }
  533. m.Addresses = append(m.Addresses, DatabaseAddress{})
  534. if err := m.Addresses[len(m.Addresses)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  535. return err
  536. }
  537. iNdEx = postIndex
  538. case 3:
  539. if wireType != 0 {
  540. return fmt.Errorf("proto: wrong wireType = %d for field Seen", wireType)
  541. }
  542. m.Seen = 0
  543. for shift := uint(0); ; shift += 7 {
  544. if shift >= 64 {
  545. return ErrIntOverflowDatabase
  546. }
  547. if iNdEx >= l {
  548. return io.ErrUnexpectedEOF
  549. }
  550. b := dAtA[iNdEx]
  551. iNdEx++
  552. m.Seen |= int64(b&0x7F) << shift
  553. if b < 0x80 {
  554. break
  555. }
  556. }
  557. default:
  558. iNdEx = preIndex
  559. skippy, err := skipDatabase(dAtA[iNdEx:])
  560. if err != nil {
  561. return err
  562. }
  563. if (skippy < 0) || (iNdEx+skippy) < 0 {
  564. return ErrInvalidLengthDatabase
  565. }
  566. if (iNdEx + skippy) > l {
  567. return io.ErrUnexpectedEOF
  568. }
  569. iNdEx += skippy
  570. }
  571. }
  572. if iNdEx > l {
  573. return io.ErrUnexpectedEOF
  574. }
  575. return nil
  576. }
  577. func (m *DatabaseAddress) Unmarshal(dAtA []byte) error {
  578. l := len(dAtA)
  579. iNdEx := 0
  580. for iNdEx < l {
  581. preIndex := iNdEx
  582. var wire uint64
  583. for shift := uint(0); ; shift += 7 {
  584. if shift >= 64 {
  585. return ErrIntOverflowDatabase
  586. }
  587. if iNdEx >= l {
  588. return io.ErrUnexpectedEOF
  589. }
  590. b := dAtA[iNdEx]
  591. iNdEx++
  592. wire |= uint64(b&0x7F) << shift
  593. if b < 0x80 {
  594. break
  595. }
  596. }
  597. fieldNum := int32(wire >> 3)
  598. wireType := int(wire & 0x7)
  599. if wireType == 4 {
  600. return fmt.Errorf("proto: DatabaseAddress: wiretype end group for non-group")
  601. }
  602. if fieldNum <= 0 {
  603. return fmt.Errorf("proto: DatabaseAddress: illegal tag %d (wire type %d)", fieldNum, wire)
  604. }
  605. switch fieldNum {
  606. case 1:
  607. if wireType != 2 {
  608. return fmt.Errorf("proto: wrong wireType = %d for field Address", wireType)
  609. }
  610. var stringLen uint64
  611. for shift := uint(0); ; shift += 7 {
  612. if shift >= 64 {
  613. return ErrIntOverflowDatabase
  614. }
  615. if iNdEx >= l {
  616. return io.ErrUnexpectedEOF
  617. }
  618. b := dAtA[iNdEx]
  619. iNdEx++
  620. stringLen |= uint64(b&0x7F) << shift
  621. if b < 0x80 {
  622. break
  623. }
  624. }
  625. intStringLen := int(stringLen)
  626. if intStringLen < 0 {
  627. return ErrInvalidLengthDatabase
  628. }
  629. postIndex := iNdEx + intStringLen
  630. if postIndex < 0 {
  631. return ErrInvalidLengthDatabase
  632. }
  633. if postIndex > l {
  634. return io.ErrUnexpectedEOF
  635. }
  636. m.Address = string(dAtA[iNdEx:postIndex])
  637. iNdEx = postIndex
  638. case 2:
  639. if wireType != 0 {
  640. return fmt.Errorf("proto: wrong wireType = %d for field Expires", wireType)
  641. }
  642. m.Expires = 0
  643. for shift := uint(0); ; shift += 7 {
  644. if shift >= 64 {
  645. return ErrIntOverflowDatabase
  646. }
  647. if iNdEx >= l {
  648. return io.ErrUnexpectedEOF
  649. }
  650. b := dAtA[iNdEx]
  651. iNdEx++
  652. m.Expires |= int64(b&0x7F) << shift
  653. if b < 0x80 {
  654. break
  655. }
  656. }
  657. default:
  658. iNdEx = preIndex
  659. skippy, err := skipDatabase(dAtA[iNdEx:])
  660. if err != nil {
  661. return err
  662. }
  663. if (skippy < 0) || (iNdEx+skippy) < 0 {
  664. return ErrInvalidLengthDatabase
  665. }
  666. if (iNdEx + skippy) > l {
  667. return io.ErrUnexpectedEOF
  668. }
  669. iNdEx += skippy
  670. }
  671. }
  672. if iNdEx > l {
  673. return io.ErrUnexpectedEOF
  674. }
  675. return nil
  676. }
  677. func skipDatabase(dAtA []byte) (n int, err error) {
  678. l := len(dAtA)
  679. iNdEx := 0
  680. depth := 0
  681. for iNdEx < l {
  682. var wire uint64
  683. for shift := uint(0); ; shift += 7 {
  684. if shift >= 64 {
  685. return 0, ErrIntOverflowDatabase
  686. }
  687. if iNdEx >= l {
  688. return 0, io.ErrUnexpectedEOF
  689. }
  690. b := dAtA[iNdEx]
  691. iNdEx++
  692. wire |= (uint64(b) & 0x7F) << shift
  693. if b < 0x80 {
  694. break
  695. }
  696. }
  697. wireType := int(wire & 0x7)
  698. switch wireType {
  699. case 0:
  700. for shift := uint(0); ; shift += 7 {
  701. if shift >= 64 {
  702. return 0, ErrIntOverflowDatabase
  703. }
  704. if iNdEx >= l {
  705. return 0, io.ErrUnexpectedEOF
  706. }
  707. iNdEx++
  708. if dAtA[iNdEx-1] < 0x80 {
  709. break
  710. }
  711. }
  712. case 1:
  713. iNdEx += 8
  714. case 2:
  715. var length int
  716. for shift := uint(0); ; shift += 7 {
  717. if shift >= 64 {
  718. return 0, ErrIntOverflowDatabase
  719. }
  720. if iNdEx >= l {
  721. return 0, io.ErrUnexpectedEOF
  722. }
  723. b := dAtA[iNdEx]
  724. iNdEx++
  725. length |= (int(b) & 0x7F) << shift
  726. if b < 0x80 {
  727. break
  728. }
  729. }
  730. if length < 0 {
  731. return 0, ErrInvalidLengthDatabase
  732. }
  733. iNdEx += length
  734. case 3:
  735. depth++
  736. case 4:
  737. if depth == 0 {
  738. return 0, ErrUnexpectedEndOfGroupDatabase
  739. }
  740. depth--
  741. case 5:
  742. iNdEx += 4
  743. default:
  744. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  745. }
  746. if iNdEx < 0 {
  747. return 0, ErrInvalidLengthDatabase
  748. }
  749. if depth == 0 {
  750. return iNdEx, nil
  751. }
  752. }
  753. return 0, io.ErrUnexpectedEOF
  754. }
  755. var (
  756. ErrInvalidLengthDatabase = fmt.Errorf("proto: negative length found during unmarshaling")
  757. ErrIntOverflowDatabase = fmt.Errorf("proto: integer overflow")
  758. ErrUnexpectedEndOfGroupDatabase = fmt.Errorf("proto: unexpected end of group")
  759. )