{Eventhub} API-Version for az eventhubs eventhub az eventhubs namespace cmdlets updated to 2024-05-01-preview (#29957)

* [Eventhub]:New feature update

* updates

* updates

* updates

* updates

* updates

* updates

* updateds

* updateds

* test recording

* test recording

* updates recording

* updates recording cluster

* updates

* updates help & params.py

* update & linter fix

* updates again linter'

* updates again linter'

* Update _help.py

* Update _help.py

* updateS

* recording

---------

Co-authored-by: Your Name <[email protected]>

Author: schaudhari6254888

src/azure-cli/azure/cli/command_modules/eventhubs/_help.py

@@ -668,6 +668,29 @@
         az eventhubs namespace identity remove --namespace-name mynamespace -g MyResourceGroup --system-assigned --user-assigned /subscriptions/{subscriptionId}}/resourceGroups/{resourcegroup}/providers/Microsoft.ManagedIdentity/userAssignedIdentities/MSIName
 """
 
+helps['eventhubs namespace replica'] = """
+type: group
+short-summary: Manage eventhubs namespace replicas.
+"""
+
+helps['eventhubs namespace replica add'] = """
+type: command
+short-summary: Add one or more Replica properties to a namespace.
+examples:
+  - name: Add one or more Replica properties to a namespace.
+    text: |
+        az eventhubs namespace replica add --namespace-name mynamespace -g MyResourceGroup --geo-data-replication-config role-type=Secondary location-name=mylocation cluster-arm-id=/subscriptions/{mysubcriptionid}/resourceGroups/{myResourcegroup}/providers/Microsoft.EventHub/clusters/{clustername}
+"""
+
+helps['eventhubs namespace replica remove'] = """
+type: command
+short-summary: Remove one or more Replica properties to a namespace.
+examples:
+  - name: Remove one or more Replica properties to a namespace.
+    text: |
+        az eventhubs namespace replica remove --namespace-name mynamespace -g MyResourceGroup --geo-data-replication-config role-type=Secondary location-name=mylocation cluster-arm-id=/subscriptions/{mysubcriptionid}/resourceGroups/{myResourcegroup}/providers/Microsoft.EventHub/clusters/{clustername}
+"""
+
 helps['eventhubs namespace schema-registry'] = """
 type: group
 short-summary: Manages eventhubs namespace schema registry.

src/azure-cli/azure/cli/command_modules/eventhubs/_params.py

@@ -17,7 +17,7 @@ def load_arguments_eh(self, _):
     from knack.arguments import CLIArgumentType
     from azure.cli.core.profiles import ResourceType
     (SkuName, TlsVersion) = self.get_models('SkuName', 'TlsVersion', resource_type=ResourceType.MGMT_EVENTHUB)
-    from azure.cli.command_modules.eventhubs.action import AlertAddEncryption, ConstructPolicy, AlertAddIpRule, AlertAddVirtualNetwork, ConstructPolicyName
+    from azure.cli.command_modules.eventhubs.action import AlertAddEncryption, ConstructPolicy, AlertAddIpRule, AlertAddVirtualNetwork, ConstructPolicyName, AlertAddlocation
 
     namespace_name_arg_type = CLIArgumentType(options_list=['--namespace-name'], help='Name of Namespace', id_part='name')
 
@@ -47,6 +47,7 @@ def load_arguments_eh(self, _):
                    help='Enable System Assigned Identity')
         c.argument('mi_user_assigned', arg_group='Managed Identity', nargs='+', help='List of User Assigned Identity ids.')
         c.argument('encryption_config', action=AlertAddEncryption, nargs='+', help='List of KeyVaultProperties objects.')
+        c.argument('geo_data_replication_config', action=AlertAddlocation, options_list=['--geo-data-replication-config', '--replica-config'], nargs='+', help='A list of regions where replicas of the namespace are maintained Object')
         c.argument('minimum_tls_version', arg_type=get_enum_type(TlsVersion), options_list=['--minimum-tls-version', '--min-tls'], help='The minimum TLS version for the cluster to support, e.g. 1.2')
         c.argument('require_infrastructure_encryption', options_list=['--infra-encryption'],
                    arg_type=get_three_state_flag(),
@@ -55,6 +56,7 @@ def load_arguments_eh(self, _):
                    arg_type=get_enum_type(['Enabled', 'Disabled']),
                    help='This determines if traffic is allowed over public network. By default it is enabled. If value is SecuredByPerimeter then Inbound and Outbound communication is controlled by the network security perimeter and profile\' access rules.')
         c.argument('alternate_name', help='Alternate name specified when alias and namespace names are same.')
+        c.argument('max_replication_lag_duration_in_seconds', type=int, options_list=['--max-replication-lag-duration-in-seconds', '--max-lag'], help='The maximum acceptable lag for data replication operations from the primary replica to a quorum of secondary replicas')
 
     with self.argument_context('eventhubs namespace create', min_api='2021-06-01-preview') as c:
         c.argument('cluster_arm_id', options_list=['--cluster-arm-id'], help='Cluster ARM ID of the Namespace')
