networkdb.pb.go 66 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554
  1. // Code generated by protoc-gen-gogo.
  2. // source: networkdb.proto
  3. // DO NOT EDIT!
  4. /*
  5. Package networkdb is a generated protocol buffer package.
  6. It is generated from these files:
  7. networkdb.proto
  8. It has these top-level messages:
  9. GossipMessage
  10. NodeEvent
  11. NetworkEvent
  12. NetworkEntry
  13. NetworkPushPull
  14. TableEvent
  15. BulkSyncMessage
  16. CompoundMessage
  17. */
  18. package networkdb
  19. import proto "github.com/gogo/protobuf/proto"
  20. import fmt "fmt"
  21. import math "math"
  22. import _ "github.com/gogo/protobuf/gogoproto"
  23. import github_com_hashicorp_serf_serf "github.com/hashicorp/serf/serf"
  24. import strings "strings"
  25. import github_com_gogo_protobuf_proto "github.com/gogo/protobuf/proto"
  26. import sort "sort"
  27. import strconv "strconv"
  28. import reflect "reflect"
  29. import io "io"
  30. // Reference imports to suppress errors if they are not otherwise used.
  31. var _ = proto.Marshal
  32. var _ = fmt.Errorf
  33. var _ = math.Inf
  34. // This is a compile-time assertion to ensure that this generated file
  35. // is compatible with the proto package it is being compiled against.
  36. const _ = proto.GoGoProtoPackageIsVersion1
  37. // MessageType enum defines all the core message types that networkdb
  38. // uses to communicate to peers.
  39. type MessageType int32
  40. const (
  41. MessageTypeInvalid MessageType = 0
  42. // NetworEvent message type is used to communicate network
  43. // attachments on the node.
  44. MessageTypeNetworkEvent MessageType = 1
  45. // TableEvent message type is used to communicate any table
  46. // CRUD event that happened on the node.
  47. MessageTypeTableEvent MessageType = 2
  48. // PushPull message type is used to syncup all network
  49. // attachments on a peer node either during startup of this
  50. // node or with a random peer node periodically thereafter.
  51. MessageTypePushPull MessageType = 3
  52. // BulkSync message is used to bulksync the whole networkdb
  53. // state with a peer node during startup of this node or with
  54. // a random peer node periodically thereafter.
  55. MessageTypeBulkSync MessageType = 4
  56. // Compound message type is used to form a compound message
  57. // which is a pack of many message of above types, packed into
  58. // a single compound message.
  59. MessageTypeCompound MessageType = 5
  60. // NodeEvent message type is used to communicare node
  61. // join/leave events in the cluster
  62. MessageTypeNodeEvent MessageType = 6
  63. )
  64. var MessageType_name = map[int32]string{
  65. 0: "INVALID",
  66. 1: "NETWORK_EVENT",
  67. 2: "TABLE_EVENT",
  68. 3: "PUSH_PULL",
  69. 4: "BULK_SYNC",
  70. 5: "COMPOUND",
  71. 6: "NODE_EVENT",
  72. }
  73. var MessageType_value = map[string]int32{
  74. "INVALID": 0,
  75. "NETWORK_EVENT": 1,
  76. "TABLE_EVENT": 2,
  77. "PUSH_PULL": 3,
  78. "BULK_SYNC": 4,
  79. "COMPOUND": 5,
  80. "NODE_EVENT": 6,
  81. }
  82. func (x MessageType) String() string {
  83. return proto.EnumName(MessageType_name, int32(x))
  84. }
  85. func (MessageType) EnumDescriptor() ([]byte, []int) { return fileDescriptorNetworkdb, []int{0} }
  86. type NodeEvent_Type int32
  87. const (
  88. NodeEventTypeInvalid NodeEvent_Type = 0
  89. // Join event is generated when this node joins the cluster.
  90. NodeEventTypeJoin NodeEvent_Type = 1
  91. // Leave event is generated when this node leaves the cluster.
  92. NodeEventTypeLeave NodeEvent_Type = 2
  93. )
  94. var NodeEvent_Type_name = map[int32]string{
  95. 0: "INVALID",
  96. 1: "JOIN",
  97. 2: "LEAVE",
  98. }
  99. var NodeEvent_Type_value = map[string]int32{
  100. "INVALID": 0,
  101. "JOIN": 1,
  102. "LEAVE": 2,
  103. }
  104. func (x NodeEvent_Type) String() string {
  105. return proto.EnumName(NodeEvent_Type_name, int32(x))
  106. }
  107. func (NodeEvent_Type) EnumDescriptor() ([]byte, []int) { return fileDescriptorNetworkdb, []int{1, 0} }
  108. type NetworkEvent_Type int32
  109. const (
  110. NetworkEventTypeInvalid NetworkEvent_Type = 0
  111. // Join event is generated when this node joins a network.
  112. NetworkEventTypeJoin NetworkEvent_Type = 1
  113. // Leave event is generated when this node leaves a network.
  114. NetworkEventTypeLeave NetworkEvent_Type = 2
  115. )
  116. var NetworkEvent_Type_name = map[int32]string{
  117. 0: "INVALID",
  118. 1: "JOIN",
  119. 2: "LEAVE",
  120. }
  121. var NetworkEvent_Type_value = map[string]int32{
  122. "INVALID": 0,
  123. "JOIN": 1,
  124. "LEAVE": 2,
  125. }
  126. func (x NetworkEvent_Type) String() string {
  127. return proto.EnumName(NetworkEvent_Type_name, int32(x))
  128. }
  129. func (NetworkEvent_Type) EnumDescriptor() ([]byte, []int) { return fileDescriptorNetworkdb, []int{2, 0} }
  130. type TableEvent_Type int32
  131. const (
  132. TableEventTypeInvalid TableEvent_Type = 0
  133. // Create signifies that this table entry was just
  134. // created.
  135. TableEventTypeCreate TableEvent_Type = 1
  136. // Update signifies that this table entry was just
  137. // updated.
  138. TableEventTypeUpdate TableEvent_Type = 2
  139. // Delete signifies that this table entry was just
  140. // updated.
  141. TableEventTypeDelete TableEvent_Type = 3
  142. )
  143. var TableEvent_Type_name = map[int32]string{
  144. 0: "INVALID",
  145. 1: "CREATE",
  146. 2: "UPDATE",
  147. 3: "DELETE",
  148. }
  149. var TableEvent_Type_value = map[string]int32{
  150. "INVALID": 0,
  151. "CREATE": 1,
  152. "UPDATE": 2,
  153. "DELETE": 3,
  154. }
  155. func (x TableEvent_Type) String() string {
  156. return proto.EnumName(TableEvent_Type_name, int32(x))
  157. }
  158. func (TableEvent_Type) EnumDescriptor() ([]byte, []int) { return fileDescriptorNetworkdb, []int{5, 0} }
  159. // GossipMessage is a basic message header used by all messages types.
  160. type GossipMessage struct {
  161. Type MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=networkdb.MessageType" json:"type,omitempty"`
  162. Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
  163. }
  164. func (m *GossipMessage) Reset() { *m = GossipMessage{} }
  165. func (*GossipMessage) ProtoMessage() {}
  166. func (*GossipMessage) Descriptor() ([]byte, []int) { return fileDescriptorNetworkdb, []int{0} }
  167. // NodeEvent message payload definition.
  168. type NodeEvent struct {
  169. Type NodeEvent_Type `protobuf:"varint,1,opt,name=type,proto3,enum=networkdb.NodeEvent_Type" json:"type,omitempty"`
  170. // Lamport time using a network lamport clock indicating the
  171. // time this event was generated on the node where it was
  172. // generated.
  173. LTime github_com_hashicorp_serf_serf.LamportTime `protobuf:"varint,2,opt,name=l_time,json=lTime,proto3,customtype=github.com/hashicorp/serf/serf.LamportTime" json:"l_time"`
  174. // Source node name.
  175. NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
  176. }
  177. func (m *NodeEvent) Reset() { *m = NodeEvent{} }
  178. func (*NodeEvent) ProtoMessage() {}
  179. func (*NodeEvent) Descriptor() ([]byte, []int) { return fileDescriptorNetworkdb, []int{1} }
  180. // NetworkEvent message payload definition.
  181. type NetworkEvent struct {
  182. Type NetworkEvent_Type `protobuf:"varint,1,opt,name=type,proto3,enum=networkdb.NetworkEvent_Type" json:"type,omitempty"`
  183. // Lamport time using a network lamport clock indicating the
  184. // time this event was generated on the node where it was
  185. // generated.
  186. LTime github_com_hashicorp_serf_serf.LamportTime `protobuf:"varint,2,opt,name=l_time,json=lTime,proto3,customtype=github.com/hashicorp/serf/serf.LamportTime" json:"l_time"`
  187. // Source node name.
  188. NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
  189. // ID of the network for which the event is generated.
  190. NetworkID string `protobuf:"bytes,4,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
  191. }
  192. func (m *NetworkEvent) Reset() { *m = NetworkEvent{} }
  193. func (*NetworkEvent) ProtoMessage() {}
  194. func (*NetworkEvent) Descriptor() ([]byte, []int) { return fileDescriptorNetworkdb, []int{2} }
  195. // NetworkEntry for push pull of networks.
  196. type NetworkEntry struct {
  197. // ID of the network
  198. NetworkID string `protobuf:"bytes,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
  199. // Latest lamport time of the network attachment when this
  200. // network event was recorded.
  201. LTime github_com_hashicorp_serf_serf.LamportTime `protobuf:"varint,2,opt,name=l_time,json=lTime,proto3,customtype=github.com/hashicorp/serf/serf.LamportTime" json:"l_time"`
  202. // Source node name where this network attachment happened.
  203. NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
  204. // Indicates if a leave from this network is in progress.
  205. Leaving bool `protobuf:"varint,4,opt,name=leaving,proto3" json:"leaving,omitempty"`
  206. }
  207. func (m *NetworkEntry) Reset() { *m = NetworkEntry{} }
  208. func (*NetworkEntry) ProtoMessage() {}
  209. func (*NetworkEntry) Descriptor() ([]byte, []int) { return fileDescriptorNetworkdb, []int{3} }
  210. // NetworkPushpull message payload definition.
  211. type NetworkPushPull struct {
  212. // Lamport time when this push pull was initiated.
  213. LTime github_com_hashicorp_serf_serf.LamportTime `protobuf:"varint,1,opt,name=l_time,json=lTime,proto3,customtype=github.com/hashicorp/serf/serf.LamportTime" json:"l_time"`
  214. Networks []*NetworkEntry `protobuf:"bytes,2,rep,name=networks" json:"networks,omitempty"`
  215. // Name of the node sending this push pull payload.
  216. NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
  217. }
  218. func (m *NetworkPushPull) Reset() { *m = NetworkPushPull{} }
  219. func (*NetworkPushPull) ProtoMessage() {}
  220. func (*NetworkPushPull) Descriptor() ([]byte, []int) { return fileDescriptorNetworkdb, []int{4} }
  221. func (m *NetworkPushPull) GetNetworks() []*NetworkEntry {
  222. if m != nil {
  223. return m.Networks
  224. }
  225. return nil
  226. }
  227. // TableEvent message payload definition.
  228. type TableEvent struct {
  229. Type TableEvent_Type `protobuf:"varint,1,opt,name=type,proto3,enum=networkdb.TableEvent_Type" json:"type,omitempty"`
  230. // Lamport time when this event was generated.
  231. LTime github_com_hashicorp_serf_serf.LamportTime `protobuf:"varint,2,opt,name=l_time,json=lTime,proto3,customtype=github.com/hashicorp/serf/serf.LamportTime" json:"l_time"`
  232. // Node name where this event originated.
  233. NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
  234. // ID of the network to which this table entry belongs.
  235. NetworkID string `protobuf:"bytes,4,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
  236. // Name of the table to which this table entry belongs.
  237. TableName string `protobuf:"bytes,5,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
  238. // Entry key.
  239. Key string `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
  240. // Entry value.
  241. Value []byte `protobuf:"bytes,7,opt,name=value,proto3" json:"value,omitempty"`
  242. }
  243. func (m *TableEvent) Reset() { *m = TableEvent{} }
  244. func (*TableEvent) ProtoMessage() {}
  245. func (*TableEvent) Descriptor() ([]byte, []int) { return fileDescriptorNetworkdb, []int{5} }
  246. // BulkSync message payload definition.
  247. type BulkSyncMessage struct {
  248. // Lamport time when this bulk sync was initiated.
  249. LTime github_com_hashicorp_serf_serf.LamportTime `protobuf:"varint,1,opt,name=l_time,json=lTime,proto3,customtype=github.com/hashicorp/serf/serf.LamportTime" json:"l_time"`
  250. // Indicates if this bulksync is a response to a bulk sync
  251. // request from a peer node.
  252. Unsolicited bool `protobuf:"varint,2,opt,name=unsolicited,proto3" json:"unsolicited,omitempty"`
  253. // Name of the node which is producing this bulk sync message.
  254. NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
  255. // List of network names whose table entries are getting
  256. // bulksynced as part of the bulksync.
  257. Networks []string `protobuf:"bytes,4,rep,name=networks" json:"networks,omitempty"`
  258. // Bulksync payload
  259. Payload []byte `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
  260. }
  261. func (m *BulkSyncMessage) Reset() { *m = BulkSyncMessage{} }
  262. func (*BulkSyncMessage) ProtoMessage() {}
  263. func (*BulkSyncMessage) Descriptor() ([]byte, []int) { return fileDescriptorNetworkdb, []int{6} }
  264. // Compound message payload definition.
  265. type CompoundMessage struct {
  266. // A list of simple messages.
  267. Messages []*CompoundMessage_SimpleMessage `protobuf:"bytes,1,rep,name=messages" json:"messages,omitempty"`
  268. }
  269. func (m *CompoundMessage) Reset() { *m = CompoundMessage{} }
  270. func (*CompoundMessage) ProtoMessage() {}
  271. func (*CompoundMessage) Descriptor() ([]byte, []int) { return fileDescriptorNetworkdb, []int{7} }
  272. func (m *CompoundMessage) GetMessages() []*CompoundMessage_SimpleMessage {
  273. if m != nil {
  274. return m.Messages
  275. }
  276. return nil
  277. }
  278. type CompoundMessage_SimpleMessage struct {
  279. // Bytestring payload of a message constructed using
  280. // other message type definitions.
  281. Payload []byte `protobuf:"bytes,1,opt,name=Payload,json=payload,proto3" json:"Payload,omitempty"`
  282. }
  283. func (m *CompoundMessage_SimpleMessage) Reset() { *m = CompoundMessage_SimpleMessage{} }
  284. func (*CompoundMessage_SimpleMessage) ProtoMessage() {}
  285. func (*CompoundMessage_SimpleMessage) Descriptor() ([]byte, []int) {
  286. return fileDescriptorNetworkdb, []int{7, 0}
  287. }
  288. func init() {
  289. proto.RegisterType((*GossipMessage)(nil), "networkdb.GossipMessage")
  290. proto.RegisterType((*NodeEvent)(nil), "networkdb.NodeEvent")
  291. proto.RegisterType((*NetworkEvent)(nil), "networkdb.NetworkEvent")
  292. proto.RegisterType((*NetworkEntry)(nil), "networkdb.NetworkEntry")
  293. proto.RegisterType((*NetworkPushPull)(nil), "networkdb.NetworkPushPull")
  294. proto.RegisterType((*TableEvent)(nil), "networkdb.TableEvent")
  295. proto.RegisterType((*BulkSyncMessage)(nil), "networkdb.BulkSyncMessage")
  296. proto.RegisterType((*CompoundMessage)(nil), "networkdb.CompoundMessage")
  297. proto.RegisterType((*CompoundMessage_SimpleMessage)(nil), "networkdb.CompoundMessage.SimpleMessage")
  298. proto.RegisterEnum("networkdb.MessageType", MessageType_name, MessageType_value)
  299. proto.RegisterEnum("networkdb.NodeEvent_Type", NodeEvent_Type_name, NodeEvent_Type_value)
  300. proto.RegisterEnum("networkdb.NetworkEvent_Type", NetworkEvent_Type_name, NetworkEvent_Type_value)
  301. proto.RegisterEnum("networkdb.TableEvent_Type", TableEvent_Type_name, TableEvent_Type_value)
  302. }
  303. func (this *GossipMessage) GoString() string {
  304. if this == nil {
  305. return "nil"
  306. }
  307. s := make([]string, 0, 6)
  308. s = append(s, "&networkdb.GossipMessage{")
  309. s = append(s, "Type: "+fmt.Sprintf("%#v", this.Type)+",\n")
  310. s = append(s, "Data: "+fmt.Sprintf("%#v", this.Data)+",\n")
  311. s = append(s, "}")
  312. return strings.Join(s, "")
  313. }
  314. func (this *NodeEvent) GoString() string {
  315. if this == nil {
  316. return "nil"
  317. }
  318. s := make([]string, 0, 7)
  319. s = append(s, "&networkdb.NodeEvent{")
  320. s = append(s, "Type: "+fmt.Sprintf("%#v", this.Type)+",\n")
  321. s = append(s, "LTime: "+fmt.Sprintf("%#v", this.LTime)+",\n")
  322. s = append(s, "NodeName: "+fmt.Sprintf("%#v", this.NodeName)+",\n")
  323. s = append(s, "}")
  324. return strings.Join(s, "")
  325. }
  326. func (this *NetworkEvent) GoString() string {
  327. if this == nil {
  328. return "nil"
  329. }
  330. s := make([]string, 0, 8)
  331. s = append(s, "&networkdb.NetworkEvent{")
  332. s = append(s, "Type: "+fmt.Sprintf("%#v", this.Type)+",\n")
  333. s = append(s, "LTime: "+fmt.Sprintf("%#v", this.LTime)+",\n")
  334. s = append(s, "NodeName: "+fmt.Sprintf("%#v", this.NodeName)+",\n")
  335. s = append(s, "NetworkID: "+fmt.Sprintf("%#v", this.NetworkID)+",\n")
  336. s = append(s, "}")
  337. return strings.Join(s, "")
  338. }
  339. func (this *NetworkEntry) GoString() string {
  340. if this == nil {
  341. return "nil"
  342. }
  343. s := make([]string, 0, 8)
  344. s = append(s, "&networkdb.NetworkEntry{")
  345. s = append(s, "NetworkID: "+fmt.Sprintf("%#v", this.NetworkID)+",\n")
  346. s = append(s, "LTime: "+fmt.Sprintf("%#v", this.LTime)+",\n")
  347. s = append(s, "NodeName: "+fmt.Sprintf("%#v", this.NodeName)+",\n")
  348. s = append(s, "Leaving: "+fmt.Sprintf("%#v", this.Leaving)+",\n")
  349. s = append(s, "}")
  350. return strings.Join(s, "")
  351. }
  352. func (this *NetworkPushPull) GoString() string {
  353. if this == nil {
  354. return "nil"
  355. }
  356. s := make([]string, 0, 7)
  357. s = append(s, "&networkdb.NetworkPushPull{")
  358. s = append(s, "LTime: "+fmt.Sprintf("%#v", this.LTime)+",\n")
  359. if this.Networks != nil {
  360. s = append(s, "Networks: "+fmt.Sprintf("%#v", this.Networks)+",\n")
  361. }
  362. s = append(s, "NodeName: "+fmt.Sprintf("%#v", this.NodeName)+",\n")
  363. s = append(s, "}")
  364. return strings.Join(s, "")
  365. }
  366. func (this *TableEvent) GoString() string {
  367. if this == nil {
  368. return "nil"
  369. }
  370. s := make([]string, 0, 11)
  371. s = append(s, "&networkdb.TableEvent{")
  372. s = append(s, "Type: "+fmt.Sprintf("%#v", this.Type)+",\n")
  373. s = append(s, "LTime: "+fmt.Sprintf("%#v", this.LTime)+",\n")
  374. s = append(s, "NodeName: "+fmt.Sprintf("%#v", this.NodeName)+",\n")
  375. s = append(s, "NetworkID: "+fmt.Sprintf("%#v", this.NetworkID)+",\n")
  376. s = append(s, "TableName: "+fmt.Sprintf("%#v", this.TableName)+",\n")
  377. s = append(s, "Key: "+fmt.Sprintf("%#v", this.Key)+",\n")
  378. s = append(s, "Value: "+fmt.Sprintf("%#v", this.Value)+",\n")
  379. s = append(s, "}")
  380. return strings.Join(s, "")
  381. }
  382. func (this *BulkSyncMessage) GoString() string {
  383. if this == nil {
  384. return "nil"
  385. }
  386. s := make([]string, 0, 9)
  387. s = append(s, "&networkdb.BulkSyncMessage{")
  388. s = append(s, "LTime: "+fmt.Sprintf("%#v", this.LTime)+",\n")
  389. s = append(s, "Unsolicited: "+fmt.Sprintf("%#v", this.Unsolicited)+",\n")
  390. s = append(s, "NodeName: "+fmt.Sprintf("%#v", this.NodeName)+",\n")
  391. s = append(s, "Networks: "+fmt.Sprintf("%#v", this.Networks)+",\n")
  392. s = append(s, "Payload: "+fmt.Sprintf("%#v", this.Payload)+",\n")
  393. s = append(s, "}")
  394. return strings.Join(s, "")
  395. }
  396. func (this *CompoundMessage) GoString() string {
  397. if this == nil {
  398. return "nil"
  399. }
  400. s := make([]string, 0, 5)
  401. s = append(s, "&networkdb.CompoundMessage{")
  402. if this.Messages != nil {
  403. s = append(s, "Messages: "+fmt.Sprintf("%#v", this.Messages)+",\n")
  404. }
  405. s = append(s, "}")
  406. return strings.Join(s, "")
  407. }
  408. func (this *CompoundMessage_SimpleMessage) GoString() string {
  409. if this == nil {
  410. return "nil"
  411. }
  412. s := make([]string, 0, 5)
  413. s = append(s, "&networkdb.CompoundMessage_SimpleMessage{")
  414. s = append(s, "Payload: "+fmt.Sprintf("%#v", this.Payload)+",\n")
  415. s = append(s, "}")
  416. return strings.Join(s, "")
  417. }
  418. func valueToGoStringNetworkdb(v interface{}, typ string) string {
  419. rv := reflect.ValueOf(v)
  420. if rv.IsNil() {
  421. return "nil"
  422. }
  423. pv := reflect.Indirect(rv).Interface()
  424. return fmt.Sprintf("func(v %v) *%v { return &v } ( %#v )", typ, typ, pv)
  425. }
  426. func extensionToGoStringNetworkdb(e map[int32]github_com_gogo_protobuf_proto.Extension) string {
  427. if e == nil {
  428. return "nil"
  429. }
  430. s := "map[int32]proto.Extension{"
  431. keys := make([]int, 0, len(e))
  432. for k := range e {
  433. keys = append(keys, int(k))
  434. }
  435. sort.Ints(keys)
  436. ss := []string{}
  437. for _, k := range keys {
  438. ss = append(ss, strconv.Itoa(k)+": "+e[int32(k)].GoString())
  439. }
  440. s += strings.Join(ss, ",") + "}"
  441. return s
  442. }
  443. func (m *GossipMessage) Marshal() (data []byte, err error) {
  444. size := m.Size()
  445. data = make([]byte, size)
  446. n, err := m.MarshalTo(data)
  447. if err != nil {
  448. return nil, err
  449. }
  450. return data[:n], nil
  451. }
  452. func (m *GossipMessage) MarshalTo(data []byte) (int, error) {
  453. var i int
  454. _ = i
  455. var l int
  456. _ = l
  457. if m.Type != 0 {
  458. data[i] = 0x8
  459. i++
  460. i = encodeVarintNetworkdb(data, i, uint64(m.Type))
  461. }
  462. if len(m.Data) > 0 {
  463. data[i] = 0x12
  464. i++
  465. i = encodeVarintNetworkdb(data, i, uint64(len(m.Data)))
  466. i += copy(data[i:], m.Data)
  467. }
  468. return i, nil
  469. }
  470. func (m *NodeEvent) Marshal() (data []byte, err error) {
  471. size := m.Size()
  472. data = make([]byte, size)
  473. n, err := m.MarshalTo(data)
  474. if err != nil {
  475. return nil, err
  476. }
  477. return data[:n], nil
  478. }
  479. func (m *NodeEvent) MarshalTo(data []byte) (int, error) {
  480. var i int
  481. _ = i
  482. var l int
  483. _ = l
  484. if m.Type != 0 {
  485. data[i] = 0x8
  486. i++
  487. i = encodeVarintNetworkdb(data, i, uint64(m.Type))
  488. }
  489. if m.LTime != 0 {
  490. data[i] = 0x10
  491. i++
  492. i = encodeVarintNetworkdb(data, i, uint64(m.LTime))
  493. }
  494. if len(m.NodeName) > 0 {
  495. data[i] = 0x1a
  496. i++
  497. i = encodeVarintNetworkdb(data, i, uint64(len(m.NodeName)))
  498. i += copy(data[i:], m.NodeName)
  499. }
  500. return i, nil
  501. }
  502. func (m *NetworkEvent) Marshal() (data []byte, err error) {
  503. size := m.Size()
  504. data = make([]byte, size)
  505. n, err := m.MarshalTo(data)
  506. if err != nil {
  507. return nil, err
  508. }
  509. return data[:n], nil
  510. }
  511. func (m *NetworkEvent) MarshalTo(data []byte) (int, error) {
  512. var i int
  513. _ = i
  514. var l int
  515. _ = l
  516. if m.Type != 0 {
  517. data[i] = 0x8
  518. i++
  519. i = encodeVarintNetworkdb(data, i, uint64(m.Type))
  520. }
  521. if m.LTime != 0 {
  522. data[i] = 0x10
  523. i++
  524. i = encodeVarintNetworkdb(data, i, uint64(m.LTime))
  525. }
  526. if len(m.NodeName) > 0 {
  527. data[i] = 0x1a
  528. i++
  529. i = encodeVarintNetworkdb(data, i, uint64(len(m.NodeName)))
  530. i += copy(data[i:], m.NodeName)
  531. }
  532. if len(m.NetworkID) > 0 {
  533. data[i] = 0x22
  534. i++
  535. i = encodeVarintNetworkdb(data, i, uint64(len(m.NetworkID)))
  536. i += copy(data[i:], m.NetworkID)
  537. }
  538. return i, nil
  539. }
  540. func (m *NetworkEntry) Marshal() (data []byte, err error) {
  541. size := m.Size()
  542. data = make([]byte, size)
  543. n, err := m.MarshalTo(data)
  544. if err != nil {
  545. return nil, err
  546. }
  547. return data[:n], nil
  548. }
  549. func (m *NetworkEntry) MarshalTo(data []byte) (int, error) {
  550. var i int
  551. _ = i
  552. var l int
  553. _ = l
  554. if len(m.NetworkID) > 0 {
  555. data[i] = 0xa
  556. i++
  557. i = encodeVarintNetworkdb(data, i, uint64(len(m.NetworkID)))
  558. i += copy(data[i:], m.NetworkID)
  559. }
  560. if m.LTime != 0 {
  561. data[i] = 0x10
  562. i++
  563. i = encodeVarintNetworkdb(data, i, uint64(m.LTime))
  564. }
  565. if len(m.NodeName) > 0 {
  566. data[i] = 0x1a
  567. i++
  568. i = encodeVarintNetworkdb(data, i, uint64(len(m.NodeName)))
  569. i += copy(data[i:], m.NodeName)
  570. }
  571. if m.Leaving {
  572. data[i] = 0x20
  573. i++
  574. if m.Leaving {
  575. data[i] = 1
  576. } else {
  577. data[i] = 0
  578. }
  579. i++
  580. }
  581. return i, nil
  582. }
  583. func (m *NetworkPushPull) Marshal() (data []byte, err error) {
  584. size := m.Size()
  585. data = make([]byte, size)
  586. n, err := m.MarshalTo(data)
  587. if err != nil {
  588. return nil, err
  589. }
  590. return data[:n], nil
  591. }
  592. func (m *NetworkPushPull) MarshalTo(data []byte) (int, error) {
  593. var i int
  594. _ = i
  595. var l int
  596. _ = l
  597. if m.LTime != 0 {
  598. data[i] = 0x8
  599. i++
  600. i = encodeVarintNetworkdb(data, i, uint64(m.LTime))
  601. }
  602. if len(m.Networks) > 0 {
  603. for _, msg := range m.Networks {
  604. data[i] = 0x12
  605. i++
  606. i = encodeVarintNetworkdb(data, i, uint64(msg.Size()))
  607. n, err := msg.MarshalTo(data[i:])
  608. if err != nil {
  609. return 0, err
  610. }
  611. i += n
  612. }
  613. }
  614. if len(m.NodeName) > 0 {
  615. data[i] = 0x1a
  616. i++
  617. i = encodeVarintNetworkdb(data, i, uint64(len(m.NodeName)))
  618. i += copy(data[i:], m.NodeName)
  619. }
  620. return i, nil
  621. }
  622. func (m *TableEvent) Marshal() (data []byte, err error) {
  623. size := m.Size()
  624. data = make([]byte, size)
  625. n, err := m.MarshalTo(data)
  626. if err != nil {
  627. return nil, err
  628. }
  629. return data[:n], nil
  630. }
  631. func (m *TableEvent) MarshalTo(data []byte) (int, error) {
  632. var i int
  633. _ = i
  634. var l int
  635. _ = l
  636. if m.Type != 0 {
  637. data[i] = 0x8
  638. i++
  639. i = encodeVarintNetworkdb(data, i, uint64(m.Type))
  640. }
  641. if m.LTime != 0 {
  642. data[i] = 0x10
  643. i++
  644. i = encodeVarintNetworkdb(data, i, uint64(m.LTime))
  645. }
  646. if len(m.NodeName) > 0 {
  647. data[i] = 0x1a
  648. i++
  649. i = encodeVarintNetworkdb(data, i, uint64(len(m.NodeName)))
  650. i += copy(data[i:], m.NodeName)
  651. }
  652. if len(m.NetworkID) > 0 {
  653. data[i] = 0x22
  654. i++
  655. i = encodeVarintNetworkdb(data, i, uint64(len(m.NetworkID)))
  656. i += copy(data[i:], m.NetworkID)
  657. }
  658. if len(m.TableName) > 0 {
  659. data[i] = 0x2a
  660. i++
  661. i = encodeVarintNetworkdb(data, i, uint64(len(m.TableName)))
  662. i += copy(data[i:], m.TableName)
  663. }
  664. if len(m.Key) > 0 {
  665. data[i] = 0x32
  666. i++
  667. i = encodeVarintNetworkdb(data, i, uint64(len(m.Key)))
  668. i += copy(data[i:], m.Key)
  669. }
  670. if len(m.Value) > 0 {
  671. data[i] = 0x3a
  672. i++
  673. i = encodeVarintNetworkdb(data, i, uint64(len(m.Value)))
  674. i += copy(data[i:], m.Value)
  675. }
  676. return i, nil
  677. }
  678. func (m *BulkSyncMessage) Marshal() (data []byte, err error) {
  679. size := m.Size()
  680. data = make([]byte, size)
  681. n, err := m.MarshalTo(data)
  682. if err != nil {
  683. return nil, err
  684. }
  685. return data[:n], nil
  686. }
  687. func (m *BulkSyncMessage) MarshalTo(data []byte) (int, error) {
  688. var i int
  689. _ = i
  690. var l int
  691. _ = l
  692. if m.LTime != 0 {
  693. data[i] = 0x8
  694. i++
  695. i = encodeVarintNetworkdb(data, i, uint64(m.LTime))
  696. }
  697. if m.Unsolicited {
  698. data[i] = 0x10
  699. i++
  700. if m.Unsolicited {
  701. data[i] = 1
  702. } else {
  703. data[i] = 0
  704. }
  705. i++
  706. }
  707. if len(m.NodeName) > 0 {
  708. data[i] = 0x1a
  709. i++
  710. i = encodeVarintNetworkdb(data, i, uint64(len(m.NodeName)))
  711. i += copy(data[i:], m.NodeName)
  712. }
  713. if len(m.Networks) > 0 {
  714. for _, s := range m.Networks {
  715. data[i] = 0x22
  716. i++
  717. l = len(s)
  718. for l >= 1<<7 {
  719. data[i] = uint8(uint64(l)&0x7f | 0x80)
  720. l >>= 7
  721. i++
  722. }
  723. data[i] = uint8(l)
  724. i++
  725. i += copy(data[i:], s)
  726. }
  727. }
  728. if len(m.Payload) > 0 {
  729. data[i] = 0x2a
  730. i++
  731. i = encodeVarintNetworkdb(data, i, uint64(len(m.Payload)))
  732. i += copy(data[i:], m.Payload)
  733. }
  734. return i, nil
  735. }
  736. func (m *CompoundMessage) Marshal() (data []byte, err error) {
  737. size := m.Size()
  738. data = make([]byte, size)
  739. n, err := m.MarshalTo(data)
  740. if err != nil {
  741. return nil, err
  742. }
  743. return data[:n], nil
  744. }
  745. func (m *CompoundMessage) MarshalTo(data []byte) (int, error) {
  746. var i int
  747. _ = i
  748. var l int
  749. _ = l
  750. if len(m.Messages) > 0 {
  751. for _, msg := range m.Messages {
  752. data[i] = 0xa
  753. i++
  754. i = encodeVarintNetworkdb(data, i, uint64(msg.Size()))
  755. n, err := msg.MarshalTo(data[i:])
  756. if err != nil {
  757. return 0, err
  758. }
  759. i += n
  760. }
  761. }
  762. return i, nil
  763. }
  764. func (m *CompoundMessage_SimpleMessage) Marshal() (data []byte, err error) {
  765. size := m.Size()
  766. data = make([]byte, size)
  767. n, err := m.MarshalTo(data)
  768. if err != nil {
  769. return nil, err
  770. }
  771. return data[:n], nil
  772. }
  773. func (m *CompoundMessage_SimpleMessage) MarshalTo(data []byte) (int, error) {
  774. var i int
  775. _ = i
  776. var l int
  777. _ = l
  778. if len(m.Payload) > 0 {
  779. data[i] = 0xa
  780. i++
  781. i = encodeVarintNetworkdb(data, i, uint64(len(m.Payload)))
  782. i += copy(data[i:], m.Payload)
  783. }
  784. return i, nil
  785. }
  786. func encodeFixed64Networkdb(data []byte, offset int, v uint64) int {
  787. data[offset] = uint8(v)
  788. data[offset+1] = uint8(v >> 8)
  789. data[offset+2] = uint8(v >> 16)
  790. data[offset+3] = uint8(v >> 24)
  791. data[offset+4] = uint8(v >> 32)
  792. data[offset+5] = uint8(v >> 40)
  793. data[offset+6] = uint8(v >> 48)
  794. data[offset+7] = uint8(v >> 56)
  795. return offset + 8
  796. }
  797. func encodeFixed32Networkdb(data []byte, offset int, v uint32) int {
  798. data[offset] = uint8(v)
  799. data[offset+1] = uint8(v >> 8)
  800. data[offset+2] = uint8(v >> 16)
  801. data[offset+3] = uint8(v >> 24)
  802. return offset + 4
  803. }
  804. func encodeVarintNetworkdb(data []byte, offset int, v uint64) int {
  805. for v >= 1<<7 {
  806. data[offset] = uint8(v&0x7f | 0x80)
  807. v >>= 7
  808. offset++
  809. }
  810. data[offset] = uint8(v)
  811. return offset + 1
  812. }
  813. func (m *GossipMessage) Size() (n int) {
  814. var l int
  815. _ = l
  816. if m.Type != 0 {
  817. n += 1 + sovNetworkdb(uint64(m.Type))
  818. }
  819. l = len(m.Data)
  820. if l > 0 {
  821. n += 1 + l + sovNetworkdb(uint64(l))
  822. }
  823. return n
  824. }
  825. func (m *NodeEvent) Size() (n int) {
  826. var l int
  827. _ = l
  828. if m.Type != 0 {
  829. n += 1 + sovNetworkdb(uint64(m.Type))
  830. }
  831. if m.LTime != 0 {
  832. n += 1 + sovNetworkdb(uint64(m.LTime))
  833. }
  834. l = len(m.NodeName)
  835. if l > 0 {
  836. n += 1 + l + sovNetworkdb(uint64(l))
  837. }
  838. return n
  839. }
  840. func (m *NetworkEvent) Size() (n int) {
  841. var l int
  842. _ = l
  843. if m.Type != 0 {
  844. n += 1 + sovNetworkdb(uint64(m.Type))
  845. }
  846. if m.LTime != 0 {
  847. n += 1 + sovNetworkdb(uint64(m.LTime))
  848. }
  849. l = len(m.NodeName)
  850. if l > 0 {
  851. n += 1 + l + sovNetworkdb(uint64(l))
  852. }
  853. l = len(m.NetworkID)
  854. if l > 0 {
  855. n += 1 + l + sovNetworkdb(uint64(l))
  856. }
  857. return n
  858. }
  859. func (m *NetworkEntry) Size() (n int) {
  860. var l int
  861. _ = l
  862. l = len(m.NetworkID)
  863. if l > 0 {
  864. n += 1 + l + sovNetworkdb(uint64(l))
  865. }
  866. if m.LTime != 0 {
  867. n += 1 + sovNetworkdb(uint64(m.LTime))
  868. }
  869. l = len(m.NodeName)
  870. if l > 0 {
  871. n += 1 + l + sovNetworkdb(uint64(l))
  872. }
  873. if m.Leaving {
  874. n += 2
  875. }
  876. return n
  877. }
  878. func (m *NetworkPushPull) Size() (n int) {
  879. var l int
  880. _ = l
  881. if m.LTime != 0 {
  882. n += 1 + sovNetworkdb(uint64(m.LTime))
  883. }
  884. if len(m.Networks) > 0 {
  885. for _, e := range m.Networks {
  886. l = e.Size()
  887. n += 1 + l + sovNetworkdb(uint64(l))
  888. }
  889. }
  890. l = len(m.NodeName)
  891. if l > 0 {
  892. n += 1 + l + sovNetworkdb(uint64(l))
  893. }
  894. return n
  895. }
  896. func (m *TableEvent) Size() (n int) {
  897. var l int
  898. _ = l
  899. if m.Type != 0 {
  900. n += 1 + sovNetworkdb(uint64(m.Type))
  901. }
  902. if m.LTime != 0 {
  903. n += 1 + sovNetworkdb(uint64(m.LTime))
  904. }
  905. l = len(m.NodeName)
  906. if l > 0 {
  907. n += 1 + l + sovNetworkdb(uint64(l))
  908. }
  909. l = len(m.NetworkID)
  910. if l > 0 {
  911. n += 1 + l + sovNetworkdb(uint64(l))
  912. }
  913. l = len(m.TableName)
  914. if l > 0 {
  915. n += 1 + l + sovNetworkdb(uint64(l))
  916. }
  917. l = len(m.Key)
  918. if l > 0 {
  919. n += 1 + l + sovNetworkdb(uint64(l))
  920. }
  921. l = len(m.Value)
  922. if l > 0 {
  923. n += 1 + l + sovNetworkdb(uint64(l))
  924. }
  925. return n
  926. }
  927. func (m *BulkSyncMessage) Size() (n int) {
  928. var l int
  929. _ = l
  930. if m.LTime != 0 {
  931. n += 1 + sovNetworkdb(uint64(m.LTime))
  932. }
  933. if m.Unsolicited {
  934. n += 2
  935. }
  936. l = len(m.NodeName)
  937. if l > 0 {
  938. n += 1 + l + sovNetworkdb(uint64(l))
  939. }
  940. if len(m.Networks) > 0 {
  941. for _, s := range m.Networks {
  942. l = len(s)
  943. n += 1 + l + sovNetworkdb(uint64(l))
  944. }
  945. }
  946. l = len(m.Payload)
  947. if l > 0 {
  948. n += 1 + l + sovNetworkdb(uint64(l))
  949. }
  950. return n
  951. }
  952. func (m *CompoundMessage) Size() (n int) {
  953. var l int
  954. _ = l
  955. if len(m.Messages) > 0 {
  956. for _, e := range m.Messages {
  957. l = e.Size()
  958. n += 1 + l + sovNetworkdb(uint64(l))
  959. }
  960. }
  961. return n
  962. }
  963. func (m *CompoundMessage_SimpleMessage) Size() (n int) {
  964. var l int
  965. _ = l
  966. l = len(m.Payload)
  967. if l > 0 {
  968. n += 1 + l + sovNetworkdb(uint64(l))
  969. }
  970. return n
  971. }
  972. func sovNetworkdb(x uint64) (n int) {
  973. for {
  974. n++
  975. x >>= 7
  976. if x == 0 {
  977. break
  978. }
  979. }
  980. return n
  981. }
  982. func sozNetworkdb(x uint64) (n int) {
  983. return sovNetworkdb(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  984. }
  985. func (this *GossipMessage) String() string {
  986. if this == nil {
  987. return "nil"
  988. }
  989. s := strings.Join([]string{`&GossipMessage{`,
  990. `Type:` + fmt.Sprintf("%v", this.Type) + `,`,
  991. `Data:` + fmt.Sprintf("%v", this.Data) + `,`,
  992. `}`,
  993. }, "")
  994. return s
  995. }
  996. func (this *NodeEvent) String() string {
  997. if this == nil {
  998. return "nil"
  999. }
  1000. s := strings.Join([]string{`&NodeEvent{`,
  1001. `Type:` + fmt.Sprintf("%v", this.Type) + `,`,
  1002. `LTime:` + fmt.Sprintf("%v", this.LTime) + `,`,
  1003. `NodeName:` + fmt.Sprintf("%v", this.NodeName) + `,`,
  1004. `}`,
  1005. }, "")
  1006. return s
  1007. }
  1008. func (this *NetworkEvent) String() string {
  1009. if this == nil {
  1010. return "nil"
  1011. }
  1012. s := strings.Join([]string{`&NetworkEvent{`,
  1013. `Type:` + fmt.Sprintf("%v", this.Type) + `,`,
  1014. `LTime:` + fmt.Sprintf("%v", this.LTime) + `,`,
  1015. `NodeName:` + fmt.Sprintf("%v", this.NodeName) + `,`,
  1016. `NetworkID:` + fmt.Sprintf("%v", this.NetworkID) + `,`,
  1017. `}`,
  1018. }, "")
  1019. return s
  1020. }
  1021. func (this *NetworkEntry) String() string {
  1022. if this == nil {
  1023. return "nil"
  1024. }
  1025. s := strings.Join([]string{`&NetworkEntry{`,
  1026. `NetworkID:` + fmt.Sprintf("%v", this.NetworkID) + `,`,
  1027. `LTime:` + fmt.Sprintf("%v", this.LTime) + `,`,
  1028. `NodeName:` + fmt.Sprintf("%v", this.NodeName) + `,`,
  1029. `Leaving:` + fmt.Sprintf("%v", this.Leaving) + `,`,
  1030. `}`,
  1031. }, "")
  1032. return s
  1033. }
  1034. func (this *NetworkPushPull) String() string {
  1035. if this == nil {
  1036. return "nil"
  1037. }
  1038. s := strings.Join([]string{`&NetworkPushPull{`,
  1039. `LTime:` + fmt.Sprintf("%v", this.LTime) + `,`,
  1040. `Networks:` + strings.Replace(fmt.Sprintf("%v", this.Networks), "NetworkEntry", "NetworkEntry", 1) + `,`,
  1041. `NodeName:` + fmt.Sprintf("%v", this.NodeName) + `,`,
  1042. `}`,
  1043. }, "")
  1044. return s
  1045. }
  1046. func (this *TableEvent) String() string {
  1047. if this == nil {
  1048. return "nil"
  1049. }
  1050. s := strings.Join([]string{`&TableEvent{`,
  1051. `Type:` + fmt.Sprintf("%v", this.Type) + `,`,
  1052. `LTime:` + fmt.Sprintf("%v", this.LTime) + `,`,
  1053. `NodeName:` + fmt.Sprintf("%v", this.NodeName) + `,`,
  1054. `NetworkID:` + fmt.Sprintf("%v", this.NetworkID) + `,`,
  1055. `TableName:` + fmt.Sprintf("%v", this.TableName) + `,`,
  1056. `Key:` + fmt.Sprintf("%v", this.Key) + `,`,
  1057. `Value:` + fmt.Sprintf("%v", this.Value) + `,`,
  1058. `}`,
  1059. }, "")
  1060. return s
  1061. }
  1062. func (this *BulkSyncMessage) String() string {
  1063. if this == nil {
  1064. return "nil"
  1065. }
  1066. s := strings.Join([]string{`&BulkSyncMessage{`,
  1067. `LTime:` + fmt.Sprintf("%v", this.LTime) + `,`,
  1068. `Unsolicited:` + fmt.Sprintf("%v", this.Unsolicited) + `,`,
  1069. `NodeName:` + fmt.Sprintf("%v", this.NodeName) + `,`,
  1070. `Networks:` + fmt.Sprintf("%v", this.Networks) + `,`,
  1071. `Payload:` + fmt.Sprintf("%v", this.Payload) + `,`,
  1072. `}`,
  1073. }, "")
  1074. return s
  1075. }
  1076. func (this *CompoundMessage) String() string {
  1077. if this == nil {
  1078. return "nil"
  1079. }
  1080. s := strings.Join([]string{`&CompoundMessage{`,
  1081. `Messages:` + strings.Replace(fmt.Sprintf("%v", this.Messages), "CompoundMessage_SimpleMessage", "CompoundMessage_SimpleMessage", 1) + `,`,
  1082. `}`,
  1083. }, "")
  1084. return s
  1085. }
  1086. func (this *CompoundMessage_SimpleMessage) String() string {
  1087. if this == nil {
  1088. return "nil"
  1089. }
  1090. s := strings.Join([]string{`&CompoundMessage_SimpleMessage{`,
  1091. `Payload:` + fmt.Sprintf("%v", this.Payload) + `,`,
  1092. `}`,
  1093. }, "")
  1094. return s
  1095. }
  1096. func valueToStringNetworkdb(v interface{}) string {
  1097. rv := reflect.ValueOf(v)
  1098. if rv.IsNil() {
  1099. return "nil"
  1100. }
  1101. pv := reflect.Indirect(rv).Interface()
  1102. return fmt.Sprintf("*%v", pv)
  1103. }
  1104. func (m *GossipMessage) Unmarshal(data []byte) error {
  1105. l := len(data)
  1106. iNdEx := 0
  1107. for iNdEx < l {
  1108. preIndex := iNdEx
  1109. var wire uint64
  1110. for shift := uint(0); ; shift += 7 {
  1111. if shift >= 64 {
  1112. return ErrIntOverflowNetworkdb
  1113. }
  1114. if iNdEx >= l {
  1115. return io.ErrUnexpectedEOF
  1116. }
  1117. b := data[iNdEx]
  1118. iNdEx++
  1119. wire |= (uint64(b) & 0x7F) << shift
  1120. if b < 0x80 {
  1121. break
  1122. }
  1123. }
  1124. fieldNum := int32(wire >> 3)
  1125. wireType := int(wire & 0x7)
  1126. if wireType == 4 {
  1127. return fmt.Errorf("proto: GossipMessage: wiretype end group for non-group")
  1128. }
  1129. if fieldNum <= 0 {
  1130. return fmt.Errorf("proto: GossipMessage: illegal tag %d (wire type %d)", fieldNum, wire)
  1131. }
  1132. switch fieldNum {
  1133. case 1:
  1134. if wireType != 0 {
  1135. return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
  1136. }
  1137. m.Type = 0
  1138. for shift := uint(0); ; shift += 7 {
  1139. if shift >= 64 {
  1140. return ErrIntOverflowNetworkdb
  1141. }
  1142. if iNdEx >= l {
  1143. return io.ErrUnexpectedEOF
  1144. }
  1145. b := data[iNdEx]
  1146. iNdEx++
  1147. m.Type |= (MessageType(b) & 0x7F) << shift
  1148. if b < 0x80 {
  1149. break
  1150. }
  1151. }
  1152. case 2:
  1153. if wireType != 2 {
  1154. return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType)
  1155. }
  1156. var byteLen int
  1157. for shift := uint(0); ; shift += 7 {
  1158. if shift >= 64 {
  1159. return ErrIntOverflowNetworkdb
  1160. }
  1161. if iNdEx >= l {
  1162. return io.ErrUnexpectedEOF
  1163. }
  1164. b := data[iNdEx]
  1165. iNdEx++
  1166. byteLen |= (int(b) & 0x7F) << shift
  1167. if b < 0x80 {
  1168. break
  1169. }
  1170. }
  1171. if byteLen < 0 {
  1172. return ErrInvalidLengthNetworkdb
  1173. }
  1174. postIndex := iNdEx + byteLen
  1175. if postIndex > l {
  1176. return io.ErrUnexpectedEOF
  1177. }
  1178. m.Data = append(m.Data[:0], data[iNdEx:postIndex]...)
  1179. if m.Data == nil {
  1180. m.Data = []byte{}
  1181. }
  1182. iNdEx = postIndex
  1183. default:
  1184. iNdEx = preIndex
  1185. skippy, err := skipNetworkdb(data[iNdEx:])
  1186. if err != nil {
  1187. return err
  1188. }
  1189. if skippy < 0 {
  1190. return ErrInvalidLengthNetworkdb
  1191. }
  1192. if (iNdEx + skippy) > l {
  1193. return io.ErrUnexpectedEOF
  1194. }
  1195. iNdEx += skippy
  1196. }
  1197. }
  1198. if iNdEx > l {
  1199. return io.ErrUnexpectedEOF
  1200. }
  1201. return nil
  1202. }
  1203. func (m *NodeEvent) Unmarshal(data []byte) error {
  1204. l := len(data)
  1205. iNdEx := 0
  1206. for iNdEx < l {
  1207. preIndex := iNdEx
  1208. var wire uint64
  1209. for shift := uint(0); ; shift += 7 {
  1210. if shift >= 64 {
  1211. return ErrIntOverflowNetworkdb
  1212. }
  1213. if iNdEx >= l {
  1214. return io.ErrUnexpectedEOF
  1215. }
  1216. b := data[iNdEx]
  1217. iNdEx++
  1218. wire |= (uint64(b) & 0x7F) << shift
  1219. if b < 0x80 {
  1220. break
  1221. }
  1222. }
  1223. fieldNum := int32(wire >> 3)
  1224. wireType := int(wire & 0x7)
  1225. if wireType == 4 {
  1226. return fmt.Errorf("proto: NodeEvent: wiretype end group for non-group")
  1227. }
  1228. if fieldNum <= 0 {
  1229. return fmt.Errorf("proto: NodeEvent: illegal tag %d (wire type %d)", fieldNum, wire)
  1230. }
  1231. switch fieldNum {
  1232. case 1:
  1233. if wireType != 0 {
  1234. return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
  1235. }
  1236. m.Type = 0
  1237. for shift := uint(0); ; shift += 7 {
  1238. if shift >= 64 {
  1239. return ErrIntOverflowNetworkdb
  1240. }
  1241. if iNdEx >= l {
  1242. return io.ErrUnexpectedEOF
  1243. }
  1244. b := data[iNdEx]
  1245. iNdEx++
  1246. m.Type |= (NodeEvent_Type(b) & 0x7F) << shift
  1247. if b < 0x80 {
  1248. break
  1249. }
  1250. }
  1251. case 2:
  1252. if wireType != 0 {
  1253. return fmt.Errorf("proto: wrong wireType = %d for field LTime", wireType)
  1254. }
  1255. m.LTime = 0
  1256. for shift := uint(0); ; shift += 7 {
  1257. if shift >= 64 {
  1258. return ErrIntOverflowNetworkdb
  1259. }
  1260. if iNdEx >= l {
  1261. return io.ErrUnexpectedEOF
  1262. }
  1263. b := data[iNdEx]
  1264. iNdEx++
  1265. m.LTime |= (github_com_hashicorp_serf_serf.LamportTime(b) & 0x7F) << shift
  1266. if b < 0x80 {
  1267. break
  1268. }
  1269. }
  1270. case 3:
  1271. if wireType != 2 {
  1272. return fmt.Errorf("proto: wrong wireType = %d for field NodeName", wireType)
  1273. }
  1274. var stringLen uint64
  1275. for shift := uint(0); ; shift += 7 {
  1276. if shift >= 64 {
  1277. return ErrIntOverflowNetworkdb
  1278. }
  1279. if iNdEx >= l {
  1280. return io.ErrUnexpectedEOF
  1281. }
  1282. b := data[iNdEx]
  1283. iNdEx++
  1284. stringLen |= (uint64(b) & 0x7F) << shift
  1285. if b < 0x80 {
  1286. break
  1287. }
  1288. }
  1289. intStringLen := int(stringLen)
  1290. if intStringLen < 0 {
  1291. return ErrInvalidLengthNetworkdb
  1292. }
  1293. postIndex := iNdEx + intStringLen
  1294. if postIndex > l {
  1295. return io.ErrUnexpectedEOF
  1296. }
  1297. m.NodeName = string(data[iNdEx:postIndex])
  1298. iNdEx = postIndex
  1299. default:
  1300. iNdEx = preIndex
  1301. skippy, err := skipNetworkdb(data[iNdEx:])
  1302. if err != nil {
  1303. return err
  1304. }
  1305. if skippy < 0 {
  1306. return ErrInvalidLengthNetworkdb
  1307. }
  1308. if (iNdEx + skippy) > l {
  1309. return io.ErrUnexpectedEOF
  1310. }
  1311. iNdEx += skippy
  1312. }
  1313. }
  1314. if iNdEx > l {
  1315. return io.ErrUnexpectedEOF
  1316. }
  1317. return nil
  1318. }
  1319. func (m *NetworkEvent) Unmarshal(data []byte) error {
  1320. l := len(data)
  1321. iNdEx := 0
  1322. for iNdEx < l {
  1323. preIndex := iNdEx
  1324. var wire uint64
  1325. for shift := uint(0); ; shift += 7 {
  1326. if shift >= 64 {
  1327. return ErrIntOverflowNetworkdb
  1328. }
  1329. if iNdEx >= l {
  1330. return io.ErrUnexpectedEOF
  1331. }
  1332. b := data[iNdEx]
  1333. iNdEx++
  1334. wire |= (uint64(b) & 0x7F) << shift
  1335. if b < 0x80 {
  1336. break
  1337. }
  1338. }
  1339. fieldNum := int32(wire >> 3)
  1340. wireType := int(wire & 0x7)
  1341. if wireType == 4 {
  1342. return fmt.Errorf("proto: NetworkEvent: wiretype end group for non-group")
  1343. }
  1344. if fieldNum <= 0 {
  1345. return fmt.Errorf("proto: NetworkEvent: illegal tag %d (wire type %d)", fieldNum, wire)
  1346. }
  1347. switch fieldNum {
  1348. case 1:
  1349. if wireType != 0 {
  1350. return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
  1351. }
  1352. m.Type = 0
  1353. for shift := uint(0); ; shift += 7 {
  1354. if shift >= 64 {
  1355. return ErrIntOverflowNetworkdb
  1356. }
  1357. if iNdEx >= l {
  1358. return io.ErrUnexpectedEOF
  1359. }
  1360. b := data[iNdEx]
  1361. iNdEx++
  1362. m.Type |= (NetworkEvent_Type(b) & 0x7F) << shift
  1363. if b < 0x80 {
  1364. break
  1365. }
  1366. }
  1367. case 2:
  1368. if wireType != 0 {
  1369. return fmt.Errorf("proto: wrong wireType = %d for field LTime", wireType)
  1370. }
  1371. m.LTime = 0
  1372. for shift := uint(0); ; shift += 7 {
  1373. if shift >= 64 {
  1374. return ErrIntOverflowNetworkdb
  1375. }
  1376. if iNdEx >= l {
  1377. return io.ErrUnexpectedEOF
  1378. }
  1379. b := data[iNdEx]
  1380. iNdEx++
  1381. m.LTime |= (github_com_hashicorp_serf_serf.LamportTime(b) & 0x7F) << shift
  1382. if b < 0x80 {
  1383. break
  1384. }
  1385. }
  1386. case 3:
  1387. if wireType != 2 {
  1388. return fmt.Errorf("proto: wrong wireType = %d for field NodeName", wireType)
  1389. }
  1390. var stringLen uint64
  1391. for shift := uint(0); ; shift += 7 {
  1392. if shift >= 64 {
  1393. return ErrIntOverflowNetworkdb
  1394. }
  1395. if iNdEx >= l {
  1396. return io.ErrUnexpectedEOF
  1397. }
  1398. b := data[iNdEx]
  1399. iNdEx++
  1400. stringLen |= (uint64(b) & 0x7F) << shift
  1401. if b < 0x80 {
  1402. break
  1403. }
  1404. }
  1405. intStringLen := int(stringLen)
  1406. if intStringLen < 0 {
  1407. return ErrInvalidLengthNetworkdb
  1408. }
  1409. postIndex := iNdEx + intStringLen
  1410. if postIndex > l {
  1411. return io.ErrUnexpectedEOF
  1412. }
  1413. m.NodeName = string(data[iNdEx:postIndex])
  1414. iNdEx = postIndex
  1415. case 4:
  1416. if wireType != 2 {
  1417. return fmt.Errorf("proto: wrong wireType = %d for field NetworkID", wireType)
  1418. }
  1419. var stringLen uint64
  1420. for shift := uint(0); ; shift += 7 {
  1421. if shift >= 64 {
  1422. return ErrIntOverflowNetworkdb
  1423. }
  1424. if iNdEx >= l {
  1425. return io.ErrUnexpectedEOF
  1426. }
  1427. b := data[iNdEx]
  1428. iNdEx++
  1429. stringLen |= (uint64(b) & 0x7F) << shift
  1430. if b < 0x80 {
  1431. break
  1432. }
  1433. }
  1434. intStringLen := int(stringLen)
  1435. if intStringLen < 0 {
  1436. return ErrInvalidLengthNetworkdb
  1437. }
  1438. postIndex := iNdEx + intStringLen
  1439. if postIndex > l {
  1440. return io.ErrUnexpectedEOF
  1441. }
  1442. m.NetworkID = string(data[iNdEx:postIndex])
  1443. iNdEx = postIndex
  1444. default:
  1445. iNdEx = preIndex
  1446. skippy, err := skipNetworkdb(data[iNdEx:])
  1447. if err != nil {
  1448. return err
  1449. }
  1450. if skippy < 0 {
  1451. return ErrInvalidLengthNetworkdb
  1452. }
  1453. if (iNdEx + skippy) > l {
  1454. return io.ErrUnexpectedEOF
  1455. }
  1456. iNdEx += skippy
  1457. }
  1458. }
  1459. if iNdEx > l {
  1460. return io.ErrUnexpectedEOF
  1461. }
  1462. return nil
  1463. }
  1464. func (m *NetworkEntry) Unmarshal(data []byte) error {
  1465. l := len(data)
  1466. iNdEx := 0
  1467. for iNdEx < l {
  1468. preIndex := iNdEx
  1469. var wire uint64
  1470. for shift := uint(0); ; shift += 7 {
  1471. if shift >= 64 {
  1472. return ErrIntOverflowNetworkdb
  1473. }
  1474. if iNdEx >= l {
  1475. return io.ErrUnexpectedEOF
  1476. }
  1477. b := data[iNdEx]
  1478. iNdEx++
  1479. wire |= (uint64(b) & 0x7F) << shift
  1480. if b < 0x80 {
  1481. break
  1482. }
  1483. }
  1484. fieldNum := int32(wire >> 3)
  1485. wireType := int(wire & 0x7)
  1486. if wireType == 4 {
  1487. return fmt.Errorf("proto: NetworkEntry: wiretype end group for non-group")
  1488. }
  1489. if fieldNum <= 0 {
  1490. return fmt.Errorf("proto: NetworkEntry: illegal tag %d (wire type %d)", fieldNum, wire)
  1491. }
  1492. switch fieldNum {
  1493. case 1:
  1494. if wireType != 2 {
  1495. return fmt.Errorf("proto: wrong wireType = %d for field NetworkID", wireType)
  1496. }
  1497. var stringLen uint64
  1498. for shift := uint(0); ; shift += 7 {
  1499. if shift >= 64 {
  1500. return ErrIntOverflowNetworkdb
  1501. }
  1502. if iNdEx >= l {
  1503. return io.ErrUnexpectedEOF
  1504. }
  1505. b := data[iNdEx]
  1506. iNdEx++
  1507. stringLen |= (uint64(b) & 0x7F) << shift
  1508. if b < 0x80 {
  1509. break
  1510. }
  1511. }
  1512. intStringLen := int(stringLen)
  1513. if intStringLen < 0 {
  1514. return ErrInvalidLengthNetworkdb
  1515. }
  1516. postIndex := iNdEx + intStringLen
  1517. if postIndex > l {
  1518. return io.ErrUnexpectedEOF
  1519. }
  1520. m.NetworkID = string(data[iNdEx:postIndex])
  1521. iNdEx = postIndex
  1522. case 2:
  1523. if wireType != 0 {
  1524. return fmt.Errorf("proto: wrong wireType = %d for field LTime", wireType)
  1525. }
  1526. m.LTime = 0
  1527. for shift := uint(0); ; shift += 7 {
  1528. if shift >= 64 {
  1529. return ErrIntOverflowNetworkdb
  1530. }
  1531. if iNdEx >= l {
  1532. return io.ErrUnexpectedEOF
  1533. }
  1534. b := data[iNdEx]
  1535. iNdEx++
  1536. m.LTime |= (github_com_hashicorp_serf_serf.LamportTime(b) & 0x7F) << shift
  1537. if b < 0x80 {
  1538. break
  1539. }
  1540. }
  1541. case 3:
  1542. if wireType != 2 {
  1543. return fmt.Errorf("proto: wrong wireType = %d for field NodeName", wireType)
  1544. }
  1545. var stringLen uint64
  1546. for shift := uint(0); ; shift += 7 {
  1547. if shift >= 64 {
  1548. return ErrIntOverflowNetworkdb
  1549. }
  1550. if iNdEx >= l {
  1551. return io.ErrUnexpectedEOF
  1552. }
  1553. b := data[iNdEx]
  1554. iNdEx++
  1555. stringLen |= (uint64(b) & 0x7F) << shift
  1556. if b < 0x80 {
  1557. break
  1558. }
  1559. }
  1560. intStringLen := int(stringLen)
  1561. if intStringLen < 0 {
  1562. return ErrInvalidLengthNetworkdb
  1563. }
  1564. postIndex := iNdEx + intStringLen
  1565. if postIndex > l {
  1566. return io.ErrUnexpectedEOF
  1567. }
  1568. m.NodeName = string(data[iNdEx:postIndex])
  1569. iNdEx = postIndex
  1570. case 4:
  1571. if wireType != 0 {
  1572. return fmt.Errorf("proto: wrong wireType = %d for field Leaving", wireType)
  1573. }
  1574. var v int
  1575. for shift := uint(0); ; shift += 7 {
  1576. if shift >= 64 {
  1577. return ErrIntOverflowNetworkdb
  1578. }
  1579. if iNdEx >= l {
  1580. return io.ErrUnexpectedEOF
  1581. }
  1582. b := data[iNdEx]
  1583. iNdEx++
  1584. v |= (int(b) & 0x7F) << shift
  1585. if b < 0x80 {
  1586. break
  1587. }
  1588. }
  1589. m.Leaving = bool(v != 0)
  1590. default:
  1591. iNdEx = preIndex
  1592. skippy, err := skipNetworkdb(data[iNdEx:])
  1593. if err != nil {
  1594. return err
  1595. }
  1596. if skippy < 0 {
  1597. return ErrInvalidLengthNetworkdb
  1598. }
  1599. if (iNdEx + skippy) > l {
  1600. return io.ErrUnexpectedEOF
  1601. }
  1602. iNdEx += skippy
  1603. }
  1604. }
  1605. if iNdEx > l {
  1606. return io.ErrUnexpectedEOF
  1607. }
  1608. return nil
  1609. }
  1610. func (m *NetworkPushPull) Unmarshal(data []byte) error {
  1611. l := len(data)
  1612. iNdEx := 0
  1613. for iNdEx < l {
  1614. preIndex := iNdEx
  1615. var wire uint64
  1616. for shift := uint(0); ; shift += 7 {
  1617. if shift >= 64 {
  1618. return ErrIntOverflowNetworkdb
  1619. }
  1620. if iNdEx >= l {
  1621. return io.ErrUnexpectedEOF
  1622. }
  1623. b := data[iNdEx]
  1624. iNdEx++
  1625. wire |= (uint64(b) & 0x7F) << shift
  1626. if b < 0x80 {
  1627. break
  1628. }
  1629. }
  1630. fieldNum := int32(wire >> 3)
  1631. wireType := int(wire & 0x7)
  1632. if wireType == 4 {
  1633. return fmt.Errorf("proto: NetworkPushPull: wiretype end group for non-group")
  1634. }
  1635. if fieldNum <= 0 {
  1636. return fmt.Errorf("proto: NetworkPushPull: illegal tag %d (wire type %d)", fieldNum, wire)
  1637. }
  1638. switch fieldNum {
  1639. case 1:
  1640. if wireType != 0 {
  1641. return fmt.Errorf("proto: wrong wireType = %d for field LTime", wireType)
  1642. }
  1643. m.LTime = 0
  1644. for shift := uint(0); ; shift += 7 {
  1645. if shift >= 64 {
  1646. return ErrIntOverflowNetworkdb
  1647. }
  1648. if iNdEx >= l {
  1649. return io.ErrUnexpectedEOF
  1650. }
  1651. b := data[iNdEx]
  1652. iNdEx++
  1653. m.LTime |= (github_com_hashicorp_serf_serf.LamportTime(b) & 0x7F) << shift
  1654. if b < 0x80 {
  1655. break
  1656. }
  1657. }
  1658. case 2:
  1659. if wireType != 2 {
  1660. return fmt.Errorf("proto: wrong wireType = %d for field Networks", wireType)
  1661. }
  1662. var msglen int
  1663. for shift := uint(0); ; shift += 7 {
  1664. if shift >= 64 {
  1665. return ErrIntOverflowNetworkdb
  1666. }
  1667. if iNdEx >= l {
  1668. return io.ErrUnexpectedEOF
  1669. }
  1670. b := data[iNdEx]
  1671. iNdEx++
  1672. msglen |= (int(b) & 0x7F) << shift
  1673. if b < 0x80 {
  1674. break
  1675. }
  1676. }
  1677. if msglen < 0 {
  1678. return ErrInvalidLengthNetworkdb
  1679. }
  1680. postIndex := iNdEx + msglen
  1681. if postIndex > l {
  1682. return io.ErrUnexpectedEOF
  1683. }
  1684. m.Networks = append(m.Networks, &NetworkEntry{})
  1685. if err := m.Networks[len(m.Networks)-1].Unmarshal(data[iNdEx:postIndex]); err != nil {
  1686. return err
  1687. }
  1688. iNdEx = postIndex
  1689. case 3:
  1690. if wireType != 2 {
  1691. return fmt.Errorf("proto: wrong wireType = %d for field NodeName", wireType)
  1692. }
  1693. var stringLen uint64
  1694. for shift := uint(0); ; shift += 7 {
  1695. if shift >= 64 {
  1696. return ErrIntOverflowNetworkdb
  1697. }
  1698. if iNdEx >= l {
  1699. return io.ErrUnexpectedEOF
  1700. }
  1701. b := data[iNdEx]
  1702. iNdEx++
  1703. stringLen |= (uint64(b) & 0x7F) << shift
  1704. if b < 0x80 {
  1705. break
  1706. }
  1707. }
  1708. intStringLen := int(stringLen)
  1709. if intStringLen < 0 {
  1710. return ErrInvalidLengthNetworkdb
  1711. }
  1712. postIndex := iNdEx + intStringLen
  1713. if postIndex > l {
  1714. return io.ErrUnexpectedEOF
  1715. }
  1716. m.NodeName = string(data[iNdEx:postIndex])
  1717. iNdEx = postIndex
  1718. default:
  1719. iNdEx = preIndex
  1720. skippy, err := skipNetworkdb(data[iNdEx:])
  1721. if err != nil {
  1722. return err
  1723. }
  1724. if skippy < 0 {
  1725. return ErrInvalidLengthNetworkdb
  1726. }
  1727. if (iNdEx + skippy) > l {
  1728. return io.ErrUnexpectedEOF
  1729. }
  1730. iNdEx += skippy
  1731. }
  1732. }
  1733. if iNdEx > l {
  1734. return io.ErrUnexpectedEOF
  1735. }
  1736. return nil
  1737. }
  1738. func (m *TableEvent) Unmarshal(data []byte) error {
  1739. l := len(data)
  1740. iNdEx := 0
  1741. for iNdEx < l {
  1742. preIndex := iNdEx
  1743. var wire uint64
  1744. for shift := uint(0); ; shift += 7 {
  1745. if shift >= 64 {
  1746. return ErrIntOverflowNetworkdb
  1747. }
  1748. if iNdEx >= l {
  1749. return io.ErrUnexpectedEOF
  1750. }
  1751. b := data[iNdEx]
  1752. iNdEx++
  1753. wire |= (uint64(b) & 0x7F) << shift
  1754. if b < 0x80 {
  1755. break
  1756. }
  1757. }
  1758. fieldNum := int32(wire >> 3)
  1759. wireType := int(wire & 0x7)
  1760. if wireType == 4 {
  1761. return fmt.Errorf("proto: TableEvent: wiretype end group for non-group")
  1762. }
  1763. if fieldNum <= 0 {
  1764. return fmt.Errorf("proto: TableEvent: illegal tag %d (wire type %d)", fieldNum, wire)
  1765. }
  1766. switch fieldNum {
  1767. case 1:
  1768. if wireType != 0 {
  1769. return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
  1770. }
  1771. m.Type = 0
  1772. for shift := uint(0); ; shift += 7 {
  1773. if shift >= 64 {
  1774. return ErrIntOverflowNetworkdb
  1775. }
  1776. if iNdEx >= l {
  1777. return io.ErrUnexpectedEOF
  1778. }
  1779. b := data[iNdEx]
  1780. iNdEx++
  1781. m.Type |= (TableEvent_Type(b) & 0x7F) << shift
  1782. if b < 0x80 {
  1783. break
  1784. }
  1785. }
  1786. case 2:
  1787. if wireType != 0 {
  1788. return fmt.Errorf("proto: wrong wireType = %d for field LTime", wireType)
  1789. }
  1790. m.LTime = 0
  1791. for shift := uint(0); ; shift += 7 {
  1792. if shift >= 64 {
  1793. return ErrIntOverflowNetworkdb
  1794. }
  1795. if iNdEx >= l {
  1796. return io.ErrUnexpectedEOF
  1797. }
  1798. b := data[iNdEx]
  1799. iNdEx++
  1800. m.LTime |= (github_com_hashicorp_serf_serf.LamportTime(b) & 0x7F) << shift
  1801. if b < 0x80 {
  1802. break
  1803. }
  1804. }
  1805. case 3:
  1806. if wireType != 2 {
  1807. return fmt.Errorf("proto: wrong wireType = %d for field NodeName", wireType)
  1808. }
  1809. var stringLen uint64
  1810. for shift := uint(0); ; shift += 7 {
  1811. if shift >= 64 {
  1812. return ErrIntOverflowNetworkdb
  1813. }
  1814. if iNdEx >= l {
  1815. return io.ErrUnexpectedEOF
  1816. }
  1817. b := data[iNdEx]
  1818. iNdEx++
  1819. stringLen |= (uint64(b) & 0x7F) << shift
  1820. if b < 0x80 {
  1821. break
  1822. }
  1823. }
  1824. intStringLen := int(stringLen)
  1825. if intStringLen < 0 {
  1826. return ErrInvalidLengthNetworkdb
  1827. }
  1828. postIndex := iNdEx + intStringLen
  1829. if postIndex > l {
  1830. return io.ErrUnexpectedEOF
  1831. }
  1832. m.NodeName = string(data[iNdEx:postIndex])
  1833. iNdEx = postIndex
  1834. case 4:
  1835. if wireType != 2 {
  1836. return fmt.Errorf("proto: wrong wireType = %d for field NetworkID", wireType)
  1837. }
  1838. var stringLen uint64
  1839. for shift := uint(0); ; shift += 7 {
  1840. if shift >= 64 {
  1841. return ErrIntOverflowNetworkdb
  1842. }
  1843. if iNdEx >= l {
  1844. return io.ErrUnexpectedEOF
  1845. }
  1846. b := data[iNdEx]
  1847. iNdEx++
  1848. stringLen |= (uint64(b) & 0x7F) << shift
  1849. if b < 0x80 {
  1850. break
  1851. }
  1852. }
  1853. intStringLen := int(stringLen)
  1854. if intStringLen < 0 {
  1855. return ErrInvalidLengthNetworkdb
  1856. }
  1857. postIndex := iNdEx + intStringLen
  1858. if postIndex > l {
  1859. return io.ErrUnexpectedEOF
  1860. }
  1861. m.NetworkID = string(data[iNdEx:postIndex])
  1862. iNdEx = postIndex
  1863. case 5:
  1864. if wireType != 2 {
  1865. return fmt.Errorf("proto: wrong wireType = %d for field TableName", wireType)
  1866. }
  1867. var stringLen uint64
  1868. for shift := uint(0); ; shift += 7 {
  1869. if shift >= 64 {
  1870. return ErrIntOverflowNetworkdb
  1871. }
  1872. if iNdEx >= l {
  1873. return io.ErrUnexpectedEOF
  1874. }
  1875. b := data[iNdEx]
  1876. iNdEx++
  1877. stringLen |= (uint64(b) & 0x7F) << shift
  1878. if b < 0x80 {
  1879. break
  1880. }
  1881. }
  1882. intStringLen := int(stringLen)
  1883. if intStringLen < 0 {
  1884. return ErrInvalidLengthNetworkdb
  1885. }
  1886. postIndex := iNdEx + intStringLen
  1887. if postIndex > l {
  1888. return io.ErrUnexpectedEOF
  1889. }
  1890. m.TableName = string(data[iNdEx:postIndex])
  1891. iNdEx = postIndex
  1892. case 6:
  1893. if wireType != 2 {
  1894. return fmt.Errorf("proto: wrong wireType = %d for field Key", wireType)
  1895. }
  1896. var stringLen uint64
  1897. for shift := uint(0); ; shift += 7 {
  1898. if shift >= 64 {
  1899. return ErrIntOverflowNetworkdb
  1900. }
  1901. if iNdEx >= l {
  1902. return io.ErrUnexpectedEOF
  1903. }
  1904. b := data[iNdEx]
  1905. iNdEx++
  1906. stringLen |= (uint64(b) & 0x7F) << shift
  1907. if b < 0x80 {
  1908. break
  1909. }
  1910. }
  1911. intStringLen := int(stringLen)
  1912. if intStringLen < 0 {
  1913. return ErrInvalidLengthNetworkdb
  1914. }
  1915. postIndex := iNdEx + intStringLen
  1916. if postIndex > l {
  1917. return io.ErrUnexpectedEOF
  1918. }
  1919. m.Key = string(data[iNdEx:postIndex])
  1920. iNdEx = postIndex
  1921. case 7:
  1922. if wireType != 2 {
  1923. return fmt.Errorf("proto: wrong wireType = %d for field Value", wireType)
  1924. }
  1925. var byteLen int
  1926. for shift := uint(0); ; shift += 7 {
  1927. if shift >= 64 {
  1928. return ErrIntOverflowNetworkdb
  1929. }
  1930. if iNdEx >= l {
  1931. return io.ErrUnexpectedEOF
  1932. }
  1933. b := data[iNdEx]
  1934. iNdEx++
  1935. byteLen |= (int(b) & 0x7F) << shift
  1936. if b < 0x80 {
  1937. break
  1938. }
  1939. }
  1940. if byteLen < 0 {
  1941. return ErrInvalidLengthNetworkdb
  1942. }
  1943. postIndex := iNdEx + byteLen
  1944. if postIndex > l {
  1945. return io.ErrUnexpectedEOF
  1946. }
  1947. m.Value = append(m.Value[:0], data[iNdEx:postIndex]...)
  1948. if m.Value == nil {
  1949. m.Value = []byte{}
  1950. }
  1951. iNdEx = postIndex
  1952. default:
  1953. iNdEx = preIndex
  1954. skippy, err := skipNetworkdb(data[iNdEx:])
  1955. if err != nil {
  1956. return err
  1957. }
  1958. if skippy < 0 {
  1959. return ErrInvalidLengthNetworkdb
  1960. }
  1961. if (iNdEx + skippy) > l {
  1962. return io.ErrUnexpectedEOF
  1963. }
  1964. iNdEx += skippy
  1965. }
  1966. }
  1967. if iNdEx > l {
  1968. return io.ErrUnexpectedEOF
  1969. }
  1970. return nil
  1971. }
  1972. func (m *BulkSyncMessage) Unmarshal(data []byte) error {
  1973. l := len(data)
  1974. iNdEx := 0
  1975. for iNdEx < l {
  1976. preIndex := iNdEx
  1977. var wire uint64
  1978. for shift := uint(0); ; shift += 7 {
  1979. if shift >= 64 {
  1980. return ErrIntOverflowNetworkdb
  1981. }
  1982. if iNdEx >= l {
  1983. return io.ErrUnexpectedEOF
  1984. }
  1985. b := data[iNdEx]
  1986. iNdEx++
  1987. wire |= (uint64(b) & 0x7F) << shift
  1988. if b < 0x80 {
  1989. break
  1990. }
  1991. }
  1992. fieldNum := int32(wire >> 3)
  1993. wireType := int(wire & 0x7)
  1994. if wireType == 4 {
  1995. return fmt.Errorf("proto: BulkSyncMessage: wiretype end group for non-group")
  1996. }
  1997. if fieldNum <= 0 {
  1998. return fmt.Errorf("proto: BulkSyncMessage: illegal tag %d (wire type %d)", fieldNum, wire)
  1999. }
  2000. switch fieldNum {
  2001. case 1:
  2002. if wireType != 0 {
  2003. return fmt.Errorf("proto: wrong wireType = %d for field LTime", wireType)
  2004. }
  2005. m.LTime = 0
  2006. for shift := uint(0); ; shift += 7 {
  2007. if shift >= 64 {
  2008. return ErrIntOverflowNetworkdb
  2009. }
  2010. if iNdEx >= l {
  2011. return io.ErrUnexpectedEOF
  2012. }
  2013. b := data[iNdEx]
  2014. iNdEx++
  2015. m.LTime |= (github_com_hashicorp_serf_serf.LamportTime(b) & 0x7F) << shift
  2016. if b < 0x80 {
  2017. break
  2018. }
  2019. }
  2020. case 2:
  2021. if wireType != 0 {
  2022. return fmt.Errorf("proto: wrong wireType = %d for field Unsolicited", wireType)
  2023. }
  2024. var v int
  2025. for shift := uint(0); ; shift += 7 {
  2026. if shift >= 64 {
  2027. return ErrIntOverflowNetworkdb
  2028. }
  2029. if iNdEx >= l {
  2030. return io.ErrUnexpectedEOF
  2031. }
  2032. b := data[iNdEx]
  2033. iNdEx++
  2034. v |= (int(b) & 0x7F) << shift
  2035. if b < 0x80 {
  2036. break
  2037. }
  2038. }
  2039. m.Unsolicited = bool(v != 0)
  2040. case 3:
  2041. if wireType != 2 {
  2042. return fmt.Errorf("proto: wrong wireType = %d for field NodeName", wireType)
  2043. }
  2044. var stringLen uint64
  2045. for shift := uint(0); ; shift += 7 {
  2046. if shift >= 64 {
  2047. return ErrIntOverflowNetworkdb
  2048. }
  2049. if iNdEx >= l {
  2050. return io.ErrUnexpectedEOF
  2051. }
  2052. b := data[iNdEx]
  2053. iNdEx++
  2054. stringLen |= (uint64(b) & 0x7F) << shift
  2055. if b < 0x80 {
  2056. break
  2057. }
  2058. }
  2059. intStringLen := int(stringLen)
  2060. if intStringLen < 0 {
  2061. return ErrInvalidLengthNetworkdb
  2062. }
  2063. postIndex := iNdEx + intStringLen
  2064. if postIndex > l {
  2065. return io.ErrUnexpectedEOF
  2066. }
  2067. m.NodeName = string(data[iNdEx:postIndex])
  2068. iNdEx = postIndex
  2069. case 4:
  2070. if wireType != 2 {
  2071. return fmt.Errorf("proto: wrong wireType = %d for field Networks", wireType)
  2072. }
  2073. var stringLen uint64
  2074. for shift := uint(0); ; shift += 7 {
  2075. if shift >= 64 {
  2076. return ErrIntOverflowNetworkdb
  2077. }
  2078. if iNdEx >= l {
  2079. return io.ErrUnexpectedEOF
  2080. }
  2081. b := data[iNdEx]
  2082. iNdEx++
  2083. stringLen |= (uint64(b) & 0x7F) << shift
  2084. if b < 0x80 {
  2085. break
  2086. }
  2087. }
  2088. intStringLen := int(stringLen)
  2089. if intStringLen < 0 {
  2090. return ErrInvalidLengthNetworkdb
  2091. }
  2092. postIndex := iNdEx + intStringLen
  2093. if postIndex > l {
  2094. return io.ErrUnexpectedEOF
  2095. }
  2096. m.Networks = append(m.Networks, string(data[iNdEx:postIndex]))
  2097. iNdEx = postIndex
  2098. case 5:
  2099. if wireType != 2 {
  2100. return fmt.Errorf("proto: wrong wireType = %d for field Payload", wireType)
  2101. }
  2102. var byteLen int
  2103. for shift := uint(0); ; shift += 7 {
  2104. if shift >= 64 {
  2105. return ErrIntOverflowNetworkdb
  2106. }
  2107. if iNdEx >= l {
  2108. return io.ErrUnexpectedEOF
  2109. }
  2110. b := data[iNdEx]
  2111. iNdEx++
  2112. byteLen |= (int(b) & 0x7F) << shift
  2113. if b < 0x80 {
  2114. break
  2115. }
  2116. }
  2117. if byteLen < 0 {
  2118. return ErrInvalidLengthNetworkdb
  2119. }
  2120. postIndex := iNdEx + byteLen
  2121. if postIndex > l {
  2122. return io.ErrUnexpectedEOF
  2123. }
  2124. m.Payload = append(m.Payload[:0], data[iNdEx:postIndex]...)
  2125. if m.Payload == nil {
  2126. m.Payload = []byte{}
  2127. }
  2128. iNdEx = postIndex
  2129. default:
  2130. iNdEx = preIndex
  2131. skippy, err := skipNetworkdb(data[iNdEx:])
  2132. if err != nil {
  2133. return err
  2134. }
  2135. if skippy < 0 {
  2136. return ErrInvalidLengthNetworkdb
  2137. }
  2138. if (iNdEx + skippy) > l {
  2139. return io.ErrUnexpectedEOF
  2140. }
  2141. iNdEx += skippy
  2142. }
  2143. }
  2144. if iNdEx > l {
  2145. return io.ErrUnexpectedEOF
  2146. }
  2147. return nil
  2148. }
  2149. func (m *CompoundMessage) Unmarshal(data []byte) error {
  2150. l := len(data)
  2151. iNdEx := 0
  2152. for iNdEx < l {
  2153. preIndex := iNdEx
  2154. var wire uint64
  2155. for shift := uint(0); ; shift += 7 {
  2156. if shift >= 64 {
  2157. return ErrIntOverflowNetworkdb
  2158. }
  2159. if iNdEx >= l {
  2160. return io.ErrUnexpectedEOF
  2161. }
  2162. b := data[iNdEx]
  2163. iNdEx++
  2164. wire |= (uint64(b) & 0x7F) << shift
  2165. if b < 0x80 {
  2166. break
  2167. }
  2168. }
  2169. fieldNum := int32(wire >> 3)
  2170. wireType := int(wire & 0x7)
  2171. if wireType == 4 {
  2172. return fmt.Errorf("proto: CompoundMessage: wiretype end group for non-group")
  2173. }
  2174. if fieldNum <= 0 {
  2175. return fmt.Errorf("proto: CompoundMessage: illegal tag %d (wire type %d)", fieldNum, wire)
  2176. }
  2177. switch fieldNum {
  2178. case 1:
  2179. if wireType != 2 {
  2180. return fmt.Errorf("proto: wrong wireType = %d for field Messages", wireType)
  2181. }
  2182. var msglen int
  2183. for shift := uint(0); ; shift += 7 {
  2184. if shift >= 64 {
  2185. return ErrIntOverflowNetworkdb
  2186. }
  2187. if iNdEx >= l {
  2188. return io.ErrUnexpectedEOF
  2189. }
  2190. b := data[iNdEx]
  2191. iNdEx++
  2192. msglen |= (int(b) & 0x7F) << shift
  2193. if b < 0x80 {
  2194. break
  2195. }
  2196. }
  2197. if msglen < 0 {
  2198. return ErrInvalidLengthNetworkdb
  2199. }
  2200. postIndex := iNdEx + msglen
  2201. if postIndex > l {
  2202. return io.ErrUnexpectedEOF
  2203. }
  2204. m.Messages = append(m.Messages, &CompoundMessage_SimpleMessage{})
  2205. if err := m.Messages[len(m.Messages)-1].Unmarshal(data[iNdEx:postIndex]); err != nil {
  2206. return err
  2207. }
  2208. iNdEx = postIndex
  2209. default:
  2210. iNdEx = preIndex
  2211. skippy, err := skipNetworkdb(data[iNdEx:])
  2212. if err != nil {
  2213. return err
  2214. }
  2215. if skippy < 0 {
  2216. return ErrInvalidLengthNetworkdb
  2217. }
  2218. if (iNdEx + skippy) > l {
  2219. return io.ErrUnexpectedEOF
  2220. }
  2221. iNdEx += skippy
  2222. }
  2223. }
  2224. if iNdEx > l {
  2225. return io.ErrUnexpectedEOF
  2226. }
  2227. return nil
  2228. }
  2229. func (m *CompoundMessage_SimpleMessage) Unmarshal(data []byte) error {
  2230. l := len(data)
  2231. iNdEx := 0
  2232. for iNdEx < l {
  2233. preIndex := iNdEx
  2234. var wire uint64
  2235. for shift := uint(0); ; shift += 7 {
  2236. if shift >= 64 {
  2237. return ErrIntOverflowNetworkdb
  2238. }
  2239. if iNdEx >= l {
  2240. return io.ErrUnexpectedEOF
  2241. }
  2242. b := data[iNdEx]
  2243. iNdEx++
  2244. wire |= (uint64(b) & 0x7F) << shift
  2245. if b < 0x80 {
  2246. break
  2247. }
  2248. }
  2249. fieldNum := int32(wire >> 3)
  2250. wireType := int(wire & 0x7)
  2251. if wireType == 4 {
  2252. return fmt.Errorf("proto: SimpleMessage: wiretype end group for non-group")
  2253. }
  2254. if fieldNum <= 0 {
  2255. return fmt.Errorf("proto: SimpleMessage: illegal tag %d (wire type %d)", fieldNum, wire)
  2256. }
  2257. switch fieldNum {
  2258. case 1:
  2259. if wireType != 2 {
  2260. return fmt.Errorf("proto: wrong wireType = %d for field Payload", wireType)
  2261. }
  2262. var byteLen int
  2263. for shift := uint(0); ; shift += 7 {
  2264. if shift >= 64 {
  2265. return ErrIntOverflowNetworkdb
  2266. }
  2267. if iNdEx >= l {
  2268. return io.ErrUnexpectedEOF
  2269. }
  2270. b := data[iNdEx]
  2271. iNdEx++
  2272. byteLen |= (int(b) & 0x7F) << shift
  2273. if b < 0x80 {
  2274. break
  2275. }
  2276. }
  2277. if byteLen < 0 {
  2278. return ErrInvalidLengthNetworkdb
  2279. }
  2280. postIndex := iNdEx + byteLen
  2281. if postIndex > l {
  2282. return io.ErrUnexpectedEOF
  2283. }
  2284. m.Payload = append(m.Payload[:0], data[iNdEx:postIndex]...)
  2285. if m.Payload == nil {
  2286. m.Payload = []byte{}
  2287. }
  2288. iNdEx = postIndex
  2289. default:
  2290. iNdEx = preIndex
  2291. skippy, err := skipNetworkdb(data[iNdEx:])
  2292. if err != nil {
  2293. return err
  2294. }
  2295. if skippy < 0 {
  2296. return ErrInvalidLengthNetworkdb
  2297. }
  2298. if (iNdEx + skippy) > l {
  2299. return io.ErrUnexpectedEOF
  2300. }
  2301. iNdEx += skippy
  2302. }
  2303. }
  2304. if iNdEx > l {
  2305. return io.ErrUnexpectedEOF
  2306. }
  2307. return nil
  2308. }
  2309. func skipNetworkdb(data []byte) (n int, err error) {
  2310. l := len(data)
  2311. iNdEx := 0
  2312. for iNdEx < l {
  2313. var wire uint64
  2314. for shift := uint(0); ; shift += 7 {
  2315. if shift >= 64 {
  2316. return 0, ErrIntOverflowNetworkdb
  2317. }
  2318. if iNdEx >= l {
  2319. return 0, io.ErrUnexpectedEOF
  2320. }
  2321. b := data[iNdEx]
  2322. iNdEx++
  2323. wire |= (uint64(b) & 0x7F) << shift
  2324. if b < 0x80 {
  2325. break
  2326. }
  2327. }
  2328. wireType := int(wire & 0x7)
  2329. switch wireType {
  2330. case 0:
  2331. for shift := uint(0); ; shift += 7 {
  2332. if shift >= 64 {
  2333. return 0, ErrIntOverflowNetworkdb
  2334. }
  2335. if iNdEx >= l {
  2336. return 0, io.ErrUnexpectedEOF
  2337. }
  2338. iNdEx++
  2339. if data[iNdEx-1] < 0x80 {
  2340. break
  2341. }
  2342. }
  2343. return iNdEx, nil
  2344. case 1:
  2345. iNdEx += 8
  2346. return iNdEx, nil
  2347. case 2:
  2348. var length int
  2349. for shift := uint(0); ; shift += 7 {
  2350. if shift >= 64 {
  2351. return 0, ErrIntOverflowNetworkdb
  2352. }
  2353. if iNdEx >= l {
  2354. return 0, io.ErrUnexpectedEOF
  2355. }
  2356. b := data[iNdEx]
  2357. iNdEx++
  2358. length |= (int(b) & 0x7F) << shift
  2359. if b < 0x80 {
  2360. break
  2361. }
  2362. }
  2363. iNdEx += length
  2364. if length < 0 {
  2365. return 0, ErrInvalidLengthNetworkdb
  2366. }
  2367. return iNdEx, nil
  2368. case 3:
  2369. for {
  2370. var innerWire uint64
  2371. var start int = iNdEx
  2372. for shift := uint(0); ; shift += 7 {
  2373. if shift >= 64 {
  2374. return 0, ErrIntOverflowNetworkdb
  2375. }
  2376. if iNdEx >= l {
  2377. return 0, io.ErrUnexpectedEOF
  2378. }
  2379. b := data[iNdEx]
  2380. iNdEx++
  2381. innerWire |= (uint64(b) & 0x7F) << shift
  2382. if b < 0x80 {
  2383. break
  2384. }
  2385. }
  2386. innerWireType := int(innerWire & 0x7)
  2387. if innerWireType == 4 {
  2388. break
  2389. }
  2390. next, err := skipNetworkdb(data[start:])
  2391. if err != nil {
  2392. return 0, err
  2393. }
  2394. iNdEx = start + next
  2395. }
  2396. return iNdEx, nil
  2397. case 4:
  2398. return iNdEx, nil
  2399. case 5:
  2400. iNdEx += 4
  2401. return iNdEx, nil
  2402. default:
  2403. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  2404. }
  2405. }
  2406. panic("unreachable")
  2407. }
  2408. var (
  2409. ErrInvalidLengthNetworkdb = fmt.Errorf("proto: negative length found during unmarshaling")
  2410. ErrIntOverflowNetworkdb = fmt.Errorf("proto: integer overflow")
  2411. )
  2412. var fileDescriptorNetworkdb = []byte{
  2413. // 887 bytes of a gzipped FileDescriptorProto
  2414. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xcc, 0x96, 0xc1, 0x6e, 0xe3, 0x44,
  2415. 0x18, 0xc7, 0xeb, 0xc4, 0x49, 0xe3, 0xaf, 0x0d, 0x1b, 0xbc, 0xdd, 0xad, 0xd7, 0x0b, 0x49, 0x31,
  2416. 0xcb, 0x2a, 0x44, 0xe0, 0xa2, 0xee, 0x13, 0x24, 0xb1, 0x05, 0xd9, 0xf5, 0x3a, 0x91, 0x93, 0x14,
  2417. 0x71, 0x8a, 0x9c, 0x78, 0x48, 0xac, 0x3a, 0xb6, 0x15, 0x3b, 0x45, 0x39, 0x81, 0x38, 0xad, 0x78,
  2418. 0x07, 0x4e, 0xcb, 0x99, 0x07, 0xe0, 0xc0, 0x89, 0xc3, 0x8a, 0x13, 0xdc, 0x10, 0x87, 0x8a, 0xee,
  2419. 0x13, 0xf0, 0x08, 0x8c, 0xc7, 0x76, 0x32, 0x4e, 0xa3, 0x5e, 0x40, 0xc0, 0xc1, 0xad, 0x67, 0xe6,
  2420. 0xe7, 0xcf, 0xdf, 0xf7, 0x9f, 0xff, 0xe7, 0x09, 0xdc, 0x71, 0x51, 0xf8, 0x85, 0xb7, 0xb8, 0xb0,
  2421. 0xc6, 0xb2, 0xbf, 0xf0, 0x42, 0x8f, 0xe7, 0xd6, 0x13, 0xe2, 0xd1, 0xd4, 0x9b, 0x7a, 0x64, 0xf6,
  2422. 0x34, 0xba, 0x8b, 0x01, 0xa9, 0x0b, 0xe5, 0x8f, 0xbd, 0x20, 0xb0, 0xfd, 0xe7, 0x28, 0x08, 0xcc,
  2423. 0x29, 0xe2, 0x1b, 0xc0, 0x86, 0x2b, 0x1f, 0x09, 0xcc, 0x09, 0x53, 0x7f, 0xe3, 0xec, 0xbe, 0xbc,
  2424. 0x89, 0x98, 0x10, 0x03, 0xbc, 0x6a, 0x10, 0x86, 0xe7, 0x81, 0xb5, 0xcc, 0xd0, 0x14, 0x72, 0x98,
  2425. 0x3d, 0x34, 0xc8, 0xbd, 0xf4, 0x32, 0x07, 0x9c, 0xee, 0x59, 0x48, 0xbd, 0x44, 0x6e, 0xc8, 0x7f,
  2426. 0x98, 0x89, 0xf6, 0x80, 0x8a, 0xb6, 0x66, 0x64, 0x2a, 0x60, 0x07, 0x8a, 0xce, 0x28, 0xb4, 0xe7,
  2427. 0x88, 0x84, 0x64, 0x5b, 0x67, 0xaf, 0xae, 0x6a, 0x7b, 0xbf, 0x5f, 0xd5, 0x1a, 0x53, 0x3b, 0x9c,
  2428. 0x2d, 0xc7, 0xf2, 0xc4, 0x9b, 0x9f, 0xce, 0xcc, 0x60, 0x66, 0x4f, 0xbc, 0x85, 0x7f, 0x1a, 0xa0,
  2429. 0xc5, 0xe7, 0xe4, 0x8f, 0xac, 0x99, 0x73, 0xdf, 0x5b, 0x84, 0x03, 0xfc, 0xa4, 0x51, 0x70, 0xa2,
  2430. 0x7f, 0xfc, 0x43, 0xe0, 0x5c, 0xfc, 0x8a, 0x91, 0x6b, 0xe2, 0x68, 0x79, 0x1c, 0x8d, 0x33, 0x4a,
  2431. 0xd1, 0x84, 0x8e, 0xc7, 0xd2, 0x97, 0xc0, 0x46, 0x6f, 0xe5, 0xdf, 0x83, 0xfd, 0x8e, 0x7e, 0xde,
  2432. 0xd4, 0x3a, 0x4a, 0x65, 0x4f, 0x14, 0xbe, 0xf9, 0xf6, 0xe4, 0x68, 0x9d, 0x56, 0xb4, 0xde, 0x71,
  2433. 0x2f, 0x4d, 0xc7, 0xb6, 0xf8, 0x1a, 0xb0, 0x4f, 0xbb, 0x1d, 0xbd, 0xc2, 0x88, 0xf7, 0x30, 0xf3,
  2434. 0x66, 0x86, 0x79, 0xea, 0xd9, 0x2e, 0xff, 0x0e, 0x14, 0x34, 0xb5, 0x79, 0xae, 0x56, 0x72, 0xe2,
  2435. 0x7d, 0x4c, 0xf0, 0x19, 0x42, 0x43, 0xe6, 0x25, 0x12, 0x0f, 0x5f, 0xbc, 0xac, 0xee, 0xfd, 0xf0,
  2436. 0x5d, 0x95, 0xbc, 0x58, 0xba, 0xce, 0xc1, 0xa1, 0x1e, 0x6b, 0x11, 0x0b, 0xf5, 0x51, 0x46, 0xa8,
  2437. 0xb7, 0x68, 0xa1, 0x28, 0xec, 0x3f, 0xd0, 0x8a, 0xff, 0x00, 0x20, 0x49, 0x66, 0x64, 0x5b, 0x02,
  2438. 0x1b, 0xad, 0xb6, 0xca, 0xaf, 0xaf, 0x6a, 0x5c, 0x92, 0x58, 0x47, 0x31, 0x52, 0x97, 0x75, 0x2c,
  2439. 0xe9, 0x05, 0x93, 0x48, 0x5b, 0xa7, 0xa5, 0x7d, 0x88, 0x45, 0x39, 0xa6, 0x0b, 0xa1, 0xd5, 0x95,
  2440. 0xd6, 0xea, 0xc6, 0x3b, 0xb0, 0x85, 0x11, 0x81, 0x1f, 0x6d, 0x04, 0x7e, 0x80, 0xa1, 0x7b, 0xdb,
  2441. 0xd0, 0x2e, 0x8d, 0x7f, 0x64, 0x36, 0x1a, 0xbb, 0xe1, 0x62, 0xb5, 0x55, 0x09, 0x73, 0x7b, 0x25,
  2442. 0xff, 0x9a, 0xbe, 0x02, 0xec, 0x3b, 0x38, 0x7b, 0xdb, 0x9d, 0x12, 0x71, 0x4b, 0x46, 0x3a, 0x94,
  2443. 0xbe, 0x67, 0xe0, 0x4e, 0x92, 0x5a, 0x6f, 0x19, 0xcc, 0x7a, 0x4b, 0xc7, 0xa1, 0xb2, 0x62, 0xfe,
  2444. 0x6e, 0x56, 0x4f, 0xa0, 0x94, 0x54, 0x1b, 0xe0, 0x12, 0xf3, 0xf5, 0x83, 0xb3, 0xe3, 0x1d, 0xb6,
  2445. 0x8b, 0x94, 0x33, 0xd6, 0xe0, 0xed, 0x6d, 0xf5, 0x73, 0x1e, 0x60, 0x60, 0x8e, 0x9d, 0xa4, 0xf9,
  2446. 0xe5, 0x8c, 0xa7, 0x45, 0x2a, 0xf8, 0x06, 0xfa, 0xdf, 0x3b, 0x9a, 0x7f, 0x1b, 0x20, 0x8c, 0xd2,
  2447. 0x8d, 0x63, 0x15, 0x48, 0x2c, 0x8e, 0xcc, 0x90, 0x60, 0x15, 0xc8, 0x5f, 0xa0, 0x95, 0x50, 0x24,
  2448. 0xf3, 0xd1, 0x2d, 0x7f, 0x04, 0x05, 0x6c, 0xec, 0x25, 0x12, 0xf6, 0xc9, 0x67, 0x31, 0x1e, 0x44,
  2449. 0x9b, 0x19, 0x37, 0xc6, 0x63, 0xba, 0x31, 0x88, 0x99, 0x37, 0x6a, 0xd0, 0x6d, 0xf1, 0x08, 0x8a,
  2450. 0x6d, 0x43, 0x6d, 0x0e, 0xd4, 0xb4, 0x31, 0xb2, 0x58, 0x7b, 0x81, 0xcc, 0x10, 0x45, 0xd4, 0xb0,
  2451. 0xa7, 0x44, 0x54, 0x6e, 0x17, 0x35, 0xf4, 0xad, 0x84, 0x52, 0x54, 0x4d, 0xc5, 0x54, 0x7e, 0x17,
  2452. 0xa5, 0x20, 0x07, 0x85, 0xdb, 0xed, 0xf3, 0x2b, 0x76, 0x5f, 0x6b, 0xe9, 0x5c, 0xf4, 0x57, 0xee,
  2453. 0x24, 0x3d, 0x1c, 0xfe, 0x41, 0xf7, 0x9d, 0xc0, 0xc1, 0xd2, 0x0d, 0x3c, 0xc7, 0x9e, 0xd8, 0x21,
  2454. 0xb2, 0xc8, 0x8e, 0x97, 0x0c, 0x7a, 0xea, 0xf6, 0x3d, 0x14, 0x29, 0xf3, 0xb2, 0xd8, 0xbc, 0x1c,
  2455. 0xe5, 0x51, 0xdc, 0x51, 0xbe, 0xb9, 0x72, 0x3c, 0xd3, 0x22, 0xdb, 0x75, 0x68, 0xa4, 0x43, 0xe9,
  2456. 0x6b, 0x5c, 0x53, 0xdb, 0xc3, 0xb9, 0x2c, 0x5d, 0x2b, 0xad, 0x49, 0x81, 0xd2, 0x3c, 0xbe, 0x0d,
  2457. 0x70, 0x55, 0x51, 0x1b, 0xd4, 0x29, 0xa7, 0x6e, 0xd1, 0x72, 0xdf, 0x9e, 0xfb, 0x0e, 0x4a, 0x46,
  2458. 0xc6, 0xfa, 0x49, 0xf1, 0x7d, 0x28, 0x67, 0x96, 0xa2, 0x24, 0x7a, 0x49, 0x12, 0x4c, 0x26, 0x89,
  2459. 0xc6, 0x4f, 0x39, 0x38, 0xa0, 0xce, 0x52, 0xfe, 0x5d, 0xda, 0x10, 0xe4, 0xf8, 0xa0, 0x56, 0x53,
  2460. 0x37, 0xc8, 0x50, 0xd6, 0xd5, 0xc1, 0xa7, 0x5d, 0xe3, 0xd9, 0x48, 0x3d, 0x57, 0xf5, 0x01, 0x36,
  2461. 0x05, 0xf9, 0xa8, 0x52, 0x68, 0xe6, 0x3c, 0x69, 0xc0, 0xc1, 0xa0, 0xd9, 0xd2, 0xd4, 0x84, 0x4e,
  2462. 0x3e, 0x9b, 0x14, 0x4d, 0xf5, 0xe9, 0x63, 0xe0, 0x7a, 0xc3, 0xfe, 0x27, 0xa3, 0xde, 0x50, 0xd3,
  2463. 0xb0, 0x41, 0x8e, 0x31, 0x79, 0x97, 0x22, 0xd7, 0xdf, 0x1e, 0xcc, 0xb5, 0x86, 0xda, 0xb3, 0x51,
  2464. 0xff, 0x33, 0xbd, 0x5d, 0x61, 0x6f, 0x70, 0xa9, 0x59, 0xf0, 0xa9, 0x5a, 0x6a, 0x77, 0x9f, 0xf7,
  2465. 0xba, 0x43, 0x5d, 0xa9, 0x14, 0x6e, 0x60, 0xa9, 0xa2, 0xf8, 0x84, 0x00, 0xbd, 0xab, 0xa4, 0x19,
  2466. 0x16, 0x63, 0x63, 0xd2, 0xf5, 0xa4, 0x87, 0xa8, 0x78, 0x37, 0x31, 0x26, 0x2d, 0x5b, 0x4b, 0xf8,
  2467. 0xed, 0xba, 0xba, 0xf7, 0xe7, 0x75, 0x95, 0xf9, 0xea, 0x75, 0x95, 0x79, 0x85, 0xaf, 0x5f, 0xf0,
  2468. 0xf5, 0x07, 0xbe, 0xc6, 0x45, 0xf2, 0xd3, 0xe6, 0xc9, 0x5f, 0x01, 0x00, 0x00, 0xff, 0xff, 0x21,
  2469. 0x78, 0x72, 0xc3, 0x0e, 0x09, 0x00, 0x00,
  2470. }