Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
29 changes: 28 additions & 1 deletion sdk/eventhub/azure-mgmt-eventhub/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,32 @@
# Release History

## 10.0.0 (2021-11-01)

**Features**

- Model ErrorResponse has a new parameter error
- Model NetworkRuleSet has a new parameter location
- Model Eventhub has a new parameter location
- Model ConsumerGroup has a new parameter location
- Model ArmDisasterRecovery has a new parameter location
- Model Operation has a new parameter is_data_action
- Model Operation has a new parameter origin
- Model Operation has a new parameter properties
- Model PrivateEndpointConnection has a new parameter location
- Model Destination has a new parameter data_lake_account_name
- Model Destination has a new parameter data_lake_subscription_id
- Model Destination has a new parameter data_lake_folder_path
- Model EHNamespace has a new parameter alternate_name
- Model OperationDisplay has a new parameter description
- Model AuthorizationRule has a new parameter location
- Added operation NamespacesOperations.list_network_rule_set
- Added operation group SchemaRegistryOperations

**Breaking changes**

- Model ErrorResponse no longer has parameter message
- Model ErrorResponse no longer has parameter code

## 9.1.0 (2021-09-17)

**Features**
Expand Down Expand Up @@ -291,4 +318,4 @@ This wheel package is built with the azure wheel extension

## 0.1.0 (2016-10-27)

- Initial Release
- Initial Release
2 changes: 1 addition & 1 deletion sdk/eventhub/azure-mgmt-eventhub/_meta.json
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
"@autorest/python@5.8.4",
"@autorest/modelerfour@4.19.2"
],
"commit": "c9992af7235a6550087d4fed8f081ed35019f605",
"commit": "ea69fef496210478b8a9e2c3f8804f3acfb35891",
"repository_url": "https://github.com/Azure/azure-rest-api-specs",
"autorest_command": "autorest specification/eventhub/resource-manager/readme.md --multiapi --python --python-mode=update --python-sdks-folder=/home/vsts/work/1/s/azure-sdk-for-python/sdk --track2 --use=@autorest/python@5.8.4 --use=@autorest/modelerfour@4.19.2 --version=3.4.5",
"readme": "specification/eventhub/resource-manager/readme.md"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ def __init__(self, *args, **kwargs):
pass

class EventHubManagementClient(MultiApiClientMixin, _SDKClient):
"""Azure Event Hubs client.
"""Azure Event Hubs client for managing Event Hubs Cluster, IPFilter Rules and VirtualNetworkRules resources.

This ready contains multiple API versions, to help you deal with all of the Azure clouds
(Azure Stack, Azure Government, Azure China, etc.).
Expand All @@ -56,11 +56,12 @@ class EventHubManagementClient(MultiApiClientMixin, _SDKClient):
:keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
"""

DEFAULT_API_VERSION = '2017-04-01'
DEFAULT_API_VERSION = '2021-11-01'
_PROFILE_TAG = "azure.mgmt.eventhub.EventHubManagementClient"
LATEST_PROFILE = ProfileDefinition({
_PROFILE_TAG: {
None: DEFAULT_API_VERSION,
'regions': '2017-04-01',
}},
_PROFILE_TAG + " latest"
)
Expand Down Expand Up @@ -96,6 +97,7 @@ def models(cls, api_version=DEFAULT_API_VERSION):
* 2018-01-01-preview: :mod:`v2018_01_01_preview.models<azure.mgmt.eventhub.v2018_01_01_preview.models>`
* 2021-01-01-preview: :mod:`v2021_01_01_preview.models<azure.mgmt.eventhub.v2021_01_01_preview.models>`
* 2021-06-01-preview: :mod:`v2021_06_01_preview.models<azure.mgmt.eventhub.v2021_06_01_preview.models>`
* 2021-11-01: :mod:`v2021_11_01.models<azure.mgmt.eventhub.v2021_11_01.models>`
"""
if api_version == '2015-08-01':
from .v2015_08_01 import models
Expand All @@ -112,6 +114,9 @@ def models(cls, api_version=DEFAULT_API_VERSION):
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview import models
return models
elif api_version == '2021-11-01':
from .v2021_11_01 import models
return models
raise ValueError("API version {} is not available".format(api_version))

@property
Expand All @@ -120,12 +125,15 @@ def clusters(self):

