66# Changes may cause incorrect behavior and will be lost if the code is regenerated.
77# --------------------------------------------------------------------------
88
9- from typing import TYPE_CHECKING
9+ from copy import deepcopy
10+ from typing import Any , Optional , TYPE_CHECKING
1011
12+ from azure .core .rest import HttpRequest , HttpResponse
1113from azure .mgmt .core import ARMPipelineClient
1214from msrest import Deserializer , Serializer
1315
16+ from . import models
17+ from ._configuration import RelayAPIConfiguration
18+ from .operations import HybridConnectionsOperations , NamespacesOperations , Operations , WCFRelaysOperations
19+
1420if TYPE_CHECKING :
1521 # pylint: disable=unused-import,ungrouped-imports
16- from typing import Any , Optional
17-
1822 from azure .core .credentials import TokenCredential
19- from azure .core .pipeline .transport import HttpRequest , HttpResponse
20-
21- from ._configuration import RelayAPIConfiguration
22- from .operations import Operations
23- from .operations import NamespacesOperations
24- from .operations import HybridConnectionsOperations
25- from .operations import WCFRelaysOperations
26- from . import models
27-
2823
29- class RelayAPI ( object ) :
24+ class RelayAPI :
3025 """Use these API to manage Azure Relay resources through Azure Resource Manager.
3126
3227 :ivar operations: Operations operations
@@ -39,56 +34,60 @@ class RelayAPI(object):
3934 :vartype wcf_relays: azure.mgmt.relay.operations.WCFRelaysOperations
4035 :param credential: Credential needed for the client to connect to Azure.
4136 :type credential: ~azure.core.credentials.TokenCredential
42- :param subscription_id: Subscription credentials which uniquely identify the Microsoft Azure subscription. The subscription ID forms part of the URI for every service call.
37+ :param subscription_id: Subscription credentials which uniquely identify the Microsoft Azure
38+ subscription. The subscription ID forms part of the URI for every service call.
4339 :type subscription_id: str
44- :param str base_url: Service URL
45- :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
40+ :param base_url: Service URL. Default value is 'https://management.azure.com'.
41+ :type base_url: str
42+ :keyword int polling_interval: Default waiting time between two polls for LRO operations if no
43+ Retry-After header is present.
4644 """
4745
4846 def __init__ (
4947 self ,
50- credential , # type: "TokenCredential"
51- subscription_id , # type: str
52- base_url = None , # type: Optional[str]
53- ** kwargs # type: Any
54- ):
55- # type: (...) -> None
56- if not base_url :
57- base_url = 'https://management.azure.com'
58- self ._config = RelayAPIConfiguration (credential , subscription_id , ** kwargs )
48+ credential : "TokenCredential" ,
49+ subscription_id : str ,
50+ base_url : str = "https://management.azure.com" ,
51+ ** kwargs : Any
52+ ) -> None :
53+ self ._config = RelayAPIConfiguration (credential = credential , subscription_id = subscription_id , ** kwargs )
5954 self ._client = ARMPipelineClient (base_url = base_url , config = self ._config , ** kwargs )
6055
6156 client_models = {k : v for k , v in models .__dict__ .items () if isinstance (v , type )}
6257 self ._serialize = Serializer (client_models )
63- self ._serialize .client_side_validation = False
6458 self ._deserialize = Deserializer (client_models )
59+ self ._serialize .client_side_validation = False
60+ self .operations = Operations (self ._client , self ._config , self ._serialize , self ._deserialize )
61+ self .namespaces = NamespacesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
62+ self .hybrid_connections = HybridConnectionsOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
63+ self .wcf_relays = WCFRelaysOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
6564
66- self .operations = Operations (
67- self ._client , self ._config , self ._serialize , self ._deserialize )
68- self .namespaces = NamespacesOperations (
69- self ._client , self ._config , self ._serialize , self ._deserialize )
70- self .hybrid_connections = HybridConnectionsOperations (
71- self ._client , self ._config , self ._serialize , self ._deserialize )
72- self .wcf_relays = WCFRelaysOperations (
73- self ._client , self ._config , self ._serialize , self ._deserialize )
74-
75- def _send_request (self , http_request , ** kwargs ):
76- # type: (HttpRequest, Any) -> HttpResponse
65+
66+ def _send_request (
67+ self ,
68+ request , # type: HttpRequest
69+ ** kwargs : Any
70+ ) -> HttpResponse :
7771 """Runs the network request through the client's chained policies.
7872
79- :param http_request: The network request you want to make. Required.
80- :type http_request: ~azure.core.pipeline.transport.HttpRequest
81- :keyword bool stream: Whether the response payload will be streamed. Defaults to True.
73+ >>> from azure.core.rest import HttpRequest
74+ >>> request = HttpRequest("GET", "https://www.example.org/")
75+ <HttpRequest [GET], url: 'https://www.example.org/'>
76+ >>> response = client._send_request(request)
77+ <HttpResponse: 200 OK>
78+
79+ For more information on this code flow, see https://aka.ms/azsdk/python/protocol/quickstart
80+
81+ :param request: The network request you want to make. Required.
82+ :type request: ~azure.core.rest.HttpRequest
83+ :keyword bool stream: Whether the response payload will be streamed. Defaults to False.
8284 :return: The response of your network call. Does not do error handling on your response.
83- :rtype: ~azure.core.pipeline.transport .HttpResponse
85+ :rtype: ~azure.core.rest .HttpResponse
8486 """
85- path_format_arguments = {
86- 'subscriptionId' : self ._serialize .url ("self._config.subscription_id" , self ._config .subscription_id , 'str' ),
87- }
88- http_request .url = self ._client .format_url (http_request .url , ** path_format_arguments )
89- stream = kwargs .pop ("stream" , True )
90- pipeline_response = self ._client ._pipeline .run (http_request , stream = stream , ** kwargs )
91- return pipeline_response .http_response
87+
88+ request_copy = deepcopy (request )
89+ request_copy .url = self ._client .format_url (request_copy .url )
90+ return self ._client .send_request (request_copy , ** kwargs )
9291
9392 def close (self ):
9493 # type: () -> None
0 commit comments