@@ -77,10 +79,13 @@ def load_arguments_eh(self, _):
             c.argument('archive_name_format', arg_group='Capture-Destination', help='Blob naming convention for archive, e.g. {Namespace}/{EventHub}/{PartitionId}/{Year}/{Month}/{Day}/{Hour}/{Minute}/{Second}. Here all the parameters (Namespace,EventHub .. etc) are mandatory irrespective of order')
             c.argument('retention_time_in_hours', type=int, arg_group='Retention-Description', options_list=['--retention-time-in-hours', '--retention-time'], help="Number of hours to retain the events for this Event Hub. This value is only used when cleanupPolicy is Delete. If cleanupPolicy is Compaction the returned value of this property is Long.MaxValue")
             c.argument('tombstone_retention_time_in_hours', type=int, arg_group='Retention-Description', options_list=['--tombstone-retention-time-in-hours', '--tombstone-time'], help="Number of hours to retain the tombstone markers of a compacted Event Hub. This value is only used when cleanupPolicy is Compaction. Consumer must complete reading the tombstone marker within this specified amount of time if consumer begins from starting offset to ensure they get a valid snapshot for the specific key described by the tombstone marker within the compacted Event Hub")
-            c.argument('cleanup_policy', arg_group='Retention-Description', arg_type=get_enum_type(['Delete', 'Compact']), help="Enumerates the possible values for cleanup policy")
+            c.argument('cleanup_policy', arg_group='Retention-Description', arg_type=get_enum_type(['Delete', 'Compact', 'DeleteOrCompact']), help="Enumerates the possible values for cleanup policy")
             c.argument('mi_system_assigned', arg_group='Capture-Destination', arg_type=get_three_state_flag(),
                        help='Enable System Assigned Identity')
             c.argument('mi_user_assigned', arg_group='Capture-Destination', help='List of User Assigned Identity ids.')
+            c.argument('user_metadata', help="Gets and Sets Metadata of User.")
+            c.argument('timestamp_type', arg_type=get_enum_type(['Create', 'LogAppend']), help='Denotes the type of timestamp the message will hold.')
+            c.argument('min_compaction_lag_in_mins', type=int, arg_group='Retention-Description', options_list=['--min-lag', '--min-compaction-lag-in-mins'], help="The minimum time a message will remain ineligible for compaction in the log. This value is used when cleanupPolicy is Compact or DeleteOrCompact.")
     with self.argument_context('eventhubs eventhub list') as c:
         c.argument('namespace_name', options_list=['--namespace-name'], id_part=None, help='Name of Namespace')
 
@@ -152,6 +157,14 @@ def load_arguments_eh(self, _):
             c.argument('require_infrastructure_encryption', options_list=['--infra-encryption'],
                        arg_type=get_three_state_flag(),
                        help='A boolean value that indicates whether Infrastructure Encryption (Double Encryption) is enabled/disabled')
+# Location
+    with self.argument_context('eventhubs namespace replica', resource_type=ResourceType.MGMT_EVENTHUB) as c:
+        c.argument('namespace_name', options_list=['--namespace-name'], id_part=None, help='Name of the Namespace')
+
+    for scope in ['eventhubs namespace replica add', 'eventhubs namespace replica remove']:
+        with self.argument_context(scope, resource_type=ResourceType.MGMT_EVENTHUB) as c:
+            c.argument('geo_data_replication_config', action=AlertAddlocation, nargs='+',
+                       help='A list of regions where replicas of the namespace are maintained Object')
 
 # Application Group
     with self.argument_context('eventhubs namespace application-group') as c:

src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/__init__.py

@@ -4,3 +4,7 @@
 #
 # Code generated by aaz-dev-tools
 # --------------------------------------------------------------------------------------------
+
+# pylint: skip-file
+# flake8: noqa
+

src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/__cmd_group.py

@@ -20,4 +20,4 @@ class __CMDGroup(AAZCommandGroup):
     pass
 
 
-__all__ = ["__CMDGroup"]
+__all__ = ["__CMDGroup"]

src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/_list.py

@@ -388,4 +388,4 @@ class _ListHelper:
     """Helper class for List"""
 
 
-__all__ = ["List"]
+__all__ = ["List"]

src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/_show.py

@@ -233,4 +233,4 @@ class _ShowHelper:
     """Helper class for Show"""
 
 
-__all__ = ["Show"]
+__all__ = ["Show"]

src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/_update.py

@@ -476,4 +476,4 @@ def _build_schema_cluster_read(cls, _schema):
         _schema.type = cls._schema_cluster_read.type
 
 
-__all__ = ["Update"]
+__all__ = ["Update"]

src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/cluster/_wait.py

@@ -232,4 +232,4 @@ class _WaitHelper:
     """Helper class for Wait"""
 
 
-__all__ = ["Wait"]
+__all__ = ["Wait"]

src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/__cmd_group.py

@@ -20,4 +20,4 @@ class __CMDGroup(AAZCommandGroup):
     pass
 
 
-__all__ = ["__CMDGroup"]
+__all__ = ["__CMDGroup"]