* 2018-01-01-preview: :class:`ClustersOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.ClustersOperations>`
* 2021-06-01-preview: :class:`ClustersOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.ClustersOperations>`
* 2021-11-01: :class:`ClustersOperations<azure.mgmt.eventhub.v2021_11_01.operations.ClustersOperations>`
"""
api_version = self._get_api_version('clusters')
if api_version == '2018-01-01-preview':
from .v2018_01_01_preview.operations import ClustersOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import ClustersOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import ClustersOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'clusters'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -136,12 +144,15 @@ def configuration(self):

* 2018-01-01-preview: :class:`ConfigurationOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.ConfigurationOperations>`
* 2021-06-01-preview: :class:`ConfigurationOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.ConfigurationOperations>`
* 2021-11-01: :class:`ConfigurationOperations<azure.mgmt.eventhub.v2021_11_01.operations.ConfigurationOperations>`
"""
api_version = self._get_api_version('configuration')
if api_version == '2018-01-01-preview':
from .v2018_01_01_preview.operations import ConfigurationOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import ConfigurationOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import ConfigurationOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'configuration'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -155,6 +166,7 @@ def consumer_groups(self):
* 2018-01-01-preview: :class:`ConsumerGroupsOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.ConsumerGroupsOperations>`
* 2021-01-01-preview: :class:`ConsumerGroupsOperations<azure.mgmt.eventhub.v2021_01_01_preview.operations.ConsumerGroupsOperations>`
* 2021-06-01-preview: :class:`ConsumerGroupsOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.ConsumerGroupsOperations>`
* 2021-11-01: :class:`ConsumerGroupsOperations<azure.mgmt.eventhub.v2021_11_01.operations.ConsumerGroupsOperations>`
"""
api_version = self._get_api_version('consumer_groups')
if api_version == '2015-08-01':
Expand All @@ -167,6 +179,8 @@ def consumer_groups(self):
from .v2021_01_01_preview.operations import ConsumerGroupsOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import ConsumerGroupsOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import ConsumerGroupsOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'consumer_groups'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -179,6 +193,7 @@ def disaster_recovery_configs(self):
* 2018-01-01-preview: :class:`DisasterRecoveryConfigsOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.DisasterRecoveryConfigsOperations>`
* 2021-01-01-preview: :class:`DisasterRecoveryConfigsOperations<azure.mgmt.eventhub.v2021_01_01_preview.operations.DisasterRecoveryConfigsOperations>`
* 2021-06-01-preview: :class:`DisasterRecoveryConfigsOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.DisasterRecoveryConfigsOperations>`
* 2021-11-01: :class:`DisasterRecoveryConfigsOperations<azure.mgmt.eventhub.v2021_11_01.operations.DisasterRecoveryConfigsOperations>`
"""
api_version = self._get_api_version('disaster_recovery_configs')
if api_version == '2017-04-01':
Expand All @@ -189,6 +204,8 @@ def disaster_recovery_configs(self):
from .v2021_01_01_preview.operations import DisasterRecoveryConfigsOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import DisasterRecoveryConfigsOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import DisasterRecoveryConfigsOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'disaster_recovery_configs'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -202,6 +219,7 @@ def event_hubs(self):
* 2018-01-01-preview: :class:`EventHubsOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.EventHubsOperations>`
* 2021-01-01-preview: :class:`EventHubsOperations<azure.mgmt.eventhub.v2021_01_01_preview.operations.EventHubsOperations>`
* 2021-06-01-preview: :class:`EventHubsOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.EventHubsOperations>`
* 2021-11-01: :class:`EventHubsOperations<azure.mgmt.eventhub.v2021_11_01.operations.EventHubsOperations>`
"""
api_version = self._get_api_version('event_hubs')
if api_version == '2015-08-01':
Expand All @@ -214,6 +232,8 @@ def event_hubs(self):
from .v2021_01_01_preview.operations import EventHubsOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import EventHubsOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import EventHubsOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'event_hubs'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -227,6 +247,7 @@ def namespaces(self):
* 2018-01-01-preview: :class:`NamespacesOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.NamespacesOperations>`
* 2021-01-01-preview: :class:`NamespacesOperations<azure.mgmt.eventhub.v2021_01_01_preview.operations.NamespacesOperations>`
* 2021-06-01-preview: :class:`NamespacesOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.NamespacesOperations>`
* 2021-11-01: :class:`NamespacesOperations<azure.mgmt.eventhub.v2021_11_01.operations.NamespacesOperations>`
"""
api_version = self._get_api_version('namespaces')
if api_version == '2015-08-01':
Expand All @@ -239,6 +260,8 @@ def namespaces(self):
from .v2021_01_01_preview.operations import NamespacesOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import NamespacesOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import NamespacesOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'namespaces'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -252,6 +275,7 @@ def operations(self):
* 2018-01-01-preview: :class:`Operations<azure.mgmt.eventhub.v2018_01_01_preview.operations.Operations>`
* 2021-01-01-preview: :class:`Operations<azure.mgmt.eventhub.v2021_01_01_preview.operations.Operations>`
* 2021-06-01-preview: :class:`Operations<azure.mgmt.eventhub.v2021_06_01_preview.operations.Operations>`
* 2021-11-01: :class:`Operations<azure.mgmt.eventhub.v2021_11_01.operations.Operations>`
"""
api_version = self._get_api_version('operations')
if api_version == '2015-08-01':
Expand All @@ -264,6 +288,8 @@ def operations(self):
from .v2021_01_01_preview.operations import Operations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import Operations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import Operations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'operations'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -275,6 +301,7 @@ def private_endpoint_connections(self):
* 2018-01-01-preview: :class:`PrivateEndpointConnectionsOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.PrivateEndpointConnectionsOperations>`
* 2021-01-01-preview: :class:`PrivateEndpointConnectionsOperations<azure.mgmt.eventhub.v2021_01_01_preview.operations.PrivateEndpointConnectionsOperations>`
* 2021-06-01-preview: :class:`PrivateEndpointConnectionsOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.PrivateEndpointConnectionsOperations>`
* 2021-11-01: :class:`PrivateEndpointConnectionsOperations<azure.mgmt.eventhub.v2021_11_01.operations.PrivateEndpointConnectionsOperations>`
"""
api_version = self._get_api_version('private_endpoint_connections')
if api_version == '2018-01-01-preview':
Expand All @@ -283,6 +310,8 @@ def private_endpoint_connections(self):
from .v2021_01_01_preview.operations import PrivateEndpointConnectionsOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import PrivateEndpointConnectionsOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import PrivateEndpointConnectionsOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'private_endpoint_connections'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -294,6 +323,7 @@ def private_link_resources(self):
* 2018-01-01-preview: :class:`PrivateLinkResourcesOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.PrivateLinkResourcesOperations>`
* 2021-01-01-preview: :class:`PrivateLinkResourcesOperations<azure.mgmt.eventhub.v2021_01_01_preview.operations.PrivateLinkResourcesOperations>`
* 2021-06-01-preview: :class:`PrivateLinkResourcesOperations<azure.mgmt.eventhub.v2021_06_01_preview.operations.PrivateLinkResourcesOperations>`
* 2021-11-01: :class:`PrivateLinkResourcesOperations<azure.mgmt.eventhub.v2021_11_01.operations.PrivateLinkResourcesOperations>`
"""
api_version = self._get_api_version('private_link_resources')
if api_version == '2018-01-01-preview':
Expand All @@ -302,6 +332,8 @@ def private_link_resources(self):
from .v2021_01_01_preview.operations import PrivateLinkResourcesOperations as OperationClass
elif api_version == '2021-06-01-preview':
from .v2021_06_01_preview.operations import PrivateLinkResourcesOperations as OperationClass
elif api_version == '2021-11-01':
from .v2021_11_01.operations import PrivateLinkResourcesOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'private_link_resources'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
Expand All @@ -322,6 +354,19 @@ def regions(self):
raise ValueError("API version {} does not have operation group 'regions'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))

@property
def schema_registry(self):
"""Instance depends on the API version:

* 2021-11-01: :class:`SchemaRegistryOperations<azure.mgmt.eventhub.v2021_11_01.operations.SchemaRegistryOperations>`
"""
api_version = self._get_api_version('schema_registry')
if api_version == '2021-11-01':
from .v2021_11_01.operations import SchemaRegistryOperations as OperationClass
else:
raise ValueError("API version {} does not have operation group 'schema_registry'".format(api_version))
return OperationClass(self._client, self._config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))

def close(self):
self._client.close()
def __enter__(self):
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,4 +5,4 @@
# license information.
# --------------------------------------------------------------------------

VERSION = "9.1.0"
VERSION = "10.0.0"
Loading