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