477
// only on queue_type. Keep fetching pages until we have enough rows or
478
// exhaust the result set.
480
>
pageToken := request.NextPageToken
481
>
482
>
for len(queues) < request.PageSize {
483
>
remaining := request.PageSize - len(queues)
484
>
iter := s.session.Query(
485
>
templateGetQueueNamesQuery,
486
>
request.QueueType,
487
>
).PageSize(remaining).PageState(pageToken).WithContext(ctx).Iter()
488
>
489
>
for {
490
>
var (
491
>
queueName string
492
>
metadataBytes []byte
493
>
metadataEncoding string
494
>
version int64
495
>
)
496
>
if !iter.Scan(&queueName, &metadataBytes, &metadataEncoding, &version) {
497
break
498
}