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 azartifacts 9 10import ( 11 "context" 12 "github.com/Azure/azure-sdk-for-go/sdk/azcore" 13 "reflect" 14) 15 16// DataFlowListResponsePager provides iteration over DataFlowListResponse pages. 17type DataFlowListResponsePager interface { 18 azcore.Pager 19 20 // Page returns the current DataFlowListResponseResponse. 21 PageResponse() DataFlowListResponseResponse 22} 23 24type dataFlowListResponseCreateRequest func(context.Context) (*azcore.Request, error) 25 26type dataFlowListResponseHandleError func(*azcore.Response) error 27 28type dataFlowListResponseHandleResponse func(*azcore.Response) (DataFlowListResponseResponse, error) 29 30type dataFlowListResponseAdvancePage func(context.Context, DataFlowListResponseResponse) (*azcore.Request, error) 31 32type dataFlowListResponsePager struct { 33 // the pipeline for making the request 34 pipeline azcore.Pipeline 35 // creates the initial request (non-LRO case) 36 requester dataFlowListResponseCreateRequest 37 // callback for handling response errors 38 errorer dataFlowListResponseHandleError 39 // callback for handling the HTTP response 40 responder dataFlowListResponseHandleResponse 41 // callback for advancing to the next page 42 advancer dataFlowListResponseAdvancePage 43 // contains the current response 44 current DataFlowListResponseResponse 45 // status codes for successful retrieval 46 statusCodes []int 47 // any error encountered 48 err error 49} 50 51func (p *dataFlowListResponsePager) Err() error { 52 return p.err 53} 54 55func (p *dataFlowListResponsePager) 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.DataFlowListResponse.NextLink == nil || len(*p.current.DataFlowListResponse.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 *dataFlowListResponsePager) PageResponse() DataFlowListResponseResponse { 89 return p.current 90} 91 92// DatasetListResponsePager provides iteration over DatasetListResponse pages. 93type DatasetListResponsePager interface { 94 azcore.Pager 95 96 // Page returns the current DatasetListResponseResponse. 97 PageResponse() DatasetListResponseResponse 98} 99 100type datasetListResponseCreateRequest func(context.Context) (*azcore.Request, error) 101 102type datasetListResponseHandleError func(*azcore.Response) error 103 104type datasetListResponseHandleResponse func(*azcore.Response) (DatasetListResponseResponse, error) 105 106type datasetListResponseAdvancePage func(context.Context, DatasetListResponseResponse) (*azcore.Request, error) 107 108type datasetListResponsePager struct { 109 // the pipeline for making the request 110 pipeline azcore.Pipeline 111 // creates the initial request (non-LRO case) 112 requester datasetListResponseCreateRequest 113 // callback for handling response errors 114 errorer datasetListResponseHandleError 115 // callback for handling the HTTP response 116 responder datasetListResponseHandleResponse 117 // callback for advancing to the next page 118 advancer datasetListResponseAdvancePage 119 // contains the current response 120 current DatasetListResponseResponse 121 // status codes for successful retrieval 122 statusCodes []int 123 // any error encountered 124 err error 125} 126 127func (p *datasetListResponsePager) Err() error { 128 return p.err 129} 130 131func (p *datasetListResponsePager) 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.DatasetListResponse.NextLink == nil || len(*p.current.DatasetListResponse.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 *datasetListResponsePager) PageResponse() DatasetListResponseResponse { 165 return p.current 166} 167 168// LibraryListResponsePager provides iteration over LibraryListResponse pages. 169type LibraryListResponsePager interface { 170 azcore.Pager 171 172 // Page returns the current LibraryListResponseResponse. 173 PageResponse() LibraryListResponseResponse 174} 175 176type libraryListResponseCreateRequest func(context.Context) (*azcore.Request, error) 177 178type libraryListResponseHandleError func(*azcore.Response) error 179 180type libraryListResponseHandleResponse func(*azcore.Response) (LibraryListResponseResponse, error) 181 182type libraryListResponseAdvancePage func(context.Context, LibraryListResponseResponse) (*azcore.Request, error) 183 184type libraryListResponsePager struct { 185 // the pipeline for making the request 186 pipeline azcore.Pipeline 187 // creates the initial request (non-LRO case) 188 requester libraryListResponseCreateRequest 189 // callback for handling response errors 190 errorer libraryListResponseHandleError 191 // callback for handling the HTTP response 192 responder libraryListResponseHandleResponse 193 // callback for advancing to the next page 194 advancer libraryListResponseAdvancePage 195 // contains the current response 196 current LibraryListResponseResponse 197 // status codes for successful retrieval 198 statusCodes []int 199 // any error encountered 200 err error 201} 202 203func (p *libraryListResponsePager) Err() error { 204 return p.err 205} 206 207func (p *libraryListResponsePager) 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.LibraryListResponse.NextLink == nil || len(*p.current.LibraryListResponse.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 *libraryListResponsePager) PageResponse() LibraryListResponseResponse { 241 return p.current 242} 243 244// LinkedServiceListResponsePager provides iteration over LinkedServiceListResponse pages. 245type LinkedServiceListResponsePager interface { 246 azcore.Pager 247 248 // Page returns the current LinkedServiceListResponseResponse. 249 PageResponse() LinkedServiceListResponseResponse 250} 251 252type linkedServiceListResponseCreateRequest func(context.Context) (*azcore.Request, error) 253 254type linkedServiceListResponseHandleError func(*azcore.Response) error 255 256type linkedServiceListResponseHandleResponse func(*azcore.Response) (LinkedServiceListResponseResponse, error) 257 258type linkedServiceListResponseAdvancePage func(context.Context, LinkedServiceListResponseResponse) (*azcore.Request, error) 259 260type linkedServiceListResponsePager struct { 261 // the pipeline for making the request 262 pipeline azcore.Pipeline 263 // creates the initial request (non-LRO case) 264 requester linkedServiceListResponseCreateRequest 265 // callback for handling response errors 266 errorer linkedServiceListResponseHandleError 267 // callback for handling the HTTP response 268 responder linkedServiceListResponseHandleResponse 269 // callback for advancing to the next page 270 advancer linkedServiceListResponseAdvancePage 271 // contains the current response 272 current LinkedServiceListResponseResponse 273 // status codes for successful retrieval 274 statusCodes []int 275 // any error encountered 276 err error 277} 278 279func (p *linkedServiceListResponsePager) Err() error { 280 return p.err 281} 282 283func (p *linkedServiceListResponsePager) 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.LinkedServiceListResponse.NextLink == nil || len(*p.current.LinkedServiceListResponse.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 *linkedServiceListResponsePager) PageResponse() LinkedServiceListResponseResponse { 317 return p.current 318} 319 320// NotebookListResponsePager provides iteration over NotebookListResponse pages. 321type NotebookListResponsePager interface { 322 azcore.Pager 323 324 // Page returns the current NotebookListResponseResponse. 325 PageResponse() NotebookListResponseResponse 326} 327 328type notebookListResponseCreateRequest func(context.Context) (*azcore.Request, error) 329 330type notebookListResponseHandleError func(*azcore.Response) error 331 332type notebookListResponseHandleResponse func(*azcore.Response) (NotebookListResponseResponse, error) 333 334type notebookListResponseAdvancePage func(context.Context, NotebookListResponseResponse) (*azcore.Request, error) 335 336type notebookListResponsePager struct { 337 // the pipeline for making the request 338 pipeline azcore.Pipeline 339 // creates the initial request (non-LRO case) 340 requester notebookListResponseCreateRequest 341 // callback for handling response errors 342 errorer notebookListResponseHandleError 343 // callback for handling the HTTP response 344 responder notebookListResponseHandleResponse 345 // callback for advancing to the next page 346 advancer notebookListResponseAdvancePage 347 // contains the current response 348 current NotebookListResponseResponse 349 // status codes for successful retrieval 350 statusCodes []int 351 // any error encountered 352 err error 353} 354 355func (p *notebookListResponsePager) Err() error { 356 return p.err 357} 358 359func (p *notebookListResponsePager) 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.NotebookListResponse.NextLink == nil || len(*p.current.NotebookListResponse.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 *notebookListResponsePager) PageResponse() NotebookListResponseResponse { 393 return p.current 394} 395 396// PipelineListResponsePager provides iteration over PipelineListResponse pages. 397type PipelineListResponsePager interface { 398 azcore.Pager 399 400 // Page returns the current PipelineListResponseResponse. 401 PageResponse() PipelineListResponseResponse 402} 403 404type pipelineListResponseCreateRequest func(context.Context) (*azcore.Request, error) 405 406type pipelineListResponseHandleError func(*azcore.Response) error 407 408type pipelineListResponseHandleResponse func(*azcore.Response) (PipelineListResponseResponse, error) 409 410type pipelineListResponseAdvancePage func(context.Context, PipelineListResponseResponse) (*azcore.Request, error) 411 412type pipelineListResponsePager struct { 413 // the pipeline for making the request 414 pipeline azcore.Pipeline 415 // creates the initial request (non-LRO case) 416 requester pipelineListResponseCreateRequest 417 // callback for handling response errors 418 errorer pipelineListResponseHandleError 419 // callback for handling the HTTP response 420 responder pipelineListResponseHandleResponse 421 // callback for advancing to the next page 422 advancer pipelineListResponseAdvancePage 423 // contains the current response 424 current PipelineListResponseResponse 425 // status codes for successful retrieval 426 statusCodes []int 427 // any error encountered 428 err error 429} 430 431func (p *pipelineListResponsePager) Err() error { 432 return p.err 433} 434 435func (p *pipelineListResponsePager) 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.PipelineListResponse.NextLink == nil || len(*p.current.PipelineListResponse.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 *pipelineListResponsePager) PageResponse() PipelineListResponseResponse { 469 return p.current 470} 471 472// QueryDataFlowDebugSessionsResponsePager provides iteration over QueryDataFlowDebugSessionsResponse pages. 473type QueryDataFlowDebugSessionsResponsePager interface { 474 azcore.Pager 475 476 // Page returns the current QueryDataFlowDebugSessionsResponseResponse. 477 PageResponse() QueryDataFlowDebugSessionsResponseResponse 478} 479 480type queryDataFlowDebugSessionsResponseCreateRequest func(context.Context) (*azcore.Request, error) 481 482type queryDataFlowDebugSessionsResponseHandleError func(*azcore.Response) error 483 484type queryDataFlowDebugSessionsResponseHandleResponse func(*azcore.Response) (QueryDataFlowDebugSessionsResponseResponse, error) 485 486type queryDataFlowDebugSessionsResponseAdvancePage func(context.Context, QueryDataFlowDebugSessionsResponseResponse) (*azcore.Request, error) 487 488type queryDataFlowDebugSessionsResponsePager struct { 489 // the pipeline for making the request 490 pipeline azcore.Pipeline 491 // creates the initial request (non-LRO case) 492 requester queryDataFlowDebugSessionsResponseCreateRequest 493 // callback for handling response errors 494 errorer queryDataFlowDebugSessionsResponseHandleError 495 // callback for handling the HTTP response 496 responder queryDataFlowDebugSessionsResponseHandleResponse 497 // callback for advancing to the next page 498 advancer queryDataFlowDebugSessionsResponseAdvancePage 499 // contains the current response 500 current QueryDataFlowDebugSessionsResponseResponse 501 // status codes for successful retrieval 502 statusCodes []int 503 // any error encountered 504 err error 505} 506 507func (p *queryDataFlowDebugSessionsResponsePager) Err() error { 508 return p.err 509} 510 511func (p *queryDataFlowDebugSessionsResponsePager) 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.QueryDataFlowDebugSessionsResponse.NextLink == nil || len(*p.current.QueryDataFlowDebugSessionsResponse.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 *queryDataFlowDebugSessionsResponsePager) PageResponse() QueryDataFlowDebugSessionsResponseResponse { 545 return p.current 546} 547 548// SQLScriptsListResponsePager provides iteration over SQLScriptsListResponse pages. 549type SQLScriptsListResponsePager interface { 550 azcore.Pager 551 552 // Page returns the current SQLScriptsListResponseResponse. 553 PageResponse() SQLScriptsListResponseResponse 554} 555 556type sqlScriptsListResponseCreateRequest func(context.Context) (*azcore.Request, error) 557 558type sqlScriptsListResponseHandleError func(*azcore.Response) error 559 560type sqlScriptsListResponseHandleResponse func(*azcore.Response) (SQLScriptsListResponseResponse, error) 561 562type sqlScriptsListResponseAdvancePage func(context.Context, SQLScriptsListResponseResponse) (*azcore.Request, error) 563 564type sqlScriptsListResponsePager struct { 565 // the pipeline for making the request 566 pipeline azcore.Pipeline 567 // creates the initial request (non-LRO case) 568 requester sqlScriptsListResponseCreateRequest 569 // callback for handling response errors 570 errorer sqlScriptsListResponseHandleError 571 // callback for handling the HTTP response 572 responder sqlScriptsListResponseHandleResponse 573 // callback for advancing to the next page 574 advancer sqlScriptsListResponseAdvancePage 575 // contains the current response 576 current SQLScriptsListResponseResponse 577 // status codes for successful retrieval 578 statusCodes []int 579 // any error encountered 580 err error 581} 582 583func (p *sqlScriptsListResponsePager) Err() error { 584 return p.err 585} 586 587func (p *sqlScriptsListResponsePager) 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.SQLScriptsListResponse.NextLink == nil || len(*p.current.SQLScriptsListResponse.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 *sqlScriptsListResponsePager) PageResponse() SQLScriptsListResponseResponse { 621 return p.current 622} 623 624// SparkJobDefinitionsListResponsePager provides iteration over SparkJobDefinitionsListResponse pages. 625type SparkJobDefinitionsListResponsePager interface { 626 azcore.Pager 627 628 // Page returns the current SparkJobDefinitionsListResponseResponse. 629 PageResponse() SparkJobDefinitionsListResponseResponse 630} 631 632type sparkJobDefinitionsListResponseCreateRequest func(context.Context) (*azcore.Request, error) 633 634type sparkJobDefinitionsListResponseHandleError func(*azcore.Response) error 635 636type sparkJobDefinitionsListResponseHandleResponse func(*azcore.Response) (SparkJobDefinitionsListResponseResponse, error) 637 638type sparkJobDefinitionsListResponseAdvancePage func(context.Context, SparkJobDefinitionsListResponseResponse) (*azcore.Request, error) 639 640type sparkJobDefinitionsListResponsePager struct { 641 // the pipeline for making the request 642 pipeline azcore.Pipeline 643 // creates the initial request (non-LRO case) 644 requester sparkJobDefinitionsListResponseCreateRequest 645 // callback for handling response errors 646 errorer sparkJobDefinitionsListResponseHandleError 647 // callback for handling the HTTP response 648 responder sparkJobDefinitionsListResponseHandleResponse 649 // callback for advancing to the next page 650 advancer sparkJobDefinitionsListResponseAdvancePage 651 // contains the current response 652 current SparkJobDefinitionsListResponseResponse 653 // status codes for successful retrieval 654 statusCodes []int 655 // any error encountered 656 err error 657} 658 659func (p *sparkJobDefinitionsListResponsePager) Err() error { 660 return p.err 661} 662 663func (p *sparkJobDefinitionsListResponsePager) 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.SparkJobDefinitionsListResponse.NextLink == nil || len(*p.current.SparkJobDefinitionsListResponse.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 *sparkJobDefinitionsListResponsePager) PageResponse() SparkJobDefinitionsListResponseResponse { 697 return p.current 698} 699 700// TriggerListResponsePager provides iteration over TriggerListResponse pages. 701type TriggerListResponsePager interface { 702 azcore.Pager 703 704 // Page returns the current TriggerListResponseResponse. 705 PageResponse() TriggerListResponseResponse 706} 707 708type triggerListResponseCreateRequest func(context.Context) (*azcore.Request, error) 709 710type triggerListResponseHandleError func(*azcore.Response) error 711 712type triggerListResponseHandleResponse func(*azcore.Response) (TriggerListResponseResponse, error) 713 714type triggerListResponseAdvancePage func(context.Context, TriggerListResponseResponse) (*azcore.Request, error) 715 716type triggerListResponsePager struct { 717 // the pipeline for making the request 718 pipeline azcore.Pipeline 719 // creates the initial request (non-LRO case) 720 requester triggerListResponseCreateRequest 721 // callback for handling response errors 722 errorer triggerListResponseHandleError 723 // callback for handling the HTTP response 724 responder triggerListResponseHandleResponse 725 // callback for advancing to the next page 726 advancer triggerListResponseAdvancePage 727 // contains the current response 728 current TriggerListResponseResponse 729 // status codes for successful retrieval 730 statusCodes []int 731 // any error encountered 732 err error 733} 734 735func (p *triggerListResponsePager) Err() error { 736 return p.err 737} 738 739func (p *triggerListResponsePager) 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.TriggerListResponse.NextLink == nil || len(*p.current.TriggerListResponse.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 *triggerListResponsePager) PageResponse() TriggerListResponseResponse { 773 return p.current 774} 775