tSrSSKJr SSKJr SSKJr SSKrSSKrSSKJr SSK J r SSK J r SS K J r SS K J r SSKJ r SS KJr SS KJr SSKrSS KJr SSSS.rSrSrSrSrSrSr"SS\ R:5rSrSr Sr!SSSS.r"S+S jr#\4S!jr$S"r%S#r&S$r'S%r(S&r)S,S'jr*"S(S)\RV5r,\,RZ4S*jr.g)-zDConvenience functions and classes for dealing with instances groups.)absolute_import)division)unicode_literalsN)encoding) exceptions)lister)path_simplifier)utils)log) properties)rangez4Lists the named ports for an instance group resourcea Named ports are key:value pairs metadata representing the service name and the port that it's running on. Named ports can be assigned to an instance group, which indicates that the service is available on all instances in the group. This information is used by Application Load Balancers and proxy Network Load Balancers. *{command}* lists the named ports (name and port tuples) for an instance group. z For example, to list named ports for an instance group: $ {command} example-instance-group --zone=us-central1-a The above example lists named ports assigned to an instance group named 'example-instance-group' in the ``us-central1-a'' zone. )brief DESCRIPTIONEXAMPLESic(UR5S:H$)z#Checks if group reference is zonal.compute.instanceGroups) Collection) group_refs ;lib/googlecloudsdk/api_lib/compute/instance_groups_utils.py IsZonalGroupr=s    #; ;;cUVs/sH$o"RU:wdMUR5PM& nn[U5(a)[R"SSSR U5-5egs snf)a6Validate if provided list in zone given as parameter. Args: instances: list of instances resources to be validated zone: a zone all instances must be in order to pass validation Raises: InvalidArgumentException: If any instance is in different zone than given as parameter. instanceszaThe zone of instance must match the instance group zone. Following instances has invalid zone: %sz, N)zoneSelfLinkanycalliope_exceptionsInvalidArgumentExceptionjoin)rrinstinvalid_instancess rValidateInstanceInZoner"Bs{$-C#,4 T0A't}}#,C   6 63 ))% &' ((Cs A,A,c#J# UHn[X!5HnUv M M g7f)zDExtracts items stored in given attribute of instance group response.N)getattr) responses attr_nameresponseitems rUnwrapResponser)Vs#h, j-s!#cUR$)a>UriFunc for listing instance-group related subresources. Function returns field with URI for objects being subresources of instance-groups, with instance fields. Works for list-instances and instance-configs list commands. Args: resource: instance-group subresource with instance field Returns: URI of instance )instance)resources r$UriFuncForListInstanceRelatedObjectsr-]s   rcURnUR5S:XaFURnURS5"UR 5UR UR S9nOEURnURS5"UR 5URUR S9nURUSU4/S9n[[US55$)z)Gets the request to fetch instance group.rGet) instanceGrouprproject)r0regionr1requests namedPorts) apitools_clientrinstanceGroupsGetRequestTypeNamerr1regionInstanceGroupsr2 MakeRequestslistr))rcompute_clientcomputeservicerequestresultss rOutputNamedPortsForGrouprBms  * *'77$$G$$U+nn& ^^!!#G **G$$U+nn&!!#G  ' '7E72K1L ' M' nWl3 44rc\rSrSrSrSrg)FingerprintFetchExceptionzBException thrown when there is a problem with getting fingerprint.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rFrrrDrDsJrrDcURn[U5(aFURnURR UR UR URS9nOEURnURRUR URURS9n/nURUSU4/US9nU(a[R"U[SS9 USR$)z)Gets fingerprint of given instance group.)r1rr0)r1r2r0r/)r4errors_to_collectz'Could not set named ports for resource:) error_messager)r6rr7MESSAGES_MODULEComputeInstanceGroupsGetRequestr1rr0r:%ComputeRegionInstanceGroupsGetRequestr2r;r RaiseExceptionrD fingerprint)r=rr>r?r@errors resourcess r_GetGroupFingerprintrWs  * *')$$G%%EE!! ^^--F/G **G%%KK!!--L/G &))%)** )  !?A 1 ! !!rcURnURn[X5n[U5(aPUR UUS9nUR UR 5UURURS9UR4$URUUS9nURUR 5UURURS9UR4$)aReturns a request to get named ports and service to send request. Args: compute_client: GCE API client, group_ref: reference to instance group (zonal or regional), ports: list of named ports to set Returns: request, message to send in order to set named ports on instance group, service, service where request should be sent - regionInstanceGroups for regional groups - instanceGroups for zonal groups )rTr5)r0"instanceGroupsSetNamedPortsRequestrr1)r0(regionInstanceGroupsSetNamedPortsRequestr2r1)r6messagesrWr"InstanceGroupsSetNamedPortsRequest)ComputeInstanceGroupsSetNamedPortsRequestr9rr1r7(RegionInstanceGroupsSetNamedPortsRequest/ComputeRegionInstanceGroupsSetNamedPortsRequestr2r:)r=rportsr>r[rT request_bodys rGetSetNamedPortsRequestForGrouprbs  * *'  $ $( %^?+)>>?L  = =nn&+7 ^^!! > #%,$:$:  ;; DDEL  C Cnn&1=!! D #%,$@$@  AArc B/nUHnURS5S:wa[R"US5eURS5upEUR 5(d[R"US5eUR UR U[U5S95 M U$)zValidates named ports flags.:z+Named ports should follow NAME:PORT format.)nameport)countrrsplitisdigitappend NamedPortint)r[ named_portsr` named_porthostrgs rValidateAndParseNamedPortsArgsrqs %j!  8 8 C EE!!#&JD <<>>  8 8 C EE LL##CI#>?  ,rz2Sets the list of named ports for an instance groupa Named ports are key:value pairs metadata representing the service name and the port that it's running on. Named ports can be assigned to an instance group, which indicates that the service is available on all instances in the group. This information is used by Application Load Balancers and proxy Network Load Balancers. *{command}* sets the list of named ports for all instances in an instance group. Note: Running this command will clear all existing named ports. a2 For example, to apply the named ports to an entire instance group: $ {command} example-instance-group --named-ports=example-service:1111 --zone=us-central1-a The above example will assign a name 'example-service' for port 1111 to the instance group called 'example-instance-group' in the ``us-central1-a'' zone. The command removes any named ports that are already set for this instance group. To clear named ports from instance group provide empty named ports list as parameter: $ {command} example-instance-group --named-ports="" --zone=us-central1-a c`[R"SSS/5n/nUVs/sHn[R"U5PM n nUR 5S:XaWU HOn UR U UR URS.SS9n URU"U U R5S95 MQ U$UR 5S :XGaAURRn U RS 5"UR5URUR S 9n 0nURU S U 4/S 9Hn U R(dXU(d"[!S R#U R$S95eUc/nURSR#U R$S95 MlU RU[R"U R5'M U H8n X;aURU"U XS95 M"URU"U SS95 M: U$[!SR#UR 555es snf)aCreates reference to instances in instance group (zonal or regional). Args: resources: Resources parser for the client. compute_client: Client for the current release track. igm_ref: URL to the target IGM. instance_names_or_urls: names or full URLs of target instances. skip_instances_on_validation_error: If true, skip instances that are not yet allocated to any zone. This can happen when the instance is being created in a regional IGM by a resize-request and is still in a queue. warnings: A list to collect warnings for skipped instances if skip_instances_on_validation_error is true. Returns: A dict where instance names are keys, and corresponding references are values. Unresolved names are present in dict with value None. InstanceNameWithReference instance_nameinstance_referencecompute.instanceGroupManagers)r1rzcompute.instancesparams collection)rtru#compute.regionInstanceGroupManagersListManagedInstances)instanceGroupManagerr2r1r3zPCannot perform action on instance {name} as it is not yet allocated to any zone.)rfNzTSkipped performing action on instance {name} as it is not yet allocated to any zone.Unknown reference type {0}) collections namedtupler r9rParser1rrkrr6regionInstanceGroupManagersr8r2r;r+ ValueErrorformatrf)rVr=igm_refinstance_names_or_urls"skip_instances_on_validation_errorwarnings_InstanceNameWithReferenceinstance_references name_or_urlnames_to_resolvert instance_refr?r@resolved_referencess rCreateInstanceReferencesrsi2 +55!O5I#J L0/+;'/ <<) __  ll ) %*l  $)!-!6!6!8 :;* DD,,HHG$$%;<$\\^~~!G&332G<=4?  " "1,,2F#((-3-   H //,,2F#((-3- $0$9$9/..   !")?,*  -"" &+#6#E G H "" &+ F G*  1889K9K9MN OOws H+c/n[X5R=(d /n[U5n[SXR5H@n[R "U5n[Xq5nXFXb-UlUR U5 MB U$)aSplit request into parts according to max_length limit. Example: requests = SplitInstancesInRequest( self.messages. ComputeInstanceGroupManagersAbandonInstancesRequest( instanceGroupManager=igm_ref.Name(), instanceGroupManagersAbandonInstancesRequest=( self.messages.InstanceGroupManagersAbandonInstancesRequest( instances=instances, ) ), project=igm_ref.project, zone=igm_ref.zone, ), 'instanceGroupManagersAbandonInstancesRequest') Then: return client.MakeRequests(LiftRequestsList(service, method, requests)) Args: request: _messages.Message, request to split request_field: str, name of property inside request holding instances field max_length: int, max_length of instances property Returns: List of requests with instances field length limited by max_length. r)r$rlenr rCopyProtoMessagerk) r@ request_field max_lengthresult all_instancesni request_partfields rSplitInstancesInRequestrUst< &'1;;Ar- -! A "a,,W5L L 0E#al3EO MM, # -rc#*# UH nXU4v M g7f)z(a, b, [c]) -> [(a, b, c)].NrF)r?methodr4r@s rGenerateRequestTuplesr~sg G $$scR/nUH@upVn/nURXVU4/U5 URXx45 URU5 MB /n UHVupxU(aSn OSn [Xr5RH,n U RU [ R "U 5U S.5 M. MX U $)aMake *-instances requests with feedback per instance. Args: client: Compute client. requests: [(service, method, request)]. instances_holder_field: name of field inside request holding list of instances. errors_to_collect: A list for capturing errors. If any response contains an error, it is added to this list. Returns: A list of request statuses per instance. Requests status is a dictionary object, see SendInstancesRequestsAndPostProcessOutputs for details. FAILSUCCESSselfLink instanceNamestatus)r;rkextendr$rr r9) clientr4instances_holder_fieldrNrequest_resultsr?rr@rUstatus_per_instanceinstance_statusr+s r#MakeRequestsAndGetStatusPerInstancers&/"*gw F '734f=G,-V$ #+(og o!oG<FF  )..x8#" G ) rc[5nUR=(d /HnURURR:waUR UR 5 MDSnSnUR=(d /HCnURS:Xa URnURS:XdURS:XdMASnME U(aU(aUR X$'MUR UR 5 M U$)aExtract from operation instances skipped due to graceful validation. Args: operation: Operation containing warnings. warnings_to_collect: A list to collect warnings unrelated to graceful validation. Returns: Dict from resource path of a skipped instance to validation error. NFr+validation_errorvalidation_outcomeT) dictrcodeCodeValueValuesEnumNOT_CRITICAL_ERRORrkmessagedatakeyvalue) operationwarnings_to_collectskipped_instanceswarningskipped_instance_pathis_graceful_validation_warningwarning_metadatas r.ExtractSkippedInstancesAndCollectOtherWarningsrsf##)r)g||w22EEE  1 %*"$LL.B.    + 0 6 6   #5 5   #7 7)-& / &*?18.  1)** rc /nUHPupgn/n URXgU4/U SSSS9n U =(d S/un URXU 45 URU 5 MR /n UGHupn U (aG[X5RH,n U RU [ R "U 5SS.5 M. MUU R(a8[RRSRU R55 [X5n[X5RHSn XRS5S -SnSnX;aS nXnOS nU RU [ R "U 5UUS .5 MU GM U $) aMake *-instances requests with feedback per instance. Specialized version of MakeRequestsAndGetStatusPerInstance. Checks operations for warnings presence to evaluate statuses per instance. Gracefully validated requests may produce warnings on operations, indicating instances skipped. It would be merged with MakeRequestsAndGetStatusPerInstance after we see there's no issues with this implementation. Args: client: Compute client. requests: [(service, method, request)]. instances_holder_field: name of field inside request holding list of instances. warnings_to_collect: A list for capturing warnings. If any completed operation will contain skipped instances, function will append warning suggesting how to find additional details on the operation, warnings unrelated to graceful validation will be collected as is. errors_to_collect: A list for capturing errors. If any response contains an error, it is added to this list. Returns: See MakeRequestsAndGetStatusPerInstance. FT) log_warnings no_followupalways_return_operationNrrzUpdated [{0}]. z /projects/reSKIPPEDr)rrrvalidationError)r;rkrr$rr r9 targetLinkr rwriterrfind)rr4rrrNrr?rr@rU operationsrrr+r instance_pathrrs r0MakeRequestsAndGetStatusPerInstanceFromOperationrs:/"*gw F$$w&@%A%+2715=A %CJ &KYG78V$#+$3 g& g>HH("" +00:$  I    +2293G3GHIH *g>HH(!|!?@&I  " "6 ** )rc ## URnUR5S:XaURRn OSUR5S:XaURRn O([ SR UR555e/n /n [URUUUUU 5n U V s/sH"n U R(dMU RPM$ nn U[UU5l [X#5n[XU5n/nU(aUR[UUX;U 55 OUR[!UUUU 55 U V s/sH"n U R(aMU R"PM$ nn URUVs/sH n[%USS9PM sn5 UHnUv M U (a+[&R("[*R,"SU 55 U (a[*R."U 5egs sn fs sn fs snf7f)a8Make *-instances requests and format output. Method resolves instance references, splits them to make batch of requests, adds to results statuses for unresolved instances, and yields all statuses raising errors, if any, in the end. Args: api_holder: Compute API holder. method_name: Name of the (region) instance groups managers service method to call. request_template: Partially filled *-instances request (no instances). instances_holder_field: Name of the field inside request holding instances field. igm_ref: URL to the target IGM. instances: A list of names of the instances to apply method to. per_instance_status_enabled: Enable functionality parsing resulting operation for graceful validation related warnings to allow per-instance status output. The plan is to gradually enable this for all per-instance commands in GA (even where graceful validation is not available / not used). skip_instances_on_validation_error: If true, skip instances that are not yet allocated to any zone. This can happen when the instance is being created in a regional IGM by a resize-request and is still in a queue. Yields: A list of request statuses per instance. Requests status is a dictionary object with link to an instance keyed with 'selfLink', instance name keyed with 'instanceName', and status indicating if operation succeeded for instance keyed with 'status'. Status might be 'FAIL', 'SUCCESS', 'SKIPPED' in case of graceful validation, or 'MEMBER_NOT_FOUND' (in case of regional MIGs, when instance name cannot be resolved). rvrzr}MEMBER_NOT_FOUND)rrz!Some requests generated warnings:N)rrr6rrrrrrVrur$rrrrrrrtrr rr ConstructListr)rrrrrrper_instance_status_enabledrrr?rNrinstances_with_referencesr+rr4request_tuplesrequest_status_per_instanceunresolved_instance_namesrfrs r*SendInstancesRequestsAndPostProcessOutputsrLs R   & <<$$::GDD$$@@G 1889K9K9MN OO6  ( 0/(  $ $"h!!/ /B  ""+ $%5 N((xH. " &&8 N$:    &&+FN,B,= ?@0/(  ( (h/ $$+&+$ %78+& ,f L,KK ?/ 12  " "#4 55O, &s8B-H /G<G<A2H  H#H3H HA3H c$\rSrSrSrSrSrSrSrg)InstanceGroupFilteringModeiz?Filtering mode for Instance Groups based on dynamic properties.rerFN) rGrHrIrJrK ALL_GROUPSONLY_MANAGED_GROUPSONLY_UNMANAGED_GROUPSrLrFrrrrsG*rrc VURnURn/n[U5n[UVs/sHnSU;dM USPM sn5n0nUHn UR U S[ R RRR0SS9n U RU;a[5XR'XRRU R5 M /n [R"U5H`upU R[R "UR"R$U U SUR"R&UR(US95 Mb /n[+UR"S5(Ga [UVs/sHnSU;dM USPM sn5n0nUHbnUR US S 9nURU;a[5UUR'UURRUR,5 Md [R"U5Haun nUR[R."UR"R0U USUR"R&UR(US 95 Mc [U 5[U5-n[UVs/sH#n[2R4"UR65PM% sn5nU(a[8R:"U5 /nUHnUS nUR=S S5n[2R4"U5nUU;nU(aU[>R@:XaMRU(dU[>RB:XaMoU(aSOSUS'U(aUUS'UREU5 M U$s snfs snfs snf)a-Add information if instance group is managed. Args: compute_holder: ComputeApiHolder, The compute API holder items: list of instance group messages, filter_mode: InstanceGroupFilteringMode, managed/unmanaged filtering options Returns: list of instance groups with computed dynamic properties rr1z compute.zonesrwN)r?r1requested_zones filter_exprhttp batch_urlrUr:r2zcompute.regions)ry)r?r1requested_regionsrrrrUrz/instanceGroups/z/instanceGroupManagers/YesNo isManagedinstanceGroupManagerUri)#rrVr<setrr VALUEScorer1 GetOrFailaddrsix iteritemsrrGetZonalResourcesr6rrrhasattrr2GetRegionalResourcesrr ScopedSuffixrr rreplacerrrrk)compute_holderitems filter_moderrVrUig zone_linksproject_to_zonesrzone_refzonal_instance_group_managersr1zones regional_instance_group_managers region_linksproject_to_regionsr2 region_refregionsinstance_group_managersigminstance_group_managers_refsrAr( self_link igm_self_link scoped_suffix is_manageds r%ComputeInstanceGroupManagerMembershiprsn  &&&) & u+%?2&B,JBvJ?@*d z((--55?? # $H //+.5''(%%&**8==9#% &67ng!(()A)A&&<<  # # ( (""*8&(" V # #%;<<uGuB 8 uGHL??66G?Hj   #5 514:--.++,001B1BC   MM*<=&--f.I.I((DD#%%**$$/> () -./"%(&*(#""3<<0(&*"+  V$ 'dZ I%%57M#00?M">>J1GGG 3GG G",$D(5d $% NN4#& .W@8H(&*s N N N! N!**N&)FN)FF)/rK __future__rrrr~enumapitools.base.pyrgooglecloudsdk.api_lib.computerrr r googlecloudsdk.calliopergooglecloudsdk.corer r r six.movesr +INSTANCE_GROUP_GET_NAMED_PORT_DETAILED_HELPINSTANCES_MAX_LENGTHrr"r)r-rBErrorrDrWrbrqSET_NAMED_PORTS_HELPrrrrrrrrEnumrrrrFrrrsK&' %51:0E#* D /+.< ((  5&K 0 0K":&AR  B L(-  XPz(<&R%)X"JNb" X!&',d6N(B'L'L[r