return nil, persistence.ErrNegativeListQueuesOffset
}
rows, err := q.DB.SelectNameFromQueueV2Metadata(ctx, sqlplugin.QueueV2MetadataTypeFilter{
queue_v2.go
QueueType: request.QueueType,
PageSize: request.PageSize,
PageOffset: offset,
})
if err != nil && !errors.Is(err, sql.ErrNoRows) {
return nil, serviceerror.NewUnavailablef(
"ListQueues failed for type: %v. SelectNameFromQueueV2Metadata operation failed. Error: %v",