17 def validate_create_service(namespace):  argument
18     if namespace.state == 'stateless':
19         if namespace.target_replica_set_size or namespace.min_replica_set_size:
22         if not namespace.instance_count:
25         if namespace.instance_count:
27         if not namespace.target_replica_set_size or not namespace.min_replica_set_size:
30     if not namespace.service_name.startswith(namespace.application_name):
32 …                 "for example: '{}~{}'".format(namespace.application_name, namespace.service_name))
35 def validate_update_application(cmd, namespace):  argument
38 …               (namespace.resource_group_name, namespace.cluster_name, namespace.application_name))
40         raise CLIError("Application '{}' Not Found.".format(namespace.application_name))
41     if namespace.application_type_version is not None:
42         if app.type_version == namespace.application_type_version:
46                                           (namespace.resource_group_name,
47                                            namespace.cluster_name,
49                                            namespace.application_type_version))
53                            .format(app.type_name, namespace.application_type_version))
55     if namespace.upgrade_replica_set_check_timeout:
56 …     namespace.upgrade_replica_set_check_timeout = int(namespace.upgrade_replica_set_check_timeout)
57     if namespace.health_check_stable_duration:
58         namespace.health_check_stable_duration = int(namespace.health_check_stable_duration)
59     if namespace.health_check_retry_timeout:
60         namespace.health_check_retry_timeout = int(namespace.health_check_retry_timeout)
61     if namespace.health_check_wait_duration:
62         namespace.health_check_wait_duration = int(namespace.health_check_wait_duration)
63     if namespace.upgrade_timeout:
64         namespace.upgrade_timeout = int(namespace.upgrade_timeout)
65     if namespace.upgrade_domain_timeout:
66         namespace.upgrade_domain_timeout = int(namespace.upgrade_domain_timeout)
67     if namespace.minimum_nodes:
68         namespace.minimum_nodes = int(namespace.minimum_nodes)
69         if namespace.minimum_nodes < 0:
71     if namespace.maximum_nodes:
72         namespace.maximum_nodes = int(namespace.maximum_nodes)
73         if namespace.maximum_nodes < 0:
77 def validate_create_application(cmd, namespace):  argument
79     if namespace.package_url is None:
81                                           (namespace.resource_group_name,
82                                            namespace.cluster_name,
83                                            namespace.application_type_name,
84                                            namespace.application_type_version))
88 …                      .format(namespace.application_type_name, namespace.application_type_version))
90     if namespace.minimum_nodes:
91         namespace.minimum_nodes = int(namespace.minimum_nodes)
92         if namespace.minimum_nodes < 0:
94     if namespace.maximum_nodes:
95         namespace.maximum_nodes = int(namespace.maximum_nodes)
96         if namespace.maximum_nodes < 0:
101 def validate_create_managed_cluster(cmd, namespace):  argument
102     rg = _get_resource_group_by_name(cmd.cli_ctx, namespace.resource_group_name)
103     if rg is None and namespace.location is None:
106                        .format(namespace.resource_group_name))
108     if namespace.client_cert_issuer_thumbprint is not None:
109         if namespace.client_cert_common_name is None:
112     if namespace.upgrade_mode is None or namespace.upgrade_mode == 'Automatic':
113         if namespace.code_version is not None:
116     if namespace.upgrade_cadence is not None:
117         if namespace.upgrade_mode == 'Manual':
121 def validate_create_managed_service(namespace):  argument
122     if namespace.service_type is None:
125     if namespace.state.lower() == ServiceKind.STATELESS.lower():
126         if namespace.target_replica_set_size or namespace.min_replica_set_size:
129         if not namespace.instance_count:
131         namespace.instance_count = int(namespace.instance_count)
132     elif namespace.state.lower() == ServiceKind.STATEFUL.lower():
133         if namespace.instance_count:
135         if not namespace.target_replica_set_size or not namespace.min_replica_set_size:
137         namespace.target_replica_set_size = int(namespace.target_replica_set_size)
138         namespace.min_replica_set_size = int(namespace.min_replica_set_size)
140         raise ValidationError("Invalid --state '%s': service state is not valid." % namespace.state)
142     if namespace.partition_scheme is None:
145     if namespace.partition_scheme.lower() == PartitionScheme.NAMED.lower():
146         if namespace.partition_names is None:
148                                   % namespace.partition_scheme)
149     elif namespace.partition_scheme.lower() == PartitionScheme.SINGLETON.lower():
151     elif namespace.partition_scheme.lower() == PartitionScheme.UNIFORM_INT64_RANGE.lower():
152 …   if namespace.partition_count is None or namespace.low_key is None or namespace.high_key is None:
155                 % namespace.partition_scheme)
156         namespace.partition_count = int(namespace.partition_count)
157         namespace.low_key = int(namespace.low_key)
158         namespace.high_key = int(namespace.high_key)
161 …"Invalid --partition_scheme '%s': service partition_scheme is not valid." % namespace.partition_sc…
164 def validate_update_managed_service(cmd, namespace):  argument
167                                  (namespace.resource_group_name, namespace.cluster_name,
168                                   namespace.application_name, namespace.service_name))
170         if namespace.target_replica_set_size or namespace.min_replica_set_size:
173         if namespace.instance_count is not None:
174             namespace.instance_count = int(namespace.instance_count)
176         if namespace.instance_count:
178         if namespace.target_replica_set_size is not None:
179             namespace.target_replica_set_size = int(namespace.target_replica_set_size)
180         if namespace.min_replica_set_size is not None:
181             namespace.min_replica_set_size = int(namespace.min_replica_set_size)
186 def validate_create_managed_service_load_metric(cmd, namespace):  argument
189                                  (namespace.resource_group_name, namespace.cluster_name,
190                                   namespace.application_name, namespace.service_name))
193         raise ValidationError("Service '{}' Not Found.".format(namespace.service_name))
195 …    if namespace.metric_name is None or namespace.weight is None or namespace.default_load is None:
197 …     if namespace.primary_default_load is not None or namespace.secondary_default_load is not None:
201         namespace.default_load = int(namespace.default_load)
203         if namespace.metric_name is None or namespace.weight is None or \
204            namespace.primary_default_load is None or namespace.secondary_default_load is None:
207         if namespace.default_load is not None:
209         namespace.primary_default_load = int(namespace.primary_default_load)
210         namespace.secondary_default_load = int(namespace.secondary_default_load)
213 …if any(namespace.metric_name == metric.name for metric in service.properties.service_load_metrics):
214         raise ValidationError("Duplicate metric names are not allowed: %s." % namespace.metric_name)
217 def validate_update_managed_service_load_metric(cmd, namespace):  argument
220                                  (namespace.resource_group_name, namespace.cluster_name,
221                                   namespace.application_name, namespace.service_name))
224         raise CLIError("Service '{}' Not Found.".format(namespace.service_name))
226 …     if namespace.primary_default_load is not None or namespace.secondary_default_load is not None:
230         if namespace.default_load is not None:
231             namespace.default_load = int(namespace.default_load)
233         if namespace.default_load is not None:
235         if namespace.primary_default_load is not None:
236             namespace.primary_default_load = int(namespace.primary_default_load)
237         if namespace.secondary_default_load is not None:
238             namespace.secondary_default_load = int(namespace.secondary_default_load)
243 def validate_create_managed_service_correlation(cmd, namespace):  argument
246                                  (namespace.resource_group_name, namespace.cluster_name,
247                                   namespace.application_name, namespace.service_name))
250         raise ValidationError("Service '{}' Not Found.".format(namespace.service_name))
256 def validate_update_managed_service_correlation(cmd, namespace):  argument
259                                  (namespace.resource_group_name, namespace.cluster_name,
260                                   namespace.application_name, namespace.service_name))
263         raise ValidationError("Service '{}' Not Found.".format(namespace.service_name))
266 def validate_update_managed_application(cmd, namespace):  argument
269 …               (namespace.resource_group_name, namespace.cluster_name, namespace.application_name))
271         raise CLIError("Application '{}' Not Found.".format(namespace.application_name))
272     if namespace.application_type_version is not None:
273         if app.version.endswith(namespace.application_type_version):
278                                           (namespace.resource_group_name,
279                                            namespace.cluster_name,
281                                            namespace.application_type_version))
285                                   .format(app.type_name, namespace.application_type_version))
287     if namespace.upgrade_replica_set_check_timeout:
288 …     namespace.upgrade_replica_set_check_timeout = int(namespace.upgrade_replica_set_check_timeout)
289     if namespace.health_check_stable_duration:
290         namespace.health_check_stable_duration = int(namespace.health_check_stable_duration)
291     if namespace.health_check_retry_timeout:
292         namespace.health_check_retry_timeout = int(namespace.health_check_retry_timeout)
293     if namespace.health_check_wait_duration:
294         namespace.health_check_wait_duration = int(namespace.health_check_wait_duration)
295     if namespace.upgrade_timeout:
296         namespace.upgrade_timeout = int(namespace.upgrade_timeout)
297     if namespace.upgrade_domain_timeout:
298         namespace.upgrade_domain_timeout = int(namespace.upgrade_domain_timeout)
301 def validate_create_managed_application(cmd, namespace):  argument
303     if namespace.package_url is None:
305                                           (namespace.resource_group_name,
306                                            namespace.cluster_name,
307                                            namespace.application_type_name,
308                                            namespace.application_type_version))
313 …                      .format(namespace.application_type_name, namespace.application_type_version))