*PSrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKJ r SSK J r SS K J r SS K Jr SS KJr SS KJr SSKrS r"SS\5rSr"SS\5r"SS\5rSr"SS\ R45rSrSrSrSrSSS.r \!"S/5r"\RFRI5\RFRJ:wa \ S ==S!- ss'S2S"jr&S#r'S$r(S%r)S2S&jr*S'r+"S(S)\5r,"S*S+\5r-S,r.S3S-jr/S3S.jr0S3S/jr1"S0S1\5r2g)4zCLibrary for generating the files for local development environment.)absolute_import)division)print_function)unicode_literalsN)run_subprocess) exceptions) properties) console_io) platforms)timeszgcloud-local-devc.\rSrSrSrSr\S5rSrg) _KubeCluster#zA kubernetes cluster. Attributes: context_name: Kubernetes context name. env_vars: Docker env vars. shared_docker: Whether the kubernetes cluster shares a docker instance with the developer's machine. cXlX lg)zInitializes KubeCluster with cluster name. Args: context_name: Kubernetes context. shared_docker: Whether the kubernetes cluster shares a docker instance with the developer's machine. N context_name shared_docker)selfrrs 1lib/googlecloudsdk/command_lib/code/kubernetes.py__init___KubeCluster.__init__-s%&c0$Nrs renv_vars_KubeCluster.env_vars8s IrrN) __name__ __module__ __qualname____firstlineno____doc__rpropertyr__static_attributes__rrrrr#s  '  rrcj[R"[R"[ 5S/55$)z(Returns the current version of minikube.version)six ensure_text subprocess check_output _FindMinikuberrrGetMinikubeVersionr-=s# 00-/91MN OOrc(\rSrSrSr\S5rSrg)MinikubeClusterBzA cluster on minikube. Attributes: context_name: Kubernetes context name. env_vars: Docker environment variables. shared_docker: Whether the kubernetes cluster shares a docker instance with the developer's machine. c,[UR5$r)_GetMinikubeDockerEnvsrrs rrMinikubeCluster.env_varsLs !$"3"3 44rrN)rr r!r"r#r$rr%rrrr/r/Bs 5 5rr/c4\rSrSrSrSSjrSrSrSrg) MinikubeQz$Starts and stops a minikube cluster.Nc4XlX lX0lX@lgr) _cluster_name _stop_cluster _vm_driver_debug)r cluster_name stop_cluster vm_driverdebugs rrMinikube.__init__Ts &%OKrc[URURUR5 [ URURS:H5$)Ndocker)_StartMinikubeClusterr8r:r;r/rs r __enter__Minikube.__enter__^s8$,,doot{{K 4--t(/J KKrchUR(a![URUR5 ggr)r9 _StopMinikuber8r;rexc_type exc_valuetbs r__exit__Minikube.__exit__bs$ D&& 4r)r8r;r9r:)TNF rr r!r"r#rrDrLr%rrrr5r5Qs ,! L5rr5c[RRRR 5=(d [ R "S5$)Nminikube)r VALUEScodeminikube_path_overrideGetrGetGcloudPreferredExecutablerrrr,r,gs:    7 7 ; ; = B  5 5j ACrc\rSrSrSrSrg)MinikubeStartErrorlz!Error if minikube fails to start.rN)rr r!r"r#r%rrrrWrWls)rrWzio.k8s.sigs.minikube.stepz&io.k8s.sigs.minikube.download.progresszio.k8s.sigs.minikube.errorzThe minimum allowed is 2 CPUs.z4Not enough CPUs. Cloud Run Emulator requires 2 CPUs.zCannot reach docker daemon.)2969HOST_HOME_PERMISSIONrYz Increase Docker VM CPUs to 2.c [U5(Gd [5SSUSSSSS/ nU(a+URSU-5 US :XaURS 5 U(aURS S /5 S U-n[R "[ RRRRSS95Rn[R"U5n[R"X5US9H!nU(a [!SU5 [#Xg5 M# SSS5 gg!,(df  g=f![$a<n[&R("[*U[,R."5S5 SnAgSnAff=f)zStarts a minikube cluster.start-pz--keep-contextz--interactive=falsez--delete-on-failurez--install-addons=falsez --output=jsonz --vm-driver=rBz--container-runtime=dockerz--alsologtostderrz-v8z)Starting development environment '%s' ...T)required)event_timeout_sec show_stderrrPN)_IsMinikubeClusterUpr,appendextendr ParseDurationr rQrRminikube_event_timeoutrT total_secondsr ProgressBarrStreamOutputJsonprint_HandleMinikubeStatusEvent Exceptionr(reraiserWsysexc_info) r<r>r?cmd start_msg event_timeout progress_barjson_objes rrCrCsI":  - - /       "  c  >I-.  **1 2  '/0= Li))    7 7 ; ; < +m  ! !) , &77 eEH  *h ' $\ < E - ,3 .2 - , :KK"As||~a'899:s6CD2;D!D2! D/+D2/D22 E8<2E33E8cUS[:XaoUSnURSS5S:waSURSS5S:wa<[US5n[US5nU[U5- nUR U5 g g g US[ :Xa}USnURSS5S:waaURSS5S:waJSU;aC[US5n[US5n[US5nX6-U- nUR U5 g g g g US[ :Xa\SUS;aRUSnSU;a!S U;aUS[;a[US 5eUSn[RUS 5n[U5eg g ) zHandle a minikube json event.typedata currentstep totalstepsprogressexitcodeidadvicez#Unable to start Cloud Run Emulator.N) _MINIKUBE_STEPgetintfloat SetProgress_MINIKUBE_DOWNLOAD_PROGRESS_MINIKUBE_ERROR _MINIKUBE_PASSTHROUGH_ADVICE_IDSrW_MINIKUBE_ERROR_MESSAGES) rtrury current_step total_stepscompletion_fractiondownload_progress exit_codemsgs rrlrls f' F D xx r"b(TXXlB-G2-Mm,-l\*+k(5+==23 .N( 66 F D #r) r"b(Z4-?m,-l\*+kZ 01)=L23 .@( * O+ hv>N0N F D  T) T 66 tH~ ..z"i $ ( ()N Pc s ##1O+rcn[5SSUS/n[R"USS9n[SU55$)z8Get the docker environment settings for a given cluster.z docker-envr^z --shell=none) timeout_secc3# UH7o(dM URS5(aM#URSS5v M9 g7f)#=N) startswithsplit).0lines r )_GetMinikubeDockerEnvs..s5Q%*Td4??3;OdjjaUs AAA)r,rGetOutputLinesdict)r<rqliness rr2r2sD ,lNK#  ' ' <% Q%*Q QQrc[5SSUSS/n[R"USSS9nSU;=(a USR5S :H$![[ R 4a gf=f) z(Checks if a minikube cluster is running.statusr^-ojsonrFrraHostRunning)r,r GetOutputJsonstrip ValueErrorr*CalledProcessError)r<rqrs rrcrcsq (D,fE#  ) ) 0F V  Cv 4 4 6) CC j33 4 s7A A'&A'c~[5SSU/n[SU-5 [R"USUS9 [S5 g)zStop a minikube cluster.stopr^z)Stopping development environment '%s' ...r show_output Development environment stopped.Nr,rkrRun)r<r?rqs rrGrGs; &$ 5#3lBCScu=*+rc~[5SSU/n[SU-5 [R"USSS9 [S5 g) zDelete a minikube cluster.deleter^z)Deleting development environment '%s' ...rFrrNr)r<rqs rDeleteMinikubers; (D,7#3lBCScu=*+rc,^\rSrSrSrU4SjrSrU=r$)ExternalClusterzA external kubernetes cluster. Attributes: context_name: Kubernetes context name. env_vars: Docker environment variables. shared_docker: Whether the kubernetes cluster shares a docker instance with the developer's machine. c.>[[U] US5 g)z[Initializes ExternalCluster with profile name. Args: cluster_name: Name of the cluster. FN)superrr)rr< __class__s rrExternalCluster.__init__ s  /4),>rr)rr r!r"r#rr% __classcell__)rs@rrrs??rrc*\rSrSrSrSrSrSrSrg)ExternalClusterContextiz1Do nothing context manager for external clusters.cXlgr _kube_context)r kube_contexts rrExternalClusterContext.__init__s%rc,[UR5$r)rrrs rrD ExternalClusterContext.__enter__s 4-- ..rcgrrrHs rrLExternalClusterContext.__exit__srrNrNrrrrrs9&/ rrc.[R"S5$)Nkubectl)rrUrrr _FindKubectlr s  4 4Y ??rc~[5/nU(aUSU/- nU/SQ- n[R"USSS9nSU-U;$)N --context)r namespacesrnamerFrz namespace/)rrr) namespacerrqrs r_NamespaceExistsr$sP #K &&C ,,#,, ru.*  !Z //rcr[5/nU(aUSU/- nUSSU/- n[R"USSS9 g)NrcreaterrFrrrrrrrqs r_CreateNamespacer.A #K &&C(K ++#Sbez5Context to create and tear down kubernetes namespace.Nc*XlX lSUlg)zsInitialize KubeNamespace. Args: namespace: (str) Namespace name. context_name: (str) Kubernetes context name. FN) _namespace _context_name_delete_namespace)rrrs rrKubeNamespace.__init__As O%"Drc[URUR5(d([URUR5 SUlgg)NT)rrrrrrs rrDKubeNamespace.__enter__Ls; DOOT-?-? @ @t(:(:;#d ArchUR(a![URUR5 ggr)rrrrrHs rrLKubeNamespace.__exit__Qs$ t(:(:;r)rrrrrNrrrrr>s= #$ rsBJ&%' :**2.* )64P 5l 55v5,C *))*-F.$D! A ' $-.D-E#F  $$&)*C*C*I*II4 $DD %:P,$^Q,,?l?&  V  @0==