< Summary

Class:Azure.ResourceManager.Storage.QueueOperations
Assembly:Azure.ResourceManager.Storage
File(s):C:\Git\azure-sdk-for-net\sdk\storage\Azure.ResourceManager.Storage\src\Generated\QueueOperations.cs
Covered lines:0
Uncovered lines:106
Coverable lines:106
Total lines:305
Line coverage:0% (0 of 106)
Covered branches:0
Total branches:8
Branch coverage:0% (0 of 8)

Metrics

MethodCyclomatic complexity Line coverage Branch coverage
get_RestClient()-0%100%
.ctor()-0%100%
.ctor(...)-0%100%
CreateAsync()-0%100%
Create(...)-0%100%
UpdateAsync()-0%100%
Update(...)-0%100%
GetAsync()-0%100%
Get(...)-0%100%
DeleteAsync()-0%100%
Delete(...)-0%100%
ListAsync(...)-0%0%
<ListAsync()-0%100%
<ListAsync()-0%100%
List(...)-0%0%

File(s)

C:\Git\azure-sdk-for-net\sdk\storage\Azure.ResourceManager.Storage\src\Generated\QueueOperations.cs

#LineLine coverage
 1// Copyright (c) Microsoft Corporation. All rights reserved.
 2// Licensed under the MIT License.
 3
 4// <auto-generated/>
 5
 6#nullable disable
 7
 8using System;
 9using System.Threading;
 10using System.Threading.Tasks;
 11using Azure;
 12using Azure.Core;
 13using Azure.Core.Pipeline;
 14using Azure.ResourceManager.Storage.Models;
 15
 16namespace Azure.ResourceManager.Storage
 17{
 18    /// <summary> The Queue service client. </summary>
 19    public partial class QueueOperations
 20    {
 21        private readonly ClientDiagnostics _clientDiagnostics;
 22        private readonly HttpPipeline _pipeline;
 023        internal QueueRestOperations RestClient { get; }
 24        /// <summary> Initializes a new instance of QueueOperations for mocking. </summary>
 025        protected QueueOperations()
 26        {
 027        }
 28        /// <summary> Initializes a new instance of QueueOperations. </summary>
 29        /// <param name="clientDiagnostics"> The handler for diagnostic messaging in the client. </param>
 30        /// <param name="pipeline"> The HTTP pipeline for sending and receiving REST requests and responses. </param>
 31        /// <param name="subscriptionId"> The ID of the target subscription. </param>
 32        /// <param name="endpoint"> server parameter. </param>
 33        /// <param name="apiVersion"> Api Version. </param>
 034        internal QueueOperations(ClientDiagnostics clientDiagnostics, HttpPipeline pipeline, string subscriptionId, Uri 
 35        {
 036            RestClient = new QueueRestOperations(clientDiagnostics, pipeline, subscriptionId, endpoint, apiVersion);
 037            _clientDiagnostics = clientDiagnostics;
 038            _pipeline = pipeline;
 039        }
 40
 41        /// <summary> Creates a new queue with the specified queue name, under the specified account. </summary>
 42        /// <param name="resourceGroupName"> The name of the resource group within the user&apos;s subscription. The nam
 43        /// <param name="accountName"> The name of the storage account within the specified resource group. Storage acco
 44        /// <param name="queueName"> A queue name must be unique within a storage account and must be between 3 and 63 c
 45        /// <param name="queue"> Queue properties and metadata to be created with. </param>
 46        /// <param name="cancellationToken"> The cancellation token to use. </param>
 47        public virtual async Task<Response<StorageQueue>> CreateAsync(string resourceGroupName, string accountName, stri
 48        {
 049            using var scope = _clientDiagnostics.CreateScope("QueueOperations.Create");
 050            scope.Start();
 51            try
 52            {
 053                return await RestClient.CreateAsync(resourceGroupName, accountName, queueName, queue, cancellationToken)
 54            }
 055            catch (Exception e)
 56            {
 057                scope.Failed(e);
 058                throw;
 59            }
 060        }
 61
 62        /// <summary> Creates a new queue with the specified queue name, under the specified account. </summary>
 63        /// <param name="resourceGroupName"> The name of the resource group within the user&apos;s subscription. The nam
 64        /// <param name="accountName"> The name of the storage account within the specified resource group. Storage acco
 65        /// <param name="queueName"> A queue name must be unique within a storage account and must be between 3 and 63 c
 66        /// <param name="queue"> Queue properties and metadata to be created with. </param>
 67        /// <param name="cancellationToken"> The cancellation token to use. </param>
 68        public virtual Response<StorageQueue> Create(string resourceGroupName, string accountName, string queueName, Sto
 69        {
 070            using var scope = _clientDiagnostics.CreateScope("QueueOperations.Create");
 071            scope.Start();
 72            try
 73            {
 074                return RestClient.Create(resourceGroupName, accountName, queueName, queue, cancellationToken);
 75            }
 076            catch (Exception e)
 77            {
 078                scope.Failed(e);
 079                throw;
 80            }
 081        }
 82
 83        /// <summary> Creates a new queue with the specified queue name, under the specified account. </summary>
 84        /// <param name="resourceGroupName"> The name of the resource group within the user&apos;s subscription. The nam
 85        /// <param name="accountName"> The name of the storage account within the specified resource group. Storage acco
 86        /// <param name="queueName"> A queue name must be unique within a storage account and must be between 3 and 63 c
 87        /// <param name="queue"> Queue properties and metadata to be created with. </param>
 88        /// <param name="cancellationToken"> The cancellation token to use. </param>
 89        public virtual async Task<Response<StorageQueue>> UpdateAsync(string resourceGroupName, string accountName, stri
 90        {
 091            using var scope = _clientDiagnostics.CreateScope("QueueOperations.Update");
 092            scope.Start();
 93            try
 94            {
 095                return await RestClient.UpdateAsync(resourceGroupName, accountName, queueName, queue, cancellationToken)
 96            }
 097            catch (Exception e)
 98            {
 099                scope.Failed(e);
 0100                throw;
 101            }
 0102        }
 103
 104        /// <summary> Creates a new queue with the specified queue name, under the specified account. </summary>
 105        /// <param name="resourceGroupName"> The name of the resource group within the user&apos;s subscription. The nam
 106        /// <param name="accountName"> The name of the storage account within the specified resource group. Storage acco
 107        /// <param name="queueName"> A queue name must be unique within a storage account and must be between 3 and 63 c
 108        /// <param name="queue"> Queue properties and metadata to be created with. </param>
 109        /// <param name="cancellationToken"> The cancellation token to use. </param>
 110        public virtual Response<StorageQueue> Update(string resourceGroupName, string accountName, string queueName, Sto
 111        {
 0112            using var scope = _clientDiagnostics.CreateScope("QueueOperations.Update");
 0113            scope.Start();
 114            try
 115            {
 0116                return RestClient.Update(resourceGroupName, accountName, queueName, queue, cancellationToken);
 117            }
 0118            catch (Exception e)
 119            {
 0120                scope.Failed(e);
 0121                throw;
 122            }
 0123        }
 124
 125        /// <summary> Gets the queue with the specified queue name, under the specified account if it exists. </summary>
 126        /// <param name="resourceGroupName"> The name of the resource group within the user&apos;s subscription. The nam
 127        /// <param name="accountName"> The name of the storage account within the specified resource group. Storage acco
 128        /// <param name="queueName"> A queue name must be unique within a storage account and must be between 3 and 63 c
 129        /// <param name="cancellationToken"> The cancellation token to use. </param>
 130        public virtual async Task<Response<StorageQueue>> GetAsync(string resourceGroupName, string accountName, string 
 131        {
 0132            using var scope = _clientDiagnostics.CreateScope("QueueOperations.Get");
 0133            scope.Start();
 134            try
 135            {
 0136                return await RestClient.GetAsync(resourceGroupName, accountName, queueName, cancellationToken).Configure
 137            }
 0138            catch (Exception e)
 139            {
 0140                scope.Failed(e);
 0141                throw;
 142            }
 0143        }
 144
 145        /// <summary> Gets the queue with the specified queue name, under the specified account if it exists. </summary>
 146        /// <param name="resourceGroupName"> The name of the resource group within the user&apos;s subscription. The nam
 147        /// <param name="accountName"> The name of the storage account within the specified resource group. Storage acco
 148        /// <param name="queueName"> A queue name must be unique within a storage account and must be between 3 and 63 c
 149        /// <param name="cancellationToken"> The cancellation token to use. </param>
 150        public virtual Response<StorageQueue> Get(string resourceGroupName, string accountName, string queueName, Cancel
 151        {
 0152            using var scope = _clientDiagnostics.CreateScope("QueueOperations.Get");
 0153            scope.Start();
 154            try
 155            {
 0156                return RestClient.Get(resourceGroupName, accountName, queueName, cancellationToken);
 157            }
 0158            catch (Exception e)
 159            {
 0160                scope.Failed(e);
 0161                throw;
 162            }
 0163        }
 164
 165        /// <summary> Deletes the queue with the specified queue name, under the specified account if it exists. </summa
 166        /// <param name="resourceGroupName"> The name of the resource group within the user&apos;s subscription. The nam
 167        /// <param name="accountName"> The name of the storage account within the specified resource group. Storage acco
 168        /// <param name="queueName"> A queue name must be unique within a storage account and must be between 3 and 63 c
 169        /// <param name="cancellationToken"> The cancellation token to use. </param>
 170        public virtual async Task<Response> DeleteAsync(string resourceGroupName, string accountName, string queueName, 
 171        {
 0172            using var scope = _clientDiagnostics.CreateScope("QueueOperations.Delete");
 0173            scope.Start();
 174            try
 175            {
 0176                return await RestClient.DeleteAsync(resourceGroupName, accountName, queueName, cancellationToken).Config
 177            }
 0178            catch (Exception e)
 179            {
 0180                scope.Failed(e);
 0181                throw;
 182            }
 0183        }
 184
 185        /// <summary> Deletes the queue with the specified queue name, under the specified account if it exists. </summa
 186        /// <param name="resourceGroupName"> The name of the resource group within the user&apos;s subscription. The nam
 187        /// <param name="accountName"> The name of the storage account within the specified resource group. Storage acco
 188        /// <param name="queueName"> A queue name must be unique within a storage account and must be between 3 and 63 c
 189        /// <param name="cancellationToken"> The cancellation token to use. </param>
 190        public virtual Response Delete(string resourceGroupName, string accountName, string queueName, CancellationToken
 191        {
 0192            using var scope = _clientDiagnostics.CreateScope("QueueOperations.Delete");
 0193            scope.Start();
 194            try
 195            {
 0196                return RestClient.Delete(resourceGroupName, accountName, queueName, cancellationToken);
 197            }
 0198            catch (Exception e)
 199            {
 0200                scope.Failed(e);
 0201                throw;
 202            }
 0203        }
 204
 205        /// <summary> Gets a list of all the queues under the specified storage account. </summary>
 206        /// <param name="resourceGroupName"> The name of the resource group within the user&apos;s subscription. The nam
 207        /// <param name="accountName"> The name of the storage account within the specified resource group. Storage acco
 208        /// <param name="maxpagesize"> Optional, a maximum number of queues that should be included in a list queue resp
 209        /// <param name="filter"> Optional, When specified, only the queues with a name starting with the given filter w
 210        /// <param name="cancellationToken"> The cancellation token to use. </param>
 211        public virtual AsyncPageable<ListQueue> ListAsync(string resourceGroupName, string accountName, string maxpagesi
 212        {
 0213            if (resourceGroupName == null)
 214            {
 0215                throw new ArgumentNullException(nameof(resourceGroupName));
 216            }
 0217            if (accountName == null)
 218            {
 0219                throw new ArgumentNullException(nameof(accountName));
 220            }
 221
 222            async Task<Page<ListQueue>> FirstPageFunc(int? pageSizeHint)
 223            {
 0224                using var scope = _clientDiagnostics.CreateScope("QueueOperations.List");
 0225                scope.Start();
 226                try
 227                {
 0228                    var response = await RestClient.ListAsync(resourceGroupName, accountName, maxpagesize, filter, cance
 0229                    return Page.FromValues(response.Value.Value, response.Value.NextLink, response.GetRawResponse());
 230                }
 0231                catch (Exception e)
 232                {
 0233                    scope.Failed(e);
 0234                    throw;
 235                }
 0236            }
 237            async Task<Page<ListQueue>> NextPageFunc(string nextLink, int? pageSizeHint)
 238            {
 0239                using var scope = _clientDiagnostics.CreateScope("QueueOperations.List");
 0240                scope.Start();
 241                try
 242                {
 0243                    var response = await RestClient.ListNextPageAsync(nextLink, resourceGroupName, accountName, maxpages
 0244                    return Page.FromValues(response.Value.Value, response.Value.NextLink, response.GetRawResponse());
 245                }
 0246                catch (Exception e)
 247                {
 0248                    scope.Failed(e);
 0249                    throw;
 250                }
 0251            }
 0252            return PageableHelpers.CreateAsyncEnumerable(FirstPageFunc, NextPageFunc);
 253        }
 254
 255        /// <summary> Gets a list of all the queues under the specified storage account. </summary>
 256        /// <param name="resourceGroupName"> The name of the resource group within the user&apos;s subscription. The nam
 257        /// <param name="accountName"> The name of the storage account within the specified resource group. Storage acco
 258        /// <param name="maxpagesize"> Optional, a maximum number of queues that should be included in a list queue resp
 259        /// <param name="filter"> Optional, When specified, only the queues with a name starting with the given filter w
 260        /// <param name="cancellationToken"> The cancellation token to use. </param>
 261        public virtual Pageable<ListQueue> List(string resourceGroupName, string accountName, string maxpagesize = null,
 262        {
 0263            if (resourceGroupName == null)
 264            {
 0265                throw new ArgumentNullException(nameof(resourceGroupName));
 266            }
 0267            if (accountName == null)
 268            {
 0269                throw new ArgumentNullException(nameof(accountName));
 270            }
 271
 272            Page<ListQueue> FirstPageFunc(int? pageSizeHint)
 273            {
 0274                using var scope = _clientDiagnostics.CreateScope("QueueOperations.List");
 0275                scope.Start();
 276                try
 277                {
 0278                    var response = RestClient.List(resourceGroupName, accountName, maxpagesize, filter, cancellationToke
 0279                    return Page.FromValues(response.Value.Value, response.Value.NextLink, response.GetRawResponse());
 280                }
 0281                catch (Exception e)
 282                {
 0283                    scope.Failed(e);
 0284                    throw;
 285                }
 0286            }
 287            Page<ListQueue> NextPageFunc(string nextLink, int? pageSizeHint)
 288            {
 0289                using var scope = _clientDiagnostics.CreateScope("QueueOperations.List");
 0290                scope.Start();
 291                try
 292                {
 0293                    var response = RestClient.ListNextPage(nextLink, resourceGroupName, accountName, maxpagesize, filter
 0294                    return Page.FromValues(response.Value.Value, response.Value.NextLink, response.GetRawResponse());
 295                }
 0296                catch (Exception e)
 297                {
 0298                    scope.Failed(e);
 0299                    throw;
 300                }
 0301            }
 0302            return PageableHelpers.CreateEnumerable(FirstPageFunc, NextPageFunc);
 303        }
 304    }
 305}