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