1// +build go1.13 2 3// Copyright (c) Microsoft Corporation. All rights reserved. 4// Licensed under the MIT License. See License.txt in the project root for license information. 5// Code generated by Microsoft (R) AutoRest Code Generator. 6// Changes may cause incorrect behavior and will be lost if the code is regenerated. 7 8package armcontainerregistry 9 10import ( 11 "context" 12 "github.com/Azure/azure-sdk-for-go/sdk/azcore" 13 "reflect" 14) 15 16// AgentPoolListResultPager provides iteration over AgentPoolListResult pages. 17type AgentPoolListResultPager interface { 18 azcore.Pager 19 20 // PageResponse returns the current AgentPoolListResultResponse. 21 PageResponse() AgentPoolListResultResponse 22} 23 24type agentPoolListResultCreateRequest func(context.Context) (*azcore.Request, error) 25 26type agentPoolListResultHandleError func(*azcore.Response) error 27 28type agentPoolListResultHandleResponse func(*azcore.Response) (AgentPoolListResultResponse, error) 29 30type agentPoolListResultAdvancePage func(context.Context, AgentPoolListResultResponse) (*azcore.Request, error) 31 32type agentPoolListResultPager struct { 33 // the pipeline for making the request 34 pipeline azcore.Pipeline 35 // creates the initial request (non-LRO case) 36 requester agentPoolListResultCreateRequest 37 // callback for handling response errors 38 errorer agentPoolListResultHandleError 39 // callback for handling the HTTP response 40 responder agentPoolListResultHandleResponse 41 // callback for advancing to the next page 42 advancer agentPoolListResultAdvancePage 43 // contains the current response 44 current AgentPoolListResultResponse 45 // status codes for successful retrieval 46 statusCodes []int 47 // any error encountered 48 err error 49} 50 51func (p *agentPoolListResultPager) Err() error { 52 return p.err 53} 54 55func (p *agentPoolListResultPager) NextPage(ctx context.Context) bool { 56 var req *azcore.Request 57 var err error 58 if !reflect.ValueOf(p.current).IsZero() { 59 if p.current.AgentPoolListResult.NextLink == nil || len(*p.current.AgentPoolListResult.NextLink) == 0 { 60 return false 61 } 62 req, err = p.advancer(ctx, p.current) 63 } else { 64 req, err = p.requester(ctx) 65 } 66 if err != nil { 67 p.err = err 68 return false 69 } 70 resp, err := p.pipeline.Do(req) 71 if err != nil { 72 p.err = err 73 return false 74 } 75 if !resp.HasStatusCode(p.statusCodes...) { 76 p.err = p.errorer(resp) 77 return false 78 } 79 result, err := p.responder(resp) 80 if err != nil { 81 p.err = err 82 return false 83 } 84 p.current = result 85 return true 86} 87 88func (p *agentPoolListResultPager) PageResponse() AgentPoolListResultResponse { 89 return p.current 90} 91 92// ConnectedRegistryListResultPager provides iteration over ConnectedRegistryListResult pages. 93type ConnectedRegistryListResultPager interface { 94 azcore.Pager 95 96 // PageResponse returns the current ConnectedRegistryListResultResponse. 97 PageResponse() ConnectedRegistryListResultResponse 98} 99 100type connectedRegistryListResultCreateRequest func(context.Context) (*azcore.Request, error) 101 102type connectedRegistryListResultHandleError func(*azcore.Response) error 103 104type connectedRegistryListResultHandleResponse func(*azcore.Response) (ConnectedRegistryListResultResponse, error) 105 106type connectedRegistryListResultAdvancePage func(context.Context, ConnectedRegistryListResultResponse) (*azcore.Request, error) 107 108type connectedRegistryListResultPager struct { 109 // the pipeline for making the request 110 pipeline azcore.Pipeline 111 // creates the initial request (non-LRO case) 112 requester connectedRegistryListResultCreateRequest 113 // callback for handling response errors 114 errorer connectedRegistryListResultHandleError 115 // callback for handling the HTTP response 116 responder connectedRegistryListResultHandleResponse 117 // callback for advancing to the next page 118 advancer connectedRegistryListResultAdvancePage 119 // contains the current response 120 current ConnectedRegistryListResultResponse 121 // status codes for successful retrieval 122 statusCodes []int 123 // any error encountered 124 err error 125} 126 127func (p *connectedRegistryListResultPager) Err() error { 128 return p.err 129} 130 131func (p *connectedRegistryListResultPager) NextPage(ctx context.Context) bool { 132 var req *azcore.Request 133 var err error 134 if !reflect.ValueOf(p.current).IsZero() { 135 if p.current.ConnectedRegistryListResult.NextLink == nil || len(*p.current.ConnectedRegistryListResult.NextLink) == 0 { 136 return false 137 } 138 req, err = p.advancer(ctx, p.current) 139 } else { 140 req, err = p.requester(ctx) 141 } 142 if err != nil { 143 p.err = err 144 return false 145 } 146 resp, err := p.pipeline.Do(req) 147 if err != nil { 148 p.err = err 149 return false 150 } 151 if !resp.HasStatusCode(p.statusCodes...) { 152 p.err = p.errorer(resp) 153 return false 154 } 155 result, err := p.responder(resp) 156 if err != nil { 157 p.err = err 158 return false 159 } 160 p.current = result 161 return true 162} 163 164func (p *connectedRegistryListResultPager) PageResponse() ConnectedRegistryListResultResponse { 165 return p.current 166} 167 168// EventListResultPager provides iteration over EventListResult pages. 169type EventListResultPager interface { 170 azcore.Pager 171 172 // PageResponse returns the current EventListResultResponse. 173 PageResponse() EventListResultResponse 174} 175 176type eventListResultCreateRequest func(context.Context) (*azcore.Request, error) 177 178type eventListResultHandleError func(*azcore.Response) error 179 180type eventListResultHandleResponse func(*azcore.Response) (EventListResultResponse, error) 181 182type eventListResultAdvancePage func(context.Context, EventListResultResponse) (*azcore.Request, error) 183 184type eventListResultPager struct { 185 // the pipeline for making the request 186 pipeline azcore.Pipeline 187 // creates the initial request (non-LRO case) 188 requester eventListResultCreateRequest 189 // callback for handling response errors 190 errorer eventListResultHandleError 191 // callback for handling the HTTP response 192 responder eventListResultHandleResponse 193 // callback for advancing to the next page 194 advancer eventListResultAdvancePage 195 // contains the current response 196 current EventListResultResponse 197 // status codes for successful retrieval 198 statusCodes []int 199 // any error encountered 200 err error 201} 202 203func (p *eventListResultPager) Err() error { 204 return p.err 205} 206 207func (p *eventListResultPager) NextPage(ctx context.Context) bool { 208 var req *azcore.Request 209 var err error 210 if !reflect.ValueOf(p.current).IsZero() { 211 if p.current.EventListResult.NextLink == nil || len(*p.current.EventListResult.NextLink) == 0 { 212 return false 213 } 214 req, err = p.advancer(ctx, p.current) 215 } else { 216 req, err = p.requester(ctx) 217 } 218 if err != nil { 219 p.err = err 220 return false 221 } 222 resp, err := p.pipeline.Do(req) 223 if err != nil { 224 p.err = err 225 return false 226 } 227 if !resp.HasStatusCode(p.statusCodes...) { 228 p.err = p.errorer(resp) 229 return false 230 } 231 result, err := p.responder(resp) 232 if err != nil { 233 p.err = err 234 return false 235 } 236 p.current = result 237 return true 238} 239 240func (p *eventListResultPager) PageResponse() EventListResultResponse { 241 return p.current 242} 243 244// ExportPipelineListResultPager provides iteration over ExportPipelineListResult pages. 245type ExportPipelineListResultPager interface { 246 azcore.Pager 247 248 // PageResponse returns the current ExportPipelineListResultResponse. 249 PageResponse() ExportPipelineListResultResponse 250} 251 252type exportPipelineListResultCreateRequest func(context.Context) (*azcore.Request, error) 253 254type exportPipelineListResultHandleError func(*azcore.Response) error 255 256type exportPipelineListResultHandleResponse func(*azcore.Response) (ExportPipelineListResultResponse, error) 257 258type exportPipelineListResultAdvancePage func(context.Context, ExportPipelineListResultResponse) (*azcore.Request, error) 259 260type exportPipelineListResultPager struct { 261 // the pipeline for making the request 262 pipeline azcore.Pipeline 263 // creates the initial request (non-LRO case) 264 requester exportPipelineListResultCreateRequest 265 // callback for handling response errors 266 errorer exportPipelineListResultHandleError 267 // callback for handling the HTTP response 268 responder exportPipelineListResultHandleResponse 269 // callback for advancing to the next page 270 advancer exportPipelineListResultAdvancePage 271 // contains the current response 272 current ExportPipelineListResultResponse 273 // status codes for successful retrieval 274 statusCodes []int 275 // any error encountered 276 err error 277} 278 279func (p *exportPipelineListResultPager) Err() error { 280 return p.err 281} 282 283func (p *exportPipelineListResultPager) NextPage(ctx context.Context) bool { 284 var req *azcore.Request 285 var err error 286 if !reflect.ValueOf(p.current).IsZero() { 287 if p.current.ExportPipelineListResult.NextLink == nil || len(*p.current.ExportPipelineListResult.NextLink) == 0 { 288 return false 289 } 290 req, err = p.advancer(ctx, p.current) 291 } else { 292 req, err = p.requester(ctx) 293 } 294 if err != nil { 295 p.err = err 296 return false 297 } 298 resp, err := p.pipeline.Do(req) 299 if err != nil { 300 p.err = err 301 return false 302 } 303 if !resp.HasStatusCode(p.statusCodes...) { 304 p.err = p.errorer(resp) 305 return false 306 } 307 result, err := p.responder(resp) 308 if err != nil { 309 p.err = err 310 return false 311 } 312 p.current = result 313 return true 314} 315 316func (p *exportPipelineListResultPager) PageResponse() ExportPipelineListResultResponse { 317 return p.current 318} 319 320// ImportPipelineListResultPager provides iteration over ImportPipelineListResult pages. 321type ImportPipelineListResultPager interface { 322 azcore.Pager 323 324 // PageResponse returns the current ImportPipelineListResultResponse. 325 PageResponse() ImportPipelineListResultResponse 326} 327 328type importPipelineListResultCreateRequest func(context.Context) (*azcore.Request, error) 329 330type importPipelineListResultHandleError func(*azcore.Response) error 331 332type importPipelineListResultHandleResponse func(*azcore.Response) (ImportPipelineListResultResponse, error) 333 334type importPipelineListResultAdvancePage func(context.Context, ImportPipelineListResultResponse) (*azcore.Request, error) 335 336type importPipelineListResultPager struct { 337 // the pipeline for making the request 338 pipeline azcore.Pipeline 339 // creates the initial request (non-LRO case) 340 requester importPipelineListResultCreateRequest 341 // callback for handling response errors 342 errorer importPipelineListResultHandleError 343 // callback for handling the HTTP response 344 responder importPipelineListResultHandleResponse 345 // callback for advancing to the next page 346 advancer importPipelineListResultAdvancePage 347 // contains the current response 348 current ImportPipelineListResultResponse 349 // status codes for successful retrieval 350 statusCodes []int 351 // any error encountered 352 err error 353} 354 355func (p *importPipelineListResultPager) Err() error { 356 return p.err 357} 358 359func (p *importPipelineListResultPager) NextPage(ctx context.Context) bool { 360 var req *azcore.Request 361 var err error 362 if !reflect.ValueOf(p.current).IsZero() { 363 if p.current.ImportPipelineListResult.NextLink == nil || len(*p.current.ImportPipelineListResult.NextLink) == 0 { 364 return false 365 } 366 req, err = p.advancer(ctx, p.current) 367 } else { 368 req, err = p.requester(ctx) 369 } 370 if err != nil { 371 p.err = err 372 return false 373 } 374 resp, err := p.pipeline.Do(req) 375 if err != nil { 376 p.err = err 377 return false 378 } 379 if !resp.HasStatusCode(p.statusCodes...) { 380 p.err = p.errorer(resp) 381 return false 382 } 383 result, err := p.responder(resp) 384 if err != nil { 385 p.err = err 386 return false 387 } 388 p.current = result 389 return true 390} 391 392func (p *importPipelineListResultPager) PageResponse() ImportPipelineListResultResponse { 393 return p.current 394} 395 396// OperationListResultPager provides iteration over OperationListResult pages. 397type OperationListResultPager interface { 398 azcore.Pager 399 400 // PageResponse returns the current OperationListResultResponse. 401 PageResponse() OperationListResultResponse 402} 403 404type operationListResultCreateRequest func(context.Context) (*azcore.Request, error) 405 406type operationListResultHandleError func(*azcore.Response) error 407 408type operationListResultHandleResponse func(*azcore.Response) (OperationListResultResponse, error) 409 410type operationListResultAdvancePage func(context.Context, OperationListResultResponse) (*azcore.Request, error) 411 412type operationListResultPager struct { 413 // the pipeline for making the request 414 pipeline azcore.Pipeline 415 // creates the initial request (non-LRO case) 416 requester operationListResultCreateRequest 417 // callback for handling response errors 418 errorer operationListResultHandleError 419 // callback for handling the HTTP response 420 responder operationListResultHandleResponse 421 // callback for advancing to the next page 422 advancer operationListResultAdvancePage 423 // contains the current response 424 current OperationListResultResponse 425 // status codes for successful retrieval 426 statusCodes []int 427 // any error encountered 428 err error 429} 430 431func (p *operationListResultPager) Err() error { 432 return p.err 433} 434 435func (p *operationListResultPager) NextPage(ctx context.Context) bool { 436 var req *azcore.Request 437 var err error 438 if !reflect.ValueOf(p.current).IsZero() { 439 if p.current.OperationListResult.NextLink == nil || len(*p.current.OperationListResult.NextLink) == 0 { 440 return false 441 } 442 req, err = p.advancer(ctx, p.current) 443 } else { 444 req, err = p.requester(ctx) 445 } 446 if err != nil { 447 p.err = err 448 return false 449 } 450 resp, err := p.pipeline.Do(req) 451 if err != nil { 452 p.err = err 453 return false 454 } 455 if !resp.HasStatusCode(p.statusCodes...) { 456 p.err = p.errorer(resp) 457 return false 458 } 459 result, err := p.responder(resp) 460 if err != nil { 461 p.err = err 462 return false 463 } 464 p.current = result 465 return true 466} 467 468func (p *operationListResultPager) PageResponse() OperationListResultResponse { 469 return p.current 470} 471 472// PipelineRunListResultPager provides iteration over PipelineRunListResult pages. 473type PipelineRunListResultPager interface { 474 azcore.Pager 475 476 // PageResponse returns the current PipelineRunListResultResponse. 477 PageResponse() PipelineRunListResultResponse 478} 479 480type pipelineRunListResultCreateRequest func(context.Context) (*azcore.Request, error) 481 482type pipelineRunListResultHandleError func(*azcore.Response) error 483 484type pipelineRunListResultHandleResponse func(*azcore.Response) (PipelineRunListResultResponse, error) 485 486type pipelineRunListResultAdvancePage func(context.Context, PipelineRunListResultResponse) (*azcore.Request, error) 487 488type pipelineRunListResultPager struct { 489 // the pipeline for making the request 490 pipeline azcore.Pipeline 491 // creates the initial request (non-LRO case) 492 requester pipelineRunListResultCreateRequest 493 // callback for handling response errors 494 errorer pipelineRunListResultHandleError 495 // callback for handling the HTTP response 496 responder pipelineRunListResultHandleResponse 497 // callback for advancing to the next page 498 advancer pipelineRunListResultAdvancePage 499 // contains the current response 500 current PipelineRunListResultResponse 501 // status codes for successful retrieval 502 statusCodes []int 503 // any error encountered 504 err error 505} 506 507func (p *pipelineRunListResultPager) Err() error { 508 return p.err 509} 510 511func (p *pipelineRunListResultPager) NextPage(ctx context.Context) bool { 512 var req *azcore.Request 513 var err error 514 if !reflect.ValueOf(p.current).IsZero() { 515 if p.current.PipelineRunListResult.NextLink == nil || len(*p.current.PipelineRunListResult.NextLink) == 0 { 516 return false 517 } 518 req, err = p.advancer(ctx, p.current) 519 } else { 520 req, err = p.requester(ctx) 521 } 522 if err != nil { 523 p.err = err 524 return false 525 } 526 resp, err := p.pipeline.Do(req) 527 if err != nil { 528 p.err = err 529 return false 530 } 531 if !resp.HasStatusCode(p.statusCodes...) { 532 p.err = p.errorer(resp) 533 return false 534 } 535 result, err := p.responder(resp) 536 if err != nil { 537 p.err = err 538 return false 539 } 540 p.current = result 541 return true 542} 543 544func (p *pipelineRunListResultPager) PageResponse() PipelineRunListResultResponse { 545 return p.current 546} 547 548// PrivateEndpointConnectionListResultPager provides iteration over PrivateEndpointConnectionListResult pages. 549type PrivateEndpointConnectionListResultPager interface { 550 azcore.Pager 551 552 // PageResponse returns the current PrivateEndpointConnectionListResultResponse. 553 PageResponse() PrivateEndpointConnectionListResultResponse 554} 555 556type privateEndpointConnectionListResultCreateRequest func(context.Context) (*azcore.Request, error) 557 558type privateEndpointConnectionListResultHandleError func(*azcore.Response) error 559 560type privateEndpointConnectionListResultHandleResponse func(*azcore.Response) (PrivateEndpointConnectionListResultResponse, error) 561 562type privateEndpointConnectionListResultAdvancePage func(context.Context, PrivateEndpointConnectionListResultResponse) (*azcore.Request, error) 563 564type privateEndpointConnectionListResultPager struct { 565 // the pipeline for making the request 566 pipeline azcore.Pipeline 567 // creates the initial request (non-LRO case) 568 requester privateEndpointConnectionListResultCreateRequest 569 // callback for handling response errors 570 errorer privateEndpointConnectionListResultHandleError 571 // callback for handling the HTTP response 572 responder privateEndpointConnectionListResultHandleResponse 573 // callback for advancing to the next page 574 advancer privateEndpointConnectionListResultAdvancePage 575 // contains the current response 576 current PrivateEndpointConnectionListResultResponse 577 // status codes for successful retrieval 578 statusCodes []int 579 // any error encountered 580 err error 581} 582 583func (p *privateEndpointConnectionListResultPager) Err() error { 584 return p.err 585} 586 587func (p *privateEndpointConnectionListResultPager) NextPage(ctx context.Context) bool { 588 var req *azcore.Request 589 var err error 590 if !reflect.ValueOf(p.current).IsZero() { 591 if p.current.PrivateEndpointConnectionListResult.NextLink == nil || len(*p.current.PrivateEndpointConnectionListResult.NextLink) == 0 { 592 return false 593 } 594 req, err = p.advancer(ctx, p.current) 595 } else { 596 req, err = p.requester(ctx) 597 } 598 if err != nil { 599 p.err = err 600 return false 601 } 602 resp, err := p.pipeline.Do(req) 603 if err != nil { 604 p.err = err 605 return false 606 } 607 if !resp.HasStatusCode(p.statusCodes...) { 608 p.err = p.errorer(resp) 609 return false 610 } 611 result, err := p.responder(resp) 612 if err != nil { 613 p.err = err 614 return false 615 } 616 p.current = result 617 return true 618} 619 620func (p *privateEndpointConnectionListResultPager) PageResponse() PrivateEndpointConnectionListResultResponse { 621 return p.current 622} 623 624// PrivateLinkResourceListResultPager provides iteration over PrivateLinkResourceListResult pages. 625type PrivateLinkResourceListResultPager interface { 626 azcore.Pager 627 628 // PageResponse returns the current PrivateLinkResourceListResultResponse. 629 PageResponse() PrivateLinkResourceListResultResponse 630} 631 632type privateLinkResourceListResultCreateRequest func(context.Context) (*azcore.Request, error) 633 634type privateLinkResourceListResultHandleError func(*azcore.Response) error 635 636type privateLinkResourceListResultHandleResponse func(*azcore.Response) (PrivateLinkResourceListResultResponse, error) 637 638type privateLinkResourceListResultAdvancePage func(context.Context, PrivateLinkResourceListResultResponse) (*azcore.Request, error) 639 640type privateLinkResourceListResultPager struct { 641 // the pipeline for making the request 642 pipeline azcore.Pipeline 643 // creates the initial request (non-LRO case) 644 requester privateLinkResourceListResultCreateRequest 645 // callback for handling response errors 646 errorer privateLinkResourceListResultHandleError 647 // callback for handling the HTTP response 648 responder privateLinkResourceListResultHandleResponse 649 // callback for advancing to the next page 650 advancer privateLinkResourceListResultAdvancePage 651 // contains the current response 652 current PrivateLinkResourceListResultResponse 653 // status codes for successful retrieval 654 statusCodes []int 655 // any error encountered 656 err error 657} 658 659func (p *privateLinkResourceListResultPager) Err() error { 660 return p.err 661} 662 663func (p *privateLinkResourceListResultPager) NextPage(ctx context.Context) bool { 664 var req *azcore.Request 665 var err error 666 if !reflect.ValueOf(p.current).IsZero() { 667 if p.current.PrivateLinkResourceListResult.NextLink == nil || len(*p.current.PrivateLinkResourceListResult.NextLink) == 0 { 668 return false 669 } 670 req, err = p.advancer(ctx, p.current) 671 } else { 672 req, err = p.requester(ctx) 673 } 674 if err != nil { 675 p.err = err 676 return false 677 } 678 resp, err := p.pipeline.Do(req) 679 if err != nil { 680 p.err = err 681 return false 682 } 683 if !resp.HasStatusCode(p.statusCodes...) { 684 p.err = p.errorer(resp) 685 return false 686 } 687 result, err := p.responder(resp) 688 if err != nil { 689 p.err = err 690 return false 691 } 692 p.current = result 693 return true 694} 695 696func (p *privateLinkResourceListResultPager) PageResponse() PrivateLinkResourceListResultResponse { 697 return p.current 698} 699 700// RegistryListResultPager provides iteration over RegistryListResult pages. 701type RegistryListResultPager interface { 702 azcore.Pager 703 704 // PageResponse returns the current RegistryListResultResponse. 705 PageResponse() RegistryListResultResponse 706} 707 708type registryListResultCreateRequest func(context.Context) (*azcore.Request, error) 709 710type registryListResultHandleError func(*azcore.Response) error 711 712type registryListResultHandleResponse func(*azcore.Response) (RegistryListResultResponse, error) 713 714type registryListResultAdvancePage func(context.Context, RegistryListResultResponse) (*azcore.Request, error) 715 716type registryListResultPager struct { 717 // the pipeline for making the request 718 pipeline azcore.Pipeline 719 // creates the initial request (non-LRO case) 720 requester registryListResultCreateRequest 721 // callback for handling response errors 722 errorer registryListResultHandleError 723 // callback for handling the HTTP response 724 responder registryListResultHandleResponse 725 // callback for advancing to the next page 726 advancer registryListResultAdvancePage 727 // contains the current response 728 current RegistryListResultResponse 729 // status codes for successful retrieval 730 statusCodes []int 731 // any error encountered 732 err error 733} 734 735func (p *registryListResultPager) Err() error { 736 return p.err 737} 738 739func (p *registryListResultPager) NextPage(ctx context.Context) bool { 740 var req *azcore.Request 741 var err error 742 if !reflect.ValueOf(p.current).IsZero() { 743 if p.current.RegistryListResult.NextLink == nil || len(*p.current.RegistryListResult.NextLink) == 0 { 744 return false 745 } 746 req, err = p.advancer(ctx, p.current) 747 } else { 748 req, err = p.requester(ctx) 749 } 750 if err != nil { 751 p.err = err 752 return false 753 } 754 resp, err := p.pipeline.Do(req) 755 if err != nil { 756 p.err = err 757 return false 758 } 759 if !resp.HasStatusCode(p.statusCodes...) { 760 p.err = p.errorer(resp) 761 return false 762 } 763 result, err := p.responder(resp) 764 if err != nil { 765 p.err = err 766 return false 767 } 768 p.current = result 769 return true 770} 771 772func (p *registryListResultPager) PageResponse() RegistryListResultResponse { 773 return p.current 774} 775 776// ReplicationListResultPager provides iteration over ReplicationListResult pages. 777type ReplicationListResultPager interface { 778 azcore.Pager 779 780 // PageResponse returns the current ReplicationListResultResponse. 781 PageResponse() ReplicationListResultResponse 782} 783 784type replicationListResultCreateRequest func(context.Context) (*azcore.Request, error) 785 786type replicationListResultHandleError func(*azcore.Response) error 787 788type replicationListResultHandleResponse func(*azcore.Response) (ReplicationListResultResponse, error) 789 790type replicationListResultAdvancePage func(context.Context, ReplicationListResultResponse) (*azcore.Request, error) 791 792type replicationListResultPager struct { 793 // the pipeline for making the request 794 pipeline azcore.Pipeline 795 // creates the initial request (non-LRO case) 796 requester replicationListResultCreateRequest 797 // callback for handling response errors 798 errorer replicationListResultHandleError 799 // callback for handling the HTTP response 800 responder replicationListResultHandleResponse 801 // callback for advancing to the next page 802 advancer replicationListResultAdvancePage 803 // contains the current response 804 current ReplicationListResultResponse 805 // status codes for successful retrieval 806 statusCodes []int 807 // any error encountered 808 err error 809} 810 811func (p *replicationListResultPager) Err() error { 812 return p.err 813} 814 815func (p *replicationListResultPager) NextPage(ctx context.Context) bool { 816 var req *azcore.Request 817 var err error 818 if !reflect.ValueOf(p.current).IsZero() { 819 if p.current.ReplicationListResult.NextLink == nil || len(*p.current.ReplicationListResult.NextLink) == 0 { 820 return false 821 } 822 req, err = p.advancer(ctx, p.current) 823 } else { 824 req, err = p.requester(ctx) 825 } 826 if err != nil { 827 p.err = err 828 return false 829 } 830 resp, err := p.pipeline.Do(req) 831 if err != nil { 832 p.err = err 833 return false 834 } 835 if !resp.HasStatusCode(p.statusCodes...) { 836 p.err = p.errorer(resp) 837 return false 838 } 839 result, err := p.responder(resp) 840 if err != nil { 841 p.err = err 842 return false 843 } 844 p.current = result 845 return true 846} 847 848func (p *replicationListResultPager) PageResponse() ReplicationListResultResponse { 849 return p.current 850} 851 852// RunListResultPager provides iteration over RunListResult pages. 853type RunListResultPager interface { 854 azcore.Pager 855 856 // PageResponse returns the current RunListResultResponse. 857 PageResponse() RunListResultResponse 858} 859 860type runListResultCreateRequest func(context.Context) (*azcore.Request, error) 861 862type runListResultHandleError func(*azcore.Response) error 863 864type runListResultHandleResponse func(*azcore.Response) (RunListResultResponse, error) 865 866type runListResultAdvancePage func(context.Context, RunListResultResponse) (*azcore.Request, error) 867 868type runListResultPager struct { 869 // the pipeline for making the request 870 pipeline azcore.Pipeline 871 // creates the initial request (non-LRO case) 872 requester runListResultCreateRequest 873 // callback for handling response errors 874 errorer runListResultHandleError 875 // callback for handling the HTTP response 876 responder runListResultHandleResponse 877 // callback for advancing to the next page 878 advancer runListResultAdvancePage 879 // contains the current response 880 current RunListResultResponse 881 // status codes for successful retrieval 882 statusCodes []int 883 // any error encountered 884 err error 885} 886 887func (p *runListResultPager) Err() error { 888 return p.err 889} 890 891func (p *runListResultPager) NextPage(ctx context.Context) bool { 892 var req *azcore.Request 893 var err error 894 if !reflect.ValueOf(p.current).IsZero() { 895 if p.current.RunListResult.NextLink == nil || len(*p.current.RunListResult.NextLink) == 0 { 896 return false 897 } 898 req, err = p.advancer(ctx, p.current) 899 } else { 900 req, err = p.requester(ctx) 901 } 902 if err != nil { 903 p.err = err 904 return false 905 } 906 resp, err := p.pipeline.Do(req) 907 if err != nil { 908 p.err = err 909 return false 910 } 911 if !resp.HasStatusCode(p.statusCodes...) { 912 p.err = p.errorer(resp) 913 return false 914 } 915 result, err := p.responder(resp) 916 if err != nil { 917 p.err = err 918 return false 919 } 920 p.current = result 921 return true 922} 923 924func (p *runListResultPager) PageResponse() RunListResultResponse { 925 return p.current 926} 927 928// ScopeMapListResultPager provides iteration over ScopeMapListResult pages. 929type ScopeMapListResultPager interface { 930 azcore.Pager 931 932 // PageResponse returns the current ScopeMapListResultResponse. 933 PageResponse() ScopeMapListResultResponse 934} 935 936type scopeMapListResultCreateRequest func(context.Context) (*azcore.Request, error) 937 938type scopeMapListResultHandleError func(*azcore.Response) error 939 940type scopeMapListResultHandleResponse func(*azcore.Response) (ScopeMapListResultResponse, error) 941 942type scopeMapListResultAdvancePage func(context.Context, ScopeMapListResultResponse) (*azcore.Request, error) 943 944type scopeMapListResultPager struct { 945 // the pipeline for making the request 946 pipeline azcore.Pipeline 947 // creates the initial request (non-LRO case) 948 requester scopeMapListResultCreateRequest 949 // callback for handling response errors 950 errorer scopeMapListResultHandleError 951 // callback for handling the HTTP response 952 responder scopeMapListResultHandleResponse 953 // callback for advancing to the next page 954 advancer scopeMapListResultAdvancePage 955 // contains the current response 956 current ScopeMapListResultResponse 957 // status codes for successful retrieval 958 statusCodes []int 959 // any error encountered 960 err error 961} 962 963func (p *scopeMapListResultPager) Err() error { 964 return p.err 965} 966 967func (p *scopeMapListResultPager) NextPage(ctx context.Context) bool { 968 var req *azcore.Request 969 var err error 970 if !reflect.ValueOf(p.current).IsZero() { 971 if p.current.ScopeMapListResult.NextLink == nil || len(*p.current.ScopeMapListResult.NextLink) == 0 { 972 return false 973 } 974 req, err = p.advancer(ctx, p.current) 975 } else { 976 req, err = p.requester(ctx) 977 } 978 if err != nil { 979 p.err = err 980 return false 981 } 982 resp, err := p.pipeline.Do(req) 983 if err != nil { 984 p.err = err 985 return false 986 } 987 if !resp.HasStatusCode(p.statusCodes...) { 988 p.err = p.errorer(resp) 989 return false 990 } 991 result, err := p.responder(resp) 992 if err != nil { 993 p.err = err 994 return false 995 } 996 p.current = result 997 return true 998} 999 1000func (p *scopeMapListResultPager) PageResponse() ScopeMapListResultResponse { 1001 return p.current 1002} 1003 1004// TaskListResultPager provides iteration over TaskListResult pages. 1005type TaskListResultPager interface { 1006 azcore.Pager 1007 1008 // PageResponse returns the current TaskListResultResponse. 1009 PageResponse() TaskListResultResponse 1010} 1011 1012type taskListResultCreateRequest func(context.Context) (*azcore.Request, error) 1013 1014type taskListResultHandleError func(*azcore.Response) error 1015 1016type taskListResultHandleResponse func(*azcore.Response) (TaskListResultResponse, error) 1017 1018type taskListResultAdvancePage func(context.Context, TaskListResultResponse) (*azcore.Request, error) 1019 1020type taskListResultPager struct { 1021 // the pipeline for making the request 1022 pipeline azcore.Pipeline 1023 // creates the initial request (non-LRO case) 1024 requester taskListResultCreateRequest 1025 // callback for handling response errors 1026 errorer taskListResultHandleError 1027 // callback for handling the HTTP response 1028 responder taskListResultHandleResponse 1029 // callback for advancing to the next page 1030 advancer taskListResultAdvancePage 1031 // contains the current response 1032 current TaskListResultResponse 1033 // status codes for successful retrieval 1034 statusCodes []int 1035 // any error encountered 1036 err error 1037} 1038 1039func (p *taskListResultPager) Err() error { 1040 return p.err 1041} 1042 1043func (p *taskListResultPager) NextPage(ctx context.Context) bool { 1044 var req *azcore.Request 1045 var err error 1046 if !reflect.ValueOf(p.current).IsZero() { 1047 if p.current.TaskListResult.NextLink == nil || len(*p.current.TaskListResult.NextLink) == 0 { 1048 return false 1049 } 1050 req, err = p.advancer(ctx, p.current) 1051 } else { 1052 req, err = p.requester(ctx) 1053 } 1054 if err != nil { 1055 p.err = err 1056 return false 1057 } 1058 resp, err := p.pipeline.Do(req) 1059 if err != nil { 1060 p.err = err 1061 return false 1062 } 1063 if !resp.HasStatusCode(p.statusCodes...) { 1064 p.err = p.errorer(resp) 1065 return false 1066 } 1067 result, err := p.responder(resp) 1068 if err != nil { 1069 p.err = err 1070 return false 1071 } 1072 p.current = result 1073 return true 1074} 1075 1076func (p *taskListResultPager) PageResponse() TaskListResultResponse { 1077 return p.current 1078} 1079 1080// TaskRunListResultPager provides iteration over TaskRunListResult pages. 1081type TaskRunListResultPager interface { 1082 azcore.Pager 1083 1084 // PageResponse returns the current TaskRunListResultResponse. 1085 PageResponse() TaskRunListResultResponse 1086} 1087 1088type taskRunListResultCreateRequest func(context.Context) (*azcore.Request, error) 1089 1090type taskRunListResultHandleError func(*azcore.Response) error 1091 1092type taskRunListResultHandleResponse func(*azcore.Response) (TaskRunListResultResponse, error) 1093 1094type taskRunListResultAdvancePage func(context.Context, TaskRunListResultResponse) (*azcore.Request, error) 1095 1096type taskRunListResultPager struct { 1097 // the pipeline for making the request 1098 pipeline azcore.Pipeline 1099 // creates the initial request (non-LRO case) 1100 requester taskRunListResultCreateRequest 1101 // callback for handling response errors 1102 errorer taskRunListResultHandleError 1103 // callback for handling the HTTP response 1104 responder taskRunListResultHandleResponse 1105 // callback for advancing to the next page 1106 advancer taskRunListResultAdvancePage 1107 // contains the current response 1108 current TaskRunListResultResponse 1109 // status codes for successful retrieval 1110 statusCodes []int 1111 // any error encountered 1112 err error 1113} 1114 1115func (p *taskRunListResultPager) Err() error { 1116 return p.err 1117} 1118 1119func (p *taskRunListResultPager) NextPage(ctx context.Context) bool { 1120 var req *azcore.Request 1121 var err error 1122 if !reflect.ValueOf(p.current).IsZero() { 1123 if p.current.TaskRunListResult.NextLink == nil || len(*p.current.TaskRunListResult.NextLink) == 0 { 1124 return false 1125 } 1126 req, err = p.advancer(ctx, p.current) 1127 } else { 1128 req, err = p.requester(ctx) 1129 } 1130 if err != nil { 1131 p.err = err 1132 return false 1133 } 1134 resp, err := p.pipeline.Do(req) 1135 if err != nil { 1136 p.err = err 1137 return false 1138 } 1139 if !resp.HasStatusCode(p.statusCodes...) { 1140 p.err = p.errorer(resp) 1141 return false 1142 } 1143 result, err := p.responder(resp) 1144 if err != nil { 1145 p.err = err 1146 return false 1147 } 1148 p.current = result 1149 return true 1150} 1151 1152func (p *taskRunListResultPager) PageResponse() TaskRunListResultResponse { 1153 return p.current 1154} 1155 1156// TokenListResultPager provides iteration over TokenListResult pages. 1157type TokenListResultPager interface { 1158 azcore.Pager 1159 1160 // PageResponse returns the current TokenListResultResponse. 1161 PageResponse() TokenListResultResponse 1162} 1163 1164type tokenListResultCreateRequest func(context.Context) (*azcore.Request, error) 1165 1166type tokenListResultHandleError func(*azcore.Response) error 1167 1168type tokenListResultHandleResponse func(*azcore.Response) (TokenListResultResponse, error) 1169 1170type tokenListResultAdvancePage func(context.Context, TokenListResultResponse) (*azcore.Request, error) 1171 1172type tokenListResultPager struct { 1173 // the pipeline for making the request 1174 pipeline azcore.Pipeline 1175 // creates the initial request (non-LRO case) 1176 requester tokenListResultCreateRequest 1177 // callback for handling response errors 1178 errorer tokenListResultHandleError 1179 // callback for handling the HTTP response 1180 responder tokenListResultHandleResponse 1181 // callback for advancing to the next page 1182 advancer tokenListResultAdvancePage 1183 // contains the current response 1184 current TokenListResultResponse 1185 // status codes for successful retrieval 1186 statusCodes []int 1187 // any error encountered 1188 err error 1189} 1190 1191func (p *tokenListResultPager) Err() error { 1192 return p.err 1193} 1194 1195func (p *tokenListResultPager) NextPage(ctx context.Context) bool { 1196 var req *azcore.Request 1197 var err error 1198 if !reflect.ValueOf(p.current).IsZero() { 1199 if p.current.TokenListResult.NextLink == nil || len(*p.current.TokenListResult.NextLink) == 0 { 1200 return false 1201 } 1202 req, err = p.advancer(ctx, p.current) 1203 } else { 1204 req, err = p.requester(ctx) 1205 } 1206 if err != nil { 1207 p.err = err 1208 return false 1209 } 1210 resp, err := p.pipeline.Do(req) 1211 if err != nil { 1212 p.err = err 1213 return false 1214 } 1215 if !resp.HasStatusCode(p.statusCodes...) { 1216 p.err = p.errorer(resp) 1217 return false 1218 } 1219 result, err := p.responder(resp) 1220 if err != nil { 1221 p.err = err 1222 return false 1223 } 1224 p.current = result 1225 return true 1226} 1227 1228func (p *tokenListResultPager) PageResponse() TokenListResultResponse { 1229 return p.current 1230} 1231 1232// WebhookListResultPager provides iteration over WebhookListResult pages. 1233type WebhookListResultPager interface { 1234 azcore.Pager 1235 1236 // PageResponse returns the current WebhookListResultResponse. 1237 PageResponse() WebhookListResultResponse 1238} 1239 1240type webhookListResultCreateRequest func(context.Context) (*azcore.Request, error) 1241 1242type webhookListResultHandleError func(*azcore.Response) error 1243 1244type webhookListResultHandleResponse func(*azcore.Response) (WebhookListResultResponse, error) 1245 1246type webhookListResultAdvancePage func(context.Context, WebhookListResultResponse) (*azcore.Request, error) 1247 1248type webhookListResultPager struct { 1249 // the pipeline for making the request 1250 pipeline azcore.Pipeline 1251 // creates the initial request (non-LRO case) 1252 requester webhookListResultCreateRequest 1253 // callback for handling response errors 1254 errorer webhookListResultHandleError 1255 // callback for handling the HTTP response 1256 responder webhookListResultHandleResponse 1257 // callback for advancing to the next page 1258 advancer webhookListResultAdvancePage 1259 // contains the current response 1260 current WebhookListResultResponse 1261 // status codes for successful retrieval 1262 statusCodes []int 1263 // any error encountered 1264 err error 1265} 1266 1267func (p *webhookListResultPager) Err() error { 1268 return p.err 1269} 1270 1271func (p *webhookListResultPager) NextPage(ctx context.Context) bool { 1272 var req *azcore.Request 1273 var err error 1274 if !reflect.ValueOf(p.current).IsZero() { 1275 if p.current.WebhookListResult.NextLink == nil || len(*p.current.WebhookListResult.NextLink) == 0 { 1276 return false 1277 } 1278 req, err = p.advancer(ctx, p.current) 1279 } else { 1280 req, err = p.requester(ctx) 1281 } 1282 if err != nil { 1283 p.err = err 1284 return false 1285 } 1286 resp, err := p.pipeline.Do(req) 1287 if err != nil { 1288 p.err = err 1289 return false 1290 } 1291 if !resp.HasStatusCode(p.statusCodes...) { 1292 p.err = p.errorer(resp) 1293 return false 1294 } 1295 result, err := p.responder(resp) 1296 if err != nil { 1297 p.err = err 1298 return false 1299 } 1300 p.current = result 1301 return true 1302} 1303 1304func (p *webhookListResultPager) PageResponse() WebhookListResultResponse { 1305 return p.current 1306} 1307