*DdZddlmZddlmZddlmZddlmZddlZddlZddlm Z ddl m Z dd l m Z dd l mZdd lmZdd lmZddlZd ZGddeZdZGddeZGddeZdZGdde j4ZdZdZdZdZdddZ e!dgZ"ejFjIejFjJk7r e d xxd!z cc<d2d"Z&d#Z'd$Z(d%Z)d2d&Z*d'Z+Gd(d)eZ,Gd*d+eZ-d,Z.d3d-Z/d3d.Z0d3d/Z1Gd0d1eZ2y)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&eZdZdZdZedZy) _KubeClusterzA 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. c ||_||_y)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__z_KubeCluster.__init__-s%D&DciSNrs renv_varsz_KubeCluster.env_vars8s IrN)__name__ __module__ __qualname____doc__rpropertyrrrrrr#s  '  rrcftjtjt dgS)z(Returns the current version of minikube.version)six ensure_text subprocess check_output _FindMinikuberrrGetMinikubeVersionr'=s# 00-/91MN OOrc eZdZdZedZy)MinikubeClusterzA 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,t|jSr)_GetMinikubeDockerEnvsrrs rrzMinikubeCluster.env_varsLs !$"3"3 44rN)rrrrrrrrrr)r)Bs 5 5rr)c*eZdZdZ ddZdZdZy)Minikubez$Starts and stops a minikube cluster.Nc<||_||_||_||_yr) _cluster_name _stop_cluster _vm_driver_debug)r cluster_name stop_cluster vm_driverdebugs rrzMinikube.__init__Ts" &D%DDODKrct|j|j|jt |j|jdk(S)Ndocker)_StartMinikubeClusterr/r1r2r)rs r __enter__zMinikube.__enter__^s8$,,doot{{K 4--t(/J KKrc^|jr!t|j|jyyr)r0 _StopMinikuber/r2rexc_type exc_valuetbs r__exit__zMinikube.__exit__bs$ D&& 4r)TNFrrrrrr:rArrrr-r-Qs ,! L5rr-ctjjjj xst j dS)Nminikube)r VALUEScodeminikube_path_overrideGetrGetGcloudPreferredExecutablerrrr&r&gs:    7 7 ; ; = B  5 5j ACrceZdZdZy)MinikubeStartErrorz!Error if minikube fails to start.N)rrrrrrrrKrKls)rrKzio.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_PERMISSIONrLz Increase Docker VM CPUs to 2.c  t|stdd|dddddg }|r*|jd|z|d k(r|jd |r|jd d gd |z}t j t jjjjdj}tj|5}tj|||D]}|r t!d|t#|| dddyy#1swYyxYw#t$$r:}t'j(t*|t-j.dYd}~yd}~wwxYw)zStarts a minikube cluster.start-pz--keep-contextz--interactive=falsez--delete-on-failurez--install-addons=falsez --output=jsonz --vm-driver=r8z--container-runtime=dockerz--alsologtostderrz-v8z)Starting development environment '%s' ...T)required)event_timeout_sec show_stderrrDN)_IsMinikubeClusterUpr&appendextendr ParseDurationr rErFminikube_event_timeoutrH total_secondsr ProgressBarrStreamOutputJsonprint_HandleMinikubeStatusEvent Exceptionr"reraiserKsysexc_info) r3r5r6cmd start_msg event_timeout progress_barjson_objes rr9r9sJ":  - /       "  c  >I-.  **1 2  '/0= Li))    7 7 ; ; < +m  ! !) , &77 =eEH  *h ' $\8 < E - ,3 .2 - , :KK"As||~a'899:s6C D 8DDDDD E%0EEc|dtk(rm|d}|jdddk7rR|jdddk7rN0N F D  T) T 66 tH~ ..z"i $ ( ()N Pc s ##1O+rcrtdd|dg}tj|d}td|DS)z8Get the docker environment settings for a given cluster.z docker-envrQz --shell=none) timeout_secc3jK|]+}|s|jdr|jdd-yw)#=N) startswithsplit).0lines r z)_GetMinikubeDockerEnvs..s-Q%*Td4??3;OdjjaUs 333)r&rGetOutputLinesdict)r3rdliness rr+r+sD ,lNK#  ' ' <% Q%*Q QQrctdd|ddg} tj|dd}d|vxr|djd k(S#tt j f$rYywxYw) z(Checks if a minikube cluster is running.statusrQ-ojsonrFrrTHostRunning)r&r GetOutputJsonstrip ValueErrorr$CalledProcessError)r3rdrs rrVrVsq (D,fE#  ) ) 0F V  Cv 4 4 6) CC j33 4 s3AA"!A"ctdd|g}td|ztj|d|tdy)zStop a minikube cluster.stoprQz)Stopping development environment '%s' ...r show_output Development environment stopped.Nr&r^rRun)r3r6rds rr<r<s; &$ 5#3lBCScu=*+rctdd|g}td|ztj|ddtdy) zDelete a minikube cluster.deleterQz)Deleting development environment '%s' ...rFrrNr)r3rds rDeleteMinikubers; (D,7#3lBCScu=*+rc"eZdZdZfdZxZS)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.tt| |dy)zgInitializes ExternalCluster with profile name. Args: cluster_name: Name of the cluster. FN)superrr)rr3 __class__s rrzExternalCluster.__init__ s  /4),>r)rrrrr __classcell__)rs@rrrs??rrc"eZdZdZdZdZdZy)ExternalClusterContextz1Do nothing context manager for external clusters.c||_yr) _kube_context)r kube_contexts rrzExternalClusterContext.__init__s %Drc,t|jSr)rrrs rr:z ExternalClusterContext.__enter__s 4-- ..rcyrrr=s rrAzExternalClusterContext.__exit__srNrBrrrrrs9&/ rrc,tjdS)Nkubectl)rrIrrr _FindKubectlr s  4 4Y ??rcvtg}|r|d|gz }|gdz }tj|dd}d|z|vS)N --context)ru namespacesrnamerFrz namespace/)rrr) namespacerrdrs r_NamespaceExistsr$sP #K &&C ,,#,, ru.*  !Z //rcltg}|r|d|gz }|dd|gz }tj|ddy)NrcreaterrFrrrrrrrds r_CreateNamespacer.A #K &&C(K ++#Sbes= #$ rsBJ&%' :**2.* )64P 5l 55v5,C *))*-F.$D! A ' $-.D-E#F  $$&)*C*C*I*II4 $DD %:P,$^Q,,?l?&  V  @0==