Skip to content

Commit b388099

Browse files
Shekar2004Shekar2004
committed
[Confluent] CLI extension generation for api version 2025-08-18-preview
1 parent 179e0c7 commit b388099

38 files changed

+9522
-2
lines changed

‎linter_exclusions.yml‎

Lines changed: 69 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -401,6 +401,75 @@ codespace plan create:
401401
confidentialledger managedccfs update:
402402
rule_exclusions:
403403
- missing_command_test_coverage
404+
confluent organization environment:
405+
rule_exclusions:
406+
- require_wait_command_if_no_wait
407+
confluent organization environment cluster:
408+
rule_exclusions:
409+
- require_wait_command_if_no_wait
410+
confluent organization environment cluster connector:
411+
rule_exclusions:
412+
- require_wait_command_if_no_wait
413+
confluent organization environment cluster topic:
414+
rule_exclusions:
415+
- require_wait_command_if_no_wait
416+
confluent agreement default create:
417+
rule_exclusions:
418+
- missing_command_example
419+
confluent organization environment create:
420+
rule_exclusions:
421+
- missing_command_example
422+
parameters:
423+
stream_governance_config:
424+
rule_exclusions:
425+
- option_length_too_long
426+
confluent organization environment update:
427+
rule_exclusions:
428+
- missing_command_example
429+
parameters:
430+
stream_governance_config:
431+
rule_exclusions:
432+
- option_length_too_long
433+
confluent organization environment cluster create:
434+
rule_exclusions:
435+
- missing_command_example
436+
confluent organization environment cluster update:
437+
rule_exclusions:
438+
- missing_command_example
439+
confluent organization environment cluster connector create:
440+
rule_exclusions:
441+
- missing_command_example
442+
parameters:
443+
connector_service_type_info:
444+
rule_exclusions:
445+
- option_length_too_long
446+
confluent organization environment cluster connector update:
447+
rule_exclusions:
448+
- missing_command_example
449+
parameters:
450+
connector_service_type_info:
451+
rule_exclusions:
452+
- option_length_too_long
453+
confluent organization environment cluster topic create:
454+
rule_exclusions:
455+
- missing_command_example
456+
parameters:
457+
partitions_reassignments:
458+
rule_exclusions:
459+
- option_length_too_long
460+
confluent organization environment cluster topic update:
461+
rule_exclusions:
462+
- missing_command_example
463+
parameters:
464+
partitions_reassignments:
465+
rule_exclusions:
466+
- option_length_too_long
467+
confluent validation orgvalidate:
468+
rule_exclusions:
469+
- missing_command_example
470+
confluent validation orgvalidate-v2:
471+
rule_exclusions:
472+
- missing_command_example
404473
containerapp env create:
405474
parameters:
406475
infrastructure_subnet_resource_id:

‎src/confluent/HISTORY.rst‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,16 @@
22
33
Release History
44
===============
5+
1.2.0
6+
+++++
7+
* Updated to API version 2025-08-18-preview.
8+
* Added `az confluent agreement list` and `az confluent agreement default create` commands for managing Confluent marketplace agreements.
9+
* Added `az confluent organization environment create/delete/update` commands for managing environments within a Confluent organization.
10+
* Added `az confluent organization environment cluster create/delete/update` commands for managing clusters within an environment.
11+
* Added `az confluent organization environment cluster connector create/delete/list/show/update` commands for managing connectors within a cluster.
12+
* Added `az confluent organization environment cluster topic create/delete/list/show/update` commands for managing topics within a cluster.
13+
* Added `az confluent validation orgvalidate` and `az confluent validation orgvalidate-v2` commands for validating Confluent organization configurations.
14+
515
1.1.0
616
+++++
717
* Updated az confluent organization create command to accept term_id as an optional parameter.

‎src/confluent/azext_confluent/aaz/latest/confluent/agreement/__cmd_group.py‎

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
# --------------------------------------------------------------------------------------------
2+
# Copyright (c) Microsoft Corporation. All rights reserved.
3+
# Licensed under the MIT License. See License.txt in the project root for license information.
4+
#
5+
# Code generated by aaz-dev-tools
6+
# --------------------------------------------------------------------------------------------
7+
8+
# pylint: skip-file
9+
# flake8: noqa
10+
11+
from azure.cli.core.aaz import *
12+
13+
14+
@register_command_group(
15+
"confluent agreement",
16+
)
17+
class __CMDGroup(AAZCommandGroup):
18+
"""Manage Agreement
19+
"""
20+
pass
21+
22+
23+
__all__ = ["__CMDGroup"]

