GSrSSKrSSKJr SSKJr "SS\R 5r"SS\5rS r S r S r S r S r SrSrSrSrSrSrSrSrSrSrSrSrSrSrSrS\S\S\S \4S!jrg)"z*Utilities for `gcloud network-management`.N)Any) exceptionsc\rSrSrSrSrg)NetworkManagementErrorz6Top-level exception for all Network Management errors.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r9lib/googlecloudsdk/command_lib/network_management/util.pyrrs>rrc\rSrSrSrSrg)InvalidInputErrorzException for invalid input.rNr rrrrrs$rrcS/n[U5S:aURS5 [U5Hup4URSRXS95 US:Xa"[U5S:XaURS5 MKU[U5S- :XaURS 5 MpU[U5S- :dMURS 5 M URS 5 S R U5$) zOCreates a message to specify at least one endpoint, separated by commas and or.zInvalid Connectivity Test. zAt least one of z--{endpoint_type}-{endpoint}) endpoint_typeendpointrz or z, or z, z must be specified.)lenappend enumerateformatjoin) endpointsr error_msgindexrs r"GetClearSingleEndpointAttrErrorMsgr#s,-)^a '("9-oe &--' .   zc)n)v #i.1$ $w Y!# #t. ()  rc0U=RS- slU$)zXAdd locations/global to parent path, since it isn't automatically populated by apitools./locations/global)parent unused_ref unused_argsrequests rAppendLocationsGlobalToParentr+6s ..''. .rc0U=RS- slU$)Nr%)namer's r"UpdateOperationRequestNameVariabler.<s ,,%%, .rc`URnU(dXlU$X;a US-U-UlU$)z"Adds name of field to update mask.,) updateMask)field patch_request update_masks rAddFieldToUpdateMaskr5As>((+ $  *S058M rcH1SknX;a [XS5 g[XS5 g)N> cloudFunctionappEngineVersioncloudRunRevisionr)setattr)r endpoint_nameproto_endpoint_fieldss rClearEndpointValuer=Ks( + HT* HR(rcURn[X15n1SknSnUHn[XGS5(dMUS- nM US:d[XBS5(d/[XB5 [X1U5 X0l[ US-U-U5$/SQnUS:XaUR /SQ5 US :XaUR /S Q5 [ [X55e zNChecks if given endpoint can be removed from Connectivity Test and removes it.> gkePodinstance ipAddress redisClusterr7 redisInstanceforwardingRuler8r9cloudSqlInstancegkeMasterClusterrNr.)rAz ip-addresszgke-master-clusterzgke-podzcloud-sql-instancesource)zcloud-functionzapp-engine-versionzcloud-run-revision destination)zforwarding-rulezredis-instancez redis-clusterconnectivityTestgetattrr=r:r5extendrr# r3rr;testrendpoint_fieldsnon_empty_endpoint_fieldsr2r s rClearSingleEndpointAttrrSY  ' '$ T )( / ex%%1$"'t++x/ D*%)" m+] I   % *9D rcp/SQnUH+upEnURU5(dM[UUU5nM- U$z5Handles clear_source_* and clear_destination_* flags.))clear_source_instancerIrA)clear_source_ip_addressrIrB)clear_source_gke_master_clusterrIrG)clear_source_gke_podrIr@)clear_source_cloud_sql_instancerIrF)clear_source_cloud_functionrIr7)clear_source_app_engine_versionrIr8)clear_source_cloud_run_revisionrIr9)clear_destination_instancerJrA)clear_destination_ip_addressrJrB)$clear_destination_gke_master_clusterrJrG)clear_destination_gke_podrJr@)$clear_destination_cloud_sql_instancerJrF)!clear_destination_forwarding_rulerJrE) clear_destination_redis_instancerJrD)clear_destination_redis_clusterrJrC) IsSpecifiedrSr(argsr3flags_and_endpointsflagrr;s rClearEndpointAttrsrlsI6-@(d= -   m-@ rcURn[X15n1SknSnUHn[XGS5(dMUS- nM US:d[XBS5(d/[XB5 [X1U5 X0l[ US-U-U5$/SQnUS:XaUR /SQ5 US :XaUR /S Q5 [ [X55er?rKrOs rClearSingleEndpointAttrBetarnrTrcp/SQnUH+upEnURU5(dM[UUU5nM- U$rV)rgrnrhs rClearEndpointAttrsBetarpsI6-@(d= 1   m-@ rcSS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)z5Checks if all provided instances are in valid format.source_instancedestination_instancezEprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/zones/[-\w]+/instances/[-\w]+zInvalid value for flag {}: {} Expected instance in the following format: projects/my-project/zones/zone/instances/my-instancerecompilergrMmatchrrr(rir*flagsinstance_patternrkrAs rValidateInstanceNamesr{s %ZZNd $h  # #H - - EEKVF   .rcSS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)z4Checks if all provided networks are in valid format.source_networkdestination_networkz>projects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/global/networks/[-\w]+zxInvalid value for flag {}: {} Expected network in the following format: projects/my-project/global/networks/my-networkrt)r(rir*rynetwork_patternrknetworks rValidateNetworkURIsr/s %JJG/d #g  " "7 + + ??Ev@   .rcSS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)zFChecks if all provided GKE Master Clusters URIs are in correct format.source_gke_master_clusterdestination_gke_master_clusterzPprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/(zones|locations)/[-\w]+/clusters/[-\w]+zInvalid value for flag {}: {} Expected Google Kubernetes Engine master cluster in the following format: projects/my-project/location/location/clusters/my-clusterrt)r(rir*ryrzrkclusters rValidateGKEMasterClustersURIsrGs"& %ZZYd #g  # #G , , IIOJ   .rcSS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)zFChecks if all provided Cloud SQL Instances URIs are in correct format.source_cloud_sql_instancedestination_cloud_sql_instancez8projects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/instances/[-\w]+z~Invalid value for flag {}: {} Expected Cloud SQL instance in the following format: projects/my-project/instances/my-instancertrxs rValidateCloudSQLInstancesURIsr^s"& %ZZAd $h  # #H - - ::@&:P   .rcS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)zBChecks if all provided Cloud Functions URIs are in correct format.source_cloud_functionzIprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/locations/[-\w]+/functions/[-\w]+zInvalid value for flag {}: {} Expected Cloud Function in the following format: projects/my-project/locations/location/functions/my-functionrt)r(rir*ryfunction_patternrkfunctions rValidateCloudFunctionsURIsrss %ZZRd   D ! !t"H  ! !( + +  K 6$ !    .rcS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)zEChecks if all provided App Engine version URIs are in correct format.source_app_engine_versionzCapps/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/services/[-\w]+/versions/[-\w]+zInvalid value for flag {}: {} Expected App Engine version in the following format: apps/my-project/services/my-service/versions/my-versionrt)r(rir*ryversion_patternrkversions rValidateAppEngineVersionsURIsrs" %JJL/d   D ! !d!G   ) )  FFLfG    .rcS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)zFChecks if all provided Cloud Run revisions URIs are in correct format.source_cloud_run_revisionzIprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/locations/[-\w]+/revisions/[-\w]+zInvalid value for flag {}: {} Expected Cloud Run revision in the following format: projects/my-project/locations/location/revisions/my-revisionrt)r(rir*ryrevision_patternrkrevisions rValidateCloudRunRevisionsURIsrs" %ZZRd   D ! !t"H  ! !( + +  K 6$ !    .rcS/n[R"S5nUHGnURU5(dM[X5nUR U5(aM>[ S5e U$)zCChecks if all provided forwarding rules URIs are in correct format.destination_forwarding_rulezVprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/(global|regions/[-\w]+)/forwardingRules/[-\w]+zInvalid value for flag {flag}: {forwarding_rule} Expected forwarding rule in one of the following formats: projects/my-project/global/forwardingRules/my-forwarding-rule projects/my-project/regions/us-central1/forwardingRules/my-forwarding-rulerurvrgrMrwr)r(rir*ryforwarding_rule_patternrkforwarding_rules rValidateForwardingRulesURIsrsw$ %JJ_d   D ! !d)O " ( ( 9 9  [   .rcS/n[R"S5nUHGnURU5(dM[X5nUR U5(aM>[ S5e U$)zAChecks if all provided Redis Instance URIs are in correct format.destination_redis_instancezIprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/locations/[-\w]+/instances/[-\w]+zInvalid value for flag {flag}: {redis_instance} Expected Redis Instance in the following format: projects/my-project/locations/location/instances/my-redis-instance r)r(rir*ryredis_instance_patternrkredis_instances rValidateRedisInstancesURIsrsq ' (%::Rd   D ! !T(N ! ' ' 7 7  U   .rcS/n[R"S5nUHGnURU5(dM[X5nUR U5(aM>[ S5e U$)z@Checks if all provided Redis Cluster URIs are in correct format.destination_redis_clusterzHprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/locations/[-\w]+/clusters/[-\w]+zInvalid value for flag {flag}: {redis_cluster} Expected Redis Cluster in the following format: projects/my-project/locations/location/clusters/my-redis-cluster r)r(rir*ryredis_cluster_patternrk redis_clusters rValidateRedisClustersURIsrsq & '%**Qd   D ! !D'M & &} 5 5  S   .rctURS5(a!URS5(d [S5eU$)zZChecks if destination-gke-master-cluster was specified when destination-fqdn is specified.destination_fqdnrzXdestination-fqdn can only be specified when destination-gke-master-cluster is specified )rgr)r(rir*s r ValidateFqdnrsD ())$2B2B&33  9  .rr(rir*returncSS/n[R"S[R5nUHGnURU5(dM[ X5nUR U5(aM>[ S5e U$)a8Checks if all provided GKE Pod URIs are in correct format. Args: unused_ref: The resource reference. args: The parsed command line arguments. request: The request proto message. Returns: The request proto message. Raises: InvalidInputError: If any provided GKE Pod URI is not in the correct format. source_gke_poddestination_gke_poda projects/ (?:[a-z][a-z0-9-\.:]*[a-z0-9]) # Project ID /(zones|locations)/[-\w]+ # Zone or Region /clusters/[-\w]+ # Cluster Name /k8s/namespaces/[-\w]+ # Namespace /pods/[-\w]+ # Pod Name aInvalid value for flag {flag}: {gke_pod} Expected GKE Pod in one of the following formats: projects/my-project/zones/zone/clusters/my-cluster/k8s/namespaces/my-namespace/pods/my-pod projects/my-project/locations/location/clusters/my-cluster/k8s/namespaces/my-namespace/pods/my-pod)rurvVERBOSErgrMrwr)r(rir*rygke_pod_patternrkgke_pods rValidateGkePodsURIsrs 2 3%JJ  jj /d   D ! !d!G   ) )  s   .r)rrutypingrgooglecloudsdk.corerErrorrrr#r+r.r5r=rSrlrnrpr{rrrrrrrrrrrrrrrs1 *?Z--?%.%.   )4n%P4n%P00.*.0..(( &C&s&S&S&r