+SrSSKJr SSKrSSKJr SSKJr SSK J r SSK J r SSK J r SS K Jr SS K Jr SS KJr SS KJr SS KJr "SS\ R*5r"SS\5rSr"SS\5rSrSSjrSrSSjrSSjrSrg)zFUtilities for loading and parsing kubeconfig used for Connect Gateway.) annotationsN)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__/sNJDMDJDM::j)'.mmGFO$* 7#!%jjf$::j)'.mmGFO$*rc URS$Ncurrent-contextr(r)s rcurrent_contextKubeconfig.current_context<s ::' ((rcUR$N)r'r5s rr+Kubeconfig.filename@s >>rc URRUS5 URRUS5 URRUS5 URR S5U:XaSURS'gg)Nr3)r&popr#r%r(get)r)keys rClearKubeconfig.ClearDsfMMc4 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)_fprK gke_gcloud_auth_plugin_file_paths r SaveToFileKubeconfig.SaveToFileKs  "$--"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_pathrrZ inner_errorr`)r]r+r^r_s r LoadFromFileKubeconfig.LoadFromFilevsh( ^^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 loadrrdr` DefaultPath)r]r*rJr^r_s 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) rerIOErrorrdebugrZrGMakeDirrIrJrKEmptyKubeconfigrS)r]r+r_rs r LoadOrCreateKubeconfig.LoadOrCreates   h '' 7  iiHOO 23((3j  sB(A:B#B(#B(cHUR[R55$r9)rqr ri)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)r GetEncodedValuerIenvironsplitpathseprJabspathr OperatingSystem IsWindowsrLrrZ)rhome_dir home_drive home_paths rriKubeconfig.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)rVr6dictrDr#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+strr9)r*bytesrJrreturnr )F)rr rboolrNone)rrrrrr/propertyr6r+r@rSrV classmethodr`rerjrqrt staticmethodrirrrrrr 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_credentialsGetBoolr rrrPaths sdk_bin_pathrr_SDK_BIN_PATH_NOT_FOUNDrrIrJrL)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,r- namespace)r$r.r)r$r,r-rctxs rContextr5s. #  rcS//SS0/S.$)Nv1r<Config) apiVersionr&r#r3kind preferencesr%rrrrrprpCs! rr9)r) r __future__rrItypingr googlecloudsdk.api_lib.containerrrgooglecloudsdk.corerrcore_exceptionsrr r googlecloudsdk.core.utilr r rGr rrrMobjectr rrrrrrprrrrs M" O&=#*$-8.9O ! !9MM*H&pDpDf&H-`  r