‎src/confluent/azext_confluent/aaz/latest/confluent/agreement/__init__.py‎

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
# --------------------------------------------------------------------------------------------
2+
# Copyright (c) Microsoft Corporation. All rights reserved.
3+
# Licensed under the MIT License. See License.txt in the project root for license information.
4+
#
5+
# Code generated by aaz-dev-tools
6+
# --------------------------------------------------------------------------------------------
7+
8+
# pylint: skip-file
9+
# flake8: noqa
10+
11+
from .__cmd_group import *
12+
from ._list import *

‎src/confluent/azext_confluent/aaz/latest/confluent/agreement/_list.py‎

Lines changed: 205 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,205 @@
1+
# --------------------------------------------------------------------------------------------
2+
# Copyright (c) Microsoft Corporation. All rights reserved.
3+
# Licensed under the MIT License. See License.txt in the project root for license information.
4+
#
5+
# Code generated by aaz-dev-tools
6+
# --------------------------------------------------------------------------------------------
7+
8+
# pylint: skip-file
9+
# flake8: noqa
10+
11+
from azure.cli.core.aaz import *
12+
13+
14+
@register_command(
15+
"confluent agreement list",
16+
)
17+
class List(AAZCommand):
18+
"""List Confluent marketplace agreements in the subscription.
19+
"""
20+
21+
_aaz_info = {
22+
"version": "2024-02-13",
23+
"resources": [
24+
["mgmt-plane", "/subscriptions/{}/providers/microsoft.confluent/agreements", "2024-02-13"],
25+
]
26+
}
27+
28+
AZ_SUPPORT_PAGINATION = True
29+
30+
def _handler(self, command_args):
31+
super()._handler(command_args)
32+
return self.build_paging(self._execute_operations, self._output)
33+
34+
_args_schema = None
35+
36+
@classmethod
37+
def _build_arguments_schema(cls, *args, **kwargs):
38+
if cls._args_schema is not None:
39+
return cls._args_schema
40+
cls._args_schema = super()._build_arguments_schema(*args, **kwargs)
41+
42+
# define Arg Group ""
43+
return cls._args_schema
44+
45+
def _execute_operations(self):
46+
self.pre_operations()
47+
self.MarketplaceAgreementsList(ctx=self.ctx)()
48+
self.post_operations()
49+
50+
@register_callback
51+
def pre_operations(self):
52+
pass
53+
54+
@register_callback
55+
def post_operations(self):
56+
pass
57+
58+
def _output(self, *args, **kwargs):
59+
result = self.deserialize_output(self.ctx.vars.instance.value, client_flatten=True)
60+
next_link = self.deserialize_output(self.ctx.vars.instance.next_link)
61+
return result, next_link
62+
63+
class MarketplaceAgreementsList(AAZHttpOperation):
64+
CLIENT_TYPE = "MgmtClient"
65+
66+
def __call__(self, *args, **kwargs):
67+
request = self.make_request()
68+
session = self.client.send_request(request=request, stream=False, **kwargs)
69+
if session.http_response.status_code in [200]:
70+
return self.on_200(session)
71+
72+
return self.on_error(session.http_response)
73+
74+
@property
75+
def url(self):
76+
return self.client.format_url(
77+
"/subscriptions/{subscriptionId}/providers/Microsoft.Confluent/agreements",
78+
**self.url_parameters
79+
)
80+
81+
@property
82+
def method(self):
83+
return "GET"
84+
85+
@property
86+
def error_format(self):
87+
return "ODataV4Format"
88+
89+
@property
90+
def url_parameters(self):
91+
parameters = {
92+
**self.serialize_url_param(
93+
"subscriptionId", self.ctx.subscription_id,
94+
required=True,
95+
),
96+
}
97+
return parameters
98+
99+
@property
100+
def query_parameters(self):
101+
parameters = {
102+
**self.serialize_query_param(
103+
"api-version", "2024-02-13",
104+
required=True,
105+
),
106+
}
107+
return parameters
108+
109+
@property
110+
def header_parameters(self):
111+
parameters = {
112+
**self.serialize_header_param(
113+
"Accept", "application/json",
114+
),
115+
}
116+
return parameters
117+
118+
def on_200(self, session):
119+
data = self.deserialize_http_content(session)
120+
self.ctx.set_var(
121+
"instance",
122+
data,
123+
schema_builder=self._build_schema_on_200
124+
)
125+
126+
_schema_on_200 = None
127+
128+
@classmethod
129+
def _build_schema_on_200(cls):
130+
if cls._schema_on_200 is not None:
131+
return cls._schema_on_200
132+
133+
cls._schema_on_200 = AAZObjectType()
134+
135+
_schema_on_200 = cls._schema_on_200
136+
_schema_on_200.next_link = AAZStrType(
137+
serialized_name="nextLink",
138+
)
139+
_schema_on_200.value = AAZListType()
140+
141+
value = cls._schema_on_200.value
142+
value.Element = AAZObjectType()
143+
144+
_element = cls._schema_on_200.value.Element
145+
_element.id = AAZStrType(
146+
flags={"read_only": True},
147+
)
148+
_element.name = AAZStrType(
149+
flags={"read_only": True},
150+
)
151+
_element.properties = AAZObjectType(
152+
flags={"client_flatten": True},
153+
)
154+
_element.system_data = AAZObjectType(
155+
serialized_name="systemData",
156+
flags={"read_only": True},
157+
)
158+
_element.type = AAZStrType(
159+
flags={"read_only": True},
160+
)
161+
162+
properties = cls._schema_on_200.value.Element.properties
163+
properties.accepted = AAZBoolType()
164+
properties.license_text_link = AAZStrType(
165+
serialized_name="licenseTextLink",
166+
)
167+
properties.plan = AAZStrType()
168+
properties.privacy_policy_link = AAZStrType(
169+
serialized_name="privacyPolicyLink",
170+
)
171+
properties.product = AAZStrType()
172+
properties.publisher = AAZStrType()
173+
properties.retrieve_datetime = AAZStrType(
174+
serialized_name="retrieveDatetime",
175+
)
176+
properties.signature = AAZStrType()
177+
178+
system_data = cls._schema_on_200.value.Element.system_data
179+
system_data.created_at = AAZStrType(
180+
serialized_name="createdAt",
181+
)
182+
system_data.created_by = AAZStrType(
183+
serialized_name="createdBy",
184+
)
185+
system_data.created_by_type = AAZStrType(
186+
serialized_name="createdByType",
187+
)
188+
system_data.last_modified_at = AAZStrType(
189+
serialized_name="lastModifiedAt",
190+
)
191+
system_data.last_modified_by = AAZStrType(
192+
serialized_name="lastModifiedBy",
193+
)
194+
system_data.last_modified_by_type = AAZStrType(
195+
serialized_name="lastModifiedByType",
196+
)
197+
198+
return cls._schema_on_200
199+
200+
201+
class _ListHelper:
202+
"""Helper class for List"""
203+
204+
205+
__all__ = ["List"]

