blob: 90045a5c975985c27512bbdaaf56b4f5c3c30cdc [file] [log] [blame]
khenaidoo43c52cc2019-01-15 21:32:26 -05001// Code generated by protoc-gen-gogo. DO NOT EDIT.
2// source: etcdserver.proto
3
4/*
5 Package etcdserverpb is a generated protocol buffer package.
6
7 It is generated from these files:
8 etcdserver.proto
9 raft_internal.proto
10 rpc.proto
11
12 It has these top-level messages:
13 Request
14 Metadata
15 RequestHeader
16 InternalRaftRequest
17 EmptyResponse
18 InternalAuthenticateRequest
19 ResponseHeader
20 RangeRequest
21 RangeResponse
22 PutRequest
23 PutResponse
24 DeleteRangeRequest
25 DeleteRangeResponse
26 RequestOp
27 ResponseOp
28 Compare
29 TxnRequest
30 TxnResponse
31 CompactionRequest
32 CompactionResponse
33 HashRequest
34 HashKVRequest
35 HashKVResponse
36 HashResponse
37 SnapshotRequest
38 SnapshotResponse
39 WatchRequest
40 WatchCreateRequest
41 WatchCancelRequest
42 WatchResponse
43 LeaseGrantRequest
44 LeaseGrantResponse
45 LeaseRevokeRequest
46 LeaseRevokeResponse
47 LeaseKeepAliveRequest
48 LeaseKeepAliveResponse
49 LeaseTimeToLiveRequest
50 LeaseTimeToLiveResponse
51 LeaseLeasesRequest
52 LeaseStatus
53 LeaseLeasesResponse
54 Member
55 MemberAddRequest
56 MemberAddResponse
57 MemberRemoveRequest
58 MemberRemoveResponse
59 MemberUpdateRequest
60 MemberUpdateResponse
61 MemberListRequest
62 MemberListResponse
63 DefragmentRequest
64 DefragmentResponse
65 MoveLeaderRequest
66 MoveLeaderResponse
67 AlarmRequest
68 AlarmMember
69 AlarmResponse
70 StatusRequest
71 StatusResponse
72 AuthEnableRequest
73 AuthDisableRequest
74 AuthenticateRequest
75 AuthUserAddRequest
76 AuthUserGetRequest
77 AuthUserDeleteRequest
78 AuthUserChangePasswordRequest
79 AuthUserGrantRoleRequest
80 AuthUserRevokeRoleRequest
81 AuthRoleAddRequest
82 AuthRoleGetRequest
83 AuthUserListRequest
84 AuthRoleListRequest
85 AuthRoleDeleteRequest
86 AuthRoleGrantPermissionRequest
87 AuthRoleRevokePermissionRequest
88 AuthEnableResponse
89 AuthDisableResponse
90 AuthenticateResponse
91 AuthUserAddResponse
92 AuthUserGetResponse
93 AuthUserDeleteResponse
94 AuthUserChangePasswordResponse
95 AuthUserGrantRoleResponse
96 AuthUserRevokeRoleResponse
97 AuthRoleAddResponse
98 AuthRoleGetResponse
99 AuthRoleListResponse
100 AuthUserListResponse
101 AuthRoleDeleteResponse
102 AuthRoleGrantPermissionResponse
103 AuthRoleRevokePermissionResponse
104*/
105package etcdserverpb
106
107import (
108 "fmt"
109
110 proto "github.com/golang/protobuf/proto"
111
112 math "math"
113
114 _ "github.com/gogo/protobuf/gogoproto"
115
116 io "io"
117)
118
119// Reference imports to suppress errors if they are not otherwise used.
120var _ = proto.Marshal
121var _ = fmt.Errorf
122var _ = math.Inf
123
124// This is a compile-time assertion to ensure that this generated file
125// is compatible with the proto package it is being compiled against.
126// A compilation error at this line likely means your copy of the
127// proto package needs to be updated.
128const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
129
130type Request struct {
131 ID uint64 `protobuf:"varint,1,opt,name=ID" json:"ID"`
132 Method string `protobuf:"bytes,2,opt,name=Method" json:"Method"`
133 Path string `protobuf:"bytes,3,opt,name=Path" json:"Path"`
134 Val string `protobuf:"bytes,4,opt,name=Val" json:"Val"`
135 Dir bool `protobuf:"varint,5,opt,name=Dir" json:"Dir"`
136 PrevValue string `protobuf:"bytes,6,opt,name=PrevValue" json:"PrevValue"`
137 PrevIndex uint64 `protobuf:"varint,7,opt,name=PrevIndex" json:"PrevIndex"`
138 PrevExist *bool `protobuf:"varint,8,opt,name=PrevExist" json:"PrevExist,omitempty"`
139 Expiration int64 `protobuf:"varint,9,opt,name=Expiration" json:"Expiration"`
140 Wait bool `protobuf:"varint,10,opt,name=Wait" json:"Wait"`
141 Since uint64 `protobuf:"varint,11,opt,name=Since" json:"Since"`
142 Recursive bool `protobuf:"varint,12,opt,name=Recursive" json:"Recursive"`
143 Sorted bool `protobuf:"varint,13,opt,name=Sorted" json:"Sorted"`
144 Quorum bool `protobuf:"varint,14,opt,name=Quorum" json:"Quorum"`
145 Time int64 `protobuf:"varint,15,opt,name=Time" json:"Time"`
146 Stream bool `protobuf:"varint,16,opt,name=Stream" json:"Stream"`
147 Refresh *bool `protobuf:"varint,17,opt,name=Refresh" json:"Refresh,omitempty"`
148 XXX_unrecognized []byte `json:"-"`
149}
150
151func (m *Request) Reset() { *m = Request{} }
152func (m *Request) String() string { return proto.CompactTextString(m) }
153func (*Request) ProtoMessage() {}
154func (*Request) Descriptor() ([]byte, []int) { return fileDescriptorEtcdserver, []int{0} }
155
156type Metadata struct {
157 NodeID uint64 `protobuf:"varint,1,opt,name=NodeID" json:"NodeID"`
158 ClusterID uint64 `protobuf:"varint,2,opt,name=ClusterID" json:"ClusterID"`
159 XXX_unrecognized []byte `json:"-"`
160}
161
162func (m *Metadata) Reset() { *m = Metadata{} }
163func (m *Metadata) String() string { return proto.CompactTextString(m) }
164func (*Metadata) ProtoMessage() {}
165func (*Metadata) Descriptor() ([]byte, []int) { return fileDescriptorEtcdserver, []int{1} }
166
167func init() {
168 proto.RegisterType((*Request)(nil), "etcdserverpb.Request")
169 proto.RegisterType((*Metadata)(nil), "etcdserverpb.Metadata")
170}
171func (m *Request) Marshal() (dAtA []byte, err error) {
172 size := m.Size()
173 dAtA = make([]byte, size)
174 n, err := m.MarshalTo(dAtA)
175 if err != nil {
176 return nil, err
177 }
178 return dAtA[:n], nil
179}
180
181func (m *Request) MarshalTo(dAtA []byte) (int, error) {
182 var i int
183 _ = i
184 var l int
185 _ = l
186 dAtA[i] = 0x8
187 i++
188 i = encodeVarintEtcdserver(dAtA, i, uint64(m.ID))
189 dAtA[i] = 0x12
190 i++
191 i = encodeVarintEtcdserver(dAtA, i, uint64(len(m.Method)))
192 i += copy(dAtA[i:], m.Method)
193 dAtA[i] = 0x1a
194 i++
195 i = encodeVarintEtcdserver(dAtA, i, uint64(len(m.Path)))
196 i += copy(dAtA[i:], m.Path)
197 dAtA[i] = 0x22
198 i++
199 i = encodeVarintEtcdserver(dAtA, i, uint64(len(m.Val)))
200 i += copy(dAtA[i:], m.Val)
201 dAtA[i] = 0x28
202 i++
203 if m.Dir {
204 dAtA[i] = 1
205 } else {
206 dAtA[i] = 0
207 }
208 i++
209 dAtA[i] = 0x32
210 i++
211 i = encodeVarintEtcdserver(dAtA, i, uint64(len(m.PrevValue)))
212 i += copy(dAtA[i:], m.PrevValue)
213 dAtA[i] = 0x38
214 i++
215 i = encodeVarintEtcdserver(dAtA, i, uint64(m.PrevIndex))
216 if m.PrevExist != nil {
217 dAtA[i] = 0x40
218 i++
219 if *m.PrevExist {
220 dAtA[i] = 1
221 } else {
222 dAtA[i] = 0
223 }
224 i++
225 }
226 dAtA[i] = 0x48
227 i++
228 i = encodeVarintEtcdserver(dAtA, i, uint64(m.Expiration))
229 dAtA[i] = 0x50
230 i++
231 if m.Wait {
232 dAtA[i] = 1
233 } else {
234 dAtA[i] = 0
235 }
236 i++
237 dAtA[i] = 0x58
238 i++
239 i = encodeVarintEtcdserver(dAtA, i, uint64(m.Since))
240 dAtA[i] = 0x60
241 i++
242 if m.Recursive {
243 dAtA[i] = 1
244 } else {
245 dAtA[i] = 0
246 }
247 i++
248 dAtA[i] = 0x68
249 i++
250 if m.Sorted {
251 dAtA[i] = 1
252 } else {
253 dAtA[i] = 0
254 }
255 i++
256 dAtA[i] = 0x70
257 i++
258 if m.Quorum {
259 dAtA[i] = 1
260 } else {
261 dAtA[i] = 0
262 }
263 i++
264 dAtA[i] = 0x78
265 i++
266 i = encodeVarintEtcdserver(dAtA, i, uint64(m.Time))
267 dAtA[i] = 0x80
268 i++
269 dAtA[i] = 0x1
270 i++
271 if m.Stream {
272 dAtA[i] = 1
273 } else {
274 dAtA[i] = 0
275 }
276 i++
277 if m.Refresh != nil {
278 dAtA[i] = 0x88
279 i++
280 dAtA[i] = 0x1
281 i++
282 if *m.Refresh {
283 dAtA[i] = 1
284 } else {
285 dAtA[i] = 0
286 }
287 i++
288 }
289 if m.XXX_unrecognized != nil {
290 i += copy(dAtA[i:], m.XXX_unrecognized)
291 }
292 return i, nil
293}
294
295func (m *Metadata) Marshal() (dAtA []byte, err error) {
296 size := m.Size()
297 dAtA = make([]byte, size)
298 n, err := m.MarshalTo(dAtA)
299 if err != nil {
300 return nil, err
301 }
302 return dAtA[:n], nil
303}
304
305func (m *Metadata) MarshalTo(dAtA []byte) (int, error) {
306 var i int
307 _ = i
308 var l int
309 _ = l
310 dAtA[i] = 0x8
311 i++
312 i = encodeVarintEtcdserver(dAtA, i, uint64(m.NodeID))
313 dAtA[i] = 0x10
314 i++
315 i = encodeVarintEtcdserver(dAtA, i, uint64(m.ClusterID))
316 if m.XXX_unrecognized != nil {
317 i += copy(dAtA[i:], m.XXX_unrecognized)
318 }
319 return i, nil
320}
321
322func encodeVarintEtcdserver(dAtA []byte, offset int, v uint64) int {
323 for v >= 1<<7 {
324 dAtA[offset] = uint8(v&0x7f | 0x80)
325 v >>= 7
326 offset++
327 }
328 dAtA[offset] = uint8(v)
329 return offset + 1
330}
331func (m *Request) Size() (n int) {
332 var l int
333 _ = l
334 n += 1 + sovEtcdserver(uint64(m.ID))
335 l = len(m.Method)
336 n += 1 + l + sovEtcdserver(uint64(l))
337 l = len(m.Path)
338 n += 1 + l + sovEtcdserver(uint64(l))
339 l = len(m.Val)
340 n += 1 + l + sovEtcdserver(uint64(l))
341 n += 2
342 l = len(m.PrevValue)
343 n += 1 + l + sovEtcdserver(uint64(l))
344 n += 1 + sovEtcdserver(uint64(m.PrevIndex))
345 if m.PrevExist != nil {
346 n += 2
347 }
348 n += 1 + sovEtcdserver(uint64(m.Expiration))
349 n += 2
350 n += 1 + sovEtcdserver(uint64(m.Since))
351 n += 2
352 n += 2
353 n += 2
354 n += 1 + sovEtcdserver(uint64(m.Time))
355 n += 3
356 if m.Refresh != nil {
357 n += 3
358 }
359 if m.XXX_unrecognized != nil {
360 n += len(m.XXX_unrecognized)
361 }
362 return n
363}
364
365func (m *Metadata) Size() (n int) {
366 var l int
367 _ = l
368 n += 1 + sovEtcdserver(uint64(m.NodeID))
369 n += 1 + sovEtcdserver(uint64(m.ClusterID))
370 if m.XXX_unrecognized != nil {
371 n += len(m.XXX_unrecognized)
372 }
373 return n
374}
375
376func sovEtcdserver(x uint64) (n int) {
377 for {
378 n++
379 x >>= 7
380 if x == 0 {
381 break
382 }
383 }
384 return n
385}
386func sozEtcdserver(x uint64) (n int) {
387 return sovEtcdserver(uint64((x << 1) ^ uint64((int64(x) >> 63))))
388}
389func (m *Request) Unmarshal(dAtA []byte) error {
390 l := len(dAtA)
391 iNdEx := 0
392 for iNdEx < l {
393 preIndex := iNdEx
394 var wire uint64
395 for shift := uint(0); ; shift += 7 {
396 if shift >= 64 {
397 return ErrIntOverflowEtcdserver
398 }
399 if iNdEx >= l {
400 return io.ErrUnexpectedEOF
401 }
402 b := dAtA[iNdEx]
403 iNdEx++
404 wire |= (uint64(b) & 0x7F) << shift
405 if b < 0x80 {
406 break
407 }
408 }
409 fieldNum := int32(wire >> 3)
410 wireType := int(wire & 0x7)
411 if wireType == 4 {
412 return fmt.Errorf("proto: Request: wiretype end group for non-group")
413 }
414 if fieldNum <= 0 {
415 return fmt.Errorf("proto: Request: illegal tag %d (wire type %d)", fieldNum, wire)
416 }
417 switch fieldNum {
418 case 1:
419 if wireType != 0 {
420 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
421 }
422 m.ID = 0
423 for shift := uint(0); ; shift += 7 {
424 if shift >= 64 {
425 return ErrIntOverflowEtcdserver
426 }
427 if iNdEx >= l {
428 return io.ErrUnexpectedEOF
429 }
430 b := dAtA[iNdEx]
431 iNdEx++
432 m.ID |= (uint64(b) & 0x7F) << shift
433 if b < 0x80 {
434 break
435 }
436 }
437 case 2:
438 if wireType != 2 {
439 return fmt.Errorf("proto: wrong wireType = %d for field Method", wireType)
440 }
441 var stringLen uint64
442 for shift := uint(0); ; shift += 7 {
443 if shift >= 64 {
444 return ErrIntOverflowEtcdserver
445 }
446 if iNdEx >= l {
447 return io.ErrUnexpectedEOF
448 }
449 b := dAtA[iNdEx]
450 iNdEx++
451 stringLen |= (uint64(b) & 0x7F) << shift
452 if b < 0x80 {
453 break
454 }
455 }
456 intStringLen := int(stringLen)
457 if intStringLen < 0 {
458 return ErrInvalidLengthEtcdserver
459 }
460 postIndex := iNdEx + intStringLen
461 if postIndex > l {
462 return io.ErrUnexpectedEOF
463 }
464 m.Method = string(dAtA[iNdEx:postIndex])
465 iNdEx = postIndex
466 case 3:
467 if wireType != 2 {
468 return fmt.Errorf("proto: wrong wireType = %d for field Path", wireType)
469 }
470 var stringLen uint64
471 for shift := uint(0); ; shift += 7 {
472 if shift >= 64 {
473 return ErrIntOverflowEtcdserver
474 }
475 if iNdEx >= l {
476 return io.ErrUnexpectedEOF
477 }
478 b := dAtA[iNdEx]
479 iNdEx++
480 stringLen |= (uint64(b) & 0x7F) << shift
481 if b < 0x80 {
482 break
483 }
484 }
485 intStringLen := int(stringLen)
486 if intStringLen < 0 {
487 return ErrInvalidLengthEtcdserver
488 }
489 postIndex := iNdEx + intStringLen
490 if postIndex > l {
491 return io.ErrUnexpectedEOF
492 }
493 m.Path = string(dAtA[iNdEx:postIndex])
494 iNdEx = postIndex
495 case 4:
496 if wireType != 2 {
497 return fmt.Errorf("proto: wrong wireType = %d for field Val", wireType)
498 }
499 var stringLen uint64
500 for shift := uint(0); ; shift += 7 {
501 if shift >= 64 {
502 return ErrIntOverflowEtcdserver
503 }
504 if iNdEx >= l {
505 return io.ErrUnexpectedEOF
506 }
507 b := dAtA[iNdEx]
508 iNdEx++
509 stringLen |= (uint64(b) & 0x7F) << shift
510 if b < 0x80 {
511 break
512 }
513 }
514 intStringLen := int(stringLen)
515 if intStringLen < 0 {
516 return ErrInvalidLengthEtcdserver
517 }
518 postIndex := iNdEx + intStringLen
519 if postIndex > l {
520 return io.ErrUnexpectedEOF
521 }
522 m.Val = string(dAtA[iNdEx:postIndex])
523 iNdEx = postIndex
524 case 5:
525 if wireType != 0 {
526 return fmt.Errorf("proto: wrong wireType = %d for field Dir", wireType)
527 }
528 var v int
529 for shift := uint(0); ; shift += 7 {
530 if shift >= 64 {
531 return ErrIntOverflowEtcdserver
532 }
533 if iNdEx >= l {
534 return io.ErrUnexpectedEOF
535 }
536 b := dAtA[iNdEx]
537 iNdEx++
538 v |= (int(b) & 0x7F) << shift
539 if b < 0x80 {
540 break
541 }
542 }
543 m.Dir = bool(v != 0)
544 case 6:
545 if wireType != 2 {
546 return fmt.Errorf("proto: wrong wireType = %d for field PrevValue", wireType)
547 }
548 var stringLen uint64
549 for shift := uint(0); ; shift += 7 {
550 if shift >= 64 {
551 return ErrIntOverflowEtcdserver
552 }
553 if iNdEx >= l {
554 return io.ErrUnexpectedEOF
555 }
556 b := dAtA[iNdEx]
557 iNdEx++
558 stringLen |= (uint64(b) & 0x7F) << shift
559 if b < 0x80 {
560 break
561 }
562 }
563 intStringLen := int(stringLen)
564 if intStringLen < 0 {
565 return ErrInvalidLengthEtcdserver
566 }
567 postIndex := iNdEx + intStringLen
568 if postIndex > l {
569 return io.ErrUnexpectedEOF
570 }
571 m.PrevValue = string(dAtA[iNdEx:postIndex])
572 iNdEx = postIndex
573 case 7:
574 if wireType != 0 {
575 return fmt.Errorf("proto: wrong wireType = %d for field PrevIndex", wireType)
576 }
577 m.PrevIndex = 0
578 for shift := uint(0); ; shift += 7 {
579 if shift >= 64 {
580 return ErrIntOverflowEtcdserver
581 }
582 if iNdEx >= l {
583 return io.ErrUnexpectedEOF
584 }
585 b := dAtA[iNdEx]
586 iNdEx++
587 m.PrevIndex |= (uint64(b) & 0x7F) << shift
588 if b < 0x80 {
589 break
590 }
591 }
592 case 8:
593 if wireType != 0 {
594 return fmt.Errorf("proto: wrong wireType = %d for field PrevExist", wireType)
595 }
596 var v int
597 for shift := uint(0); ; shift += 7 {
598 if shift >= 64 {
599 return ErrIntOverflowEtcdserver
600 }
601 if iNdEx >= l {
602 return io.ErrUnexpectedEOF
603 }
604 b := dAtA[iNdEx]
605 iNdEx++
606 v |= (int(b) & 0x7F) << shift
607 if b < 0x80 {
608 break
609 }
610 }
611 b := bool(v != 0)
612 m.PrevExist = &b
613 case 9:
614 if wireType != 0 {
615 return fmt.Errorf("proto: wrong wireType = %d for field Expiration", wireType)
616 }
617 m.Expiration = 0
618 for shift := uint(0); ; shift += 7 {
619 if shift >= 64 {
620 return ErrIntOverflowEtcdserver
621 }
622 if iNdEx >= l {
623 return io.ErrUnexpectedEOF
624 }
625 b := dAtA[iNdEx]
626 iNdEx++
627 m.Expiration |= (int64(b) & 0x7F) << shift
628 if b < 0x80 {
629 break
630 }
631 }
632 case 10:
633 if wireType != 0 {
634 return fmt.Errorf("proto: wrong wireType = %d for field Wait", wireType)
635 }
636 var v int
637 for shift := uint(0); ; shift += 7 {
638 if shift >= 64 {
639 return ErrIntOverflowEtcdserver
640 }
641 if iNdEx >= l {
642 return io.ErrUnexpectedEOF
643 }
644 b := dAtA[iNdEx]
645 iNdEx++
646 v |= (int(b) & 0x7F) << shift
647 if b < 0x80 {
648 break
649 }
650 }
651 m.Wait = bool(v != 0)
652 case 11:
653 if wireType != 0 {
654 return fmt.Errorf("proto: wrong wireType = %d for field Since", wireType)
655 }
656 m.Since = 0
657 for shift := uint(0); ; shift += 7 {
658 if shift >= 64 {
659 return ErrIntOverflowEtcdserver
660 }
661 if iNdEx >= l {
662 return io.ErrUnexpectedEOF
663 }
664 b := dAtA[iNdEx]
665 iNdEx++
666 m.Since |= (uint64(b) & 0x7F) << shift
667 if b < 0x80 {
668 break
669 }
670 }
671 case 12:
672 if wireType != 0 {
673 return fmt.Errorf("proto: wrong wireType = %d for field Recursive", wireType)
674 }
675 var v int
676 for shift := uint(0); ; shift += 7 {
677 if shift >= 64 {
678 return ErrIntOverflowEtcdserver
679 }
680 if iNdEx >= l {
681 return io.ErrUnexpectedEOF
682 }
683 b := dAtA[iNdEx]
684 iNdEx++
685 v |= (int(b) & 0x7F) << shift
686 if b < 0x80 {
687 break
688 }
689 }
690 m.Recursive = bool(v != 0)
691 case 13:
692 if wireType != 0 {
693 return fmt.Errorf("proto: wrong wireType = %d for field Sorted", wireType)
694 }
695 var v int
696 for shift := uint(0); ; shift += 7 {
697 if shift >= 64 {
698 return ErrIntOverflowEtcdserver
699 }
700 if iNdEx >= l {
701 return io.ErrUnexpectedEOF
702 }
703 b := dAtA[iNdEx]
704 iNdEx++
705 v |= (int(b) & 0x7F) << shift
706 if b < 0x80 {
707 break
708 }
709 }
710 m.Sorted = bool(v != 0)
711 case 14:
712 if wireType != 0 {
713 return fmt.Errorf("proto: wrong wireType = %d for field Quorum", wireType)
714 }
715 var v int
716 for shift := uint(0); ; shift += 7 {
717 if shift >= 64 {
718 return ErrIntOverflowEtcdserver
719 }
720 if iNdEx >= l {
721 return io.ErrUnexpectedEOF
722 }
723 b := dAtA[iNdEx]
724 iNdEx++
725 v |= (int(b) & 0x7F) << shift
726 if b < 0x80 {
727 break
728 }
729 }
730 m.Quorum = bool(v != 0)
731 case 15:
732 if wireType != 0 {
733 return fmt.Errorf("proto: wrong wireType = %d for field Time", wireType)
734 }
735 m.Time = 0
736 for shift := uint(0); ; shift += 7 {
737 if shift >= 64 {
738 return ErrIntOverflowEtcdserver
739 }
740 if iNdEx >= l {
741 return io.ErrUnexpectedEOF
742 }
743 b := dAtA[iNdEx]
744 iNdEx++
745 m.Time |= (int64(b) & 0x7F) << shift
746 if b < 0x80 {
747 break
748 }
749 }
750 case 16:
751 if wireType != 0 {
752 return fmt.Errorf("proto: wrong wireType = %d for field Stream", wireType)
753 }
754 var v int
755 for shift := uint(0); ; shift += 7 {
756 if shift >= 64 {
757 return ErrIntOverflowEtcdserver
758 }
759 if iNdEx >= l {
760 return io.ErrUnexpectedEOF
761 }
762 b := dAtA[iNdEx]
763 iNdEx++
764 v |= (int(b) & 0x7F) << shift
765 if b < 0x80 {
766 break
767 }
768 }
769 m.Stream = bool(v != 0)
770 case 17:
771 if wireType != 0 {
772 return fmt.Errorf("proto: wrong wireType = %d for field Refresh", wireType)
773 }
774 var v int
775 for shift := uint(0); ; shift += 7 {
776 if shift >= 64 {
777 return ErrIntOverflowEtcdserver
778 }
779 if iNdEx >= l {
780 return io.ErrUnexpectedEOF
781 }
782 b := dAtA[iNdEx]
783 iNdEx++
784 v |= (int(b) & 0x7F) << shift
785 if b < 0x80 {
786 break
787 }
788 }
789 b := bool(v != 0)
790 m.Refresh = &b
791 default:
792 iNdEx = preIndex
793 skippy, err := skipEtcdserver(dAtA[iNdEx:])
794 if err != nil {
795 return err
796 }
797 if skippy < 0 {
798 return ErrInvalidLengthEtcdserver
799 }
800 if (iNdEx + skippy) > l {
801 return io.ErrUnexpectedEOF
802 }
803 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
804 iNdEx += skippy
805 }
806 }
807
808 if iNdEx > l {
809 return io.ErrUnexpectedEOF
810 }
811 return nil
812}
813func (m *Metadata) Unmarshal(dAtA []byte) error {
814 l := len(dAtA)
815 iNdEx := 0
816 for iNdEx < l {
817 preIndex := iNdEx
818 var wire uint64
819 for shift := uint(0); ; shift += 7 {
820 if shift >= 64 {
821 return ErrIntOverflowEtcdserver
822 }
823 if iNdEx >= l {
824 return io.ErrUnexpectedEOF
825 }
826 b := dAtA[iNdEx]
827 iNdEx++
828 wire |= (uint64(b) & 0x7F) << shift
829 if b < 0x80 {
830 break
831 }
832 }
833 fieldNum := int32(wire >> 3)
834 wireType := int(wire & 0x7)
835 if wireType == 4 {
836 return fmt.Errorf("proto: Metadata: wiretype end group for non-group")
837 }
838 if fieldNum <= 0 {
839 return fmt.Errorf("proto: Metadata: illegal tag %d (wire type %d)", fieldNum, wire)
840 }
841 switch fieldNum {
842 case 1:
843 if wireType != 0 {
844 return fmt.Errorf("proto: wrong wireType = %d for field NodeID", wireType)
845 }
846 m.NodeID = 0
847 for shift := uint(0); ; shift += 7 {
848 if shift >= 64 {
849 return ErrIntOverflowEtcdserver
850 }
851 if iNdEx >= l {
852 return io.ErrUnexpectedEOF
853 }
854 b := dAtA[iNdEx]
855 iNdEx++
856 m.NodeID |= (uint64(b) & 0x7F) << shift
857 if b < 0x80 {
858 break
859 }
860 }
861 case 2:
862 if wireType != 0 {
863 return fmt.Errorf("proto: wrong wireType = %d for field ClusterID", wireType)
864 }
865 m.ClusterID = 0
866 for shift := uint(0); ; shift += 7 {
867 if shift >= 64 {
868 return ErrIntOverflowEtcdserver
869 }
870 if iNdEx >= l {
871 return io.ErrUnexpectedEOF
872 }
873 b := dAtA[iNdEx]
874 iNdEx++
875 m.ClusterID |= (uint64(b) & 0x7F) << shift
876 if b < 0x80 {
877 break
878 }
879 }
880 default:
881 iNdEx = preIndex
882 skippy, err := skipEtcdserver(dAtA[iNdEx:])
883 if err != nil {
884 return err
885 }
886 if skippy < 0 {
887 return ErrInvalidLengthEtcdserver
888 }
889 if (iNdEx + skippy) > l {
890 return io.ErrUnexpectedEOF
891 }
892 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
893 iNdEx += skippy
894 }
895 }
896
897 if iNdEx > l {
898 return io.ErrUnexpectedEOF
899 }
900 return nil
901}
902func skipEtcdserver(dAtA []byte) (n int, err error) {
903 l := len(dAtA)
904 iNdEx := 0
905 for iNdEx < l {
906 var wire uint64
907 for shift := uint(0); ; shift += 7 {
908 if shift >= 64 {
909 return 0, ErrIntOverflowEtcdserver
910 }
911 if iNdEx >= l {
912 return 0, io.ErrUnexpectedEOF
913 }
914 b := dAtA[iNdEx]
915 iNdEx++
916 wire |= (uint64(b) & 0x7F) << shift
917 if b < 0x80 {
918 break
919 }
920 }
921 wireType := int(wire & 0x7)
922 switch wireType {
923 case 0:
924 for shift := uint(0); ; shift += 7 {
925 if shift >= 64 {
926 return 0, ErrIntOverflowEtcdserver
927 }
928 if iNdEx >= l {
929 return 0, io.ErrUnexpectedEOF
930 }
931 iNdEx++
932 if dAtA[iNdEx-1] < 0x80 {
933 break
934 }
935 }
936 return iNdEx, nil
937 case 1:
938 iNdEx += 8
939 return iNdEx, nil
940 case 2:
941 var length int
942 for shift := uint(0); ; shift += 7 {
943 if shift >= 64 {
944 return 0, ErrIntOverflowEtcdserver
945 }
946 if iNdEx >= l {
947 return 0, io.ErrUnexpectedEOF
948 }
949 b := dAtA[iNdEx]
950 iNdEx++
951 length |= (int(b) & 0x7F) << shift
952 if b < 0x80 {
953 break
954 }
955 }
956 iNdEx += length
957 if length < 0 {
958 return 0, ErrInvalidLengthEtcdserver
959 }
960 return iNdEx, nil
961 case 3:
962 for {
963 var innerWire uint64
964 var start int = iNdEx
965 for shift := uint(0); ; shift += 7 {
966 if shift >= 64 {
967 return 0, ErrIntOverflowEtcdserver
968 }
969 if iNdEx >= l {
970 return 0, io.ErrUnexpectedEOF
971 }
972 b := dAtA[iNdEx]
973 iNdEx++
974 innerWire |= (uint64(b) & 0x7F) << shift
975 if b < 0x80 {
976 break
977 }
978 }
979 innerWireType := int(innerWire & 0x7)
980 if innerWireType == 4 {
981 break
982 }
983 next, err := skipEtcdserver(dAtA[start:])
984 if err != nil {
985 return 0, err
986 }
987 iNdEx = start + next
988 }
989 return iNdEx, nil
990 case 4:
991 return iNdEx, nil
992 case 5:
993 iNdEx += 4
994 return iNdEx, nil
995 default:
996 return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
997 }
998 }
999 panic("unreachable")
1000}
1001
1002var (
1003 ErrInvalidLengthEtcdserver = fmt.Errorf("proto: negative length found during unmarshaling")
1004 ErrIntOverflowEtcdserver = fmt.Errorf("proto: integer overflow")
1005)
1006
1007func init() { proto.RegisterFile("etcdserver.proto", fileDescriptorEtcdserver) }
1008
1009var fileDescriptorEtcdserver = []byte{
1010 // 380 bytes of a gzipped FileDescriptorProto
1011 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x5c, 0xd2, 0xdd, 0x6e, 0xda, 0x30,
1012 0x14, 0x07, 0x70, 0x0c, 0xe1, 0xcb, 0x63, 0x1b, 0xb3, 0xd0, 0x74, 0x84, 0xa6, 0x2c, 0x42, 0xbb,
1013 0xc8, 0xd5, 0xf6, 0x0e, 0x2c, 0x5c, 0x44, 0x2a, 0x15, 0x0d, 0x15, 0xbd, 0x76, 0xc9, 0x29, 0x58,
1014 0x02, 0x4c, 0x1d, 0x07, 0xf1, 0x06, 0x7d, 0x85, 0x3e, 0x12, 0x97, 0x7d, 0x82, 0xaa, 0xa5, 0x2f,
1015 0x52, 0x39, 0x24, 0xc4, 0xed, 0x5d, 0xf4, 0xfb, 0x9f, 0x1c, 0x1f, 0x7f, 0xd0, 0x2e, 0xea, 0x79,
1016 0x9c, 0xa0, 0xda, 0xa1, 0xfa, 0xbb, 0x55, 0x52, 0x4b, 0xd6, 0x29, 0x65, 0x7b, 0xdb, 0xef, 0x2d,
1017 0xe4, 0x42, 0x66, 0xc1, 0x3f, 0xf3, 0x75, 0xaa, 0x19, 0x3c, 0x38, 0xb4, 0x19, 0xe1, 0x7d, 0x8a,
1018 0x89, 0x66, 0x3d, 0x5a, 0x0d, 0x03, 0x20, 0x1e, 0xf1, 0x9d, 0xa1, 0x73, 0x78, 0xfe, 0x5d, 0x89,
1019 0xaa, 0x61, 0xc0, 0x7e, 0xd1, 0xc6, 0x18, 0xf5, 0x52, 0xc6, 0x50, 0xf5, 0x88, 0xdf, 0xce, 0x93,
1020 0xdc, 0x18, 0x50, 0x67, 0xc2, 0xf5, 0x12, 0x6a, 0x56, 0x96, 0x09, 0xfb, 0x49, 0x6b, 0x33, 0xbe,
1021 0x02, 0xc7, 0x0a, 0x0c, 0x18, 0x0f, 0x84, 0x82, 0xba, 0x47, 0xfc, 0x56, 0xe1, 0x81, 0x50, 0x6c,
1022 0x40, 0xdb, 0x13, 0x85, 0xbb, 0x19, 0x5f, 0xa5, 0x08, 0x0d, 0xeb, 0xaf, 0x92, 0x8b, 0x9a, 0x70,
1023 0x13, 0xe3, 0x1e, 0x9a, 0xd6, 0xa0, 0x25, 0x17, 0x35, 0xa3, 0xbd, 0x48, 0x34, 0xb4, 0xce, 0xab,
1024 0x90, 0xa8, 0x64, 0xf6, 0x87, 0xd2, 0xd1, 0x7e, 0x2b, 0x14, 0xd7, 0x42, 0x6e, 0xa0, 0xed, 0x11,
1025 0xbf, 0x96, 0x37, 0xb2, 0xdc, 0xec, 0xed, 0x86, 0x0b, 0x0d, 0xd4, 0x1a, 0x35, 0x13, 0xd6, 0xa7,
1026 0xf5, 0xa9, 0xd8, 0xcc, 0x11, 0xbe, 0x58, 0x33, 0x9c, 0xc8, 0xac, 0x1f, 0xe1, 0x3c, 0x55, 0x89,
1027 0xd8, 0x21, 0x74, 0xac, 0x5f, 0x4b, 0x36, 0x67, 0x3a, 0x95, 0x4a, 0x63, 0x0c, 0x5f, 0xad, 0x82,
1028 0xdc, 0x4c, 0x7a, 0x95, 0x4a, 0x95, 0xae, 0xe1, 0x9b, 0x9d, 0x9e, 0xcc, 0x4c, 0x75, 0x2d, 0xd6,
1029 0x08, 0xdf, 0xad, 0xa9, 0x33, 0xc9, 0xba, 0x6a, 0x85, 0x7c, 0x0d, 0xdd, 0x0f, 0x5d, 0x33, 0x63,
1030 0xae, 0xb9, 0xe8, 0x3b, 0x85, 0xc9, 0x12, 0x7e, 0x58, 0xa7, 0x52, 0xe0, 0xe0, 0x82, 0xb6, 0xc6,
1031 0xa8, 0x79, 0xcc, 0x35, 0x37, 0x9d, 0x2e, 0x65, 0x8c, 0x9f, 0x5e, 0x43, 0x6e, 0x66, 0x87, 0xff,
1032 0x57, 0x69, 0xa2, 0x51, 0x85, 0x41, 0xf6, 0x28, 0xce, 0xb7, 0x70, 0xe6, 0x61, 0xef, 0xf0, 0xea,
1033 0x56, 0x0e, 0x47, 0x97, 0x3c, 0x1d, 0x5d, 0xf2, 0x72, 0x74, 0xc9, 0xe3, 0x9b, 0x5b, 0x79, 0x0f,
1034 0x00, 0x00, 0xff, 0xff, 0xee, 0x40, 0xba, 0xd6, 0xa4, 0x02, 0x00, 0x00,
1035}