1// Code generated by protoc-gen-gogo. DO NOT EDIT.
2// source: github.com/containerd/containerd/api/services/leases/v1/leases.proto
3
4/*
5	Package leases is a generated protocol buffer package.
6
7	It is generated from these files:
8		github.com/containerd/containerd/api/services/leases/v1/leases.proto
9
10	It has these top-level messages:
11		Lease
12		CreateRequest
13		CreateResponse
14		DeleteRequest
15		ListRequest
16		ListResponse
17*/
18package leases
19
20import proto "github.com/gogo/protobuf/proto"
21import fmt "fmt"
22import math "math"
23
24// skipping weak import gogoproto "github.com/gogo/protobuf/gogoproto"
25import google_protobuf1 "github.com/gogo/protobuf/types"
26import _ "github.com/gogo/protobuf/types"
27
28import time "time"
29
30import context "golang.org/x/net/context"
31import grpc "google.golang.org/grpc"
32
33import types "github.com/gogo/protobuf/types"
34
35import strings "strings"
36import reflect "reflect"
37import sortkeys "github.com/gogo/protobuf/sortkeys"
38
39import io "io"
40
41// Reference imports to suppress errors if they are not otherwise used.
42var _ = proto.Marshal
43var _ = fmt.Errorf
44var _ = math.Inf
45var _ = time.Kitchen
46
47// This is a compile-time assertion to ensure that this generated file
48// is compatible with the proto package it is being compiled against.
49// A compilation error at this line likely means your copy of the
50// proto package needs to be updated.
51const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package
52
53// Lease is an object which retains resources while it exists.
54type Lease struct {
55	ID        string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
56	CreatedAt time.Time         `protobuf:"bytes,2,opt,name=created_at,json=createdAt,stdtime" json:"created_at"`
57	Labels    map[string]string `protobuf:"bytes,3,rep,name=labels" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
58}
59
60func (m *Lease) Reset()                    { *m = Lease{} }
61func (*Lease) ProtoMessage()               {}
62func (*Lease) Descriptor() ([]byte, []int) { return fileDescriptorLeases, []int{0} }
63
64type CreateRequest struct {
65	// ID is used to identity the lease, when the id is not set the service
66	// generates a random identifier for the lease.
67	ID     string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
68	Labels map[string]string `protobuf:"bytes,3,rep,name=labels" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
69}
70
71func (m *CreateRequest) Reset()                    { *m = CreateRequest{} }
72func (*CreateRequest) ProtoMessage()               {}
73func (*CreateRequest) Descriptor() ([]byte, []int) { return fileDescriptorLeases, []int{1} }
74
75type CreateResponse struct {
76	Lease *Lease `protobuf:"bytes,1,opt,name=lease" json:"lease,omitempty"`
77}
78
79func (m *CreateResponse) Reset()                    { *m = CreateResponse{} }
80func (*CreateResponse) ProtoMessage()               {}
81func (*CreateResponse) Descriptor() ([]byte, []int) { return fileDescriptorLeases, []int{2} }
82
83type DeleteRequest struct {
84	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
85	// Sync indicates that the delete and cleanup should be done
86	// synchronously before returning to the caller
87	//
88	// Default is false
89	Sync bool `protobuf:"varint,2,opt,name=sync,proto3" json:"sync,omitempty"`
90}
91
92func (m *DeleteRequest) Reset()                    { *m = DeleteRequest{} }
93func (*DeleteRequest) ProtoMessage()               {}
94func (*DeleteRequest) Descriptor() ([]byte, []int) { return fileDescriptorLeases, []int{3} }
95
96type ListRequest struct {
97	Filters []string `protobuf:"bytes,1,rep,name=filters" json:"filters,omitempty"`
98}
99
100func (m *ListRequest) Reset()                    { *m = ListRequest{} }
101func (*ListRequest) ProtoMessage()               {}
102func (*ListRequest) Descriptor() ([]byte, []int) { return fileDescriptorLeases, []int{4} }
103
104type ListResponse struct {
105	Leases []*Lease `protobuf:"bytes,1,rep,name=leases" json:"leases,omitempty"`
106}
107
108func (m *ListResponse) Reset()                    { *m = ListResponse{} }
109func (*ListResponse) ProtoMessage()               {}
110func (*ListResponse) Descriptor() ([]byte, []int) { return fileDescriptorLeases, []int{5} }
111
112func init() {
113	proto.RegisterType((*Lease)(nil), "containerd.services.leases.v1.Lease")
114	proto.RegisterType((*CreateRequest)(nil), "containerd.services.leases.v1.CreateRequest")
115	proto.RegisterType((*CreateResponse)(nil), "containerd.services.leases.v1.CreateResponse")
116	proto.RegisterType((*DeleteRequest)(nil), "containerd.services.leases.v1.DeleteRequest")
117	proto.RegisterType((*ListRequest)(nil), "containerd.services.leases.v1.ListRequest")
118	proto.RegisterType((*ListResponse)(nil), "containerd.services.leases.v1.ListResponse")
119}
120
121// Reference imports to suppress errors if they are not otherwise used.
122var _ context.Context
123var _ grpc.ClientConn
124
125// This is a compile-time assertion to ensure that this generated file
126// is compatible with the grpc package it is being compiled against.
127const _ = grpc.SupportPackageIsVersion4
128
129// Client API for Leases service
130
131type LeasesClient interface {
132	// Create creates a new lease for managing changes to metadata. A lease
133	// can be used to protect objects from being removed.
134	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
135	// Delete deletes the lease and makes any unreferenced objects created
136	// during the lease eligible for garbage collection if not referenced
137	// or retained by other resources during the lease.
138	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
139	// List lists all active leases, returning the full list of
140	// leases and optionally including the referenced resources.
141	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
142}
143
144type leasesClient struct {
145	cc *grpc.ClientConn
146}
147
148func NewLeasesClient(cc *grpc.ClientConn) LeasesClient {
149	return &leasesClient{cc}
150}
151
152func (c *leasesClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) {
153	out := new(CreateResponse)
154	err := grpc.Invoke(ctx, "/containerd.services.leases.v1.Leases/Create", in, out, c.cc, opts...)
155	if err != nil {
156		return nil, err
157	}
158	return out, nil
159}
160
161func (c *leasesClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error) {
162	out := new(google_protobuf1.Empty)
163	err := grpc.Invoke(ctx, "/containerd.services.leases.v1.Leases/Delete", in, out, c.cc, opts...)
164	if err != nil {
165		return nil, err
166	}
167	return out, nil
168}
169
170func (c *leasesClient) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) {
171	out := new(ListResponse)
172	err := grpc.Invoke(ctx, "/containerd.services.leases.v1.Leases/List", in, out, c.cc, opts...)
173	if err != nil {
174		return nil, err
175	}
176	return out, nil
177}
178
179// Server API for Leases service
180
181type LeasesServer interface {
182	// Create creates a new lease for managing changes to metadata. A lease
183	// can be used to protect objects from being removed.
184	Create(context.Context, *CreateRequest) (*CreateResponse, error)
185	// Delete deletes the lease and makes any unreferenced objects created
186	// during the lease eligible for garbage collection if not referenced
187	// or retained by other resources during the lease.
188	Delete(context.Context, *DeleteRequest) (*google_protobuf1.Empty, error)
189	// List lists all active leases, returning the full list of
190	// leases and optionally including the referenced resources.
191	List(context.Context, *ListRequest) (*ListResponse, error)
192}
193
194func RegisterLeasesServer(s *grpc.Server, srv LeasesServer) {
195	s.RegisterService(&_Leases_serviceDesc, srv)
196}
197
198func _Leases_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
199	in := new(CreateRequest)
200	if err := dec(in); err != nil {
201		return nil, err
202	}
203	if interceptor == nil {
204		return srv.(LeasesServer).Create(ctx, in)
205	}
206	info := &grpc.UnaryServerInfo{
207		Server:     srv,
208		FullMethod: "/containerd.services.leases.v1.Leases/Create",
209	}
210	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
211		return srv.(LeasesServer).Create(ctx, req.(*CreateRequest))
212	}
213	return interceptor(ctx, in, info, handler)
214}
215
216func _Leases_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
217	in := new(DeleteRequest)
218	if err := dec(in); err != nil {
219		return nil, err
220	}
221	if interceptor == nil {
222		return srv.(LeasesServer).Delete(ctx, in)
223	}
224	info := &grpc.UnaryServerInfo{
225		Server:     srv,
226		FullMethod: "/containerd.services.leases.v1.Leases/Delete",
227	}
228	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
229		return srv.(LeasesServer).Delete(ctx, req.(*DeleteRequest))
230	}
231	return interceptor(ctx, in, info, handler)
232}
233
234func _Leases_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
235	in := new(ListRequest)
236	if err := dec(in); err != nil {
237		return nil, err
238	}
239	if interceptor == nil {
240		return srv.(LeasesServer).List(ctx, in)
241	}
242	info := &grpc.UnaryServerInfo{
243		Server:     srv,
244		FullMethod: "/containerd.services.leases.v1.Leases/List",
245	}
246	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
247		return srv.(LeasesServer).List(ctx, req.(*ListRequest))
248	}
249	return interceptor(ctx, in, info, handler)
250}
251
252var _Leases_serviceDesc = grpc.ServiceDesc{
253	ServiceName: "containerd.services.leases.v1.Leases",
254	HandlerType: (*LeasesServer)(nil),
255	Methods: []grpc.MethodDesc{
256		{
257			MethodName: "Create",
258			Handler:    _Leases_Create_Handler,
259		},
260		{
261			MethodName: "Delete",
262			Handler:    _Leases_Delete_Handler,
263		},
264		{
265			MethodName: "List",
266			Handler:    _Leases_List_Handler,
267		},
268	},
269	Streams:  []grpc.StreamDesc{},
270	Metadata: "github.com/containerd/containerd/api/services/leases/v1/leases.proto",
271}
272
273func (m *Lease) Marshal() (dAtA []byte, err error) {
274	size := m.Size()
275	dAtA = make([]byte, size)
276	n, err := m.MarshalTo(dAtA)
277	if err != nil {
278		return nil, err
279	}
280	return dAtA[:n], nil
281}
282
283func (m *Lease) MarshalTo(dAtA []byte) (int, error) {
284	var i int
285	_ = i
286	var l int
287	_ = l
288	if len(m.ID) > 0 {
289		dAtA[i] = 0xa
290		i++
291		i = encodeVarintLeases(dAtA, i, uint64(len(m.ID)))
292		i += copy(dAtA[i:], m.ID)
293	}
294	dAtA[i] = 0x12
295	i++
296	i = encodeVarintLeases(dAtA, i, uint64(types.SizeOfStdTime(m.CreatedAt)))
297	n1, err := types.StdTimeMarshalTo(m.CreatedAt, dAtA[i:])
298	if err != nil {
299		return 0, err
300	}
301	i += n1
302	if len(m.Labels) > 0 {
303		for k, _ := range m.Labels {
304			dAtA[i] = 0x1a
305			i++
306			v := m.Labels[k]
307			mapSize := 1 + len(k) + sovLeases(uint64(len(k))) + 1 + len(v) + sovLeases(uint64(len(v)))
308			i = encodeVarintLeases(dAtA, i, uint64(mapSize))
309			dAtA[i] = 0xa
310			i++
311			i = encodeVarintLeases(dAtA, i, uint64(len(k)))
312			i += copy(dAtA[i:], k)
313			dAtA[i] = 0x12
314			i++
315			i = encodeVarintLeases(dAtA, i, uint64(len(v)))
316			i += copy(dAtA[i:], v)
317		}
318	}
319	return i, nil
320}
321
322func (m *CreateRequest) Marshal() (dAtA []byte, err error) {
323	size := m.Size()
324	dAtA = make([]byte, size)
325	n, err := m.MarshalTo(dAtA)
326	if err != nil {
327		return nil, err
328	}
329	return dAtA[:n], nil
330}
331
332func (m *CreateRequest) MarshalTo(dAtA []byte) (int, error) {
333	var i int
334	_ = i
335	var l int
336	_ = l
337	if len(m.ID) > 0 {
338		dAtA[i] = 0xa
339		i++
340		i = encodeVarintLeases(dAtA, i, uint64(len(m.ID)))
341		i += copy(dAtA[i:], m.ID)
342	}
343	if len(m.Labels) > 0 {
344		for k, _ := range m.Labels {
345			dAtA[i] = 0x1a
346			i++
347			v := m.Labels[k]
348			mapSize := 1 + len(k) + sovLeases(uint64(len(k))) + 1 + len(v) + sovLeases(uint64(len(v)))
349			i = encodeVarintLeases(dAtA, i, uint64(mapSize))
350			dAtA[i] = 0xa
351			i++
352			i = encodeVarintLeases(dAtA, i, uint64(len(k)))
353			i += copy(dAtA[i:], k)
354			dAtA[i] = 0x12
355			i++
356			i = encodeVarintLeases(dAtA, i, uint64(len(v)))
357			i += copy(dAtA[i:], v)
358		}
359	}
360	return i, nil
361}
362
363func (m *CreateResponse) Marshal() (dAtA []byte, err error) {
364	size := m.Size()
365	dAtA = make([]byte, size)
366	n, err := m.MarshalTo(dAtA)
367	if err != nil {
368		return nil, err
369	}
370	return dAtA[:n], nil
371}
372
373func (m *CreateResponse) MarshalTo(dAtA []byte) (int, error) {
374	var i int
375	_ = i
376	var l int
377	_ = l
378	if m.Lease != nil {
379		dAtA[i] = 0xa
380		i++
381		i = encodeVarintLeases(dAtA, i, uint64(m.Lease.Size()))
382		n2, err := m.Lease.MarshalTo(dAtA[i:])
383		if err != nil {
384			return 0, err
385		}
386		i += n2
387	}
388	return i, nil
389}
390
391func (m *DeleteRequest) Marshal() (dAtA []byte, err error) {
392	size := m.Size()
393	dAtA = make([]byte, size)
394	n, err := m.MarshalTo(dAtA)
395	if err != nil {
396		return nil, err
397	}
398	return dAtA[:n], nil
399}
400
401func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error) {
402	var i int
403	_ = i
404	var l int
405	_ = l
406	if len(m.ID) > 0 {
407		dAtA[i] = 0xa
408		i++
409		i = encodeVarintLeases(dAtA, i, uint64(len(m.ID)))
410		i += copy(dAtA[i:], m.ID)
411	}
412	if m.Sync {
413		dAtA[i] = 0x10
414		i++
415		if m.Sync {
416			dAtA[i] = 1
417		} else {
418			dAtA[i] = 0
419		}
420		i++
421	}
422	return i, nil
423}
424
425func (m *ListRequest) Marshal() (dAtA []byte, err error) {
426	size := m.Size()
427	dAtA = make([]byte, size)
428	n, err := m.MarshalTo(dAtA)
429	if err != nil {
430		return nil, err
431	}
432	return dAtA[:n], nil
433}
434
435func (m *ListRequest) MarshalTo(dAtA []byte) (int, error) {
436	var i int
437	_ = i
438	var l int
439	_ = l
440	if len(m.Filters) > 0 {
441		for _, s := range m.Filters {
442			dAtA[i] = 0xa
443			i++
444			l = len(s)
445			for l >= 1<<7 {
446				dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
447				l >>= 7
448				i++
449			}
450			dAtA[i] = uint8(l)
451			i++
452			i += copy(dAtA[i:], s)
453		}
454	}
455	return i, nil
456}
457
458func (m *ListResponse) Marshal() (dAtA []byte, err error) {
459	size := m.Size()
460	dAtA = make([]byte, size)
461	n, err := m.MarshalTo(dAtA)
462	if err != nil {
463		return nil, err
464	}
465	return dAtA[:n], nil
466}
467
468func (m *ListResponse) MarshalTo(dAtA []byte) (int, error) {
469	var i int
470	_ = i
471	var l int
472	_ = l
473	if len(m.Leases) > 0 {
474		for _, msg := range m.Leases {
475			dAtA[i] = 0xa
476			i++
477			i = encodeVarintLeases(dAtA, i, uint64(msg.Size()))
478			n, err := msg.MarshalTo(dAtA[i:])
479			if err != nil {
480				return 0, err
481			}
482			i += n
483		}
484	}
485	return i, nil
486}
487
488func encodeVarintLeases(dAtA []byte, offset int, v uint64) int {
489	for v >= 1<<7 {
490		dAtA[offset] = uint8(v&0x7f | 0x80)
491		v >>= 7
492		offset++
493	}
494	dAtA[offset] = uint8(v)
495	return offset + 1
496}
497func (m *Lease) Size() (n int) {
498	var l int
499	_ = l
500	l = len(m.ID)
501	if l > 0 {
502		n += 1 + l + sovLeases(uint64(l))
503	}
504	l = types.SizeOfStdTime(m.CreatedAt)
505	n += 1 + l + sovLeases(uint64(l))
506	if len(m.Labels) > 0 {
507		for k, v := range m.Labels {
508			_ = k
509			_ = v
510			mapEntrySize := 1 + len(k) + sovLeases(uint64(len(k))) + 1 + len(v) + sovLeases(uint64(len(v)))
511			n += mapEntrySize + 1 + sovLeases(uint64(mapEntrySize))
512		}
513	}
514	return n
515}
516
517func (m *CreateRequest) Size() (n int) {
518	var l int
519	_ = l
520	l = len(m.ID)
521	if l > 0 {
522		n += 1 + l + sovLeases(uint64(l))
523	}
524	if len(m.Labels) > 0 {
525		for k, v := range m.Labels {
526			_ = k
527			_ = v
528			mapEntrySize := 1 + len(k) + sovLeases(uint64(len(k))) + 1 + len(v) + sovLeases(uint64(len(v)))
529			n += mapEntrySize + 1 + sovLeases(uint64(mapEntrySize))
530		}
531	}
532	return n
533}
534
535func (m *CreateResponse) Size() (n int) {
536	var l int
537	_ = l
538	if m.Lease != nil {
539		l = m.Lease.Size()
540		n += 1 + l + sovLeases(uint64(l))
541	}
542	return n
543}
544
545func (m *DeleteRequest) Size() (n int) {
546	var l int
547	_ = l
548	l = len(m.ID)
549	if l > 0 {
550		n += 1 + l + sovLeases(uint64(l))
551	}
552	if m.Sync {
553		n += 2
554	}
555	return n
556}
557
558func (m *ListRequest) Size() (n int) {
559	var l int
560	_ = l
561	if len(m.Filters) > 0 {
562		for _, s := range m.Filters {
563			l = len(s)
564			n += 1 + l + sovLeases(uint64(l))
565		}
566	}
567	return n
568}
569
570func (m *ListResponse) Size() (n int) {
571	var l int
572	_ = l
573	if len(m.Leases) > 0 {
574		for _, e := range m.Leases {
575			l = e.Size()
576			n += 1 + l + sovLeases(uint64(l))
577		}
578	}
579	return n
580}
581
582func sovLeases(x uint64) (n int) {
583	for {
584		n++
585		x >>= 7
586		if x == 0 {
587			break
588		}
589	}
590	return n
591}
592func sozLeases(x uint64) (n int) {
593	return sovLeases(uint64((x << 1) ^ uint64((int64(x) >> 63))))
594}
595func (this *Lease) String() string {
596	if this == nil {
597		return "nil"
598	}
599	keysForLabels := make([]string, 0, len(this.Labels))
600	for k, _ := range this.Labels {
601		keysForLabels = append(keysForLabels, k)
602	}
603	sortkeys.Strings(keysForLabels)
604	mapStringForLabels := "map[string]string{"
605	for _, k := range keysForLabels {
606		mapStringForLabels += fmt.Sprintf("%v: %v,", k, this.Labels[k])
607	}
608	mapStringForLabels += "}"
609	s := strings.Join([]string{`&Lease{`,
610		`ID:` + fmt.Sprintf("%v", this.ID) + `,`,
611		`CreatedAt:` + strings.Replace(strings.Replace(this.CreatedAt.String(), "Timestamp", "google_protobuf2.Timestamp", 1), `&`, ``, 1) + `,`,
612		`Labels:` + mapStringForLabels + `,`,
613		`}`,
614	}, "")
615	return s
616}
617func (this *CreateRequest) String() string {
618	if this == nil {
619		return "nil"
620	}
621	keysForLabels := make([]string, 0, len(this.Labels))
622	for k, _ := range this.Labels {
623		keysForLabels = append(keysForLabels, k)
624	}
625	sortkeys.Strings(keysForLabels)
626	mapStringForLabels := "map[string]string{"
627	for _, k := range keysForLabels {
628		mapStringForLabels += fmt.Sprintf("%v: %v,", k, this.Labels[k])
629	}
630	mapStringForLabels += "}"
631	s := strings.Join([]string{`&CreateRequest{`,
632		`ID:` + fmt.Sprintf("%v", this.ID) + `,`,
633		`Labels:` + mapStringForLabels + `,`,
634		`}`,
635	}, "")
636	return s
637}
638func (this *CreateResponse) String() string {
639	if this == nil {
640		return "nil"
641	}
642	s := strings.Join([]string{`&CreateResponse{`,
643		`Lease:` + strings.Replace(fmt.Sprintf("%v", this.Lease), "Lease", "Lease", 1) + `,`,
644		`}`,
645	}, "")
646	return s
647}
648func (this *DeleteRequest) String() string {
649	if this == nil {
650		return "nil"
651	}
652	s := strings.Join([]string{`&DeleteRequest{`,
653		`ID:` + fmt.Sprintf("%v", this.ID) + `,`,
654		`Sync:` + fmt.Sprintf("%v", this.Sync) + `,`,
655		`}`,
656	}, "")
657	return s
658}
659func (this *ListRequest) String() string {
660	if this == nil {
661		return "nil"
662	}
663	s := strings.Join([]string{`&ListRequest{`,
664		`Filters:` + fmt.Sprintf("%v", this.Filters) + `,`,
665		`}`,
666	}, "")
667	return s
668}
669func (this *ListResponse) String() string {
670	if this == nil {
671		return "nil"
672	}
673	s := strings.Join([]string{`&ListResponse{`,
674		`Leases:` + strings.Replace(fmt.Sprintf("%v", this.Leases), "Lease", "Lease", 1) + `,`,
675		`}`,
676	}, "")
677	return s
678}
679func valueToStringLeases(v interface{}) string {
680	rv := reflect.ValueOf(v)
681	if rv.IsNil() {
682		return "nil"
683	}
684	pv := reflect.Indirect(rv).Interface()
685	return fmt.Sprintf("*%v", pv)
686}
687func (m *Lease) Unmarshal(dAtA []byte) error {
688	l := len(dAtA)
689	iNdEx := 0
690	for iNdEx < l {
691		preIndex := iNdEx
692		var wire uint64
693		for shift := uint(0); ; shift += 7 {
694			if shift >= 64 {
695				return ErrIntOverflowLeases
696			}
697			if iNdEx >= l {
698				return io.ErrUnexpectedEOF
699			}
700			b := dAtA[iNdEx]
701			iNdEx++
702			wire |= (uint64(b) & 0x7F) << shift
703			if b < 0x80 {
704				break
705			}
706		}
707		fieldNum := int32(wire >> 3)
708		wireType := int(wire & 0x7)
709		if wireType == 4 {
710			return fmt.Errorf("proto: Lease: wiretype end group for non-group")
711		}
712		if fieldNum <= 0 {
713			return fmt.Errorf("proto: Lease: illegal tag %d (wire type %d)", fieldNum, wire)
714		}
715		switch fieldNum {
716		case 1:
717			if wireType != 2 {
718				return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
719			}
720			var stringLen uint64
721			for shift := uint(0); ; shift += 7 {
722				if shift >= 64 {
723					return ErrIntOverflowLeases
724				}
725				if iNdEx >= l {
726					return io.ErrUnexpectedEOF
727				}
728				b := dAtA[iNdEx]
729				iNdEx++
730				stringLen |= (uint64(b) & 0x7F) << shift
731				if b < 0x80 {
732					break
733				}
734			}
735			intStringLen := int(stringLen)
736			if intStringLen < 0 {
737				return ErrInvalidLengthLeases
738			}
739			postIndex := iNdEx + intStringLen
740			if postIndex > l {
741				return io.ErrUnexpectedEOF
742			}
743			m.ID = string(dAtA[iNdEx:postIndex])
744			iNdEx = postIndex
745		case 2:
746			if wireType != 2 {
747				return fmt.Errorf("proto: wrong wireType = %d for field CreatedAt", wireType)
748			}
749			var msglen int
750			for shift := uint(0); ; shift += 7 {
751				if shift >= 64 {
752					return ErrIntOverflowLeases
753				}
754				if iNdEx >= l {
755					return io.ErrUnexpectedEOF
756				}
757				b := dAtA[iNdEx]
758				iNdEx++
759				msglen |= (int(b) & 0x7F) << shift
760				if b < 0x80 {
761					break
762				}
763			}
764			if msglen < 0 {
765				return ErrInvalidLengthLeases
766			}
767			postIndex := iNdEx + msglen
768			if postIndex > l {
769				return io.ErrUnexpectedEOF
770			}
771			if err := types.StdTimeUnmarshal(&m.CreatedAt, dAtA[iNdEx:postIndex]); err != nil {
772				return err
773			}
774			iNdEx = postIndex
775		case 3:
776			if wireType != 2 {
777				return fmt.Errorf("proto: wrong wireType = %d for field Labels", wireType)
778			}
779			var msglen int
780			for shift := uint(0); ; shift += 7 {
781				if shift >= 64 {
782					return ErrIntOverflowLeases
783				}
784				if iNdEx >= l {
785					return io.ErrUnexpectedEOF
786				}
787				b := dAtA[iNdEx]
788				iNdEx++
789				msglen |= (int(b) & 0x7F) << shift
790				if b < 0x80 {
791					break
792				}
793			}
794			if msglen < 0 {
795				return ErrInvalidLengthLeases
796			}
797			postIndex := iNdEx + msglen
798			if postIndex > l {
799				return io.ErrUnexpectedEOF
800			}
801			if m.Labels == nil {
802				m.Labels = make(map[string]string)
803			}
804			var mapkey string
805			var mapvalue string
806			for iNdEx < postIndex {
807				entryPreIndex := iNdEx
808				var wire uint64
809				for shift := uint(0); ; shift += 7 {
810					if shift >= 64 {
811						return ErrIntOverflowLeases
812					}
813					if iNdEx >= l {
814						return io.ErrUnexpectedEOF
815					}
816					b := dAtA[iNdEx]
817					iNdEx++
818					wire |= (uint64(b) & 0x7F) << shift
819					if b < 0x80 {
820						break
821					}
822				}
823				fieldNum := int32(wire >> 3)
824				if fieldNum == 1 {
825					var stringLenmapkey uint64
826					for shift := uint(0); ; shift += 7 {
827						if shift >= 64 {
828							return ErrIntOverflowLeases
829						}
830						if iNdEx >= l {
831							return io.ErrUnexpectedEOF
832						}
833						b := dAtA[iNdEx]
834						iNdEx++
835						stringLenmapkey |= (uint64(b) & 0x7F) << shift
836						if b < 0x80 {
837							break
838						}
839					}
840					intStringLenmapkey := int(stringLenmapkey)
841					if intStringLenmapkey < 0 {
842						return ErrInvalidLengthLeases
843					}
844					postStringIndexmapkey := iNdEx + intStringLenmapkey
845					if postStringIndexmapkey > l {
846						return io.ErrUnexpectedEOF
847					}
848					mapkey = string(dAtA[iNdEx:postStringIndexmapkey])
849					iNdEx = postStringIndexmapkey
850				} else if fieldNum == 2 {
851					var stringLenmapvalue uint64
852					for shift := uint(0); ; shift += 7 {
853						if shift >= 64 {
854							return ErrIntOverflowLeases
855						}
856						if iNdEx >= l {
857							return io.ErrUnexpectedEOF
858						}
859						b := dAtA[iNdEx]
860						iNdEx++
861						stringLenmapvalue |= (uint64(b) & 0x7F) << shift
862						if b < 0x80 {
863							break
864						}
865					}
866					intStringLenmapvalue := int(stringLenmapvalue)
867					if intStringLenmapvalue < 0 {
868						return ErrInvalidLengthLeases
869					}
870					postStringIndexmapvalue := iNdEx + intStringLenmapvalue
871					if postStringIndexmapvalue > l {
872						return io.ErrUnexpectedEOF
873					}
874					mapvalue = string(dAtA[iNdEx:postStringIndexmapvalue])
875					iNdEx = postStringIndexmapvalue
876				} else {
877					iNdEx = entryPreIndex
878					skippy, err := skipLeases(dAtA[iNdEx:])
879					if err != nil {
880						return err
881					}
882					if skippy < 0 {
883						return ErrInvalidLengthLeases
884					}
885					if (iNdEx + skippy) > postIndex {
886						return io.ErrUnexpectedEOF
887					}
888					iNdEx += skippy
889				}
890			}
891			m.Labels[mapkey] = mapvalue
892			iNdEx = postIndex
893		default:
894			iNdEx = preIndex
895			skippy, err := skipLeases(dAtA[iNdEx:])
896			if err != nil {
897				return err
898			}
899			if skippy < 0 {
900				return ErrInvalidLengthLeases
901			}
902			if (iNdEx + skippy) > l {
903				return io.ErrUnexpectedEOF
904			}
905			iNdEx += skippy
906		}
907	}
908
909	if iNdEx > l {
910		return io.ErrUnexpectedEOF
911	}
912	return nil
913}
914func (m *CreateRequest) Unmarshal(dAtA []byte) error {
915	l := len(dAtA)
916	iNdEx := 0
917	for iNdEx < l {
918		preIndex := iNdEx
919		var wire uint64
920		for shift := uint(0); ; shift += 7 {
921			if shift >= 64 {
922				return ErrIntOverflowLeases
923			}
924			if iNdEx >= l {
925				return io.ErrUnexpectedEOF
926			}
927			b := dAtA[iNdEx]
928			iNdEx++
929			wire |= (uint64(b) & 0x7F) << shift
930			if b < 0x80 {
931				break
932			}
933		}
934		fieldNum := int32(wire >> 3)
935		wireType := int(wire & 0x7)
936		if wireType == 4 {
937			return fmt.Errorf("proto: CreateRequest: wiretype end group for non-group")
938		}
939		if fieldNum <= 0 {
940			return fmt.Errorf("proto: CreateRequest: illegal tag %d (wire type %d)", fieldNum, wire)
941		}
942		switch fieldNum {
943		case 1:
944			if wireType != 2 {
945				return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
946			}
947			var stringLen uint64
948			for shift := uint(0); ; shift += 7 {
949				if shift >= 64 {
950					return ErrIntOverflowLeases
951				}
952				if iNdEx >= l {
953					return io.ErrUnexpectedEOF
954				}
955				b := dAtA[iNdEx]
956				iNdEx++
957				stringLen |= (uint64(b) & 0x7F) << shift
958				if b < 0x80 {
959					break
960				}
961			}
962			intStringLen := int(stringLen)
963			if intStringLen < 0 {
964				return ErrInvalidLengthLeases
965			}
966			postIndex := iNdEx + intStringLen
967			if postIndex > l {
968				return io.ErrUnexpectedEOF
969			}
970			m.ID = string(dAtA[iNdEx:postIndex])
971			iNdEx = postIndex
972		case 3:
973			if wireType != 2 {
974				return fmt.Errorf("proto: wrong wireType = %d for field Labels", wireType)
975			}
976			var msglen int
977			for shift := uint(0); ; shift += 7 {
978				if shift >= 64 {
979					return ErrIntOverflowLeases
980				}
981				if iNdEx >= l {
982					return io.ErrUnexpectedEOF
983				}
984				b := dAtA[iNdEx]
985				iNdEx++
986				msglen |= (int(b) & 0x7F) << shift
987				if b < 0x80 {
988					break
989				}
990			}
991			if msglen < 0 {
992				return ErrInvalidLengthLeases
993			}
994			postIndex := iNdEx + msglen
995			if postIndex > l {
996				return io.ErrUnexpectedEOF
997			}
998			if m.Labels == nil {
999				m.Labels = make(map[string]string)
1000			}
1001			var mapkey string
1002			var mapvalue string
1003			for iNdEx < postIndex {
1004				entryPreIndex := iNdEx
1005				var wire uint64
1006				for shift := uint(0); ; shift += 7 {
1007					if shift >= 64 {
1008						return ErrIntOverflowLeases
1009					}
1010					if iNdEx >= l {
1011						return io.ErrUnexpectedEOF
1012					}
1013					b := dAtA[iNdEx]
1014					iNdEx++
1015					wire |= (uint64(b) & 0x7F) << shift
1016					if b < 0x80 {
1017						break
1018					}
1019				}
1020				fieldNum := int32(wire >> 3)
1021				if fieldNum == 1 {
1022					var stringLenmapkey uint64
1023					for shift := uint(0); ; shift += 7 {
1024						if shift >= 64 {
1025							return ErrIntOverflowLeases
1026						}
1027						if iNdEx >= l {
1028							return io.ErrUnexpectedEOF
1029						}
1030						b := dAtA[iNdEx]
1031						iNdEx++
1032						stringLenmapkey |= (uint64(b) & 0x7F) << shift
1033						if b < 0x80 {
1034							break
1035						}
1036					}
1037					intStringLenmapkey := int(stringLenmapkey)
1038					if intStringLenmapkey < 0 {
1039						return ErrInvalidLengthLeases
1040					}
1041					postStringIndexmapkey := iNdEx + intStringLenmapkey
1042					if postStringIndexmapkey > l {
1043						return io.ErrUnexpectedEOF
1044					}
1045					mapkey = string(dAtA[iNdEx:postStringIndexmapkey])
1046					iNdEx = postStringIndexmapkey
1047				} else if fieldNum == 2 {
1048					var stringLenmapvalue uint64
1049					for shift := uint(0); ; shift += 7 {
1050						if shift >= 64 {
1051							return ErrIntOverflowLeases
1052						}
1053						if iNdEx >= l {
1054							return io.ErrUnexpectedEOF
1055						}
1056						b := dAtA[iNdEx]
1057						iNdEx++
1058						stringLenmapvalue |= (uint64(b) & 0x7F) << shift
1059						if b < 0x80 {
1060							break
1061						}
1062					}
1063					intStringLenmapvalue := int(stringLenmapvalue)
1064					if intStringLenmapvalue < 0 {
1065						return ErrInvalidLengthLeases
1066					}
1067					postStringIndexmapvalue := iNdEx + intStringLenmapvalue
1068					if postStringIndexmapvalue > l {
1069						return io.ErrUnexpectedEOF
1070					}
1071					mapvalue = string(dAtA[iNdEx:postStringIndexmapvalue])
1072					iNdEx = postStringIndexmapvalue
1073				} else {
1074					iNdEx = entryPreIndex
1075					skippy, err := skipLeases(dAtA[iNdEx:])
1076					if err != nil {
1077						return err
1078					}
1079					if skippy < 0 {
1080						return ErrInvalidLengthLeases
1081					}
1082					if (iNdEx + skippy) > postIndex {
1083						return io.ErrUnexpectedEOF
1084					}
1085					iNdEx += skippy
1086				}
1087			}
1088			m.Labels[mapkey] = mapvalue
1089			iNdEx = postIndex
1090		default:
1091			iNdEx = preIndex
1092			skippy, err := skipLeases(dAtA[iNdEx:])
1093			if err != nil {
1094				return err
1095			}
1096			if skippy < 0 {
1097				return ErrInvalidLengthLeases
1098			}
1099			if (iNdEx + skippy) > l {
1100				return io.ErrUnexpectedEOF
1101			}
1102			iNdEx += skippy
1103		}
1104	}
1105
1106	if iNdEx > l {
1107		return io.ErrUnexpectedEOF
1108	}
1109	return nil
1110}
1111func (m *CreateResponse) Unmarshal(dAtA []byte) error {
1112	l := len(dAtA)
1113	iNdEx := 0
1114	for iNdEx < l {
1115		preIndex := iNdEx
1116		var wire uint64
1117		for shift := uint(0); ; shift += 7 {
1118			if shift >= 64 {
1119				return ErrIntOverflowLeases
1120			}
1121			if iNdEx >= l {
1122				return io.ErrUnexpectedEOF
1123			}
1124			b := dAtA[iNdEx]
1125			iNdEx++
1126			wire |= (uint64(b) & 0x7F) << shift
1127			if b < 0x80 {
1128				break
1129			}
1130		}
1131		fieldNum := int32(wire >> 3)
1132		wireType := int(wire & 0x7)
1133		if wireType == 4 {
1134			return fmt.Errorf("proto: CreateResponse: wiretype end group for non-group")
1135		}
1136		if fieldNum <= 0 {
1137			return fmt.Errorf("proto: CreateResponse: illegal tag %d (wire type %d)", fieldNum, wire)
1138		}
1139		switch fieldNum {
1140		case 1:
1141			if wireType != 2 {
1142				return fmt.Errorf("proto: wrong wireType = %d for field Lease", wireType)
1143			}
1144			var msglen int
1145			for shift := uint(0); ; shift += 7 {
1146				if shift >= 64 {
1147					return ErrIntOverflowLeases
1148				}
1149				if iNdEx >= l {
1150					return io.ErrUnexpectedEOF
1151				}
1152				b := dAtA[iNdEx]
1153				iNdEx++
1154				msglen |= (int(b) & 0x7F) << shift
1155				if b < 0x80 {
1156					break
1157				}
1158			}
1159			if msglen < 0 {
1160				return ErrInvalidLengthLeases
1161			}
1162			postIndex := iNdEx + msglen
1163			if postIndex > l {
1164				return io.ErrUnexpectedEOF
1165			}
1166			if m.Lease == nil {
1167				m.Lease = &Lease{}
1168			}
1169			if err := m.Lease.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
1170				return err
1171			}
1172			iNdEx = postIndex
1173		default:
1174			iNdEx = preIndex
1175			skippy, err := skipLeases(dAtA[iNdEx:])
1176			if err != nil {
1177				return err
1178			}
1179			if skippy < 0 {
1180				return ErrInvalidLengthLeases
1181			}
1182			if (iNdEx + skippy) > l {
1183				return io.ErrUnexpectedEOF
1184			}
1185			iNdEx += skippy
1186		}
1187	}
1188
1189	if iNdEx > l {
1190		return io.ErrUnexpectedEOF
1191	}
1192	return nil
1193}
1194func (m *DeleteRequest) Unmarshal(dAtA []byte) error {
1195	l := len(dAtA)
1196	iNdEx := 0
1197	for iNdEx < l {
1198		preIndex := iNdEx
1199		var wire uint64
1200		for shift := uint(0); ; shift += 7 {
1201			if shift >= 64 {
1202				return ErrIntOverflowLeases
1203			}
1204			if iNdEx >= l {
1205				return io.ErrUnexpectedEOF
1206			}
1207			b := dAtA[iNdEx]
1208			iNdEx++
1209			wire |= (uint64(b) & 0x7F) << shift
1210			if b < 0x80 {
1211				break
1212			}
1213		}
1214		fieldNum := int32(wire >> 3)
1215		wireType := int(wire & 0x7)
1216		if wireType == 4 {
1217			return fmt.Errorf("proto: DeleteRequest: wiretype end group for non-group")
1218		}
1219		if fieldNum <= 0 {
1220			return fmt.Errorf("proto: DeleteRequest: illegal tag %d (wire type %d)", fieldNum, wire)
1221		}
1222		switch fieldNum {
1223		case 1:
1224			if wireType != 2 {
1225				return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
1226			}
1227			var stringLen uint64
1228			for shift := uint(0); ; shift += 7 {
1229				if shift >= 64 {
1230					return ErrIntOverflowLeases
1231				}
1232				if iNdEx >= l {
1233					return io.ErrUnexpectedEOF
1234				}
1235				b := dAtA[iNdEx]
1236				iNdEx++
1237				stringLen |= (uint64(b) & 0x7F) << shift
1238				if b < 0x80 {
1239					break
1240				}
1241			}
1242			intStringLen := int(stringLen)
1243			if intStringLen < 0 {
1244				return ErrInvalidLengthLeases
1245			}
1246			postIndex := iNdEx + intStringLen
1247			if postIndex > l {
1248				return io.ErrUnexpectedEOF
1249			}
1250			m.ID = string(dAtA[iNdEx:postIndex])
1251			iNdEx = postIndex
1252		case 2:
1253			if wireType != 0 {
1254				return fmt.Errorf("proto: wrong wireType = %d for field Sync", wireType)
1255			}
1256			var v int
1257			for shift := uint(0); ; shift += 7 {
1258				if shift >= 64 {
1259					return ErrIntOverflowLeases
1260				}
1261				if iNdEx >= l {
1262					return io.ErrUnexpectedEOF
1263				}
1264				b := dAtA[iNdEx]
1265				iNdEx++
1266				v |= (int(b) & 0x7F) << shift
1267				if b < 0x80 {
1268					break
1269				}
1270			}
1271			m.Sync = bool(v != 0)
1272		default:
1273			iNdEx = preIndex
1274			skippy, err := skipLeases(dAtA[iNdEx:])
1275			if err != nil {
1276				return err
1277			}
1278			if skippy < 0 {
1279				return ErrInvalidLengthLeases
1280			}
1281			if (iNdEx + skippy) > l {
1282				return io.ErrUnexpectedEOF
1283			}
1284			iNdEx += skippy
1285		}
1286	}
1287
1288	if iNdEx > l {
1289		return io.ErrUnexpectedEOF
1290	}
1291	return nil
1292}
1293func (m *ListRequest) Unmarshal(dAtA []byte) error {
1294	l := len(dAtA)
1295	iNdEx := 0
1296	for iNdEx < l {
1297		preIndex := iNdEx
1298		var wire uint64
1299		for shift := uint(0); ; shift += 7 {
1300			if shift >= 64 {
1301				return ErrIntOverflowLeases
1302			}
1303			if iNdEx >= l {
1304				return io.ErrUnexpectedEOF
1305			}
1306			b := dAtA[iNdEx]
1307			iNdEx++
1308			wire |= (uint64(b) & 0x7F) << shift
1309			if b < 0x80 {
1310				break
1311			}
1312		}
1313		fieldNum := int32(wire >> 3)
1314		wireType := int(wire & 0x7)
1315		if wireType == 4 {
1316			return fmt.Errorf("proto: ListRequest: wiretype end group for non-group")
1317		}
1318		if fieldNum <= 0 {
1319			return fmt.Errorf("proto: ListRequest: illegal tag %d (wire type %d)", fieldNum, wire)
1320		}
1321		switch fieldNum {
1322		case 1:
1323			if wireType != 2 {
1324				return fmt.Errorf("proto: wrong wireType = %d for field Filters", wireType)
1325			}
1326			var stringLen uint64
1327			for shift := uint(0); ; shift += 7 {
1328				if shift >= 64 {
1329					return ErrIntOverflowLeases
1330				}
1331				if iNdEx >= l {
1332					return io.ErrUnexpectedEOF
1333				}
1334				b := dAtA[iNdEx]
1335				iNdEx++
1336				stringLen |= (uint64(b) & 0x7F) << shift
1337				if b < 0x80 {
1338					break
1339				}
1340			}
1341			intStringLen := int(stringLen)
1342			if intStringLen < 0 {
1343				return ErrInvalidLengthLeases
1344			}
1345			postIndex := iNdEx + intStringLen
1346			if postIndex > l {
1347				return io.ErrUnexpectedEOF
1348			}
1349			m.Filters = append(m.Filters, string(dAtA[iNdEx:postIndex]))
1350			iNdEx = postIndex
1351		default:
1352			iNdEx = preIndex
1353			skippy, err := skipLeases(dAtA[iNdEx:])
1354			if err != nil {
1355				return err
1356			}
1357			if skippy < 0 {
1358				return ErrInvalidLengthLeases
1359			}
1360			if (iNdEx + skippy) > l {
1361				return io.ErrUnexpectedEOF
1362			}
1363			iNdEx += skippy
1364		}
1365	}
1366
1367	if iNdEx > l {
1368		return io.ErrUnexpectedEOF
1369	}
1370	return nil
1371}
1372func (m *ListResponse) Unmarshal(dAtA []byte) error {
1373	l := len(dAtA)
1374	iNdEx := 0
1375	for iNdEx < l {
1376		preIndex := iNdEx
1377		var wire uint64
1378		for shift := uint(0); ; shift += 7 {
1379			if shift >= 64 {
1380				return ErrIntOverflowLeases
1381			}
1382			if iNdEx >= l {
1383				return io.ErrUnexpectedEOF
1384			}
1385			b := dAtA[iNdEx]
1386			iNdEx++
1387			wire |= (uint64(b) & 0x7F) << shift
1388			if b < 0x80 {
1389				break
1390			}
1391		}
1392		fieldNum := int32(wire >> 3)
1393		wireType := int(wire & 0x7)
1394		if wireType == 4 {
1395			return fmt.Errorf("proto: ListResponse: wiretype end group for non-group")
1396		}
1397		if fieldNum <= 0 {
1398			return fmt.Errorf("proto: ListResponse: illegal tag %d (wire type %d)", fieldNum, wire)
1399		}
1400		switch fieldNum {
1401		case 1:
1402			if wireType != 2 {
1403				return fmt.Errorf("proto: wrong wireType = %d for field Leases", wireType)
1404			}
1405			var msglen int
1406			for shift := uint(0); ; shift += 7 {
1407				if shift >= 64 {
1408					return ErrIntOverflowLeases
1409				}
1410				if iNdEx >= l {
1411					return io.ErrUnexpectedEOF
1412				}
1413				b := dAtA[iNdEx]
1414				iNdEx++
1415				msglen |= (int(b) & 0x7F) << shift
1416				if b < 0x80 {
1417					break
1418				}
1419			}
1420			if msglen < 0 {
1421				return ErrInvalidLengthLeases
1422			}
1423			postIndex := iNdEx + msglen
1424			if postIndex > l {
1425				return io.ErrUnexpectedEOF
1426			}
1427			m.Leases = append(m.Leases, &Lease{})
1428			if err := m.Leases[len(m.Leases)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
1429				return err
1430			}
1431			iNdEx = postIndex
1432		default:
1433			iNdEx = preIndex
1434			skippy, err := skipLeases(dAtA[iNdEx:])
1435			if err != nil {
1436				return err
1437			}
1438			if skippy < 0 {
1439				return ErrInvalidLengthLeases
1440			}
1441			if (iNdEx + skippy) > l {
1442				return io.ErrUnexpectedEOF
1443			}
1444			iNdEx += skippy
1445		}
1446	}
1447
1448	if iNdEx > l {
1449		return io.ErrUnexpectedEOF
1450	}
1451	return nil
1452}
1453func skipLeases(dAtA []byte) (n int, err error) {
1454	l := len(dAtA)
1455	iNdEx := 0
1456	for iNdEx < l {
1457		var wire uint64
1458		for shift := uint(0); ; shift += 7 {
1459			if shift >= 64 {
1460				return 0, ErrIntOverflowLeases
1461			}
1462			if iNdEx >= l {
1463				return 0, io.ErrUnexpectedEOF
1464			}
1465			b := dAtA[iNdEx]
1466			iNdEx++
1467			wire |= (uint64(b) & 0x7F) << shift
1468			if b < 0x80 {
1469				break
1470			}
1471		}
1472		wireType := int(wire & 0x7)
1473		switch wireType {
1474		case 0:
1475			for shift := uint(0); ; shift += 7 {
1476				if shift >= 64 {
1477					return 0, ErrIntOverflowLeases
1478				}
1479				if iNdEx >= l {
1480					return 0, io.ErrUnexpectedEOF
1481				}
1482				iNdEx++
1483				if dAtA[iNdEx-1] < 0x80 {
1484					break
1485				}
1486			}
1487			return iNdEx, nil
1488		case 1:
1489			iNdEx += 8
1490			return iNdEx, nil
1491		case 2:
1492			var length int
1493			for shift := uint(0); ; shift += 7 {
1494				if shift >= 64 {
1495					return 0, ErrIntOverflowLeases
1496				}
1497				if iNdEx >= l {
1498					return 0, io.ErrUnexpectedEOF
1499				}
1500				b := dAtA[iNdEx]
1501				iNdEx++
1502				length |= (int(b) & 0x7F) << shift
1503				if b < 0x80 {
1504					break
1505				}
1506			}
1507			iNdEx += length
1508			if length < 0 {
1509				return 0, ErrInvalidLengthLeases
1510			}
1511			return iNdEx, nil
1512		case 3:
1513			for {
1514				var innerWire uint64
1515				var start int = iNdEx
1516				for shift := uint(0); ; shift += 7 {
1517					if shift >= 64 {
1518						return 0, ErrIntOverflowLeases
1519					}
1520					if iNdEx >= l {
1521						return 0, io.ErrUnexpectedEOF
1522					}
1523					b := dAtA[iNdEx]
1524					iNdEx++
1525					innerWire |= (uint64(b) & 0x7F) << shift
1526					if b < 0x80 {
1527						break
1528					}
1529				}
1530				innerWireType := int(innerWire & 0x7)
1531				if innerWireType == 4 {
1532					break
1533				}
1534				next, err := skipLeases(dAtA[start:])
1535				if err != nil {
1536					return 0, err
1537				}
1538				iNdEx = start + next
1539			}
1540			return iNdEx, nil
1541		case 4:
1542			return iNdEx, nil
1543		case 5:
1544			iNdEx += 4
1545			return iNdEx, nil
1546		default:
1547			return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
1548		}
1549	}
1550	panic("unreachable")
1551}
1552
1553var (
1554	ErrInvalidLengthLeases = fmt.Errorf("proto: negative length found during unmarshaling")
1555	ErrIntOverflowLeases   = fmt.Errorf("proto: integer overflow")
1556)
1557
1558func init() {
1559	proto.RegisterFile("github.com/containerd/containerd/api/services/leases/v1/leases.proto", fileDescriptorLeases)
1560}
1561
1562var fileDescriptorLeases = []byte{
1563	// 515 bytes of a gzipped FileDescriptorProto
1564	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x94, 0xdf, 0x8a, 0xd3, 0x40,
1565	0x14, 0xc6, 0x3b, 0xe9, 0x36, 0x6e, 0x4f, 0x5d, 0x91, 0x61, 0x59, 0x4a, 0xc4, 0xb4, 0x04, 0xc1,
1566	0xe2, 0x9f, 0x89, 0x5b, 0x6f, 0xd6, 0x5d, 0x11, 0xec, 0x76, 0x41, 0x21, 0x88, 0x04, 0x2f, 0x16,
1567	0x6f, 0x96, 0x34, 0x3d, 0x1b, 0x83, 0x69, 0x12, 0x33, 0xd3, 0x42, 0xef, 0x7c, 0x04, 0x1f, 0xc1,
1568	0x87, 0xf0, 0x21, 0x7a, 0xe9, 0xa5, 0x57, 0xab, 0x9b, 0x3b, 0xdf, 0x42, 0x32, 0x93, 0xb0, 0x7f,
1569	0x44, 0x5b, 0x65, 0xef, 0xce, 0xcc, 0x7c, 0xdf, 0x99, 0xdf, 0xf9, 0xc2, 0x04, 0x86, 0x41, 0x28,
1570	0xde, 0x4d, 0x47, 0xcc, 0x4f, 0x26, 0xb6, 0x9f, 0xc4, 0xc2, 0x0b, 0x63, 0xcc, 0xc6, 0xe7, 0x4b,
1571	0x2f, 0x0d, 0x6d, 0x8e, 0xd9, 0x2c, 0xf4, 0x91, 0xdb, 0x11, 0x7a, 0x1c, 0xb9, 0x3d, 0xdb, 0x2e,
1572	0x2b, 0x96, 0x66, 0x89, 0x48, 0xe8, 0xed, 0x33, 0x3d, 0xab, 0xb4, 0xac, 0x54, 0xcc, 0xb6, 0x8d,
1573	0xcd, 0x20, 0x09, 0x12, 0xa9, 0xb4, 0x8b, 0x4a, 0x99, 0x8c, 0x5b, 0x41, 0x92, 0x04, 0x11, 0xda,
1574	0x72, 0x35, 0x9a, 0x1e, 0xdb, 0x38, 0x49, 0xc5, 0xbc, 0x3c, 0xec, 0x5c, 0x3e, 0x14, 0xe1, 0x04,
1575	0xb9, 0xf0, 0x26, 0xa9, 0x12, 0x58, 0x3f, 0x09, 0x34, 0x9c, 0xe2, 0x06, 0xba, 0x05, 0x5a, 0x38,
1576	0x6e, 0x93, 0x2e, 0xe9, 0x35, 0x07, 0x7a, 0x7e, 0xd2, 0xd1, 0x5e, 0x0e, 0x5d, 0x2d, 0x1c, 0xd3,
1577	0x7d, 0x00, 0x3f, 0x43, 0x4f, 0xe0, 0xf8, 0xc8, 0x13, 0x6d, 0xad, 0x4b, 0x7a, 0xad, 0xbe, 0xc1,
1578	0x54, 0x5f, 0x56, 0xf5, 0x65, 0x6f, 0xaa, 0xbe, 0x83, 0xf5, 0xc5, 0x49, 0xa7, 0xf6, 0xe9, 0x7b,
1579	0x87, 0xb8, 0xcd, 0xd2, 0xf7, 0x5c, 0xd0, 0x17, 0xa0, 0x47, 0xde, 0x08, 0x23, 0xde, 0xae, 0x77,
1580	0xeb, 0xbd, 0x56, 0xff, 0x11, 0xfb, 0xeb, 0xa8, 0x4c, 0x22, 0x31, 0x47, 0x5a, 0x0e, 0x62, 0x91,
1581	0xcd, 0xdd, 0xd2, 0x6f, 0x3c, 0x81, 0xd6, 0xb9, 0x6d, 0x7a, 0x13, 0xea, 0xef, 0x71, 0xae, 0xb0,
1582	0xdd, 0xa2, 0xa4, 0x9b, 0xd0, 0x98, 0x79, 0xd1, 0x14, 0x25, 0x6a, 0xd3, 0x55, 0x8b, 0x5d, 0x6d,
1583	0x87, 0x58, 0x5f, 0x08, 0x6c, 0xec, 0x4b, 0x24, 0x17, 0x3f, 0x4c, 0x91, 0x8b, 0x3f, 0xce, 0xfc,
1584	0xfa, 0x12, 0xee, 0xce, 0x12, 0xdc, 0x0b, 0x5d, 0xaf, 0x1a, 0xdb, 0x81, 0x1b, 0x55, 0x7f, 0x9e,
1585	0x26, 0x31, 0x47, 0xba, 0x0b, 0x0d, 0x79, 0xb7, 0xf4, 0xb7, 0xfa, 0x77, 0x56, 0x09, 0xd3, 0x55,
1586	0x16, 0x6b, 0x0f, 0x36, 0x86, 0x18, 0xe1, 0xf2, 0x0c, 0x28, 0xac, 0xf1, 0x79, 0xec, 0x4b, 0x9e,
1587	0x75, 0x57, 0xd6, 0xd6, 0x5d, 0x68, 0x39, 0x21, 0x17, 0x95, 0xb5, 0x0d, 0xd7, 0x8e, 0xc3, 0x48,
1588	0x60, 0xc6, 0xdb, 0xa4, 0x5b, 0xef, 0x35, 0xdd, 0x6a, 0x69, 0x39, 0x70, 0x5d, 0x09, 0x4b, 0xe2,
1589	0xa7, 0xa0, 0x2b, 0x1e, 0x29, 0x5c, 0x15, 0xb9, 0xf4, 0xf4, 0x3f, 0x6b, 0xa0, 0xcb, 0x1d, 0x4e,
1590	0x11, 0x74, 0x15, 0x06, 0x7d, 0xf0, 0x2f, 0xdf, 0xc4, 0x78, 0xb8, 0xa2, 0xba, 0xe4, 0x7d, 0x05,
1591	0xba, 0x4a, 0x69, 0xe9, 0x35, 0x17, 0xc2, 0x34, 0xb6, 0x7e, 0x7b, 0x18, 0x07, 0xc5, 0x6b, 0xa4,
1592	0x47, 0xb0, 0x56, 0xe4, 0x41, 0xef, 0x2d, 0x9b, 0xfb, 0x2c, 0x5d, 0xe3, 0xfe, 0x4a, 0x5a, 0x05,
1593	0x3c, 0x38, 0x5c, 0x9c, 0x9a, 0xb5, 0x6f, 0xa7, 0x66, 0xed, 0x63, 0x6e, 0x92, 0x45, 0x6e, 0x92,
1594	0xaf, 0xb9, 0x49, 0x7e, 0xe4, 0x26, 0x79, 0xfb, 0xec, 0x3f, 0x7f, 0x4d, 0x7b, 0xaa, 0x3a, 0xac,
1595	0x8d, 0x74, 0x39, 0xcc, 0xe3, 0x5f, 0x01, 0x00, 0x00, 0xff, 0xff, 0x14, 0x74, 0xdd, 0x12, 0xe5,
1596	0x04, 0x00, 0x00,
1597}
1598