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