‎src/confluent/azext_confluent/aaz/latest/confluent/agreement/default/__cmd_group.py‎

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
# --------------------------------------------------------------------------------------------
2+
# Copyright (c) Microsoft Corporation. All rights reserved.
3+
# Licensed under the MIT License. See License.txt in the project root for license information.
4+
#
5+
# Code generated by aaz-dev-tools
6+
# --------------------------------------------------------------------------------------------
7+
8+
# pylint: skip-file
9+
# flake8: noqa
10+
11+
from azure.cli.core.aaz import *
12+
13+
14+
@register_command_group(
15+
"confluent agreement default",
16+
)
17+
class __CMDGroup(AAZCommandGroup):
18+
"""Manage Default
19+
"""
20+
pass
21+
22+
23+
__all__ = ["__CMDGroup"]

‎src/confluent/azext_confluent/aaz/latest/confluent/agreement/default/__init__.py‎

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
# --------------------------------------------------------------------------------------------
2+
# Copyright (c) Microsoft Corporation. All rights reserved.
3+
# Licensed under the MIT License. See License.txt in the project root for license information.
4+
#
5+
# Code generated by aaz-dev-tools
6+
# --------------------------------------------------------------------------------------------
7+
8+
# pylint: skip-file
9+
# flake8: noqa
10+
11+
from .__cmd_group import *
12+
from ._create import *

0 commit comments

Comments
 (0)