,@SrSSKJr SSKJr SSKJr SSKJr SSKrSSKJr SSK J r SS K J r SS K Jr SS K Jr SS K Jr SS K Jr SSKJr SSKJr SSKJr "SS\R05r"SS\5rSr"SS\5rSrSSjrSrSSjr SSjr!Sr"g) zFUtilities for loading and parsing kubeconfig used for Connect Gateway.)absolute_import) annotations)division)unicode_literalsN)Any) kubeconfig)config) exceptions)log) properties)yaml)encoding)files) platformsc\rSrSrSrSrg)Error%z0Class for errors raised by kubeconfig utilities.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__rClib/googlecloudsdk/command_lib/container/fleet/gwkubeconfig_util.pyrr%s8rrc\rSrSrSrSrg)MissingEnvVarError)zDAn exception raised when required environment variables are missing.rNrrrrrr)sLrrgke_gcloud_auth_plugin_cachec\rSrSrSrSSjr\S5r\S5rSr Sr Sr \ S 5r \ S 5r\ SSS jj5r\ S 5r\ S5r\S5rSSSjjrSrg ) Kubeconfig/z1Interface for interacting with a kubeconfig file.c0X lXl0Ul0Ul0UlURSHnX0RUS'M URSHnX@RUS'M URSHnXPRUS'M g)Nclustersnameuserscontexts) _filename_datar&r(r))selfraw_datafilenameclusterusercontexts r__init__Kubeconfig.__init__2sNJDMDJDM::j)'.mmGFO$* 7#!%jjf$::j)'.mmGFO$*rc URS$Ncurrent-contextr+r,s rcurrent_contextKubeconfig.current_context?s ::' ((rcUR$N)r*r8s rr.Kubeconfig.filenameCs >>rc URRUS5 URRUS5 URRUS5 URR S5U:XaSURS'gg)Nr6)r)popr&r(r+get)r,keys rClearKubeconfig.ClearGsfMMc4 MMc4 JJNN3 zz~~'(C/&(djj"#0rc,[URR55URS'[URR55URS'[UR R55URS'[ R"URS5n[R"URSS9n[ R"URU5 SSS5 [RRUR5n[RRU[5n[RR!U5(a[R""US5 gg!,(df  N=f)z^Save kubeconfig to file. Raises: Error: don't have the permission to open kubeconfig file. r&r(r)NT)privater?)listr&valuesr+r(r)r dump file_utils FileWriterr*ospathdirnamejoin&GKE_GCLOUD_AUTH_PLUGIN_CACHE_FILE_NAMEexistsWriteFileAtomically)r,_fprN gke_gcloud_auth_plugin_file_paths r SaveToFileKubeconfig.SaveToFileNs  "$--"6"6"89DJJztzz0023DJJw!$--"6"6"89DJJz $**d#A   t~~t < ii B =ggoodnn-G')ww||7(9$ ww~~677$$%ErJ8 = 2#$)T**)00DOLN N3 > .55e< ==>sA*A B'BBc[R"U5nUR U5 U"X!5$![Ra)n[SRXR55eSnAff=f)Nz&unable to load kubeconfig for {0}: {1})r load_pathrr] inner_errorrc)r`r.rarbs r LoadFromFileKubeconfig.LoadFromFileysh( ^^H %dMM$ t  ::( :AA %%' (((s1A.$A))A.Nc[R"U5nUR U5 U(dUR 5nU"X25$![Ran[SUR35eSnAff=f)zParse a YAML kubeconfig. Args: raw_data: The YAML data to parse path: The path to associate with the data. Defaults to calling `Kubeconfig.DefaultPath()`. Returns: A `Kubeconfig` instance. Raises: Error: The data is not valid YAML. z"unable to parse kubeconfig bytes: N)r loadrrgrc DefaultPath)r`r-rMrarbs r LoadFromBytesKubeconfig.LoadFromBytessoL YYx dMM$  __ d t? ::L 6u7H7H6IJ KKLsAA9A44A9cVURU5$![[4an[R"SR X!55 [ R"[RRU55 U"[5U5nUR5 UsSnA$SnAff=f)zARead in the kubeconfig, and if it doesn't exist create one there.z6unable to load default kubeconfig: {0}; recreating {1}N) rhrIOErrorr debugr]rJMakeDirrLrMrNEmptyKubeconfigrV)r`r.rbrs r LoadOrCreateKubeconfig.LoadOrCreates   h '' 7  iiHOO 23((3j  sB(A:B#B(#B(cHUR[R55$r<)rtr#rl)r`s rDefaultKubeconfig.Defaults   J224 55rc[R"[RS5nU(aAUR [R 5Sn[R RU5$[R"[RS5nU(d[RR5(a[R"[RS5n[R"[RS5nU(a&U(a[R RX#5nU(d%[R"[RS5nU(dC[SR[RR5(aSS 95eSS 95e[R RUS S 5$) z(Return default path for kubeconfig file. KUBECONFIGrHOME HOMEDRIVEHOMEPATH USERPROFILEzVenvironment variable {vars} or KUBECONFIG must be set to store credentials for kubectlz&HOMEDRIVE/HOMEPATH, USERPROFILE, HOME,)varsz.kuber )rGetEncodedValuerLenvironsplitpathseprMabspathrOperatingSystem IsWindowsrOrr])rhome_dir home_drive home_paths rrlKubeconfig.DefaultPathsK))"**lCJ##BJJ/2j WW__Z (('' F;H  11;;==++BJJ Dj**2::zBi  77<< 6 ++BJJ F   $$*F**4466<%+%D EE=C%+%D EE 77<<'8 44rctXpCU(aXCpCURUR=(d UR5 [[URR 55[URR 55-5Ul[[UR R 55[UR R 55-5Ul[[URR 55[URR 55-5Ulg)a&Merge another kubeconfig into self. By default, in case of overlapping keys, the value in self is kept and the value in the other kubeconfig is lost. Args: kubeconfig: a Kubeconfig instance overwrite: whether to overwrite overlapping keys in self with data from the other kubeconfig. N)rYr9dictrGr&itemsr(r))r,r overwriteleftrights rMergeKubeconfig.Merges%E4//H53H3HI U^^ ! ! #$tDMM,?,?,A'BBDDM U[[   !D)9)9);$<<>DJ U^^ ! ! #$tDMM,?,?,A'BBDDMr)r+r*r&r)r()r-zdict[str, Any]r.strr<)r-bytesrMrreturnr#)F)rr#rboolrNone)rrrrrr2propertyr9r.rCrVrY classmethodrcrhrmrtrw staticmethodrlrrrrrr#r#/s9 / ) )  )K6, > >2  66554DDrr#cSU0nUUS.$)z0Generate and return a cluster kubeconfig object.server)r'r/r)r'rr/s rClusterrs" ' rc,[R"UUS9$)acGenerate and return a user kubeconfig object. Args: name: str, nickname for this user entry. auth_provider: str, authentication provider if not using `exec`. `exec` may still be used regardless of this parameter's value. Returns: dict, valid kubeconfig user entry. Raises: Error: if no auth_provider is not provided when `exec` is not used. r' auth_provider)container_kubeconfigUserrs rrrs  " " ! rzPath to sdk installation not found. Please switch to application default credentials using one of $ gcloud config set container/use_application_default_credentials true $ export CLOUDSDK_CONTAINER_USE_APPLICATION_DEFAULT_CREDENTIALS=truecSU0nUS:Xa[RRRR 5(dSn[ R R5(aSn[R"5RnUc)[R"[5 [[5e[R R#X25SSSS.nXAS 'U$) aGenerate and return an auth provider config. Constructs an auth provider config entry readable by kubectl. This tells kubectl to call out to a specific gcloud command and parse the output to retrieve access tokens to authenticate to the kubernetes master. Kubernetes gcp auth provider plugin at https://github.com/kubernetes/kubernetes/tree/master/staging/src/k8s.io/client-go/plugin/pkg/client/auth/gcp Args: name: auth provider name Returns: dict, valid auth provider config entry. Raises: Error: Path to sdk installation not found. Please switch to application default credentials using one of $ gcloud config set container/use_application_default_credentials true $ export CLOUDSDK_CONTAINER_USE_APPLICATION_DEFAULT_CREDENTIALS=true. r'gcpgcloudz gcloud.cmdz"config config-helper --format=jsonz{.credential.access_token}z{.credential.token_expiry})zcmd-pathzcmd-argsz token-keyz expiry-keyr )r VALUES containeruse_app_default_credentialsGetBoolrrrr Paths sdk_bin_pathr rbSDK_BIN_PATH_NOT_FOUNDrrLrMrO)r'providerbin_namercfgs r _AuthProviderrs(d^( em!!==EEGGH  **,,h<<>..L ii&' ( ))GGLL8812 CX /rc,UUS.nU(aX4S'UUS.$)z0Generate and return a context kubeconfig object.)r/r0 namespace)r'r1r)r'r/r0rctxs rContextr8s. #  rcS//SS0/S.$)Nv1r?Config) apiVersionr)r&r6kind preferencesr(rrrrrsrsFs! rr<)r)#r __future__rrrrrLtypingr googlecloudsdk.api_lib.containerrrgooglecloudsdk.corer r core_exceptionsr r r googlecloudsdk.core.utilrrrJrrrrPobjectr#rrrrrrsrrrrs M&"' O&=#*$-8.9O ! !9MM*H&pDpDf&H-`  r