88
99from copy import deepcopy
1010from typing import Any , TYPE_CHECKING
11+ from typing_extensions import Self
1112
13+ from azure .core .pipeline import policies
1214from azure .core .rest import HttpRequest , HttpResponse
1315from azure .mgmt .core import ARMPipelineClient
16+ from azure .mgmt .core .policies import ARMAutoResourceProviderRegistrationPolicy
1417
1518from . import models as _models
1619from ._configuration import MicrosoftElasticConfiguration
1720from ._serialization import Deserializer , Serializer
1821from .operations import (
1922 AllTrafficFiltersOperations ,
2023 AssociateTrafficFilterOperations ,
24+ BillingInfoOperations ,
25+ ConnectedPartnerResourcesOperations ,
2126 CreateAndAssociateIPFilterOperations ,
2227 CreateAndAssociatePLFilterOperations ,
2328 DeploymentInfoOperations ,
2833 ListAssociatedTrafficFiltersOperations ,
2934 MonitorOperations ,
3035 MonitoredResourcesOperations ,
36+ MonitoredSubscriptionsOperations ,
3137 MonitorsOperations ,
38+ OpenAIOperations ,
3239 Operations ,
3340 OrganizationsOperations ,
3441 TagRulesOperations ,
@@ -53,12 +60,22 @@ class MicrosoftElastic: # pylint: disable=client-accepts-api-version-keyword,to
5360 :vartype monitors: azure.mgmt.elastic.operations.MonitorsOperations
5461 :ivar elastic_versions: ElasticVersionsOperations operations
5562 :vartype elastic_versions: azure.mgmt.elastic.operations.ElasticVersionsOperations
63+ :ivar monitored_subscriptions: MonitoredSubscriptionsOperations operations
64+ :vartype monitored_subscriptions:
65+ azure.mgmt.elastic.operations.MonitoredSubscriptionsOperations
5666 :ivar monitored_resources: MonitoredResourcesOperations operations
5767 :vartype monitored_resources: azure.mgmt.elastic.operations.MonitoredResourcesOperations
5868 :ivar deployment_info: DeploymentInfoOperations operations
5969 :vartype deployment_info: azure.mgmt.elastic.operations.DeploymentInfoOperations
6070 :ivar external_user: ExternalUserOperations operations
6171 :vartype external_user: azure.mgmt.elastic.operations.ExternalUserOperations
72+ :ivar billing_info: BillingInfoOperations operations
73+ :vartype billing_info: azure.mgmt.elastic.operations.BillingInfoOperations
74+ :ivar connected_partner_resources: ConnectedPartnerResourcesOperations operations
75+ :vartype connected_partner_resources:
76+ azure.mgmt.elastic.operations.ConnectedPartnerResourcesOperations
77+ :ivar open_ai: OpenAIOperations operations
78+ :vartype open_ai: azure.mgmt.elastic.operations.OpenAIOperations
6279 :ivar tag_rules: TagRulesOperations operations
6380 :vartype tag_rules: azure.mgmt.elastic.operations.TagRulesOperations
6481 :ivar vm_host: VMHostOperations operations
@@ -96,12 +113,11 @@ class MicrosoftElastic: # pylint: disable=client-accepts-api-version-keyword,to
96113 :vartype organizations: azure.mgmt.elastic.operations.OrganizationsOperations
97114 :param credential: Credential needed for the client to connect to Azure. Required.
98115 :type credential: ~azure.core.credentials.TokenCredential
99- :param subscription_id: The Azure subscription ID. This is a GUID-formatted string (e.g.
100- 00000000-0000-0000-0000-000000000000). Required.
116+ :param subscription_id: The ID of the target subscription. The value must be an UUID. Required.
101117 :type subscription_id: str
102118 :param base_url: Service URL. Default value is "https://management.azure.com".
103119 :type base_url: str
104- :keyword api_version: Api Version. Default value is "2023-02-01 -preview". Note that overriding
120+ :keyword api_version: Api Version. Default value is "2024-06-15 -preview". Note that overriding
105121 this default value may result in unsupported behavior.
106122 :paramtype api_version: str
107123 :keyword int polling_interval: Default waiting time between two polls for LRO operations if no
@@ -116,7 +132,25 @@ def __init__(
116132 ** kwargs : Any
117133 ) -> None :
118134 self ._config = MicrosoftElasticConfiguration (credential = credential , subscription_id = subscription_id , ** kwargs )
119- self ._client : ARMPipelineClient = ARMPipelineClient (base_url = base_url , config = self ._config , ** kwargs )
135+ _policies = kwargs .pop ("policies" , None )
136+ if _policies is None :
137+ _policies = [
138+ policies .RequestIdPolicy (** kwargs ),
139+ self ._config .headers_policy ,
140+ self ._config .user_agent_policy ,
141+ self ._config .proxy_policy ,
142+ policies .ContentDecodePolicy (** kwargs ),
143+ ARMAutoResourceProviderRegistrationPolicy (),
144+ self ._config .redirect_policy ,
145+ self ._config .retry_policy ,
146+ self ._config .authentication_policy ,
147+ self ._config .custom_hook_policy ,
148+ self ._config .logging_policy ,
149+ policies .DistributedTracingPolicy (** kwargs ),
150+ policies .SensitiveHeaderCleanupPolicy (** kwargs ) if self ._config .redirect_policy else None ,
151+ self ._config .http_logging_policy ,
152+ ]
153+ self ._client : ARMPipelineClient = ARMPipelineClient (base_url = base_url , policies = _policies , ** kwargs )
120154
121155 client_models = {k : v for k , v in _models .__dict__ .items () if isinstance (v , type )}
122156 self ._serialize = Serializer (client_models )
@@ -127,11 +161,19 @@ def __init__(
127161 self .elastic_versions = ElasticVersionsOperations (
128162 self ._client , self ._config , self ._serialize , self ._deserialize
129163 )
164+ self .monitored_subscriptions = MonitoredSubscriptionsOperations (
165+ self ._client , self ._config , self ._serialize , self ._deserialize
166+ )
130167 self .monitored_resources = MonitoredResourcesOperations (
131168 self ._client , self ._config , self ._serialize , self ._deserialize
132169 )
133170 self .deployment_info = DeploymentInfoOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
134171 self .external_user = ExternalUserOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
172+ self .billing_info = BillingInfoOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
173+ self .connected_partner_resources = ConnectedPartnerResourcesOperations (
174+ self ._client , self ._config , self ._serialize , self ._deserialize
175+ )
176+ self .open_ai = OpenAIOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
135177 self .tag_rules = TagRulesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
136178 self .vm_host = VMHostOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
137179 self .vm_ingestion = VMIngestionOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
@@ -164,7 +206,7 @@ def __init__(
164206 self .traffic_filters = TrafficFiltersOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
165207 self .organizations = OrganizationsOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
166208
167- def _send_request (self , request : HttpRequest , ** kwargs : Any ) -> HttpResponse :
209+ def _send_request (self , request : HttpRequest , * , stream : bool = False , * *kwargs : Any ) -> HttpResponse :
168210 """Runs the network request through the client's chained policies.
169211
170212 >>> from azure.core.rest import HttpRequest
@@ -184,12 +226,12 @@ def _send_request(self, request: HttpRequest, **kwargs: Any) -> HttpResponse:
184226
185227 request_copy = deepcopy (request )
186228 request_copy .url = self ._client .format_url (request_copy .url )
187- return self ._client .send_request (request_copy , ** kwargs )
229+ return self ._client .send_request (request_copy , stream = stream , ** kwargs ) # type: ignore
188230
189231 def close (self ) -> None :
190232 self ._client .close ()
191233
192- def __enter__ (self ) -> "MicrosoftElastic" :
234+ def __enter__ (self ) -> Self :
193235 self ._client .__enter__ ()
194236 return self
195237
0 commit comments