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