Generated from 2ce98af2928d0ec71c04190bbc490987e830cd78

fix

sdk/eventhub/azure-mgmt-eventhub/azure/mgmt/eventhub/_event_hub_management_client.py

@@ -205,6 +205,32 @@ def operations(self):
             raise NotImplementedError("APIVersion {} is not available".format(api_version))
         return OperationClass(self._client, self.config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
 
+    @property
+    def private_endpoint_connections(self):
+        """Instance depends on the API version:
+
+           * 2018-01-01-preview: :class:`PrivateEndpointConnectionsOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.PrivateEndpointConnectionsOperations>`
+        """
+        api_version = self._get_api_version('private_endpoint_connections')
+        if api_version == '2018-01-01-preview':
+            from .v2018_01_01_preview.operations import PrivateEndpointConnectionsOperations as OperationClass
+        else:
+            raise NotImplementedError("APIVersion {} is not available".format(api_version))
+        return OperationClass(self._client, self.config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
+
+    @property
+    def private_link_resources(self):
+        """Instance depends on the API version:
+
+           * 2018-01-01-preview: :class:`PrivateLinkResourcesOperations<azure.mgmt.eventhub.v2018_01_01_preview.operations.PrivateLinkResourcesOperations>`
+        """
+        api_version = self._get_api_version('private_link_resources')
+        if api_version == '2018-01-01-preview':
+            from .v2018_01_01_preview.operations import PrivateLinkResourcesOperations as OperationClass
+        else:
+            raise NotImplementedError("APIVersion {} is not available".format(api_version))
+        return OperationClass(self._client, self.config, Serializer(self._models_dict(api_version)), Deserializer(self._models_dict(api_version)))
+
     @property
     def regions(self):
         """Instance depends on the API version:

sdk/eventhub/azure-mgmt-eventhub/azure/mgmt/eventhub/v2018_01_01_preview/_event_hub_management_client.py

@@ -15,6 +15,8 @@
 from ._configuration import EventHubManagementClientConfiguration
 from .operations import ClustersOperations
 from .operations import NamespacesOperations
+from .operations import PrivateEndpointConnectionsOperations
+from .operations import PrivateLinkResourcesOperations
 from .operations import ConfigurationOperations
 from .operations import DisasterRecoveryConfigsOperations
 from .operations import EventHubsOperations
@@ -34,6 +36,10 @@ class EventHubManagementClient(SDKClient):
     :vartype clusters: azure.mgmt.eventhub.v2018_01_01_preview.operations.ClustersOperations
     :ivar namespaces: Namespaces operations
     :vartype namespaces: azure.mgmt.eventhub.v2018_01_01_preview.operations.NamespacesOperations
+    :ivar private_endpoint_connections: PrivateEndpointConnections operations
+    :vartype private_endpoint_connections: azure.mgmt.eventhub.v2018_01_01_preview.operations.PrivateEndpointConnectionsOperations
+    :ivar private_link_resources: PrivateLinkResources operations
+    :vartype private_link_resources: azure.mgmt.eventhub.v2018_01_01_preview.operations.PrivateLinkResourcesOperations
     :ivar configuration: Configuration operations
     :vartype configuration: azure.mgmt.eventhub.v2018_01_01_preview.operations.ConfigurationOperations
     :ivar disaster_recovery_configs: DisasterRecoveryConfigs operations
@@ -71,6 +77,10 @@ def __init__(
             self._client, self.config, self._serialize, self._deserialize)
         self.namespaces = NamespacesOperations(
             self._client, self.config, self._serialize, self._deserialize)
+        self.private_endpoint_connections = PrivateEndpointConnectionsOperations(
+            self._client, self.config, self._serialize, self._deserialize)
+        self.private_link_resources = PrivateLinkResourcesOperations(
+            self._client, self.config, self._serialize, self._deserialize)
         self.configuration = ConfigurationOperations(
             self._client, self.config, self._serialize, self._deserialize)
         self.disaster_recovery_configs = DisasterRecoveryConfigsOperations(

sdk/eventhub/azure-mgmt-eventhub/azure/mgmt/eventhub/v2018_01_01_preview/models/__init__.py

@@ -21,6 +21,7 @@
     from ._models_py3 import Cluster
     from ._models_py3 import ClusterQuotaConfigurationProperties
     from ._models_py3 import ClusterSku
+    from ._models_py3 import ConnectionState
     from ._models_py3 import ConsumerGroup
     from ._models_py3 import Destination
     from ._models_py3 import EHNamespace
@@ -39,6 +40,11 @@
     from ._models_py3 import NWRuleSetVirtualNetworkRules
     from ._models_py3 import Operation
     from ._models_py3 import OperationDisplay
+    from ._models_py3 import PrivateEndpoint
+    from ._models_py3 import PrivateEndpointConnection
+    from ._models_py3 import PrivateEndpointConnectionListResult
+    from ._models_py3 import PrivateLinkResource
+    from ._models_py3 import PrivateLinkResourcesListResult
     from ._models_py3 import RegenerateAccessKeyParameters
     from ._models_py3 import Resource
     from ._models_py3 import Sku
@@ -57,6 +63,7 @@
     from ._models import Cluster
     from ._models import ClusterQuotaConfigurationProperties
     from ._models import ClusterSku
+    from ._models import ConnectionState
     from ._models import ConsumerGroup
     from ._models import Destination
     from ._models import EHNamespace
@@ -75,6 +82,11 @@
     from ._models import NWRuleSetVirtualNetworkRules
     from ._models import Operation
     from ._models import OperationDisplay
+    from ._models import PrivateEndpoint
+    from ._models import PrivateEndpointConnection
+    from ._models import PrivateEndpointConnectionListResult
+    from ._models import PrivateLinkResource
+    from ._models import PrivateLinkResourcesListResult
     from ._models import RegenerateAccessKeyParameters
     from ._models import Resource
     from ._models import Sku
@@ -97,6 +109,8 @@
     SkuTier,
     IdentityType,
     KeySource,
+    PrivateLinkConnectionStatus,
+    EndPointProvisioningState,
     NetworkRuleIPAction,
     DefaultAction,
     AccessRights,
@@ -120,6 +134,7 @@
     'Cluster',
     'ClusterQuotaConfigurationProperties',
     'ClusterSku',
+    'ConnectionState',
     'ConsumerGroup',
     'Destination',
     'EHNamespace',
@@ -138,6 +153,11 @@
     'NWRuleSetVirtualNetworkRules',
     'Operation',
     'OperationDisplay',
+    'PrivateEndpoint',
+    'PrivateEndpointConnection',
+    'PrivateEndpointConnectionListResult',
+    'PrivateLinkResource',
+    'PrivateLinkResourcesListResult',
     'RegenerateAccessKeyParameters',
     'Resource',
     'Sku',
@@ -159,6 +179,8 @@
     'SkuTier',
     'IdentityType',
     'KeySource',
+    'PrivateLinkConnectionStatus',
+    'EndPointProvisioningState',
     'NetworkRuleIPAction',
     'DefaultAction',
     'AccessRights',

sdk/eventhub/azure-mgmt-eventhub/azure/mgmt/eventhub/v2018_01_01_preview/models/_event_hub_management_client_enums.py

@@ -40,6 +40,24 @@ class KeySource(str, Enum):
     microsoft_key_vault = "Microsoft.KeyVault"
 
 
+class PrivateLinkConnectionStatus(str, Enum):
+
+    pending = "Pending"
+    approved = "Approved"
+    rejected = "Rejected"
+    disconnected = "Disconnected"
+
+
+class EndPointProvisioningState(str, Enum):
+
+    creating = "Creating"
+    updating = "Updating"
+    deleting = "Deleting"
+    succeeded = "Succeeded"
+    canceled = "Canceled"
+    failed = "Failed"
+
+
 class NetworkRuleIPAction(str, Enum):
 
     allow = "Allow"

sdk/eventhub/azure-mgmt-eventhub/azure/mgmt/eventhub/v2018_01_01_preview/models/_models.py

@@ -508,6 +508,28 @@ def __init__(self, **kwargs):
         self.capacity = kwargs.get('capacity', None)
 
 
+class ConnectionState(Model):
+    """ConnectionState information.
+
+    :param status: Status of the connection. Possible values include:
+     'Pending', 'Approved', 'Rejected', 'Disconnected'
+    :type status: str or
+     ~azure.mgmt.eventhub.v2018_01_01_preview.models.PrivateLinkConnectionStatus
+    :param description: Description of the connection state.
+    :type description: str
+    """
+
+    _attribute_map = {
+        'status': {'key': 'status', 'type': 'str'},
+        'description': {'key': 'description', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(ConnectionState, self).__init__(**kwargs)
+        self.status = kwargs.get('status', None)
+        self.description = kwargs.get('description', None)
+
+
 class ConsumerGroup(Resource):
     """Single item in List or Get Consumer group operation.
 
@@ -636,6 +658,10 @@ class EHNamespace(TrackedResource):
     :param encryption: Properties of BYOK Encryption description
     :type encryption:
      ~azure.mgmt.eventhub.v2018_01_01_preview.models.Encryption
+    :param private_endpoint_connections: A collection of private endpoint
+     connection resources.
+    :type private_endpoint_connections:
+     list[~azure.mgmt.eventhub.v2018_01_01_preview.models.PrivateEndpointConnectionListResult]
     """
 
     _validation = {
@@ -669,6 +695,7 @@ class EHNamespace(TrackedResource):
         'kafka_enabled': {'key': 'properties.kafkaEnabled', 'type': 'bool'},
         'zone_redundant': {'key': 'properties.zoneRedundant', 'type': 'bool'},
         'encryption': {'key': 'properties.encryption', 'type': 'Encryption'},
+        'private_endpoint_connections': {'key': 'properties.privateEndpointConnections', 'type': '[PrivateEndpointConnectionListResult]'},
     }
 
     def __init__(self, **kwargs):
@@ -686,6 +713,7 @@ def __init__(self, **kwargs):
         self.kafka_enabled = kwargs.get('kafka_enabled', None)
         self.zone_redundant = kwargs.get('zone_redundant', None)
         self.encryption = kwargs.get('encryption', None)
+        self.private_endpoint_connections = kwargs.get('private_endpoint_connections', None)
 
 
 class EHNamespaceIdContainer(Model):
@@ -1167,6 +1195,156 @@ def __init__(self, **kwargs):
         self.operation = None
 
 
+class PrivateEndpoint(Model):
+    """PrivateEndpoint information.
+
+    :param id: The ARM identifier for Private Endpoint.
+    :type id: str
+    """
+
+    _attribute_map = {
+        'id': {'key': 'id', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(PrivateEndpoint, self).__init__(**kwargs)
+        self.id = kwargs.get('id', None)
+
+
+class PrivateEndpointConnection(TrackedResource):
+    """Properties of the PrivateEndpointConnection.
+
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
+    :ivar id: Resource ID.
+    :vartype id: str
+    :ivar name: Resource name.
+    :vartype name: str
+    :ivar type: Resource type.
+    :vartype type: str
+    :param location: Resource location.
+    :type location: str
+    :param tags: Resource tags.
+    :type tags: dict[str, str]
+    :param private_endpoint: The Private Endpoint resource for this
+     Connection.
+    :type private_endpoint:
+     ~azure.mgmt.eventhub.v2018_01_01_preview.models.PrivateEndpoint
+    :param private_link_service_connection_state: Details about the state of
+     the connection.
+    :type private_link_service_connection_state:
+     ~azure.mgmt.eventhub.v2018_01_01_preview.models.ConnectionState
+    :param provisioning_state: Provisioning state of the Private Endpoint
+     Connection. Possible values include: 'Creating', 'Updating', 'Deleting',
+     'Succeeded', 'Canceled', 'Failed'
+    :type provisioning_state: str or
+     ~azure.mgmt.eventhub.v2018_01_01_preview.models.EndPointProvisioningState
+    """
+
+    _validation = {
+        'id': {'readonly': True},
+        'name': {'readonly': True},
+        'type': {'readonly': True},
+    }
+
+    _attribute_map = {
+        'id': {'key': 'id', 'type': 'str'},
+        'name': {'key': 'name', 'type': 'str'},
+        'type': {'key': 'type', 'type': 'str'},
+        'location': {'key': 'location', 'type': 'str'},
+        'tags': {'key': 'tags', 'type': '{str}'},
+        'private_endpoint': {'key': 'properties.privateEndpoint', 'type': 'PrivateEndpoint'},
+        'private_link_service_connection_state': {'key': 'properties.privateLinkServiceConnectionState', 'type': 'ConnectionState'},
+        'provisioning_state': {'key': 'properties.provisioningState', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(PrivateEndpointConnection, self).__init__(**kwargs)
+        self.private_endpoint = kwargs.get('private_endpoint', None)
+        self.private_link_service_connection_state = kwargs.get('private_link_service_connection_state', None)
+        self.provisioning_state = kwargs.get('provisioning_state', None)
+
+
+class PrivateEndpointConnectionListResult(Model):
+    """Result of the list of all private endpoint connections operation.
+
+    :param value: A collection of private endpoint connection resources.
+    :type value:
+     list[~azure.mgmt.eventhub.v2018_01_01_preview.models.PrivateEndpointConnection]
+    :param next_link: A link for the next page of private endpoint connection
+     resources.
+    :type next_link: str
+    """
+
+    _attribute_map = {
+        'value': {'key': 'value', 'type': '[PrivateEndpointConnection]'},
+        'next_link': {'key': 'nextLink', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(PrivateEndpointConnectionListResult, self).__init__(**kwargs)
+        self.value = kwargs.get('value', None)
+        self.next_link = kwargs.get('next_link', None)
+
+
+class PrivateLinkResource(Model):
+    """Information of the private link resource.
+
+    :param group_id:
+    :type group_id: str
+    :param required_members: Required Members
+    :type required_members: list[str]
+    :param required_zone_names: Required Zone Names
+    :type required_zone_names: list[str]
+    :param id: Fully qualified identifier of the resource.
+    :type id: str
+    :param name: Name of the resource
+    :type name: str
+    :param type: Type of the resource
+    :type type: str
+    """
+
+    _attribute_map = {
+        'group_id': {'key': 'properties.groupId', 'type': 'str'},
+        'required_members': {'key': 'properties.requiredMembers', 'type': '[str]'},
+        'required_zone_names': {'key': 'properties.requiredZoneNames', 'type': '[str]'},
+        'id': {'key': 'id', 'type': 'str'},
+        'name': {'key': 'name', 'type': 'str'},
+        'type': {'key': 'type', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(PrivateLinkResource, self).__init__(**kwargs)
+        self.group_id = kwargs.get('group_id', None)
+        self.required_members = kwargs.get('required_members', None)
+        self.required_zone_names = kwargs.get('required_zone_names', None)
+        self.id = kwargs.get('id', None)
+        self.name = kwargs.get('name', None)
+        self.type = kwargs.get('type', None)
+
+
+class PrivateLinkResourcesListResult(Model):
+    """Result of the List private link resources operation.
+
+    :param value: A collection of private link resources
+    :type value:
+     list[~azure.mgmt.eventhub.v2018_01_01_preview.models.PrivateLinkResource]
+    :param next_link: A link for the next page of private link resources.
+    :type next_link: str
+    """
+
+    _attribute_map = {
+        'value': {'key': 'value', 'type': '[PrivateLinkResource]'},
+        'next_link': {'key': 'nextLink', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(PrivateLinkResourcesListResult, self).__init__(**kwargs)
+        self.value = kwargs.get('value', None)
+        self.next_link = kwargs.get('next_link', None)
+
+
 class RegenerateAccessKeyParameters(Model):
     """Parameters supplied to the Regenerate Authorization Rule operation,
     specifies which key needs to be reset.