OSrSSKJr SSKJr SSKJr SSKJr SSKrSSKJr SSK J r SS K J r SS K Jr SS KJr SS KJr SS KJr SS KJr SSKJr SSKr\R2"S5rSrSrSrSrS SjrS!Sjr S"Sjr!S"Sjr"Sr#S"Sjr$S"Sjr%S"Sjr&S!Sjr'S#Sjr(Sr)Sr*g)$z3Util functions using GKEHub API for fleet commands.)absolute_import)division)print_function)unicode_literalsN) list_pager)gkehub_api_util)apis)waiter)base) exceptions)log) resourcesz'projects/.+/locations/.+/memberships/.+c\[R"S5n[R"SU5$)Ncompute) core_apisResolveVersionGetClientInstance) api_versions :lib/googlecloudsdk/command_lib/container/fleet/api_util.py_ComputeClientr&s%((3+  $ $Y <<c0[R"SS5$)Nstoragev1)rrrr_StorageClientr+s  $ $Y 55rc8SR[X5U5$)aNGet the resource name of a membership. Args: project: the project in which to create the membership location: the GCP region of the membership. membership_id: the ID of the membership. Returns: the full resource name of the membership in the format of `projects/{project}/locations/{location}/memberships/{membership_id}` z{}/memberships/{})format ParentRef)projectlocation membership_ids r MembershipRefr#/s  # #Ig$@- PPrc$SRX5$)aGet the resource name of the parent collection of a membership. Args: project: the project of the parent collection. location: the GCP region of the membership. Returns: the resource name of the parent collection in the format of `projects/{project}/locations/{location}`. zprojects/{}/locations/{})r)r r!s rrr?s $ * *7 ==rc  [R"U5n U RnURXUS9nU (alUR U S9UR lU (a+U RS5UR R lO-SUR R lOSUR lU (GaURU S9nURUS9nURUS9nUR R(aUR RR(aUR RRR(a/XR RRRlOSUUR RRlO-UUR Rl OUUR l U(aXOR lUS:Xa0UR"R$R&UR lO5US :Xa/UR"R$R*UR lU(dU(dU(Ga?0nU(d[UR,(aJUR,R.H0n[0R2"UR45UUR6'M2 U(a.[9[0R:"U55H unnUUU'M U(a"UHnUU;dM UR=U5 M UR"R?5n[9[0R:"U55H/unnUR.RAURCUUS 95 M1 UUR lU RDRGU5n[HRJRMS ROU55 U (a:[HRJRMS ROURP55 U$[RRTRWURPS S9n[XRZ"[XR\"U RDU R^5USROURP55$)aUpdateMembership updates membership resource in the GKE Hub API. Args: name: The full resource name of the membership to update, e.g. projects/foo/locations/global/memberships/name. membership: Membership resource that needs to be updated. update_mask: Field names of membership resource to be updated. release_track: The release_track used in the gcloud command. external_id: the unique id associated with the cluster, or None if it is not available. infra_type: The infrastructure type that the cluster is running on clear_labels: Whether labels should be cleared update_labels: Labels to be updated, remove_labels: Labels to be removed, issuer_url: The discovery URL for the cluster's service account token issuer. oidc_jwks: The JSON Web Key Set string containing public keys for validating service account tokens. Set to None if the issuer_url is publicly-reachable. Still requires issuer_url to be set. api_server_version: api_server_version of the cluster async_flag: Whether to return the update operation instead of polling Returns: The updated Membership resource or the update operation if async. Raises: - apitools.base.py.HttpError: if the request returns an HTTP error - exceptions raised by waiter.WaitFor() ) membershipname updateMaskissuerutf-8N k8sVersionresourceOptionskubernetesResourcezon-premz multi-cloud)keyvaluezrequest issued for: [{}]z Check operation [{}] for status.$gkehub.projects.locations.operations collectionz&Waiting for operation [{}] to complete)0rGetApiClientForTrackMESSAGES_MODULE.GkehubProjectsLocationsMembershipsPatchRequest Authorityr& authorityencodeoidcJwksResourceOptionsKubernetesResourceMembershipEndpointendpointr1r/r- externalId Membership!InfrastructureTypeValueValuesEnumON_PREMinfrastructureType MULTI_CLOUDlabelsadditionalPropertiessix text_typer3r2sorted iteritemspop LabelsValueappendAdditionalPropertyprojects_locations_membershipsPatchr statusPrintrr'rREGISTRYParseRelativeNamer WaitForCloudOperationPollerprojects_locations_operations)r'r& update_mask release_track external_id infra_type clear_labels update_labels remove_labels issuer_url oidc_jwksapi_server_version async_flagclientmessagesrequestresource_optionskubernetes_resourcerA mem_labelsitemkvrHop op_resources rUpdateMembershiprqNsV  / / >&  # #(  C C; D @'#+#5#5Z#5#HG .7.>.>w.Gg""+/3g""+#'G //;M/N"55(6***.+0H""    $ $ 7 7    & & 9 9 I IVh   % % 8 8 H H SK['   % % 8 8 H9L##6$,g!$/!9,4,?,?,a,a,i,iG)]",4,?,?,a,a,m,mG)]mJ J--##88$"}}TZZ8 4889}56$!Q 1 7! ? ..  , , .Fs}}Z011 !!((  # # # 352!'G ,,227;"**-44T:;JJ7>>rwwGH I""44gg@5B+  !!&"G"G"("F"FH;BB277K MMrc l[R"U5n U Rn [X5n U R U R 5U US9n U(a-U R U RUS9S9n XRl ODU(a=U RUS9nU RUS9nU R US9n XRl U(aXLRl U(aOU RUS9U RlU(a*URS5U RRlU R"R%U 5n[&R(R+UR,S S 9n[.R0"[.R2"U R"U R45US 5$) a(Creates a Membership resource in the GKE Hub API. Args: project: the project in which to create the membership membership_id: the value to use for the membership_id location: the location for the membership gke_cluster_self_link: the selfLink for the cluster if it is a GKE cluster, or None if it is not external_id: the unique id associated with the cluster, or None if it is not available. release_track: the release_track used in the gcloud command, or None if it is not available. issuer_url: the discovery URL for the cluster's service account token issuer. Set to None to skip enabling Workload Identity. oidc_jwks: the JSON Web Key Set containing public keys for validating service account tokens. Set to None if the issuer_url is publicly-routable. Still requires issuer_url to be set. api_server_version: api server version of the cluster for CRD Returns: the created Membership resource. Raises: - apitools.base.py.HttpError: if the request returns an HTTP error - exceptions raised by waiter.WaitFor() )r&parent membershipId) resourceLink) gkeClusterr,r.r0r)r+r4r5z$Waiting for membership to be created)rr7r8r/GkehubProjectsLocationsMembershipsCreateRequestrCr@ GkeClusterr&rAr>r?rBr:r;r<r=rRCreaterrVrWr'r rXrYrZ)r r"r!gke_cluster_self_linkr]r\rbrcrdrfrg parent_refrhrArirjrorps rCreateMembershipr|sF  / / >&  # #(+*  D D$$&   E ' **&&4I&J+LH"*!11=O1P$77*8,,,0-2h$,!$/!#+#5#5Z#5#HG .7.>.>w.Gg""+ ,,33G<"""44gg@5B+  !!&"G"G"("F"FH9 ;;rc[RU5c [U5e[R"U5nUR R URRUS95$)aGets a Membership resource from the GKE Hub API. Args: name: the full resource name of the membership to get, e.g., projects/foo/locations/global/memberships/name. release_track: the release_track used in the gcloud command, or None if it is not available. Returns: a Membership resource Raises: apitools.base.py.HttpError: if the request returns an HTTP error exceptions.Error: if the membership name is missing the ID or improperly formatted r') _MEMBERSHIP_REmatchInvalidMembershipFormatErrorrr7rRGetr8,GkehubProjectsLocationsMembershipsGetRequest)r'r\rfs r GetMembershipr sf$$' &t ,,  / / >&  . . 2 2 IIJ rc@[R"U5nUHnU(dM SRU5nURR UR R US95nURH#n[UR5nX:XdMUs s $ M g)aeRetrieves the project that the cluster UUID has a Membership with. Args: uuid: the UUID of the cluster. projects: sequence of project IDs to consider. release_track: the release_track used in the gcloud command, or None if it is not available. Returns: a project ID. Raises: apitools.base.py.HttpError: if any request returns an HTTP error zprojects/{}/locations/globalrsN) rr7rrRListr8-GkehubProjectsLocationsMembershipsListRequestr_ClusterUUIDForMembershipNamer') uuidprojectsr\rfr rsmembership_responser&membership_uuids rProjectForClusterUUIDr%s  / / >&gw-44W=f"AAFF  N N O ,55*7 H  ".6  rcj[RU5n[U5S:wa [U5eUS$)a8Extracts the cluster UUID from the Membership resource name. Args: membership_name: the full resource name of a membership, e.g., projects/foo/locations/global/memberships/name. Returns: the name in the membership resource, a cluster UUID. Raises: exceptions.Error: if the membership was malformed. r)rfindalllenr)membership_namematchess rrrBs5  " "? 3'\Q & 77 rcP[R"U5nURRURR US95n[ RRURSS9n[R"[R"UR5US5 g)aSDeletes a membership from the GKE Hub. Args: name: the full resource name of the membership to delete, e.g., projects/foo/locations/global/memberships/name. release_track: the release_track used in the gcloud command, or None if it is not available. Raises: apitools.base.py.HttpError: if the request returns an HTTP error r~r4r5z$Waiting for membership to be deletedN)rr7rRDeleter8/GkehubProjectsLocationsMembershipsDeleteRequestrrVrWr'r rXCloudOperationPollerNoResourcesrZ)r'r\rfrorps rDeleteMembershiprWs  / / >& ,,33 LLM"""44gg@5B+.. ,,  . .01<,.rc[RRn[R"U5nUR R URRUUUS95$)aValidate the exclusivity state of the cluster. Args: cr_manifest: the YAML manifest of the Membership CR fetched from the cluster. parent_ref: the parent collection that the cluster is to be registered to. intended_membership: the ID of the membership to be created. release_track: the release_track used in the gcloud command, or None if it is not available. Returns: the ValidateExclusivityResponse from API. Raises: apitools.base.py.HttpError: if the request returns an HTTP error. )rs crManifestintendedMembership) calliope_base ReleaseTrackALPHArr7rRValidateExclusivityr8&  . . B B CC 0D2 33rc[RRn[R"U5nUR R URRX US95$)aGenerate the CR(D) manifests to apply to the registered cluster. Args: crd_manifest: the YAML manifest of the Membership CRD fetched from the cluster. cr_manifest: the YAML manifest of the Membership CR fetched from the cluster. membership_ref: the full resource name of the membership. release_track: the release_track used in the gcloud command, or None if it is not available. Returns: the GenerateExclusivityManifestResponse from API. Raises: apitools.base.py.HttpError: if the request returns an HTTP error. )r' crdManifestr) rrrrr7rRGenerateExclusivityManifestr8DGkehubProjectsLocationsMembershipsGenerateExclusivityManifestRequest) crd_manifestrmembership_refr\rfs rrrs^, ,,22-  / / >&  . . J J KK L" ##rcv[R"U5nURn U RUS9n U(aUR S5U lU(aX*lU(aX:lU(aUR S5U lU(aXZl U(aXjl URRU 5$)aGenerated the Connect Agent to apply to the registered cluster. Args: membership_ref: the full resource name of the membership. image_pull_secret_content: The image pull secret content to use for private registries or None if it is not available. is_upgrade: Is this is an upgrade operation, or None if it is not available. namespace: The namespace of the Connect Agent, or None if it is not available. proxy: The proxy address or None if it is not available. registry: The registry to pull the Connect Agent image if not using gcr.io/gkeconnect, or None if it is not available. version: The version of the Connect Agent to install/upgrade, or None if it is not available. release_track: the release_track used in the gcloud command, or None if it is not available. Returns: the GenerateConnectManifest from API. Raises: apitools.base.py.HttpError: if the request returns an HTTP error. r~r+ascii) rr7r8@GkehubProjectsLocationsMembershipsGenerateConnectManifestRequestr<imagePullSecretContent isUpgrade namespaceproxyregistryversionrRGenerateConnectManifest) rimage_pull_secret_content is_upgraderrrrr\rfrgrhs rGenerateConnectAgentManifestrs@  / / >&  # #(  U U  V '%>%E%Eg%NG""! LL)GM  O  . . F Fw OOrc^[R"SS5nURR[R R SS9S9n[5mU4Sjn[R"URUSSUS 9nU(a9UVs/sH+n[UR5(aMURPM- nnOUVs/sHoURPM nnU[T54$s snfs snf) aHLists full Membership names in the fleet for the current project. Args: filter_cluster_missing: whether to filter out memberships that are missing a cluster. Returns: A list of full membership resource names in the fleet in the form 'projects/*/locations/*/memberships/*'. A list of locations which were unreachable. gkehubv1beta-)r!rcP>TRUR5 [X5$N)update unreachablegetattr)message attributers r _GetFieldFunc*ListMembershipsFull.._GetFieldFuncs"w**+ 7 &&rrN)fieldbatch_size_attributeget_field_func)rrr8rhub_base HubCommandLocationResourceNamesetr YieldFromListrR_ClusterMissingrAr'list)filter_cluster_missingrfreqrresultm membershipsrs @rListMembershipsFullrs  & &x :&LL  5 5s 5 C M #+'  # # ++ "  &1oajj&AK$**6a666K* d;' '' +s C',C'C,cfSH+n[X5(dM[[X5SS5s $ g)N)rvmultiCloudCluster onPremClusterclusterMissingF)hasattrr)rts rrr s* ?aq}} WQ]$4e << @rcL[R"SRU55$)zReturns error for invalid membership resource names. Args: name: The membership resource name. Returns: An exceptions.Error for malformed membership names. zsFailed to get membership: {} does not match format projects/PROJECT_ID/locations/LOCATION/memberships/MEMBERSHIP_ID)r Errorrr~s rrrs&   Jt  r) NNFNNNNNF)NNNNNNNr)F)+__doc__ __future__rrrrreapitools.base.pyr&googlecloudsdk.api_lib.container.fleetrgooglecloudsdk.api_lib.utilr rr googlecloudsdk.callioper r*googlecloudsdk.command_lib.container.fleetrgooglecloudsdk.corer r rrJcompilerrrr#rrqr|rrrrrrrrrrrrrrs:&%' 'B9.9G*#) EF= 6 Q >&"& $"'#'#' $#(, %qMl#+/!%#' $#(,F;R4:*.8'+3D/3#@<@,0+/'+*.)-/31Pn#(L= r