dZddlmZddlmZddlmZddlZddlmZddlm Z ddlm Z dd l m Z dd l m Z dd l mZdd lmZdd lmZddlmZGddeZGddeZGddeZGddZy)z"Version-agnostic Fleet API client.)absolute_import)division)unicode_literalsN) Generator)encoding) list_pager)gkehub_api_util)types)util)waiter)base) resourcesceZdZdZej j fdZdZdZ dZ dZ ddZ e dejd ej"fd Ze d Ze d Ze d ZdZdZy) HubClientaClient for the GKE Hub API with related helper methods. If not provided, the default client is for the GA (v1) track. This client is a thin wrapper around the base client, and does not handle any exceptions. Fields: release_track: The release track of the command [ALPHA, BETA, GA]. client: The raw GKE Hub API client for the specified release track. messages: The matching messages module for the client. resourceless_waiter: A waiter.CloudOperationPollerNoResources for polling LROs that do not return a resource (like Deletes). feature_waiter: A waiter.CloudOperationPoller for polling Feature LROs. c`||_tj||_tj||_t j|jj|_ tj|jj|jj|_ yN)operation_service)result_servicer) release_trackr GetClientInstanceclientGetMessagesModulemessagesr CloudOperationPollerNoResourcesprojects_locations_operationsresourceless_waiterr HubFeatureOperationPollerprojects_locations_featuresfeature_waiterselfrs 4lib/googlecloudsdk/api_lib/container/fleet/client.py__init__zHubClient.__init__1s}&D((7DK**=9DM%EE++CC D*CC{{>>++CCDc|jj|||}|jjj |S)aCreates a Feature and returns the long-running operation message. Args: parent: The parent in the form /projects/*/locations/*. feature_id: The short ID for this Feature in the Hub API. feature: A Feature message specifying the Feature data to create. Returns: The long running operation reference. Use the feature_waiter and OperationRef to watch the operation and get the final status, typically using waiter.WaitFor to present a user-friendly spinner. )feature featureIdparent)r,GkehubProjectsLocationsFeaturesCreateRequestrrCreate)r!r( feature_idr&reqs r" CreateFeaturezHubClient.CreateFeature=sD -- D D E C ;; 2 2 9 9# >>r$c|jj|d}|jjj |S)zGets a Feature from the Hub API. Args: name: The full resource name in the form /projects/*/locations/*/features/*. Returns: The Feature message. T)namereturnPartialSuccess)r)GkehubProjectsLocationsFeaturesGetRequestrrGetr!r/r,s r" GetFeaturezHubClient.GetFeatureQsA -- A A ! B C ;; 2 2 6 6s ;;r$c|jj|d}|jjj |}|j S)zLists Features from the Hub API. Args: parent: The parent in the form /projects/*/locations/*. Returns: A list of Features. T)r(r0)r*GkehubProjectsLocationsFeaturesListRequestrrListr)r!r(r,resps r" ListFeatureszHubClient.ListFeaturesasJ -- B B! C C ;; 2 2 7 7 >r$c|jj|dj||}|jjj |S)a%Creates a Feature and returns the long-running operation message. Args: name: The full resource name in the form /projects/*/locations/*/features/*. mask: A string list of the field paths to update. feature: A Feature message containing the Feature data to update using the mask. Returns: The long running operation reference. Use the feature_waiter and OperationRef to watch the operation and get the final status, typically using waiter.WaitFor to present a user-friendly spinner. ,)r/ updateMaskr&)r+GkehubProjectsLocationsFeaturesPatchRequestjoinrrPatch)r!r/maskr&r,s r" UpdateFeaturezHubClient.UpdateFeaturersL -- C C 88D> D C ;; 2 2 8 8 ==r$c|jj||}|jjj |S)aDeletes a Feature and returns the long-running operation message. Args: name: The full resource name in the form /projects/*/locations/*/features/*. force: Indicates the Feature should be force deleted. Returns: The long running operation. Use the feature_waiter and OperationRef to watch the operation and get the final status, typically using waiter.WaitFor to present a user-friendly spinner. )r/force)r,GkehubProjectsLocationsFeaturesDeleteRequestrrDelete)r!r/rCr,s r" DeleteFeaturezHubClient.DeleteFeaturesA -- D D  E C ;; 2 2 9 9# >>r$opreturncXtjj|jdS)z6Parses a gkehub Operation reference from an operation.$gkehub.projects.locations.operations collection)rREGISTRYParseRelativeNamer/)rGs r" OperationRefzHubClient.OperationRefs,    / / B 0 r$cn| |jiStjd|jDS)aHelper to convert proto map Values to normal dictionaries. encoding.MessageToPyValue recursively converts values to dicts, while this method leaves the map values as proto objects. Args: proto_map_value: The map field "Value". For example, the `Feature.labels` value (of type `Features.LabelsValue`). Can be None. Returns: An OrderedDict of the map's keys/values, in the original order. c3LK|]}|j|jfywN)keyvalue).0ps r" z%HubClient.ToPyDict..s"#"FQ"Fs"$)additionalProperties collections OrderedDict)proto_map_values r"ToPyDictzHubClient.ToPyDicts@/"F"F"N i  " "#"1"F"F# r$cdtj||iStj|S)aHelper to convert proto map Values to default dictionaries. encoding.MessageToPyValue recursively converts values to dicts, while this method leaves the map values as proto objects. Args: default_factory: Pass-through to collections.defaultdict. proto_map_value: The map field "Value". For example, the `Feature.labels` value (of type `Features.LabelsValue`). Can be None. Returns: An defaultdict of the map's keys/values. )rY defaultdictrr\)default_factoryr[s r"ToPyDefaultDictzHubClient.ToPyDefaultDicts:  " "% +4+=+=o+N r$c2tj||dS)zCencoding.DictToAdditionalPropertyMessage wrapper to match ToPyDict.T) sort_items)rDictToAdditionalPropertyMessage) map_value_clsrTs r" ToProtoMapzHubClient.ToProtoMaps  3 3 } r$cb|j|jjj|S)z?Convenience wrapper for ToProtoMap for Feature.membershipSpecs.)rerFeatureMembershipSpecsValuer!spec_maps r"ToMembershipSpecszHubClient.ToMembershipSpecss# ??4==00EEx PPr$cb|j|jjj|S)z:Convenience wrapper for ToProtoMap for Feature.scopeSpecs.)rerrgScopeSpecsValueris r" ToScopeSpecszHubClient.ToScopeSpecss# ??4==00@@( KKr$N)F)__name__ __module__ __qualname____doc__r ReleaseTrackGAr#r-r4r9rArF staticmethodr OperationrResourcerOr\r`rerkrnr$r"rr"s $(#4#4#7#7 ?(< ">,?&u9+=+= && QLr$rcZeZdZdZej j fdZdZdZ dZ dZ y) HubV2ClientaClient for the GKE Hub V2 API with related helper methods. If not provided, the default client is for the GA (v2) track. This client is a thin wrapper around the base client, and does not handle any exceptions. Fields: release_track: The release track of the command [ALPHA]. client: The raw GKE Hub API client for the specified release track. messages: The matching messages module for the client. resourceless_waiter: A waiter.CloudOperationPollerNoResources for polling LROs that do not return a resource (like Deletes). membership_feature_waiter: A waiter.CloudOperationPoller for polling Membership Feature LROs. c`||_tj||_tj||_t j|jj|_ t j|jj|jj|_ yr) rr GetV2ClientInstancerGetV2MessagesModulerr rrrCloudOperationPoller'projects_locations_memberships_featuresmembership_feature_waiterr s r"r#zHubV2Client.__init__s}&D**=9DK,,];DM%EE++CC D&,%@%@{{JJ++CC&D"r$c|jj|||}|jjj |S)aCCreates a MembershipFeature and returns the long-running operation message. Args: parent: The parent in the form /projects/*/locations/*/memberships/*. feature_id: The short ID for this Feature in the Hub API. membership_feature: A MembershipFeature message specifying the MembershipFeature data to create. Returns: The long running operation reference. Use the membership_feature_waiter and OperationRef to watch the operation and get the final status, typically using waiter.WaitFor to present a user-friendly spinner. )membershipFeaturer'r()r7GkehubProjectsLocationsMembershipsFeaturesCreateRequestrrr*)r!r(r+membership_featurer,s r"CreateMembershipFeaturez#HubV2Client.CreateMembershipFeaturesD -- O O, P C ;; > > E Ec JJr$c|jj|}|jjj |S)zGets a MembershipFeature from the Hub V2 API. Args: name: The full resource name in the form /projects/*/locations/*/memberships/*/features/*. Returns: The MembershipFeature message. r/)r4GkehubProjectsLocationsMembershipsFeaturesGetRequestrrr2r3s r"GetMembershipFeaturez HubV2Client.GetMembershipFeature s> -- L L  M C ;; > > B B3 GGr$c|jj|dj||d}|jjj |S)acUpdates a MembershipFeature and returns the long-running operation message. Args: name: The full resource name in the form /projects/*/locations/*/memberships/*/features/*. mask: A string list of the field paths to update. membership_feature: A MembershipFeature message containing the Feature data to update using the mask. Returns: The long running operation reference. Use the membership_feature_waiter and OperationRef to watch the operation and get the final status, typically using waiter.WaitFor to present a user-friendly spinner. r;T)r/r<r allowMissing)r6GkehubProjectsLocationsMembershipsFeaturesPatchRequestr>rrr?)r!r/r@rr,s r"UpdateMembershipFeaturez#HubV2Client.UpdateMembershipFeaturesO -- N N 88D>, O C ;; > > D DS IIr$c|jj|}|jjj |S)aDeletes a MembershipFeature and returns the long-running operation message. Args: name: The full resource name in the form /projects/*/locations/*/memberships/*/features/*. Returns: The long running operation. Use the membership_feature_waiter and OperationRef to watch the operation and get the final status, typically using waiter.WaitFor to present a user-friendly spinner. r)r7GkehubProjectsLocationsMembershipsFeaturesDeleteRequestrrrEr3s r"DeleteMembershipFeaturez#HubV2Client.DeleteMembershipFeature3s> -- O O  P C ;; > > E Ec JJr$N) rorprqrrr rsrtr#rrrrrxr$r"rzrzs5 $(#4#4#7#7 K* HJ0Kr$rzceZdZdZej j fdZdZde jfdZ de jde jfdZde jde jfdZd Zd Zd Zd Zd ZdZdZ d:dZdZ d;dZdZ d:dZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&d Z'd!Z( d FleetClientazClient for the Fleet API with related helper methods. If not provided, the default client is for the alpha (v1) track. This client is a thin wrapper around the base client, and does not handle any exceptions. Fields: release_track: The release track of the command [ALPHA, BETA, GA]. client: The raw Fleet API client for the specified release track. messages: The matching messages module for the client. resourceless_waiter: A waiter.CloudOperationPollerNoResources for polling LROs that do not return a resource (like Deletes). fleet_waiter: A waiter.CloudOperationPoller for polling fleet LROs. c||_tj||_tj||_t j|jj|_ |tjjk(rEt j|jj|jj|_yyr)rr rrrrr rrrr rsALPHAr~projects_locations_fleets fleet_waiterr s r"r#zFleetClient.__init__Us&D((7DK**=9DM%EE++CC D))/// 55>> KKEEd0r$c|jjtj|}|jj j |S)zGets a fleet resource from the Fleet API. Args: project: the project containing the fleet. Returns: A fleet resource Raises: apitools.base.py.HttpError: if the request returns an HTTP error r)r'GkehubProjectsLocationsFleetsGetRequestr FleetResourceNamerrr2r!projectr,s r"GetFleetzFleetClient.GetFleetcsI -- ? ?  # #G , @ C ;; 0 0 4 4S 99r$r,cL|jjj|S)aTCreates a fleet resource from the Fleet API. Args: req: An HTTP create request to be sent to the API server. Returns: A long-running operation to be polled till completion, or returned directly if user specifies async flag. Raises: apitools.base.py.HttpError: if the request returns an HTTP error )rrr*r!r,s r" CreateFleetzFleetClient.CreateFleetts ;; 0 0 7 7 < -- H H I C ;; 0 0 = =c BBr$c|jj|}|jj||}|jjj |S)aSets the IAM policy for a scope resource. Args: scope_path: Full resource path of the scope. policy: IAM policy to be set for the scope. Returns: An Iam Policy. Raises: apitools.base.py.HttpError: If the request returns an HTTP error )policy)rsetIamPolicyRequest)rSetIamPolicyRequest0GkehubProjectsLocationsScopesSetIamPolicyRequestrr SetIamPolicy)r!rrpolicy_requestr,s r"SetScopeIamPolicyzFleetClient.SetScopeIamPolicys_]]667N -- H H* I C ;; 0 0 = =c BBr$ctj|}|jjd|}t j |j j|ddS)zLists scopes in a project. Args: project: Project containing the scope. Returns: A ListScopesResponse (list of scopes and next page token). Raises: apitools.base.py.HttpError: If the request returns an HTTP error rrscopesNr)r ScopeParentNamer(GkehubProjectsLocationsScopesListRequestrrrrr!rr(r,s r" ListScopeszFleetClient.ListScopess^ ! !' *F -- @ @V A C  # # -- !  r$ctj|}|jjd|}t j |j j|dddS)a8Lists scopes in a project permitted to be viewed by the caller. Args: project: Project containing the scope. Returns: A ListPermittedScopesResponse (list of permitted scopes and next page token). Raises: apitools.base.py.HttpError: If the request returns an HTTP error rr ListPermittedrNmethodrr)r rr1GkehubProjectsLocationsScopesListPermittedRequestrrrrrs r"ListPermittedScopeszFleetClient.ListPermittedScopessa ! !' *F -- I IV J C  # # -- !  r$c|jjd|}tj|jj |dddS)a0Lists memberships bound to a scope. Args: scope_path: Full resource path of the scope for listing bound memberships. Returns: A ListMembershipsResponse (list of memberships and next page token) Raises: apitools.base.py.HttpError: if the request returns an HTTP error r)r scopeNameListMemberships membershipsNr)r3GkehubProjectsLocationsScopesListMembershipsRequestrrrrrs r"ListBoundMembershipsz FleetClient.ListBoundMemberships'sQ -- K K  L C  # # --  !  r$Nc|jj|||}|jj|||}|jjj |}t jj|jd}tjtj|jj|jj|dS)aPUpdates a scope resource in the fleet. Args: scope_path: Full resource path of the scope. labels: Labels for the resource. namespace_labels: Namespace-level labels for the cluster namespace. mask: A mask of the fields to update. Returns: A longrunning operation for updating the namespace. )r/labelsnamespaceLabels)scoper/r<rJrKzWaiting for scope to be updated)rScope)GkehubProjectsLocationsScopesPatchRequestrrr?rrMrNr/r WaitForr~r) r!rrnamespace_labelsr@rr,rG op_resources r" UpdateScopezFleetClient.UpdateScope>s MM   (  E -- A A  B C  . . 4 4S 9B$$66 B7K >>## KK 1 1 KK 5 5  )  r$c|jj|}|jjj |S)zGets a namespace resource from the GKEHub API. Args: namespace_path: Full resource path of the namespace. Returns: A namespace resource. Raises: apitools.base.py.HttpError: If the request returns an HTTP error r)r1GkehubProjectsLocationsScopesNamespacesGetRequestr$projects_locations_scopes_namespacesr2)r!namespace_pathr,s r"GetScopeNamespacezFleetClient.GetScopeNamespacecs> -- I I  J C ;; ; ; ? ? DDr$c|jj|d||}|jj|||}|jjj |}t jj|jd} tjtj|jj|jj| dS)aCreates a namespace resource from the GKEHub API. Args: name: The namespace name. namespace_path: Full resource path of the namespace. parent: Full resource path of the scope containing the namespace. labels: labels for namespace resource. namespace_labels: Namespace-level labels for the cluster namespace. Returns: A namespace resource. Raises: apitools.base.py.HttpError: If the request returns an HTTP error. rr/rrr) namespacescopeNamespaceIdr(rJrK#Waiting for namespace to be created)r Namespace4GkehubProjectsLocationsScopesNamespacesCreateRequestrrr*rrMrNr/r rr~r) r!r/rr(rrrr,rGrs r"CreateScopeNamespacez FleetClient.CreateScopeNamespacets$ '' ( (I -- L Ld6 M C  9 9 @ @ EB$$66 B7K >>## KK < < KK 5 5  -  r$cV|jj|}|jjj |}t j j|jd}tjtj|jj|dS)aDeletes a namespace resource from the fleet. Args: namespace_path: Full resource path of the namespace. Returns: A long running operation for deleting the namespace. Raises: apitools.base.py.HttpError: If the request returns an HTTP error. rrJrK#Waiting for namespace to be deleted) r4GkehubProjectsLocationsScopesNamespacesDeleteRequestrrrErrMrNr/r rrr)r!rr,rGrs r"DeleteScopeNamespacez FleetClient.DeleteScopeNamespaces -- L L  M C  9 9 @ @ EB$$66 B7K >>.. KK 5 5  -  r$c|jj|d||}|jj|||}|jjj |}t jj|jd}tjtj|jj|jj|dS)aiUpdates a namespace resource in the fleet. Args: namespace_path: Full resource path of the namespace. labels: Labels for the resource. namespace_labels: Namespace-level labels for the cluster namespace. mask: A mask of the fields to update. Returns: A longrunning operation for updating the namespace. Raises: rrrr/r<rJrK#Waiting for namespace to be updated)rr3GkehubProjectsLocationsScopesNamespacesPatchRequestrrr?rrMrNr/r rr~r) r!rrrr@rr,rGrs r"UpdateScopeNamespacez FleetClient.UpdateScopeNamespaces" '' ( (I -- K K  L C  9 9 ? ? DB$$66 B7K >>## KK < < KK 5 5  -  r$c|jjd|}tj|jj |ddS)a!Lists namespaces in a project. Args: parent: Full resource path of the scope containing the namespace. Returns: A ListNamespaceResponse (list of namespaces and next page token). Raises: apitools.base.py.HttpError: If the request returns an HTTP error. rrscopeNamespacesNr)r2GkehubProjectsLocationsScopesNamespacesListRequestrrrr)r!r(r,s r"ListScopeNamespaceszFleetClient.ListScopeNamespacessN -- J JV K C  # # 88 !  r$c|jjtj||}|jj j |S)aGets a namespace resource from the GKEHub API. Args: project: the project containing the namespace. name: the namespace name. Returns: A namespace resource Raises: apitools.base.py.HttpError: if the request returns an HTTP error r)r+GkehubProjectsLocationsNamespacesGetRequestr NamespaceResourceNamerprojects_locations_namespacesr2)r!rr/r,s r" GetNamespacezFleetClient.GetNamespacesK -- C C  ' ' 6 D C ;; 4 4 8 8 ==r$c |jjtj|||}|jj ||tj |}|j jj|}tjj|jd}tjtj|j j|j j |dS)aDCreates a namespace resource from the GKEHub API. Args: name: the namespace name. scope: the scope containing the namespace. project: the project containing the namespace. Returns: A namespace resource Raises: apitools.base.py.HttpError: if the request returns an HTTP error r/r)r namespaceIdr(rJrKr)rrr r.GkehubProjectsLocationsNamespacesCreateRequestNamespaceParentNamerrr*rrMrNr/r rr~r)r!r/rrrr,rGrs r"CreateNamespacezFleetClient.CreateNamespaces ''  ' ' 6e(I -- F F''0 G C  2 2 9 9# >B$$66 B7K >>## KK 5 5 KK 5 5  -  r$c~|jjtj||}|jj j |}tjj|jd}tjtj|jj|dS)a Deletes a namespace resource from the fleet. Args: project: the project containing the namespace. name: the name of the namespace. Returns: An operation Raises: apitools.base.py.HttpError: if the request returns an HTTP error rrJrKr)r.GkehubProjectsLocationsNamespacesDeleteRequestr rrrrErrMrNr/r rrr)r!rr/r,rGrs r"DeleteNamespacezFleetClient.DeleteNamespace+s -- F F  ' ' 6 G C  2 2 9 9# >B$$66 B7K >>.. KK 5 5  -  r$c|jjtj|||}|jj |tj|||}|j j j|}tjj|jd}tjtj|j j |j j|dS)aaUpdates a namespace resource in the fleet. Args: name: the namespace name. scope: the scope containing the namespace. project: the project containing the namespace. mask: a mask of the fields to update. Returns: An operation Raises: apitools.base.py.HttpError: if the request returns an HTTP error rrrJrKr)rrr r-GkehubProjectsLocationsNamespacesPatchRequestrrr?rrMrNr/r rr~r) r!r/rrr@rr,rGrs r"UpdateNamespacezFleetClient.UpdateNamespaceGs  ''  ' ' 6e(I -- E E  ' ' 6 F C  2 2 8 8 =B$$66 B7K >>## KK 5 5 KK 5 5  -  r$c|jjdtj|}t j |j j|ddS)a Lists namespaces in a project. Args: project: the project to list namespaces from. Returns: A ListNamespaceResponse (list of namespaces and next page token) Raises: apitools.base.py.HttpError: if the request returns an HTTP error rr namespacesNr)r,GkehubProjectsLocationsNamespacesListRequestr rrrrrrs r"ListNamespaceszFleetClient.ListNamespaceslsY -- D DT55g> E C  # # 11 !  r$c|jj|}|jjj |S)zGets an RBACRoleBinding resource from the GKEHub API. Args: name: the full rolebinding resource name. Returns: An RBACRoleBinding resource Raises: apitools.base.py.HttpError: if the request returns an HTTP error r)r;GkehubProjectsLocationsNamespacesRbacrolebindingsGetRequestr.projects_locations_namespaces_rbacrolebindingsr2r3s r"GetRBACRoleBindingzFleetClient.GetRBACRoleBindings> -- S S  T C ;; E E I I# NNr$c |jj||jj|jjj|j ||}t j j|dd}|jj||j|jj}|jjj|S)aCreates an RBACRoleBinding resource from the GKEHub API. Args: name: the full rbacrolebinding resource name. role: the role. user: the user. group: the group. Returns: An RBACRoleBinding resource Raises: apitools.base.py.HttpError: if the request returns an HTTP error calliope_exceptions.RequiredArgumentException: if a required field is missing predefinedRoler/roleusergroupz5gkehub.projects.locations.namespaces.rbacrolebindingsv1alpha api_versionrBACRoleBindingrbacrolebindingIdr()rRBACRoleBindingRolePredefinedRoleValueValuesEnumupperrrMrN>GkehubProjectsLocationsNamespacesRbacrolebindingsCreateRequestNameParent RelativeNamerrr*r!r/rrr rolebindingrr,s r"CreateRBACRoleBindingz!FleetClient.CreateRBACRoleBindings"--//  ]]  ==--KK   0 K!!33 ?4H -- V V#"--/ --/ W C ;; E E L L  r$c|jj|}|jjj |S)zDeletes an RBACRoleBinding resource from the fleet. Args: name: the resource name of the rolebinding. Returns: An operation Raises: apitools.base.py.HttpError: if the request returns an HTTP error r)r>GkehubProjectsLocationsNamespacesRbacrolebindingsDeleteRequestrrrEr3s r"DeleteRBACRoleBindingz!FleetClient.DeleteRBACRoleBindingsC -- V V  W C ;; E E L L  r$c p|jj||||jj|jjj|j }|jj ||j |}|jjj|S)aHUpdates an RBACRoleBinding resource in the fleet. Args: name: the rolebinding name. user: the user. group: the group. role: the role. mask: a mask of the fields to update. Returns: An operation Raises: apitools.base.py.HttpError: if the request returns an HTTP error r)r/rrrrr/r<) rr!r"r#r$=GkehubProjectsLocationsNamespacesRbacrolebindingsPatchRequestr/rrr?)r!r/rrrr@r*r,s r"UpdateRBACRoleBindingz!FleetClient.UpdateRBACRoleBindings"--//   ]]  ==--KK   0 K -- U U#+*:*:t V C ;; E E K KC PPr$c|jjdtj||}t j |j j|ddS)afLists rolebindings in a namespace. Args: project: the project containing the namespace to list rolebindings from. namespace: the namespace to list rolebindings from. Returns: A ListNamespaceResponse (list of rolebindings and next page token) Raises: apitools.base.py.HttpError: if the request returns an HTTP error rrrbacrolebindingsNr)r -- O O  P C ;; A A E Ec JJr$c4|r|jj|}nM|jj|jjj|j}|jj |||||}t j j|dd} |jj|| j| jj} |jjj| } t j j| jd } t!j"t!j$|jj|jj&| d S) a Creates an ScopeRBACRoleBinding resource from the GKEHub API. Args: name: the full Scoperbacrolebinding resource name. role: the role. custom_role: the custom role. user: the user. group: the group. labels: labels for the RBACRoleBinding resource. Returns: An ScopeRBACRoleBinding resource Raises: apitools.base.py.HttpError: if the request returns an HTTP error calliope_exceptions.RequiredArgumentException: if a required field is missing  customRoler)r/rrrrz1gkehub.projects.locations.scopes.rbacrolebindingsrrrrJrKz)Waiting for rbacrolebinding to be created)rr"r#r$r!rrMrN:GkehubProjectsLocationsScopesRbacrolebindingsCreateRequestr&r'r(rr:r*r/r rr~r) r!r/r custom_rolerrrroledefr*rr,rGrs r"CreateScopeRBACRoleBindingz&FleetClient.CreateScopeRBACRoleBindingsg* ""k":g ""++IIjjl #g --//    0K!!33 ;4H -- R R#"--/ --/ S C  ? ? F Fs KB$$66 B7K >>## KK B B KK 5 5  3  r$cV|jj|}|jjj |}t j j|jd}tjtj|jj|dS)zDeletes an ScopeRBACRoleBinding resource from the fleet. Args: name: the resource name of the rolebinding. Returns: An operation Raises: apitools.base.py.HttpError: if the request returns an HTTP error rrJrKz)Waiting for rbacrolebinding to be deleted) r:GkehubProjectsLocationsScopesRbacrolebindingsDeleteRequestrr:rErrMrNr/r rrrr!r/r,rGrs r"DeleteScopeRBACRoleBindingz&FleetClient.DeleteScopeRBACRoleBindingRs -- R R  S C  ? ? F Fs KB$$66 B7K >>.. KK 5 5  3  r$cd}|r|jj|}|rM|jj|jjj|j}|jj |||||} |jj | | j |} |jjj| } tjj| j d} tjtj|jj|jj | dS) aUpdates an ScopeRBACRoleBinding resource in the fleet. Args: name: the rolebinding name. user: the user. group: the group. role: the predefined role. custom_role: the custom role. labels: labels for the RBACRoleBinding resource. mask: a mask of the fields to update. Returns: An operation Raises: apitools.base.py.HttpError: if the request returns an HTTP error Nr=r)r/rrrrr0rJrKz)Waiting for rbacrolebinding to be updated)rr"r#r$r!9GkehubProjectsLocationsScopesRbacrolebindingsPatchRequestr/rr:r?rrMrNr rr~r) r!r/rrrr@rr@rAr*r,rGrs r"UpdateScopeRBACRoleBindingz&FleetClient.UpdateScopeRBACRoleBindingms:(G ""k":g  ""++IIjjl #g --//    0K OO'k.>.>4 P   ? ? E Ec JB$$66 B7K >>## KK B B KK 5 5  3  r$c|jjdtj||}t j |j j|ddS)aRLists rolebindings in a scope. Args: project: the project containing the scope to list rolebindings from. scope: the scope to list rolebindings from. Returns: A ListscopeResponse (list of rolebindings and next page token) Raises: apitools.base.py.HttpError: if the request returns an HTTP error rrr4Nr)r8GkehubProjectsLocationsScopesRbacrolebindingsListRequestr ScopeRBACRoleBindingParentNamerrrr:)r!rrr,s r"ListScopeRBACRoleBindingsz%FleetClient.ListScopeRBACRoleBindingss_ NN66wF O   # # >>  !  r$c|jj|}|jjj |S)aGets a Membership-Binding resource from the GKEHub API. Args: name: the full membership-binding resource name. Returns: A Membership-Binding resource Raises: apitools.base.py.HttpError: if the request returns an HTTP error r)r4GkehubProjectsLocationsMembershipsBindingsGetRequestr'projects_locations_memberships_bindingsr2r3s r"GetMembershipBindingz FleetClient.GetMembershipBindings> -- L L  M C ;; > > B B3 GGr$cX|jj|||}tjj |dd}|jj ||j |jj}|jjj|}tjj |jd}tjtj|jj|jj |dS) aCreates a Membership-Binding resource from the GKEHub API. Args: name: the full binding resource name. scope: the Scope to be associated with Binding. labels: labels for the membership binding resource Returns: A Membership-Binding resource Raises: apitools.base.py.HttpError: if the request returns an HTTP error calliope_exceptions.RequiredArgumentException: if a required field is missing r/rrz.gkehub.projects.locations.memberships.bindingsrr)membershipBindingmembershipBindingIdr(rJrKz,Waiting for membership binding to be created)rMembershipBindingrrMrN7GkehubProjectsLocationsMembershipsBindingsCreateRequestr&r'r(rrPr*r/r rr~r) r!r/rrbindingrr,rGrs r"CreateMembershipBindingz#FleetClient.CreateMembershipBindings  mm-- v.G!!33 84H -- O O!$MMO --/ P C  < < C CC HB$$66 B7K >>## KK ? ? KK 5 5  6  r$c |jjdtj||||j}t j |jj|ddS)aLists Bindings in a Membership. Args: project: the project containing the Membership to list Bindings from. membership: the Membership to list Bindings from. location: the Membrship location to list Bindings Returns: A ListMembershipBindingResponse (list of bindings and next page token) Raises: apitools.base.py.HttpError: if the request returns an HTTP error rrmembershipBindingsNr) r5GkehubProjectsLocationsMembershipsBindingsListRequestr MembershipBindingParentNamerrrrrP)r!r membershiplocationr,s r"ListMembershipBindingsz"FleetClient.ListMembershipBindingssi -- M M// Z4+=+=  N C  # # ;; "!  r$c|jj|||}|jj||j|}|jj j |}tjj|jd}tjtj|jj |jj|dS)acUpdates a Membership-Binding resource. Args: name: the Binding name. scope: the Scope associated with binding. labels: the labels for the Membership Binding resource. mask: a mask of the fields to update. Returns: An operation Raises: apitools.base.py.HttpError: if the request returns an HTTP error rS)rTr/r<rJrKz,Waiting for membership binding to be updated)rrV6GkehubProjectsLocationsMembershipsBindingsPatchRequestr/rrPr?rrMrNr rr~r) r!r/rrr@rXr,rGrs r"UpdateMembershipBindingz#FleetClient.UpdateMembershipBindings mm-- .G -- N N!  O C  < < B B3 GB$$66 B7K >>## KK ? ? KK 5 5  6  r$cV|jj|}|jjj |}t j j|jd}tjtj|jj|dS)zDeletes a Membership-Binding resource. Args: name: the resource name of the Binding. Returns: An operation Raises: apitools.base.py.HttpError: if the request returns an HTTP error rrJrKz,Waiting for membership binding to be deleted) r7GkehubProjectsLocationsMembershipsBindingsDeleteRequestrrPrErrMrNr/r rrrrEs r"DeleteMembershipBindingz#FleetClient.DeleteMembershipBinding9s -- O O  P C  < < C CC HB$$66 B7K >>.. KK 5 5  6  r$c|jj|}|jjj |S)a"Gets a Membership RBAC RoleBinding resource from the GKEHub API. Args: name: the full Membership RBAC RoleBinding resource name. Returns: A Membership RBAC Role Binding resource. Raises: apitools.base.py.HttpError: if the request returns an HTTP error. r)r -- T T  U C ;; F F J J3 OOr$c |jj||jj|jjj|j ||}t j j|dd}|jj||j|jj}|jjj|S)aCreates a Membership RBAC RoleBinding resource from the GKEHub API. Args: name: the full Membership RBAC Role Binding resource name. role: the role for the RBAC policies. user: the user to apply the RBAC policies for. group: the group to apply the RBAC policies for. Returns: A Membership RBAC Role Binding resource. Raises: apitools.base.py.HttpError: if the request returns an HTTP error. rr6gkehub.projects.locations.memberships.rbacrolebindingsrrr)rr!r"r#r$rrMrN?GkehubProjectsLocationsMembershipsRbacrolebindingsCreateRequestr&r'r(rrir*r)s r"CreateMembershipRbacRoleBindingz+FleetClient.CreateMembershipRbacRoleBindinges--//  ]]  ==--KK   0 K!!33 @4H -- W W#"--/ --/ X C ;; F F M M  r$c|jj|}|jjj |S)aDeletes a Membership RBAC RoleBinding resource. Args: name: the resource name of the Membership RBAC RoleBinding. Returns: A long running operation for the deletion. Raises: apitools.base.py.HttpError: if the request returns an HTTP error. r)r?GkehubProjectsLocationsMembershipsRbacrolebindingsDeleteRequestrrirEr3s r"DeleteMembershipRbacRoleBindingz+FleetClient.DeleteMembershipRbacRoleBindingsC -- W W  X C ;; F F M M  r$c |jj||jj|jjj|j ||}t j j|dd}|jj||j|jj}|jjj|S)aGets YAML containing RBAC policies for a membership RBAC role binding. Args: name: the full Membership RBAC Role Binding resource name. role: the role for the RBAC policies. user: the user to apply the RBAC policies for. group: the group to apply the RBAC policies for. Returns: YAML text containing RBAC policies for a membership RBAC rolebinding. Raises: apitools.base.py.HttpError: if the request returns an HTTP error. rrrlrrr)rr!r"r#r$rrMrN^GkehubProjectsLocationsMembershipsRbacrolebindingsGenerateMembershipRBACRoleBindingYAMLRequestr&r'r(rri%GenerateMembershipRBACRoleBindingYAMLr)s r"%GenerateMembershipRbacRoleBindingYamlz1FleetClient.GenerateMembershipRbacRoleBindingYamls--//  ]]  ==--KK   0 K!!33 @4H -- v v#"--/ --/ w C ;; F F l l  r$cL|jjj|S)aCreates a rollout resource from the Fleet rollout API. Args: req: An HTTP create rollout request to be sent to the API server. Returns: A long-running operation. Raises: apitools.base.py.HttpError: if the request returns an HTTP error )rprojects_locations_rolloutsr*rs r" CreateRolloutzFleetClient.CreateRollouts ;; 2 2 9 9# >>r$cL|jjj|S)zDescribes a fleet rollout.)rrwr2rs r"DescribeRolloutzFleetClient.DescribeRollouts ;; 2 2 6 6s ;;r$c`tj|jj|d||dS)zLists fleet rollouts.rolloutspageSizer batch_sizelimitr)rrrrwr!r, page_sizers r" ListRolloutszFleetClient.ListRolloutss3  # # // '  r$cL|jjj|S)zPause a fleet rollout.)rrwPausers r" PauseRolloutzFleetClient.PauseRollouts ;; 2 2 8 8 ==r$cL|jjj|S)zResume a fleet rollout.)rrwResumers r" ResumeRolloutzFleetClient.ResumeRollout ;; 2 2 9 9# >>r$cL|jjj|S)zDelete a fleet rollout.)rrwrErs r" DeleteRolloutzFleetClient.DeleteRolloutrr$cL|jjj|S)aCreates a rollout sequence resource. Args: req: An HTTP create rollout sequence request to be sent to the API server. Returns: A long-running operation. Raises: apitools.base.py.HttpError: if the request returns an HTTP error )r#projects_locations_rolloutSequencesr*rs r"CreateRolloutSequencez!FleetClient.CreateRolloutSequences ;; : : A A# FFr$cL|jjj|S)zDescribes a rollout sequence.)rrr2rs r"DescribeRolloutSequencez#FleetClient.DescribeRolloutSequences ;; : : > >s CCr$c`tj|jj|d||dS)zLists rollout sequences.rolloutSequencesr}r~)rrrrrs r"ListRolloutSequencesz FleetClient.ListRolloutSequencess3  # # 77  '  r$cL|jjj|S)zIUpdates a RolloutSequence and returns the long-running operation message.)rrr?rs r"UpdateRolloutSequencez!FleetClient.UpdateRolloutSequence$s ;; : : @ @ EEr$cL|jjj|S)zDeletes a rollout sequence.)rrrErs r"DeleteRolloutSequencez!FleetClient.DeleteRolloutSequence*s ;; : : A A# FFr$)NNrNNrR)global)Prorprqrrr rsrtr#rr *GkehubProjectsLocationsFleetsCreateRequestr*GkehubProjectsLocationsFleetsDeleteRequestrvr)GkehubProjectsLocationsFleetsPatchRequestrrrrrrrrrrrrrrrrrr rrr+r.r2r7r;rBrFrIrMrQrYr`rcrfrjrnrqru,GkehubProjectsLocationsRolloutsCreateRequestrx)GkehubProjectsLocationsRolloutsGetRequestRolloutrz*GkehubProjectsLocationsRolloutsListRequestRolloutGeneratorr+GkehubProjectsLocationsRolloutsPauseRequestr,GkehubProjectsLocationsRolloutsResumeRequestr,GkehubProjectsLocationsRolloutsDeleteRequestr4GkehubProjectsLocationsRolloutSequencesCreateRequestr1GkehubProjectsLocationsRolloutSequencesGetRequestRolloutSequencer2GkehubProjectsLocationsRolloutSequencesListRequestRolloutSequenceGeneratorr3GkehubProjectsLocationsRolloutSequencesPatchRequestr4GkehubProjectsLocationsRolloutSequencesDeleteRequestrrxr$r"rrFs~ $(#4#4#7#7 :" =UMM ==AA= ="<@@< <"8 :C"C,.20BD#JE$IM&P8FH'R,>$!F8#J,O"'R&Q@.K$:>9v65n4H"(T6#J6P"%N&%N?CC? <@@< }}<    ; ;    >BB> ?CC? ?CC? GKKG DHHD D    C C  %%  FJJF GKKGr$rceZdZdZdej fdZdejfdZ de jfdZ d de jd ee jddffd Zy) OperationClientz3Client for the GKE Hub API long-running operations.rctj||_tj||_|jj |_y)N)r)r rrrrrservicer s r"r#zOperationClient.__init__4s7**=9DM((}EDK;;<>..t||<077  & & (  r$r,cL|jjj|S)z#Describes a long-running operation.)rrr2rs r"DescribezOperationClient.DescribeOs ;; 4 4 8 8 ==r$NrHc`tj|jj|d||dS)aALists long-running operations. Currently gcloud implements client-side filtering and limiting behavior. Args: req: List request to pass to the server. page_size: Maximum number of resources per page. limit: Client-side limit control. Returns: A list of long-running operations. operationsr}r~)rrrrrs r"r7zOperationClient.ListSs3$  # # 11 '  r$r)rorprqrrr rsr#rrwrr +GkehubProjectsLocationsOperationsGetRequestr,GkehubProjectsLocationsOperationsListRequestrrvr7rxr$r"rr1sp;=D$5$5=  2 2,>%KK>    = = $,- r$r)rr __future__rrrrYtypingrapitools.base.pyrr&googlecloudsdk.api_lib.container.fleetr r r googlecloudsdk.api_lib.utilr googlecloudsdk.callioper googlecloudsdk.corerobjectrrzrrrxr$r"rsn)&'%'B87.()uLuLpiK&iKXhG&hGV';;r$