Q2SrSSKJr SSKJr SSKJr SSKJr SSKJr SSK Jr SSK J r SSK J r SS K Jr SS KJr SS KJr SS KJr "S S\R&5r"SS\5rSrSrSrSrSSjrSSjrSrSrSrSrg)z5Command util functions for gcloud container commands.)absolute_import)division)unicode_literals) api_adapter) exceptions)log) properties) console_io) iso_duration)text)timesc\rSrSrSrSrg)Error z.Class for errors raised by container commands.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__rBlib/googlecloudsdk/command_lib/container/container_command_util.pyrr s6rrc\rSrSrSrSrg) NodePoolError$zEError when a node pool name doesn't match a node pool in the cluster.rNrrrrrr$sMrrcURHnURU:XdMUs $ [SRU55e)z@Helper function to get node pool from a cluster, given its name.z*No node pool found matching the name [{}].) nodePoolsnamerformat)clusternode_pool_name node_pools r_NodePoolFromClusterr%(sC$$i~~' % 299.I KKrcU(aSRUR5nOSnU(dU(a URnU(aSRU5nOSnSRXU5$)aReturns the prompt message during a master upgrade. Args: name: str, the name of the cluster being upgraded. server_conf: the server config object. cluster: the cluster object. new_version: str, the name of the new version, if given. Raises: NodePoolError: if the node pool name can't be found in the cluster. Returns: str, a message about which nodes in the cluster will be upgraded and to which version. version [{}]its current versionthe default cluster versionz6Master of cluster [{}] will be upgraded from {} to {}.)r!currentMasterVersiondefaultClusterVersion)r server_confr" new_versionversion_messagenew_version_messages r_MasterUpgradeMessager02se  $++G,H,HIO+O 33K(// <7 B I I 0 23rc*U(aSRUR5nOSnU(dU(a URnU(aSRU5nOSn[R"[ R "US95nSRXXg5$)a^Returns the prompt message during a rollback safe upgrade. Args: name: str, the name of the cluster being upgraded. server_conf: the server config object. cluster: the cluster object. new_version: str, the name of the new version, if given. control_plane_soak_duration: int, the soak duration in seconds for the control plane upgrade. r'r(r))secondszControl plane of cluster [{}] will be upgraded from {} to {} with a soak duration of {}. You can rollback the cluster to previous version within the soak duration.)r!r*r+r FormatDurationForJsonr Duration)r r,r"r-control_plane_soak_durationr.r/ soak_durations r_RollbackSafeUpgradeMessager7Ss $++G,H,HIO+O 33K(// <7--$?@-##)6 !4$rc^^SmSnU(a/SRTU5mU(a[X5RnOOU(aHSRTUR[R "URS55mUR nU(aSRU5n OSn U(dU(a URnU(aSRU5n OSn UU4S jn U(a]Sn U(a'U(a [UU5RRn U (aS RTTX5$S RTTU5$/n U(aHSnU(a'U(a [UU5RRnU RU "S X55 U(aHSnU(a'U(a [UU5RRnU RU "S X55 U(aISnU(a'U(a [UU5RRnU RU "SUU55 U (dSRTTX5$SRU 5$)aReturns the prompt message during a node upgrade. Args: name: str, the name of the cluster being upgraded. cluster: the cluster object. node_pool_name: str, the name of the node pool if the upgrade is for a specific node pool. new_version: str, the name of the new version, if given. new_image_type: str, the name of the new image type, if given. new_machine_type: str, the name of the new machine type, if given. new_disk_type: str, the name of the new disk type, if given. new_disk_size: int, the size of the new disk, if given. Raises: NodePoolError: if the node pool name can't be found in the cluster. Returns: str, a message about which nodes in the cluster will be upgraded and to which version, image, or config, if applicable. z All nodesNz{} in node pool [{}]z {} ({} {})noder'r(zthe master versionc`>U(aSRU5OSnSRTTXU5$)Nzfrom {}z+{} of cluster [{}] {} will change {} to {}.)r!)fieldcurrentnew from_currentr node_messages r_UpgradeMessage,_NodeUpgradeMessage.._UpgradeMessages3079##G,RL 8 ? ?dE 66rz3{} of cluster [{}] image will change from {} to {}.z+{} of cluster [{}] image will change to {}. machine_type disk_type disk_sizez2{} of cluster [{}] will be upgraded from {} to {}.r;)r!r%versioncurrentNodeCountr PluralizecurrentNodeVersionr*config imageType machineTypeappenddiskType diskSizeGbjoin)r r"r#r-new_image_typenew_machine_type new_disk_type new_disk_sizecurrent_versionr.r/rA image_typenode_upgrade_messagesrCrDrEr@s` @r_NodeUpgradeMessagerXys#.,/)00~NL,WEMMo&&g.. w//8:L00O$++O'(688>yyCJJ j:;<BB n./L>)'*8::@&   GII>&w'577=vhh   Y>@I>&w'577=vjj   Y >@  ? F FdO BB & ''rNc U(a"U(a[XX&U5n O[XX&5n O[UUUUUUU U 5n SRU 5$)aGet a message to print during gcloud container clusters upgrade. Args: name: str, the name of the cluster being upgraded. server_conf: the server config object. cluster: the cluster object. master: bool, if the upgrade applies to the master version. control_plane_soak_duration: int, the soak duration for the control plane upgrade. node_pool_name: str, the name of the node pool if the upgrade is for a specific node pool. new_version: str, the name of the new version, if given. new_image_type: str, the name of the new node image type, if given. new_machine_type: str, the name of the new machine type, if given. new_disk_type: str, the name of the new boot disk type, if given. new_disk_size: int, the size of the new boot disk in GB, if given. Raises: NodePoolError: if the node pool name can't be found in the cluster. Returns: str, a message about which nodes in the cluster will be upgraded and to which version. z{} This operation is long-running and will block other operations on the cluster (except other node pool upgrades) until it has run to completion.)r7r0rXr!) r r,r"masterr5r#r-rQrRrSrTupgrade_messages rClusterUpgradeMessager\sfF "3 W3No. Wo*  OVO,rc [USS5n[USS5n[USS5nU(aSnGO U(aj[RRRR 5(a3[RRRR 5nO[RRR R 5(a3[RRR R 5nO2[RRRR 5nU=(d U=(d U=(d UnU(aU(d[R"/SQ5eU$)aGet a location (zone or region) from argument or property. Args: args: an argparse namespace. All the arguments that were provided to this command invocation. ignore_property: bool, if true, will get location only from argument. required: bool, if true, lack of zone will cause raise an exception. is_autopilot: bool, if true, region property will take precedence over zone. Raises: MinimumArgumentException: if location if required and not provided. Returns: str, a location selected by user. locationNzoneregion)z --locationz--zonez--region) getattrr VALUEScomputer`Getr_calliope_exceptionsMinimumArgumentException)argsignore_propertyrequired is_autopilotr^r_r`location_propertys rGetZoneOrRegionrls$T:t ,( vt $$ 44 (& ))1188<<>>"))1188<<>  %%))++"))1166::<"))1188<<>  < <4 <+<( h  6 6,  /rcURS5(a UR$[USS5(agUR$)z$Gets the value of node auto-upgrade.enable_autoupgradeenable_kubernetes_alphaFN) IsSpecifiedrnrargs rGetAutoUpgraderrBs? *++  " "" T,e44   rcURS5(a UR$[USS5(ag[USS5(agUR=(d SR 5S;$) z#Gets the value of node auto-repair.enable_autorepairrelease_channelNTroFr;)r;coscos_containerdgciubuntuubuntu_containerd)rprtrarVlowerrqs r GetAutoRepairr|Lsn )**  ! !! T$d++  T,e44  // R & & (- rc[USS5nUcgUR5S:Xa [RR S5 gg)zChecks if the release_channel argument is 'extended' and prints a message. Args: args: An object (e.g., from argparse) containing command-line arguments. ruNextendedzNote: For GKE Standard edition, pay-per-use costs apply when your cluster is enrolled in the Extended release channel and your cluster's minor version enters the extended support period.)rar{rstatusPrint)rgrus rCheckReleaseChannelr]sJD"3T:/  *JJ G +rc d [R"SB0SUR_SUR_SUR_SUR _SUR _SUR_SUR_SUR_S UR_S UR_S UR_S UR_S UR_SU_SUR_SUR _SUR"_SUR$_SUR&_SUR(_SUR*_SUR,_SUR._SUR0_SUR2_SUR4_SUR6_SUR8_S[;USS5_S[;USS5_S [;US S5_S![;US!S5_S"[;US"S5_S#[;US#S5_S$[;US$S5_S%[;US%S5_S&[;US&S5_S'[;US'S5_S(UR<_S)UR>_S*UR@_S+URB_S,URD_S-URF_S.URH_S/[;US/S5_S0URJ_S1URL_S2URN_S3URP_S4[;US4S5_S5[;US5S5_S6[;US7S5_S8[;US8S5_6nUR(aW[RRUR;a9UR[RRnU(a[TRV"S9S:S;9 UR(aW[RXUR;a9UR[RXnU(a[TRV"SS:S;9 UR(aW[R^UR;a9UR[R^nU(a[TRV"S?S:S;9 UR(aW[R`UR;a9UR[R`nU(a[TRV"S@S:S;9 UR(aW[RbUR;a9UR[Rbn U (a[TRV"SAS:S;9 U$)Ca6Helper function to build ClusterUpdateOptions object from args. Args: args: an argparse namespace. All the arguments that were provided to this command invocation. locations: list of strings. Zones in which cluster has nodes. Returns: ClusterUpdateOptions, object with data used to update cluster. monitoring_servicelogging_service monitoringloggingenable_stackdriver_kubernetesdisable_addonsenable_autoscaling min_nodes max_nodestotal_min_nodestotal_max_nodeslocation_policyr$ locations!enable_master_authorized_networksmaster_authorized_networksprivate_ipv6_google_access_type workload_pooldisable_workload_identitydatabase_encryption_keydisable_database_encryptionenable_vertical_pod_autoscalingenable_autoprovisioningenable_mesh_certificatesautoprovisioning_config_file autoprovisioning_service_accountautoprovisioning_scopesautoprovisioning_locations"autoprovisioning_max_surge_upgradeN(autoprovisioning_max_unavailable_upgrade%enable_autoprovisioning_surge_upgrade*enable_autoprovisioning_blue_green_upgrade(autoprovisioning_standard_rollout_policy(autoprovisioning_node_pool_soak_duration"enable_autoprovisioning_autorepair#enable_autoprovisioning_autoupgrade!autoprovisioning_min_cpu_platformautoprovisioning_image_typemin_cpumax_cpu min_memory max_memorymin_acceleratormax_acceleratorlogging_variantin_transit_encryption&autoprovisioning_resource_manager_tags!service_account_verification_keysservice_account_signing_keys!control_plane_disk_encryption_keyboot_disk_provisioned_iops boot_disk_provisioned_throughputenable_pod_snapshotspod_snapshots_enabledenable_slice_controllerzIf the GCE Persistent Disk CSI Driver is disabled, then any pods currently using PersistentVolumes owned by the driver will fail to terminate. Any new pods that try to use those PersistentVolumes will also fail to start.T)message cancel_on_nozIf the GCP Filestore CSI Driver is disabled, then any pods currently using PersistentVolumes owned by the driver will fail to terminate. Any new pods that try to use those PersistentVolumes will also fail to start.zIf the Cloud Storage Fuse CSI Driver is disabled, then any pods currently using PersistentVolumes owned by the driver will fail to terminate. Any new pods that try to use those PersistentVolumes will also fail to start.zIf the StatefulHA Addon is disabled, then any applications currently protected will no longer be updated for high availability configuration.zIf the Parallelstore CSI Driver is disabled, then any pods currently using PersistentVolumes owned by the driver will fail to terminate. Any new pods that try to use those PersistentVolumes will also fail to start.zIf the High Scale Checkpointing is disabled, then any pods currently using Volumes owned by the driver will fail to terminate. Any new pods that try to use those Volumes will also fail to start.zIf the Lustre CSI Driver is disabled, then any pods currently using PersistentVolumes owned by the driver will fail to terminate. Any new pods that try to use those PersistentVolumes will also fail to start.r)2rUpdateClusterOptionsrrrrrrrrrrrrr$rrrrrrrrrrrrrrrarrrrrrrrrrrGCEPDCSIDRIVERr PromptContinueGCPFILESTORECSIDRIVERGCSFUSECSIDRIVER STATEFULHAPARALLELSTORECSIDRIVERHIGHSCALECHECKPOINTINGLUSTRECSIDRIVER) rgroptspdcsi_disabledfilestorecsi_disabledgcsfusecsi_disabledstatefulha_disabledparallelstorecsi_disabledhighscalecheckpointing_disabledlustrecsi_disableds rParseUpdateOptionsBaserqsq  ) )S 00S **S S ll S  %)$F$F S  (( S 00S S S **S **S **S S S )-(N(NS  "&!@!@!S "'+&J&J#S $&&%S &!% > >'S (#::)S *#'"B"B+S ,'+&J&J-S .#::/S 0 $<<1S 2$(#D#D3S 4(,'L'L5S 6#::7S 8"&!@!@9S :*1 4d*;S @07 :D0AS F-4 7-GS L29 +>> //))+7  ""d&9&99--$$&7   3 33--    ((D,?,?? $ 3 3**!, 7  ((D,?,??&*&9&9**',#&-  !!T%8%88,,##%7  +r) NNFNNNNNNN)FTF)r __future__rrr googlecloudsdk.api_lib.containerrgooglecloudsdk.callioperregooglecloudsdk.corerr googlecloudsdk.core.consoler googlecloudsdk.core.utilr r r rrr%r0r7rXr\rlrrr|rrrrrrs<&'8E*#*21)*7J  7NENK3B#L](B'+"&!&6:)-&*)-+/(,(,<@>C'T!" (qr