!'2dZddlmZddlmZddlmZddlmZddlm Z ddl m Z ddl mZdd lmZdd lmZdd lmZddlmZdd lmZdd lmZddlmZddlmZdZdZdZdZdZefdZ dZ!dZ"edfdZ#dZ$dZ%dZ&d$dZ'dZ(d%dZ)d Z*d!Z+d"Z,d#Z-y)&z(Methods and constants for global access.)absolute_import)division)unicode_literals) exceptions) api_adapterclient)util)job)service) worker_pool)apis)log) properties) resourcesv1beta1runv1-appdevexperiencec6tjt|SN)rGetClientInstanceSERVERLESS_API_NAME) api_versions 0lib/googlecloudsdk/api_lib/run/global_methods.pyGetServerlessClientInstancer,s   3[ AAcdtt|Dcgc]}|jc}Scc}w)zGet the list of all available regions from control plane. Args: client: (base_api.BaseApiClient), instance of a client to use for the list request. Returns: A list of str, which are regions. )sorted ListLocations locationId)r ls r ListRegionsr$0s, }V'<='>=s-ctjtjjj j d}|jj|jj|djS)zGet the list of all available regions from control plane. Args: client: (base_api.BaseApiClient), instance of a client to use for the list request. Returns: A list of location resources. Trequiredd)namepageSize) r ProjectPathrVALUEScoreprojectGetprojects_locationsListMESSAGES_MODULERunProjectsLocationsListRequest locations)r project_resource_relnames rr!r!=sx"--$$(($(7  " " ' ' <<'#= I rNc \tjjjj d}t j j|d|id}|jj|j|}|jj|}|jrFtjdj!dj#t%|j|j&Dcgc]"}t)j*||j$c}Scc}w) aGet the global services for a OnePlatform project. Args: client: (base_api.BaseApiClient), instance of a client to use for the list request. region: (str) optional name of location to search for services in. If not passed, this defaults to the global value for all locations. field_selector: (str) optional parameter to pass in request.field_selector. Returns: List of googlecloudsdk.api_lib.run import service.Service objects. Tr& projectsIdzrun.projects.locationsparams collection)parent fieldSelectorTThe following Cloud Run regions did not respond: {}. List results may be incomplete., )rr,r-r.r/rREGISTRYParser2'RunProjectsLocationsServicesListRequest RelativeNameprojects_locations_servicesr1 unreachablerwarningformatjoinr itemsr Service)r regionfield_selectorr.r4requestresponseitems r ListServicesrOQs     " " * * . . . ='  && G $)')  " " J J  # # %^ K ' / / 4 4W =(KK **0& IIfX112 3+ AI @NgoodF223  s?'D)ct|Sr)rOrs r ListWorkersrQxs f rc |jj|j}|jj |}|j rFt jdjdjt|j |jDcgc]"}tj||j$c}Scc}w)aGet the global services for a OnePlatform project. Args: client: (base_api.BaseApiClient), instance of a client to use for the list request. namespace: namespace/project to list jobs in Returns: List of googlecloudsdk.api_lib.run import job.Job objects. r;r=r>)r2RunNamespacesJobsListRequestrBnamespaces_jobsr1rDrrErFrGr rHr Job)r namespacerLrMrNs rListJobsrX|s  " " ? ?  # # % @ ' # # ( ( 1(KK **0& IIfX112 3+ =ENN KND#''$.. /N KK K&'Cc |jj|j}|jj |}|j rFt jdjdjt|j |jDcgc]"}tj||j$c}Scc}w)a/Get the global list of worker pools for a OnePlatform project. Args: client: (base_api.BaseApiClient), instance of a client to use for the list request. project: project to list worker pools in Returns: List of googlecloudsdk.api_lib.run import worker_pool.WorkerPool objects. rSr=r>)r2#RunNamespacesWorkerpoolsListRequestrBnamespaces_workerpoolsr1rDrrErFrGr rHr WorkerPool)r r.rLrMrNs rListWorkerPoolsr^s  " " F F  ! ! # G ' * * / / 8(KK **0& IIfX112 3+ ..  $T6#9#9:   rYcRtjt}|s4tjj j jd}|j||}|jr=tjdjdj|jd}t|j|}t!|}|Dcgc]H}|j"|vs6|j$j&r"|j$j&j(s|Jc}Scc}w)aGet all clusters with Cloud Run enabled. Args: location: str optional name of location to search for clusters in. Leaving this field blank will search in all locations. project: str optional name of project to search for clusters in. Leaving this field blank will use the project defined by the corresponding property. Returns: List of googlecloudsdk.generated_clients.apis.container.CONTAINER_API_VERSION import container_CONTAINER_API_VERSION_messages.Cluster objects Tr&zTThe following cluster locations did not respond: {}. List results may be incomplete.r>c2|j|jfSr)zoner))clusters r_SortKeyzListClusters.._SortKeys LL',, ''r)key)container_api_adapter NewAPIAdapterCONTAINER_API_VERSIONrr,r-r.r/ ListClusters missingZonesrrErFrGr clustersListCloudRunForAnthosClustersr) addonsConfigcloudRunConfigdisabled)locationr. container_apirMrcrjcrfa_cluster_namescs rrhrhs(556KL- $$,,00$0?G  ' ' :( KK **0& IIh++ ,+ (H%%8 4(4W= ! &&& &nn++nn33<<    sA D$ctjtjjj j d}|jj|}|jj|}|jS)zGet all verified domains. Args: client: (base_api.BaseApiClient), instance of a client to use for the list request. Returns: List of client.MESSAGES_MODULE.AuthorizedDomain objects Tr&rS) r r+rr,r-r.r/r2'RunProjectsAuthorizeddomainsListRequestprojects_authorizeddomainsr1domains)r r5rLrMs rListVerifiedDomainsrws}"--$$(($(7  " " J J % K ' . . 3 3G <(   rc|s4tjjjj d}t j j|j||jddS)zReturns a ref for the specified cluster. Args: cluster: container_CONTAINER_API_VERSION_messages.Cluster object project: str optional project which overrides the default Returns: A Resource object Tr&) projectIdraz!container.projects.zones.clustersr8) rr,r-r.r/rr?r@r)ra)rbr.s r GetClusterRefrzs` $$,,00$0?G    ! ! ll"GLL 94 " rcBg}|jd|t||S)amReturns a list of clusters accounting for multi-tenant projects. This function can also be used for non-multitenant projects and will operate on the single passed-in project_id. Args: project_id: The id of the project, which may or may not be multi-tenant cluster_location: The zone or region of the cluster Returns: A list of cluster refs r)insert_ClustersForProjectIds) project_idcluster_location project_idss rMultiTenantClustersForProjectrs'+ Q #  -= >>rctg}|D]0}t||}|D]}|jt||2|Sr)rhappendrz)rrrMr~rjrbs rr}r} sB (j,j9HoomGZ89  /rc d|dt} tjj|}t |}|jDcgc] \}}|dk(s |c}}S#tj $rgcYSwxYwcc}}w)aGet all clusters with Cloud Run for Anthos enabled. Args: project: str optional of project to search for clusters in. Leaving this field blank will use the project defined by the corresponding property. Returns: List of Cluster string names z projects/z/locations/global/features/OK)CLOUDRUN_FEATURE hub_client HubClient GetFeatureapi_exceptions HttpError_ListAnthosClusterStatesrH)r. crfa_specfcluster_state_objr)states rrkrk)s))))4A/q1"3"9"9"; M";;4u}$"; MM  ! ! I Ns#A% BB%A=<A=c, tjj|jj Dcic]9\}}t j ||jjj;}}}|Scc}}w#t$ricYSwxYwr) rrToPyDictmembershipStatesrHhub_utilMembershipShortnamercoder)AttributeError)rmsrs rrrAs((11!2D2DEKKMMDAq $$Q'):)::M    Is":B>A?:B?B BB)NNr).__doc__ __future__rrrapitools.base.pyrr googlecloudsdk.api_lib.containerrre&googlecloudsdk.api_lib.container.fleetr rr rgooglecloudsdk.api_lib.runr r r %googlecloudsdk.api_lib.runtime_configgooglecloudsdk.api_lib.utilrgooglecloudsdk.corerrrrgrSERVERLESS_API_VERSION _ALL_REGIONSrrr$r!rOrQrXr^rhrwrzrr}rkrrrrs/&'9QGC*.26,#*)! %-CB ?(!-T#NL8>-`(&?$N0r