membership.pb.go 36 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454
  1. // Code generated by protoc-gen-gogo. DO NOT EDIT.
  2. // source: membership.proto
  3. package membershippb
  4. import (
  5. fmt "fmt"
  6. io "io"
  7. math "math"
  8. math_bits "math/bits"
  9. _ "github.com/gogo/protobuf/gogoproto"
  10. proto "github.com/golang/protobuf/proto"
  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.ProtoPackageIsVersion3 // please upgrade the proto package
  21. // RaftAttributes represents the raft related attributes of an etcd member.
  22. type RaftAttributes struct {
  23. // peerURLs is the list of peers in the raft cluster.
  24. PeerUrls []string `protobuf:"bytes,1,rep,name=peer_urls,json=peerUrls,proto3" json:"peer_urls,omitempty"`
  25. // isLearner indicates if the member is raft learner.
  26. IsLearner bool `protobuf:"varint,2,opt,name=is_learner,json=isLearner,proto3" json:"is_learner,omitempty"`
  27. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  28. XXX_unrecognized []byte `json:"-"`
  29. XXX_sizecache int32 `json:"-"`
  30. }
  31. func (m *RaftAttributes) Reset() { *m = RaftAttributes{} }
  32. func (m *RaftAttributes) String() string { return proto.CompactTextString(m) }
  33. func (*RaftAttributes) ProtoMessage() {}
  34. func (*RaftAttributes) Descriptor() ([]byte, []int) {
  35. return fileDescriptor_949fe0d019050ef5, []int{0}
  36. }
  37. func (m *RaftAttributes) XXX_Unmarshal(b []byte) error {
  38. return m.Unmarshal(b)
  39. }
  40. func (m *RaftAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  41. if deterministic {
  42. return xxx_messageInfo_RaftAttributes.Marshal(b, m, deterministic)
  43. } else {
  44. b = b[:cap(b)]
  45. n, err := m.MarshalToSizedBuffer(b)
  46. if err != nil {
  47. return nil, err
  48. }
  49. return b[:n], nil
  50. }
  51. }
  52. func (m *RaftAttributes) XXX_Merge(src proto.Message) {
  53. xxx_messageInfo_RaftAttributes.Merge(m, src)
  54. }
  55. func (m *RaftAttributes) XXX_Size() int {
  56. return m.Size()
  57. }
  58. func (m *RaftAttributes) XXX_DiscardUnknown() {
  59. xxx_messageInfo_RaftAttributes.DiscardUnknown(m)
  60. }
  61. var xxx_messageInfo_RaftAttributes proto.InternalMessageInfo
  62. // Attributes represents all the non-raft related attributes of an etcd member.
  63. type Attributes struct {
  64. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
  65. ClientUrls []string `protobuf:"bytes,2,rep,name=client_urls,json=clientUrls,proto3" json:"client_urls,omitempty"`
  66. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  67. XXX_unrecognized []byte `json:"-"`
  68. XXX_sizecache int32 `json:"-"`
  69. }
  70. func (m *Attributes) Reset() { *m = Attributes{} }
  71. func (m *Attributes) String() string { return proto.CompactTextString(m) }
  72. func (*Attributes) ProtoMessage() {}
  73. func (*Attributes) Descriptor() ([]byte, []int) {
  74. return fileDescriptor_949fe0d019050ef5, []int{1}
  75. }
  76. func (m *Attributes) XXX_Unmarshal(b []byte) error {
  77. return m.Unmarshal(b)
  78. }
  79. func (m *Attributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  80. if deterministic {
  81. return xxx_messageInfo_Attributes.Marshal(b, m, deterministic)
  82. } else {
  83. b = b[:cap(b)]
  84. n, err := m.MarshalToSizedBuffer(b)
  85. if err != nil {
  86. return nil, err
  87. }
  88. return b[:n], nil
  89. }
  90. }
  91. func (m *Attributes) XXX_Merge(src proto.Message) {
  92. xxx_messageInfo_Attributes.Merge(m, src)
  93. }
  94. func (m *Attributes) XXX_Size() int {
  95. return m.Size()
  96. }
  97. func (m *Attributes) XXX_DiscardUnknown() {
  98. xxx_messageInfo_Attributes.DiscardUnknown(m)
  99. }
  100. var xxx_messageInfo_Attributes proto.InternalMessageInfo
  101. type Member struct {
  102. ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
  103. RaftAttributes *RaftAttributes `protobuf:"bytes,2,opt,name=raft_attributes,json=raftAttributes,proto3" json:"raft_attributes,omitempty"`
  104. MemberAttributes *Attributes `protobuf:"bytes,3,opt,name=member_attributes,json=memberAttributes,proto3" json:"member_attributes,omitempty"`
  105. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  106. XXX_unrecognized []byte `json:"-"`
  107. XXX_sizecache int32 `json:"-"`
  108. }
  109. func (m *Member) Reset() { *m = Member{} }
  110. func (m *Member) String() string { return proto.CompactTextString(m) }
  111. func (*Member) ProtoMessage() {}
  112. func (*Member) Descriptor() ([]byte, []int) {
  113. return fileDescriptor_949fe0d019050ef5, []int{2}
  114. }
  115. func (m *Member) XXX_Unmarshal(b []byte) error {
  116. return m.Unmarshal(b)
  117. }
  118. func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  119. if deterministic {
  120. return xxx_messageInfo_Member.Marshal(b, m, deterministic)
  121. } else {
  122. b = b[:cap(b)]
  123. n, err := m.MarshalToSizedBuffer(b)
  124. if err != nil {
  125. return nil, err
  126. }
  127. return b[:n], nil
  128. }
  129. }
  130. func (m *Member) XXX_Merge(src proto.Message) {
  131. xxx_messageInfo_Member.Merge(m, src)
  132. }
  133. func (m *Member) XXX_Size() int {
  134. return m.Size()
  135. }
  136. func (m *Member) XXX_DiscardUnknown() {
  137. xxx_messageInfo_Member.DiscardUnknown(m)
  138. }
  139. var xxx_messageInfo_Member proto.InternalMessageInfo
  140. type ClusterVersionSetRequest struct {
  141. Ver string `protobuf:"bytes,1,opt,name=ver,proto3" json:"ver,omitempty"`
  142. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  143. XXX_unrecognized []byte `json:"-"`
  144. XXX_sizecache int32 `json:"-"`
  145. }
  146. func (m *ClusterVersionSetRequest) Reset() { *m = ClusterVersionSetRequest{} }
  147. func (m *ClusterVersionSetRequest) String() string { return proto.CompactTextString(m) }
  148. func (*ClusterVersionSetRequest) ProtoMessage() {}
  149. func (*ClusterVersionSetRequest) Descriptor() ([]byte, []int) {
  150. return fileDescriptor_949fe0d019050ef5, []int{3}
  151. }
  152. func (m *ClusterVersionSetRequest) XXX_Unmarshal(b []byte) error {
  153. return m.Unmarshal(b)
  154. }
  155. func (m *ClusterVersionSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  156. if deterministic {
  157. return xxx_messageInfo_ClusterVersionSetRequest.Marshal(b, m, deterministic)
  158. } else {
  159. b = b[:cap(b)]
  160. n, err := m.MarshalToSizedBuffer(b)
  161. if err != nil {
  162. return nil, err
  163. }
  164. return b[:n], nil
  165. }
  166. }
  167. func (m *ClusterVersionSetRequest) XXX_Merge(src proto.Message) {
  168. xxx_messageInfo_ClusterVersionSetRequest.Merge(m, src)
  169. }
  170. func (m *ClusterVersionSetRequest) XXX_Size() int {
  171. return m.Size()
  172. }
  173. func (m *ClusterVersionSetRequest) XXX_DiscardUnknown() {
  174. xxx_messageInfo_ClusterVersionSetRequest.DiscardUnknown(m)
  175. }
  176. var xxx_messageInfo_ClusterVersionSetRequest proto.InternalMessageInfo
  177. type ClusterMemberAttrSetRequest struct {
  178. Member_ID uint64 `protobuf:"varint,1,opt,name=member_ID,json=memberID,proto3" json:"member_ID,omitempty"`
  179. MemberAttributes *Attributes `protobuf:"bytes,2,opt,name=member_attributes,json=memberAttributes,proto3" json:"member_attributes,omitempty"`
  180. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  181. XXX_unrecognized []byte `json:"-"`
  182. XXX_sizecache int32 `json:"-"`
  183. }
  184. func (m *ClusterMemberAttrSetRequest) Reset() { *m = ClusterMemberAttrSetRequest{} }
  185. func (m *ClusterMemberAttrSetRequest) String() string { return proto.CompactTextString(m) }
  186. func (*ClusterMemberAttrSetRequest) ProtoMessage() {}
  187. func (*ClusterMemberAttrSetRequest) Descriptor() ([]byte, []int) {
  188. return fileDescriptor_949fe0d019050ef5, []int{4}
  189. }
  190. func (m *ClusterMemberAttrSetRequest) XXX_Unmarshal(b []byte) error {
  191. return m.Unmarshal(b)
  192. }
  193. func (m *ClusterMemberAttrSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  194. if deterministic {
  195. return xxx_messageInfo_ClusterMemberAttrSetRequest.Marshal(b, m, deterministic)
  196. } else {
  197. b = b[:cap(b)]
  198. n, err := m.MarshalToSizedBuffer(b)
  199. if err != nil {
  200. return nil, err
  201. }
  202. return b[:n], nil
  203. }
  204. }
  205. func (m *ClusterMemberAttrSetRequest) XXX_Merge(src proto.Message) {
  206. xxx_messageInfo_ClusterMemberAttrSetRequest.Merge(m, src)
  207. }
  208. func (m *ClusterMemberAttrSetRequest) XXX_Size() int {
  209. return m.Size()
  210. }
  211. func (m *ClusterMemberAttrSetRequest) XXX_DiscardUnknown() {
  212. xxx_messageInfo_ClusterMemberAttrSetRequest.DiscardUnknown(m)
  213. }
  214. var xxx_messageInfo_ClusterMemberAttrSetRequest proto.InternalMessageInfo
  215. type DowngradeInfoSetRequest struct {
  216. Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
  217. Ver string `protobuf:"bytes,2,opt,name=ver,proto3" json:"ver,omitempty"`
  218. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  219. XXX_unrecognized []byte `json:"-"`
  220. XXX_sizecache int32 `json:"-"`
  221. }
  222. func (m *DowngradeInfoSetRequest) Reset() { *m = DowngradeInfoSetRequest{} }
  223. func (m *DowngradeInfoSetRequest) String() string { return proto.CompactTextString(m) }
  224. func (*DowngradeInfoSetRequest) ProtoMessage() {}
  225. func (*DowngradeInfoSetRequest) Descriptor() ([]byte, []int) {
  226. return fileDescriptor_949fe0d019050ef5, []int{5}
  227. }
  228. func (m *DowngradeInfoSetRequest) XXX_Unmarshal(b []byte) error {
  229. return m.Unmarshal(b)
  230. }
  231. func (m *DowngradeInfoSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  232. if deterministic {
  233. return xxx_messageInfo_DowngradeInfoSetRequest.Marshal(b, m, deterministic)
  234. } else {
  235. b = b[:cap(b)]
  236. n, err := m.MarshalToSizedBuffer(b)
  237. if err != nil {
  238. return nil, err
  239. }
  240. return b[:n], nil
  241. }
  242. }
  243. func (m *DowngradeInfoSetRequest) XXX_Merge(src proto.Message) {
  244. xxx_messageInfo_DowngradeInfoSetRequest.Merge(m, src)
  245. }
  246. func (m *DowngradeInfoSetRequest) XXX_Size() int {
  247. return m.Size()
  248. }
  249. func (m *DowngradeInfoSetRequest) XXX_DiscardUnknown() {
  250. xxx_messageInfo_DowngradeInfoSetRequest.DiscardUnknown(m)
  251. }
  252. var xxx_messageInfo_DowngradeInfoSetRequest proto.InternalMessageInfo
  253. func init() {
  254. proto.RegisterType((*RaftAttributes)(nil), "membershippb.RaftAttributes")
  255. proto.RegisterType((*Attributes)(nil), "membershippb.Attributes")
  256. proto.RegisterType((*Member)(nil), "membershippb.Member")
  257. proto.RegisterType((*ClusterVersionSetRequest)(nil), "membershippb.ClusterVersionSetRequest")
  258. proto.RegisterType((*ClusterMemberAttrSetRequest)(nil), "membershippb.ClusterMemberAttrSetRequest")
  259. proto.RegisterType((*DowngradeInfoSetRequest)(nil), "membershippb.DowngradeInfoSetRequest")
  260. }
  261. func init() { proto.RegisterFile("membership.proto", fileDescriptor_949fe0d019050ef5) }
  262. var fileDescriptor_949fe0d019050ef5 = []byte{
  263. // 367 bytes of a gzipped FileDescriptorProto
  264. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x92, 0xc1, 0x4e, 0xf2, 0x40,
  265. 0x14, 0x85, 0x99, 0x42, 0xf8, 0xdb, 0xcb, 0x1f, 0xc4, 0x09, 0x89, 0x8d, 0x68, 0x25, 0x5d, 0xb1,
  266. 0x30, 0x98, 0xe8, 0x13, 0xa0, 0xb0, 0x20, 0x81, 0xcd, 0x18, 0xdd, 0x92, 0x56, 0x2e, 0xd8, 0xa4,
  267. 0x74, 0xea, 0xcc, 0x54, 0xd7, 0xbe, 0x85, 0x4f, 0xe0, 0xb3, 0xb0, 0xf4, 0x11, 0x14, 0x5f, 0xc4,
  268. 0x74, 0x5a, 0x4a, 0x49, 0xdc, 0xb8, 0xbb, 0x3d, 0xbd, 0xf7, 0x9c, 0xf3, 0x35, 0x85, 0xd6, 0x0a,
  269. 0x57, 0x3e, 0x0a, 0xf9, 0x18, 0xc4, 0xfd, 0x58, 0x70, 0xc5, 0xe9, 0xff, 0x9d, 0x12, 0xfb, 0xc7,
  270. 0xed, 0x25, 0x5f, 0x72, 0xfd, 0xe2, 0x22, 0x9d, 0xb2, 0x1d, 0x77, 0x02, 0x4d, 0xe6, 0x2d, 0xd4,
  271. 0x40, 0x29, 0x11, 0xf8, 0x89, 0x42, 0x49, 0x3b, 0x60, 0xc5, 0x88, 0x62, 0x96, 0x88, 0x50, 0xda,
  272. 0xa4, 0x5b, 0xed, 0x59, 0xcc, 0x4c, 0x85, 0x3b, 0x11, 0x4a, 0x7a, 0x0a, 0x10, 0xc8, 0x59, 0x88,
  273. 0x9e, 0x88, 0x50, 0xd8, 0x46, 0x97, 0xf4, 0x4c, 0x66, 0x05, 0x72, 0x92, 0x09, 0xee, 0x00, 0xa0,
  274. 0xe4, 0x44, 0xa1, 0x16, 0x79, 0x2b, 0xb4, 0x49, 0x97, 0xf4, 0x2c, 0xa6, 0x67, 0x7a, 0x06, 0x8d,
  275. 0x87, 0x30, 0xc0, 0x48, 0x65, 0xfe, 0x86, 0xf6, 0x87, 0x4c, 0x4a, 0x13, 0xdc, 0x77, 0x02, 0xf5,
  276. 0xa9, 0xee, 0x4d, 0x9b, 0x60, 0x8c, 0x87, 0xfa, 0xba, 0xc6, 0x8c, 0xf1, 0x90, 0x8e, 0xe0, 0x40,
  277. 0x78, 0x0b, 0x35, 0xf3, 0x8a, 0x08, 0xdd, 0xa0, 0x71, 0x79, 0xd2, 0x2f, 0x93, 0xf6, 0xf7, 0x81,
  278. 0x58, 0x53, 0xec, 0x03, 0x8e, 0xe0, 0x30, 0x5b, 0x2f, 0x1b, 0x55, 0xb5, 0x91, 0xbd, 0x6f, 0x54,
  279. 0x32, 0xc9, 0xbf, 0xee, 0x4e, 0x71, 0xcf, 0xc1, 0xbe, 0x09, 0x13, 0xa9, 0x50, 0xdc, 0xa3, 0x90,
  280. 0x01, 0x8f, 0x6e, 0x51, 0x31, 0x7c, 0x4a, 0x50, 0x2a, 0xda, 0x82, 0xea, 0x33, 0x8a, 0x1c, 0x3c,
  281. 0x1d, 0xdd, 0x57, 0x02, 0x9d, 0x7c, 0x7d, 0x5a, 0x38, 0x95, 0x2e, 0x3a, 0x60, 0xe5, 0xa5, 0x0a,
  282. 0x64, 0x33, 0x13, 0x34, 0xf8, 0x2f, 0x8d, 0x8d, 0x3f, 0x37, 0x1e, 0xc1, 0xd1, 0x90, 0xbf, 0x44,
  283. 0x4b, 0xe1, 0xcd, 0x71, 0x1c, 0x2d, 0x78, 0x29, 0xde, 0x86, 0x7f, 0x18, 0x79, 0x7e, 0x88, 0x73,
  284. 0x1d, 0x6e, 0xb2, 0xed, 0xe3, 0x16, 0xc5, 0x28, 0x50, 0xae, 0xdb, 0xeb, 0x2f, 0xa7, 0xb2, 0xde,
  285. 0x38, 0xe4, 0x63, 0xe3, 0x90, 0xcf, 0x8d, 0x43, 0xde, 0xbe, 0x9d, 0x8a, 0x5f, 0xd7, 0xff, 0xd3,
  286. 0xd5, 0x4f, 0x00, 0x00, 0x00, 0xff, 0xff, 0xdc, 0x93, 0x7d, 0x0b, 0x87, 0x02, 0x00, 0x00,
  287. }
  288. func (m *RaftAttributes) Marshal() (dAtA []byte, err error) {
  289. size := m.Size()
  290. dAtA = make([]byte, size)
  291. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  292. if err != nil {
  293. return nil, err
  294. }
  295. return dAtA[:n], nil
  296. }
  297. func (m *RaftAttributes) MarshalTo(dAtA []byte) (int, error) {
  298. size := m.Size()
  299. return m.MarshalToSizedBuffer(dAtA[:size])
  300. }
  301. func (m *RaftAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  302. i := len(dAtA)
  303. _ = i
  304. var l int
  305. _ = l
  306. if m.XXX_unrecognized != nil {
  307. i -= len(m.XXX_unrecognized)
  308. copy(dAtA[i:], m.XXX_unrecognized)
  309. }
  310. if m.IsLearner {
  311. i--
  312. if m.IsLearner {
  313. dAtA[i] = 1
  314. } else {
  315. dAtA[i] = 0
  316. }
  317. i--
  318. dAtA[i] = 0x10
  319. }
  320. if len(m.PeerUrls) > 0 {
  321. for iNdEx := len(m.PeerUrls) - 1; iNdEx >= 0; iNdEx-- {
  322. i -= len(m.PeerUrls[iNdEx])
  323. copy(dAtA[i:], m.PeerUrls[iNdEx])
  324. i = encodeVarintMembership(dAtA, i, uint64(len(m.PeerUrls[iNdEx])))
  325. i--
  326. dAtA[i] = 0xa
  327. }
  328. }
  329. return len(dAtA) - i, nil
  330. }
  331. func (m *Attributes) Marshal() (dAtA []byte, err error) {
  332. size := m.Size()
  333. dAtA = make([]byte, size)
  334. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  335. if err != nil {
  336. return nil, err
  337. }
  338. return dAtA[:n], nil
  339. }
  340. func (m *Attributes) MarshalTo(dAtA []byte) (int, error) {
  341. size := m.Size()
  342. return m.MarshalToSizedBuffer(dAtA[:size])
  343. }
  344. func (m *Attributes) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  345. i := len(dAtA)
  346. _ = i
  347. var l int
  348. _ = l
  349. if m.XXX_unrecognized != nil {
  350. i -= len(m.XXX_unrecognized)
  351. copy(dAtA[i:], m.XXX_unrecognized)
  352. }
  353. if len(m.ClientUrls) > 0 {
  354. for iNdEx := len(m.ClientUrls) - 1; iNdEx >= 0; iNdEx-- {
  355. i -= len(m.ClientUrls[iNdEx])
  356. copy(dAtA[i:], m.ClientUrls[iNdEx])
  357. i = encodeVarintMembership(dAtA, i, uint64(len(m.ClientUrls[iNdEx])))
  358. i--
  359. dAtA[i] = 0x12
  360. }
  361. }
  362. if len(m.Name) > 0 {
  363. i -= len(m.Name)
  364. copy(dAtA[i:], m.Name)
  365. i = encodeVarintMembership(dAtA, i, uint64(len(m.Name)))
  366. i--
  367. dAtA[i] = 0xa
  368. }
  369. return len(dAtA) - i, nil
  370. }
  371. func (m *Member) Marshal() (dAtA []byte, err error) {
  372. size := m.Size()
  373. dAtA = make([]byte, size)
  374. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  375. if err != nil {
  376. return nil, err
  377. }
  378. return dAtA[:n], nil
  379. }
  380. func (m *Member) MarshalTo(dAtA []byte) (int, error) {
  381. size := m.Size()
  382. return m.MarshalToSizedBuffer(dAtA[:size])
  383. }
  384. func (m *Member) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  385. i := len(dAtA)
  386. _ = i
  387. var l int
  388. _ = l
  389. if m.XXX_unrecognized != nil {
  390. i -= len(m.XXX_unrecognized)
  391. copy(dAtA[i:], m.XXX_unrecognized)
  392. }
  393. if m.MemberAttributes != nil {
  394. {
  395. size, err := m.MemberAttributes.MarshalToSizedBuffer(dAtA[:i])
  396. if err != nil {
  397. return 0, err
  398. }
  399. i -= size
  400. i = encodeVarintMembership(dAtA, i, uint64(size))
  401. }
  402. i--
  403. dAtA[i] = 0x1a
  404. }
  405. if m.RaftAttributes != nil {
  406. {
  407. size, err := m.RaftAttributes.MarshalToSizedBuffer(dAtA[:i])
  408. if err != nil {
  409. return 0, err
  410. }
  411. i -= size
  412. i = encodeVarintMembership(dAtA, i, uint64(size))
  413. }
  414. i--
  415. dAtA[i] = 0x12
  416. }
  417. if m.ID != 0 {
  418. i = encodeVarintMembership(dAtA, i, uint64(m.ID))
  419. i--
  420. dAtA[i] = 0x8
  421. }
  422. return len(dAtA) - i, nil
  423. }
  424. func (m *ClusterVersionSetRequest) Marshal() (dAtA []byte, err error) {
  425. size := m.Size()
  426. dAtA = make([]byte, size)
  427. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  428. if err != nil {
  429. return nil, err
  430. }
  431. return dAtA[:n], nil
  432. }
  433. func (m *ClusterVersionSetRequest) MarshalTo(dAtA []byte) (int, error) {
  434. size := m.Size()
  435. return m.MarshalToSizedBuffer(dAtA[:size])
  436. }
  437. func (m *ClusterVersionSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  438. i := len(dAtA)
  439. _ = i
  440. var l int
  441. _ = l
  442. if m.XXX_unrecognized != nil {
  443. i -= len(m.XXX_unrecognized)
  444. copy(dAtA[i:], m.XXX_unrecognized)
  445. }
  446. if len(m.Ver) > 0 {
  447. i -= len(m.Ver)
  448. copy(dAtA[i:], m.Ver)
  449. i = encodeVarintMembership(dAtA, i, uint64(len(m.Ver)))
  450. i--
  451. dAtA[i] = 0xa
  452. }
  453. return len(dAtA) - i, nil
  454. }
  455. func (m *ClusterMemberAttrSetRequest) Marshal() (dAtA []byte, err error) {
  456. size := m.Size()
  457. dAtA = make([]byte, size)
  458. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  459. if err != nil {
  460. return nil, err
  461. }
  462. return dAtA[:n], nil
  463. }
  464. func (m *ClusterMemberAttrSetRequest) MarshalTo(dAtA []byte) (int, error) {
  465. size := m.Size()
  466. return m.MarshalToSizedBuffer(dAtA[:size])
  467. }
  468. func (m *ClusterMemberAttrSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  469. i := len(dAtA)
  470. _ = i
  471. var l int
  472. _ = l
  473. if m.XXX_unrecognized != nil {
  474. i -= len(m.XXX_unrecognized)
  475. copy(dAtA[i:], m.XXX_unrecognized)
  476. }
  477. if m.MemberAttributes != nil {
  478. {
  479. size, err := m.MemberAttributes.MarshalToSizedBuffer(dAtA[:i])
  480. if err != nil {
  481. return 0, err
  482. }
  483. i -= size
  484. i = encodeVarintMembership(dAtA, i, uint64(size))
  485. }
  486. i--
  487. dAtA[i] = 0x12
  488. }
  489. if m.Member_ID != 0 {
  490. i = encodeVarintMembership(dAtA, i, uint64(m.Member_ID))
  491. i--
  492. dAtA[i] = 0x8
  493. }
  494. return len(dAtA) - i, nil
  495. }
  496. func (m *DowngradeInfoSetRequest) Marshal() (dAtA []byte, err error) {
  497. size := m.Size()
  498. dAtA = make([]byte, size)
  499. n, err := m.MarshalToSizedBuffer(dAtA[:size])
  500. if err != nil {
  501. return nil, err
  502. }
  503. return dAtA[:n], nil
  504. }
  505. func (m *DowngradeInfoSetRequest) MarshalTo(dAtA []byte) (int, error) {
  506. size := m.Size()
  507. return m.MarshalToSizedBuffer(dAtA[:size])
  508. }
  509. func (m *DowngradeInfoSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
  510. i := len(dAtA)
  511. _ = i
  512. var l int
  513. _ = l
  514. if m.XXX_unrecognized != nil {
  515. i -= len(m.XXX_unrecognized)
  516. copy(dAtA[i:], m.XXX_unrecognized)
  517. }
  518. if len(m.Ver) > 0 {
  519. i -= len(m.Ver)
  520. copy(dAtA[i:], m.Ver)
  521. i = encodeVarintMembership(dAtA, i, uint64(len(m.Ver)))
  522. i--
  523. dAtA[i] = 0x12
  524. }
  525. if m.Enabled {
  526. i--
  527. if m.Enabled {
  528. dAtA[i] = 1
  529. } else {
  530. dAtA[i] = 0
  531. }
  532. i--
  533. dAtA[i] = 0x8
  534. }
  535. return len(dAtA) - i, nil
  536. }
  537. func encodeVarintMembership(dAtA []byte, offset int, v uint64) int {
  538. offset -= sovMembership(v)
  539. base := offset
  540. for v >= 1<<7 {
  541. dAtA[offset] = uint8(v&0x7f | 0x80)
  542. v >>= 7
  543. offset++
  544. }
  545. dAtA[offset] = uint8(v)
  546. return base
  547. }
  548. func (m *RaftAttributes) Size() (n int) {
  549. if m == nil {
  550. return 0
  551. }
  552. var l int
  553. _ = l
  554. if len(m.PeerUrls) > 0 {
  555. for _, s := range m.PeerUrls {
  556. l = len(s)
  557. n += 1 + l + sovMembership(uint64(l))
  558. }
  559. }
  560. if m.IsLearner {
  561. n += 2
  562. }
  563. if m.XXX_unrecognized != nil {
  564. n += len(m.XXX_unrecognized)
  565. }
  566. return n
  567. }
  568. func (m *Attributes) Size() (n int) {
  569. if m == nil {
  570. return 0
  571. }
  572. var l int
  573. _ = l
  574. l = len(m.Name)
  575. if l > 0 {
  576. n += 1 + l + sovMembership(uint64(l))
  577. }
  578. if len(m.ClientUrls) > 0 {
  579. for _, s := range m.ClientUrls {
  580. l = len(s)
  581. n += 1 + l + sovMembership(uint64(l))
  582. }
  583. }
  584. if m.XXX_unrecognized != nil {
  585. n += len(m.XXX_unrecognized)
  586. }
  587. return n
  588. }
  589. func (m *Member) Size() (n int) {
  590. if m == nil {
  591. return 0
  592. }
  593. var l int
  594. _ = l
  595. if m.ID != 0 {
  596. n += 1 + sovMembership(uint64(m.ID))
  597. }
  598. if m.RaftAttributes != nil {
  599. l = m.RaftAttributes.Size()
  600. n += 1 + l + sovMembership(uint64(l))
  601. }
  602. if m.MemberAttributes != nil {
  603. l = m.MemberAttributes.Size()
  604. n += 1 + l + sovMembership(uint64(l))
  605. }
  606. if m.XXX_unrecognized != nil {
  607. n += len(m.XXX_unrecognized)
  608. }
  609. return n
  610. }
  611. func (m *ClusterVersionSetRequest) Size() (n int) {
  612. if m == nil {
  613. return 0
  614. }
  615. var l int
  616. _ = l
  617. l = len(m.Ver)
  618. if l > 0 {
  619. n += 1 + l + sovMembership(uint64(l))
  620. }
  621. if m.XXX_unrecognized != nil {
  622. n += len(m.XXX_unrecognized)
  623. }
  624. return n
  625. }
  626. func (m *ClusterMemberAttrSetRequest) Size() (n int) {
  627. if m == nil {
  628. return 0
  629. }
  630. var l int
  631. _ = l
  632. if m.Member_ID != 0 {
  633. n += 1 + sovMembership(uint64(m.Member_ID))
  634. }
  635. if m.MemberAttributes != nil {
  636. l = m.MemberAttributes.Size()
  637. n += 1 + l + sovMembership(uint64(l))
  638. }
  639. if m.XXX_unrecognized != nil {
  640. n += len(m.XXX_unrecognized)
  641. }
  642. return n
  643. }
  644. func (m *DowngradeInfoSetRequest) Size() (n int) {
  645. if m == nil {
  646. return 0
  647. }
  648. var l int
  649. _ = l
  650. if m.Enabled {
  651. n += 2
  652. }
  653. l = len(m.Ver)
  654. if l > 0 {
  655. n += 1 + l + sovMembership(uint64(l))
  656. }
  657. if m.XXX_unrecognized != nil {
  658. n += len(m.XXX_unrecognized)
  659. }
  660. return n
  661. }
  662. func sovMembership(x uint64) (n int) {
  663. return (math_bits.Len64(x|1) + 6) / 7
  664. }
  665. func sozMembership(x uint64) (n int) {
  666. return sovMembership(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  667. }
  668. func (m *RaftAttributes) Unmarshal(dAtA []byte) error {
  669. l := len(dAtA)
  670. iNdEx := 0
  671. for iNdEx < l {
  672. preIndex := iNdEx
  673. var wire uint64
  674. for shift := uint(0); ; shift += 7 {
  675. if shift >= 64 {
  676. return ErrIntOverflowMembership
  677. }
  678. if iNdEx >= l {
  679. return io.ErrUnexpectedEOF
  680. }
  681. b := dAtA[iNdEx]
  682. iNdEx++
  683. wire |= uint64(b&0x7F) << shift
  684. if b < 0x80 {
  685. break
  686. }
  687. }
  688. fieldNum := int32(wire >> 3)
  689. wireType := int(wire & 0x7)
  690. if wireType == 4 {
  691. return fmt.Errorf("proto: RaftAttributes: wiretype end group for non-group")
  692. }
  693. if fieldNum <= 0 {
  694. return fmt.Errorf("proto: RaftAttributes: illegal tag %d (wire type %d)", fieldNum, wire)
  695. }
  696. switch fieldNum {
  697. case 1:
  698. if wireType != 2 {
  699. return fmt.Errorf("proto: wrong wireType = %d for field PeerUrls", wireType)
  700. }
  701. var stringLen uint64
  702. for shift := uint(0); ; shift += 7 {
  703. if shift >= 64 {
  704. return ErrIntOverflowMembership
  705. }
  706. if iNdEx >= l {
  707. return io.ErrUnexpectedEOF
  708. }
  709. b := dAtA[iNdEx]
  710. iNdEx++
  711. stringLen |= uint64(b&0x7F) << shift
  712. if b < 0x80 {
  713. break
  714. }
  715. }
  716. intStringLen := int(stringLen)
  717. if intStringLen < 0 {
  718. return ErrInvalidLengthMembership
  719. }
  720. postIndex := iNdEx + intStringLen
  721. if postIndex < 0 {
  722. return ErrInvalidLengthMembership
  723. }
  724. if postIndex > l {
  725. return io.ErrUnexpectedEOF
  726. }
  727. m.PeerUrls = append(m.PeerUrls, string(dAtA[iNdEx:postIndex]))
  728. iNdEx = postIndex
  729. case 2:
  730. if wireType != 0 {
  731. return fmt.Errorf("proto: wrong wireType = %d for field IsLearner", wireType)
  732. }
  733. var v int
  734. for shift := uint(0); ; shift += 7 {
  735. if shift >= 64 {
  736. return ErrIntOverflowMembership
  737. }
  738. if iNdEx >= l {
  739. return io.ErrUnexpectedEOF
  740. }
  741. b := dAtA[iNdEx]
  742. iNdEx++
  743. v |= int(b&0x7F) << shift
  744. if b < 0x80 {
  745. break
  746. }
  747. }
  748. m.IsLearner = bool(v != 0)
  749. default:
  750. iNdEx = preIndex
  751. skippy, err := skipMembership(dAtA[iNdEx:])
  752. if err != nil {
  753. return err
  754. }
  755. if (skippy < 0) || (iNdEx+skippy) < 0 {
  756. return ErrInvalidLengthMembership
  757. }
  758. if (iNdEx + skippy) > l {
  759. return io.ErrUnexpectedEOF
  760. }
  761. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  762. iNdEx += skippy
  763. }
  764. }
  765. if iNdEx > l {
  766. return io.ErrUnexpectedEOF
  767. }
  768. return nil
  769. }
  770. func (m *Attributes) Unmarshal(dAtA []byte) error {
  771. l := len(dAtA)
  772. iNdEx := 0
  773. for iNdEx < l {
  774. preIndex := iNdEx
  775. var wire uint64
  776. for shift := uint(0); ; shift += 7 {
  777. if shift >= 64 {
  778. return ErrIntOverflowMembership
  779. }
  780. if iNdEx >= l {
  781. return io.ErrUnexpectedEOF
  782. }
  783. b := dAtA[iNdEx]
  784. iNdEx++
  785. wire |= uint64(b&0x7F) << shift
  786. if b < 0x80 {
  787. break
  788. }
  789. }
  790. fieldNum := int32(wire >> 3)
  791. wireType := int(wire & 0x7)
  792. if wireType == 4 {
  793. return fmt.Errorf("proto: Attributes: wiretype end group for non-group")
  794. }
  795. if fieldNum <= 0 {
  796. return fmt.Errorf("proto: Attributes: illegal tag %d (wire type %d)", fieldNum, wire)
  797. }
  798. switch fieldNum {
  799. case 1:
  800. if wireType != 2 {
  801. return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
  802. }
  803. var stringLen uint64
  804. for shift := uint(0); ; shift += 7 {
  805. if shift >= 64 {
  806. return ErrIntOverflowMembership
  807. }
  808. if iNdEx >= l {
  809. return io.ErrUnexpectedEOF
  810. }
  811. b := dAtA[iNdEx]
  812. iNdEx++
  813. stringLen |= uint64(b&0x7F) << shift
  814. if b < 0x80 {
  815. break
  816. }
  817. }
  818. intStringLen := int(stringLen)
  819. if intStringLen < 0 {
  820. return ErrInvalidLengthMembership
  821. }
  822. postIndex := iNdEx + intStringLen
  823. if postIndex < 0 {
  824. return ErrInvalidLengthMembership
  825. }
  826. if postIndex > l {
  827. return io.ErrUnexpectedEOF
  828. }
  829. m.Name = string(dAtA[iNdEx:postIndex])
  830. iNdEx = postIndex
  831. case 2:
  832. if wireType != 2 {
  833. return fmt.Errorf("proto: wrong wireType = %d for field ClientUrls", wireType)
  834. }
  835. var stringLen uint64
  836. for shift := uint(0); ; shift += 7 {
  837. if shift >= 64 {
  838. return ErrIntOverflowMembership
  839. }
  840. if iNdEx >= l {
  841. return io.ErrUnexpectedEOF
  842. }
  843. b := dAtA[iNdEx]
  844. iNdEx++
  845. stringLen |= uint64(b&0x7F) << shift
  846. if b < 0x80 {
  847. break
  848. }
  849. }
  850. intStringLen := int(stringLen)
  851. if intStringLen < 0 {
  852. return ErrInvalidLengthMembership
  853. }
  854. postIndex := iNdEx + intStringLen
  855. if postIndex < 0 {
  856. return ErrInvalidLengthMembership
  857. }
  858. if postIndex > l {
  859. return io.ErrUnexpectedEOF
  860. }
  861. m.ClientUrls = append(m.ClientUrls, string(dAtA[iNdEx:postIndex]))
  862. iNdEx = postIndex
  863. default:
  864. iNdEx = preIndex
  865. skippy, err := skipMembership(dAtA[iNdEx:])
  866. if err != nil {
  867. return err
  868. }
  869. if (skippy < 0) || (iNdEx+skippy) < 0 {
  870. return ErrInvalidLengthMembership
  871. }
  872. if (iNdEx + skippy) > l {
  873. return io.ErrUnexpectedEOF
  874. }
  875. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  876. iNdEx += skippy
  877. }
  878. }
  879. if iNdEx > l {
  880. return io.ErrUnexpectedEOF
  881. }
  882. return nil
  883. }
  884. func (m *Member) Unmarshal(dAtA []byte) error {
  885. l := len(dAtA)
  886. iNdEx := 0
  887. for iNdEx < l {
  888. preIndex := iNdEx
  889. var wire uint64
  890. for shift := uint(0); ; shift += 7 {
  891. if shift >= 64 {
  892. return ErrIntOverflowMembership
  893. }
  894. if iNdEx >= l {
  895. return io.ErrUnexpectedEOF
  896. }
  897. b := dAtA[iNdEx]
  898. iNdEx++
  899. wire |= uint64(b&0x7F) << shift
  900. if b < 0x80 {
  901. break
  902. }
  903. }
  904. fieldNum := int32(wire >> 3)
  905. wireType := int(wire & 0x7)
  906. if wireType == 4 {
  907. return fmt.Errorf("proto: Member: wiretype end group for non-group")
  908. }
  909. if fieldNum <= 0 {
  910. return fmt.Errorf("proto: Member: illegal tag %d (wire type %d)", fieldNum, wire)
  911. }
  912. switch fieldNum {
  913. case 1:
  914. if wireType != 0 {
  915. return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
  916. }
  917. m.ID = 0
  918. for shift := uint(0); ; shift += 7 {
  919. if shift >= 64 {
  920. return ErrIntOverflowMembership
  921. }
  922. if iNdEx >= l {
  923. return io.ErrUnexpectedEOF
  924. }
  925. b := dAtA[iNdEx]
  926. iNdEx++
  927. m.ID |= uint64(b&0x7F) << shift
  928. if b < 0x80 {
  929. break
  930. }
  931. }
  932. case 2:
  933. if wireType != 2 {
  934. return fmt.Errorf("proto: wrong wireType = %d for field RaftAttributes", wireType)
  935. }
  936. var msglen int
  937. for shift := uint(0); ; shift += 7 {
  938. if shift >= 64 {
  939. return ErrIntOverflowMembership
  940. }
  941. if iNdEx >= l {
  942. return io.ErrUnexpectedEOF
  943. }
  944. b := dAtA[iNdEx]
  945. iNdEx++
  946. msglen |= int(b&0x7F) << shift
  947. if b < 0x80 {
  948. break
  949. }
  950. }
  951. if msglen < 0 {
  952. return ErrInvalidLengthMembership
  953. }
  954. postIndex := iNdEx + msglen
  955. if postIndex < 0 {
  956. return ErrInvalidLengthMembership
  957. }
  958. if postIndex > l {
  959. return io.ErrUnexpectedEOF
  960. }
  961. if m.RaftAttributes == nil {
  962. m.RaftAttributes = &RaftAttributes{}
  963. }
  964. if err := m.RaftAttributes.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  965. return err
  966. }
  967. iNdEx = postIndex
  968. case 3:
  969. if wireType != 2 {
  970. return fmt.Errorf("proto: wrong wireType = %d for field MemberAttributes", wireType)
  971. }
  972. var msglen int
  973. for shift := uint(0); ; shift += 7 {
  974. if shift >= 64 {
  975. return ErrIntOverflowMembership
  976. }
  977. if iNdEx >= l {
  978. return io.ErrUnexpectedEOF
  979. }
  980. b := dAtA[iNdEx]
  981. iNdEx++
  982. msglen |= int(b&0x7F) << shift
  983. if b < 0x80 {
  984. break
  985. }
  986. }
  987. if msglen < 0 {
  988. return ErrInvalidLengthMembership
  989. }
  990. postIndex := iNdEx + msglen
  991. if postIndex < 0 {
  992. return ErrInvalidLengthMembership
  993. }
  994. if postIndex > l {
  995. return io.ErrUnexpectedEOF
  996. }
  997. if m.MemberAttributes == nil {
  998. m.MemberAttributes = &Attributes{}
  999. }
  1000. if err := m.MemberAttributes.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1001. return err
  1002. }
  1003. iNdEx = postIndex
  1004. default:
  1005. iNdEx = preIndex
  1006. skippy, err := skipMembership(dAtA[iNdEx:])
  1007. if err != nil {
  1008. return err
  1009. }
  1010. if (skippy < 0) || (iNdEx+skippy) < 0 {
  1011. return ErrInvalidLengthMembership
  1012. }
  1013. if (iNdEx + skippy) > l {
  1014. return io.ErrUnexpectedEOF
  1015. }
  1016. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  1017. iNdEx += skippy
  1018. }
  1019. }
  1020. if iNdEx > l {
  1021. return io.ErrUnexpectedEOF
  1022. }
  1023. return nil
  1024. }
  1025. func (m *ClusterVersionSetRequest) Unmarshal(dAtA []byte) error {
  1026. l := len(dAtA)
  1027. iNdEx := 0
  1028. for iNdEx < l {
  1029. preIndex := iNdEx
  1030. var wire uint64
  1031. for shift := uint(0); ; shift += 7 {
  1032. if shift >= 64 {
  1033. return ErrIntOverflowMembership
  1034. }
  1035. if iNdEx >= l {
  1036. return io.ErrUnexpectedEOF
  1037. }
  1038. b := dAtA[iNdEx]
  1039. iNdEx++
  1040. wire |= uint64(b&0x7F) << shift
  1041. if b < 0x80 {
  1042. break
  1043. }
  1044. }
  1045. fieldNum := int32(wire >> 3)
  1046. wireType := int(wire & 0x7)
  1047. if wireType == 4 {
  1048. return fmt.Errorf("proto: ClusterVersionSetRequest: wiretype end group for non-group")
  1049. }
  1050. if fieldNum <= 0 {
  1051. return fmt.Errorf("proto: ClusterVersionSetRequest: illegal tag %d (wire type %d)", fieldNum, wire)
  1052. }
  1053. switch fieldNum {
  1054. case 1:
  1055. if wireType != 2 {
  1056. return fmt.Errorf("proto: wrong wireType = %d for field Ver", wireType)
  1057. }
  1058. var stringLen uint64
  1059. for shift := uint(0); ; shift += 7 {
  1060. if shift >= 64 {
  1061. return ErrIntOverflowMembership
  1062. }
  1063. if iNdEx >= l {
  1064. return io.ErrUnexpectedEOF
  1065. }
  1066. b := dAtA[iNdEx]
  1067. iNdEx++
  1068. stringLen |= uint64(b&0x7F) << shift
  1069. if b < 0x80 {
  1070. break
  1071. }
  1072. }
  1073. intStringLen := int(stringLen)
  1074. if intStringLen < 0 {
  1075. return ErrInvalidLengthMembership
  1076. }
  1077. postIndex := iNdEx + intStringLen
  1078. if postIndex < 0 {
  1079. return ErrInvalidLengthMembership
  1080. }
  1081. if postIndex > l {
  1082. return io.ErrUnexpectedEOF
  1083. }
  1084. m.Ver = string(dAtA[iNdEx:postIndex])
  1085. iNdEx = postIndex
  1086. default:
  1087. iNdEx = preIndex
  1088. skippy, err := skipMembership(dAtA[iNdEx:])
  1089. if err != nil {
  1090. return err
  1091. }
  1092. if (skippy < 0) || (iNdEx+skippy) < 0 {
  1093. return ErrInvalidLengthMembership
  1094. }
  1095. if (iNdEx + skippy) > l {
  1096. return io.ErrUnexpectedEOF
  1097. }
  1098. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  1099. iNdEx += skippy
  1100. }
  1101. }
  1102. if iNdEx > l {
  1103. return io.ErrUnexpectedEOF
  1104. }
  1105. return nil
  1106. }
  1107. func (m *ClusterMemberAttrSetRequest) Unmarshal(dAtA []byte) error {
  1108. l := len(dAtA)
  1109. iNdEx := 0
  1110. for iNdEx < l {
  1111. preIndex := iNdEx
  1112. var wire uint64
  1113. for shift := uint(0); ; shift += 7 {
  1114. if shift >= 64 {
  1115. return ErrIntOverflowMembership
  1116. }
  1117. if iNdEx >= l {
  1118. return io.ErrUnexpectedEOF
  1119. }
  1120. b := dAtA[iNdEx]
  1121. iNdEx++
  1122. wire |= uint64(b&0x7F) << shift
  1123. if b < 0x80 {
  1124. break
  1125. }
  1126. }
  1127. fieldNum := int32(wire >> 3)
  1128. wireType := int(wire & 0x7)
  1129. if wireType == 4 {
  1130. return fmt.Errorf("proto: ClusterMemberAttrSetRequest: wiretype end group for non-group")
  1131. }
  1132. if fieldNum <= 0 {
  1133. return fmt.Errorf("proto: ClusterMemberAttrSetRequest: illegal tag %d (wire type %d)", fieldNum, wire)
  1134. }
  1135. switch fieldNum {
  1136. case 1:
  1137. if wireType != 0 {
  1138. return fmt.Errorf("proto: wrong wireType = %d for field Member_ID", wireType)
  1139. }
  1140. m.Member_ID = 0
  1141. for shift := uint(0); ; shift += 7 {
  1142. if shift >= 64 {
  1143. return ErrIntOverflowMembership
  1144. }
  1145. if iNdEx >= l {
  1146. return io.ErrUnexpectedEOF
  1147. }
  1148. b := dAtA[iNdEx]
  1149. iNdEx++
  1150. m.Member_ID |= uint64(b&0x7F) << shift
  1151. if b < 0x80 {
  1152. break
  1153. }
  1154. }
  1155. case 2:
  1156. if wireType != 2 {
  1157. return fmt.Errorf("proto: wrong wireType = %d for field MemberAttributes", wireType)
  1158. }
  1159. var msglen int
  1160. for shift := uint(0); ; shift += 7 {
  1161. if shift >= 64 {
  1162. return ErrIntOverflowMembership
  1163. }
  1164. if iNdEx >= l {
  1165. return io.ErrUnexpectedEOF
  1166. }
  1167. b := dAtA[iNdEx]
  1168. iNdEx++
  1169. msglen |= int(b&0x7F) << shift
  1170. if b < 0x80 {
  1171. break
  1172. }
  1173. }
  1174. if msglen < 0 {
  1175. return ErrInvalidLengthMembership
  1176. }
  1177. postIndex := iNdEx + msglen
  1178. if postIndex < 0 {
  1179. return ErrInvalidLengthMembership
  1180. }
  1181. if postIndex > l {
  1182. return io.ErrUnexpectedEOF
  1183. }
  1184. if m.MemberAttributes == nil {
  1185. m.MemberAttributes = &Attributes{}
  1186. }
  1187. if err := m.MemberAttributes.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  1188. return err
  1189. }
  1190. iNdEx = postIndex
  1191. default:
  1192. iNdEx = preIndex
  1193. skippy, err := skipMembership(dAtA[iNdEx:])
  1194. if err != nil {
  1195. return err
  1196. }
  1197. if (skippy < 0) || (iNdEx+skippy) < 0 {
  1198. return ErrInvalidLengthMembership
  1199. }
  1200. if (iNdEx + skippy) > l {
  1201. return io.ErrUnexpectedEOF
  1202. }
  1203. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  1204. iNdEx += skippy
  1205. }
  1206. }
  1207. if iNdEx > l {
  1208. return io.ErrUnexpectedEOF
  1209. }
  1210. return nil
  1211. }
  1212. func (m *DowngradeInfoSetRequest) Unmarshal(dAtA []byte) error {
  1213. l := len(dAtA)
  1214. iNdEx := 0
  1215. for iNdEx < l {
  1216. preIndex := iNdEx
  1217. var wire uint64
  1218. for shift := uint(0); ; shift += 7 {
  1219. if shift >= 64 {
  1220. return ErrIntOverflowMembership
  1221. }
  1222. if iNdEx >= l {
  1223. return io.ErrUnexpectedEOF
  1224. }
  1225. b := dAtA[iNdEx]
  1226. iNdEx++
  1227. wire |= uint64(b&0x7F) << shift
  1228. if b < 0x80 {
  1229. break
  1230. }
  1231. }
  1232. fieldNum := int32(wire >> 3)
  1233. wireType := int(wire & 0x7)
  1234. if wireType == 4 {
  1235. return fmt.Errorf("proto: DowngradeInfoSetRequest: wiretype end group for non-group")
  1236. }
  1237. if fieldNum <= 0 {
  1238. return fmt.Errorf("proto: DowngradeInfoSetRequest: illegal tag %d (wire type %d)", fieldNum, wire)
  1239. }
  1240. switch fieldNum {
  1241. case 1:
  1242. if wireType != 0 {
  1243. return fmt.Errorf("proto: wrong wireType = %d for field Enabled", wireType)
  1244. }
  1245. var v int
  1246. for shift := uint(0); ; shift += 7 {
  1247. if shift >= 64 {
  1248. return ErrIntOverflowMembership
  1249. }
  1250. if iNdEx >= l {
  1251. return io.ErrUnexpectedEOF
  1252. }
  1253. b := dAtA[iNdEx]
  1254. iNdEx++
  1255. v |= int(b&0x7F) << shift
  1256. if b < 0x80 {
  1257. break
  1258. }
  1259. }
  1260. m.Enabled = bool(v != 0)
  1261. case 2:
  1262. if wireType != 2 {
  1263. return fmt.Errorf("proto: wrong wireType = %d for field Ver", wireType)
  1264. }
  1265. var stringLen uint64
  1266. for shift := uint(0); ; shift += 7 {
  1267. if shift >= 64 {
  1268. return ErrIntOverflowMembership
  1269. }
  1270. if iNdEx >= l {
  1271. return io.ErrUnexpectedEOF
  1272. }
  1273. b := dAtA[iNdEx]
  1274. iNdEx++
  1275. stringLen |= uint64(b&0x7F) << shift
  1276. if b < 0x80 {
  1277. break
  1278. }
  1279. }
  1280. intStringLen := int(stringLen)
  1281. if intStringLen < 0 {
  1282. return ErrInvalidLengthMembership
  1283. }
  1284. postIndex := iNdEx + intStringLen
  1285. if postIndex < 0 {
  1286. return ErrInvalidLengthMembership
  1287. }
  1288. if postIndex > l {
  1289. return io.ErrUnexpectedEOF
  1290. }
  1291. m.Ver = string(dAtA[iNdEx:postIndex])
  1292. iNdEx = postIndex
  1293. default:
  1294. iNdEx = preIndex
  1295. skippy, err := skipMembership(dAtA[iNdEx:])
  1296. if err != nil {
  1297. return err
  1298. }
  1299. if (skippy < 0) || (iNdEx+skippy) < 0 {
  1300. return ErrInvalidLengthMembership
  1301. }
  1302. if (iNdEx + skippy) > l {
  1303. return io.ErrUnexpectedEOF
  1304. }
  1305. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  1306. iNdEx += skippy
  1307. }
  1308. }
  1309. if iNdEx > l {
  1310. return io.ErrUnexpectedEOF
  1311. }
  1312. return nil
  1313. }
  1314. func skipMembership(dAtA []byte) (n int, err error) {
  1315. l := len(dAtA)
  1316. iNdEx := 0
  1317. depth := 0
  1318. for iNdEx < l {
  1319. var wire uint64
  1320. for shift := uint(0); ; shift += 7 {
  1321. if shift >= 64 {
  1322. return 0, ErrIntOverflowMembership
  1323. }
  1324. if iNdEx >= l {
  1325. return 0, io.ErrUnexpectedEOF
  1326. }
  1327. b := dAtA[iNdEx]
  1328. iNdEx++
  1329. wire |= (uint64(b) & 0x7F) << shift
  1330. if b < 0x80 {
  1331. break
  1332. }
  1333. }
  1334. wireType := int(wire & 0x7)
  1335. switch wireType {
  1336. case 0:
  1337. for shift := uint(0); ; shift += 7 {
  1338. if shift >= 64 {
  1339. return 0, ErrIntOverflowMembership
  1340. }
  1341. if iNdEx >= l {
  1342. return 0, io.ErrUnexpectedEOF
  1343. }
  1344. iNdEx++
  1345. if dAtA[iNdEx-1] < 0x80 {
  1346. break
  1347. }
  1348. }
  1349. case 1:
  1350. iNdEx += 8
  1351. case 2:
  1352. var length int
  1353. for shift := uint(0); ; shift += 7 {
  1354. if shift >= 64 {
  1355. return 0, ErrIntOverflowMembership
  1356. }
  1357. if iNdEx >= l {
  1358. return 0, io.ErrUnexpectedEOF
  1359. }
  1360. b := dAtA[iNdEx]
  1361. iNdEx++
  1362. length |= (int(b) & 0x7F) << shift
  1363. if b < 0x80 {
  1364. break
  1365. }
  1366. }
  1367. if length < 0 {
  1368. return 0, ErrInvalidLengthMembership
  1369. }
  1370. iNdEx += length
  1371. case 3:
  1372. depth++
  1373. case 4:
  1374. if depth == 0 {
  1375. return 0, ErrUnexpectedEndOfGroupMembership
  1376. }
  1377. depth--
  1378. case 5:
  1379. iNdEx += 4
  1380. default:
  1381. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  1382. }
  1383. if iNdEx < 0 {
  1384. return 0, ErrInvalidLengthMembership
  1385. }
  1386. if depth == 0 {
  1387. return iNdEx, nil
  1388. }
  1389. }
  1390. return 0, io.ErrUnexpectedEOF
  1391. }
  1392. var (
  1393. ErrInvalidLengthMembership = fmt.Errorf("proto: negative length found during unmarshaling")
  1394. ErrIntOverflowMembership = fmt.Errorf("proto: integer overflow")
  1395. ErrUnexpectedEndOfGroupMembership = fmt.Errorf("proto: unexpected end of group")
  1396. )