PSrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKJ r SSK J r SS K J r SSKr\R rS rS rS rS rSrSrSr\\\\\\4r\S-r\S-r\S-r\S-r\S-r\S-r\S-r\S-r \S-r!\S-r"\S-r#\S-r$\S-r%\S-r&\S-r'\S -r(\S!-r)S"r*S#r+S$r,S%r-\R\"\R^5"S&S'\055r1S(r2S)r3"S*S+\Rh5r5"S,S-\Rl5r7"S.S/\Rp5r9"S0S1\Rt5r;"S2S3\75r<"S4S5\95r=g!\a \rGNf=f)6z8Utilities for wrapping/dealing with a k8s-style objects.)absolute_import)division)print_function)unicode_literalsN)messages) condition) console_attrzserving.knative.devzautoscaling.knative.devzeventing.knative.devzclient.knative.devzcloud.googleapis.comzrun.googleapis.comzrunapps.googleapis.comz/creatorz /locationz /client-namez/client-versionz /descriptionz /launch-stagez/binary-authorizationz /binary-authorization-breakglassz/execution-environmentz/custom-audiencesz/network-interfacesz/container-dependenciesz /acceleratorz/regionsz/multi-region-idz/gclb-domain-namez/threat-detectionc[US5(a UR$[US5(a UR$[S5e)z#Metadta class from messages module. ObjectMeta(K8sIoApimachineryPkgApisMetaV1ObjectMeta4Provided module does not have a known metadata class)hasattrr r ValueErrorms ,lib/googlecloudsdk/api_lib/run/k8s_object.pyMetarTs? Q  <<q<== 5 55IJJc[US5(a UR$[US5(a UR$[S5e)z(List Metadta class from messages module.ListMeta&K8sIoApimachineryPkgApisMetaV1ListMetar )rrrrrs rrr]s? Q  ::q:;; 3 33IJJrc$[U5"U0UD6$)z+Make metadata message from messages module.)r)rargskwargss rMakeMetarfs a$ !& !!rcSnSnUR5Vs0sH%nU"U5(dMURU"U5_M' nnU"S0UD6$s snf)zProduce an instance of msg_cls, with all sub-messages initialized. Args: msg_cls: A message-class to be instantiated. Returns: An instance of the given class, with all fields initialized blank objects. cRUR(a/$[UR5$N)repeatedInitializedInstance message_typefields rInstance%InitializedInstance..Instanceus ~~ i u11 22rc6[U[R5$r) isinstancer MessageFieldr"s r IncludeField)InitializedInstance..IncludeFieldzs eX22 33r) all_fieldsname)msg_clsr$r)r#rs rr r ksa3 4 %%' '% e "ejj(5/!'  4  s AAc\rSrSrSrSr\S4Sj5r\S4Sj5r\S4Sj5r \S4Sj5r \S4S j5r \S5S j5r S4S jr S rS rSr\S5r\S5r\S5r\S5r\S5r\R.S5r\S5r\R.S5r\S5r\S5r\S5r\R.S5r\S5r\S5r\S5r\S5r\S5r \S 5r!\S!5r"\"R.S"5r"\S#5r#S4S$jr$\S%5r%\S&5r&\S'5r'\S(5r(\S)5r)S*r*\S+5r+S,r,S-r-S.r.S/r/S0r0S1r1S2r2S3r3g)6KubernetesObjectaBase class for wrappers around Kubernetes-style Object messages. Requires subclasses to provide class-level constants KIND for the k8s Kind field, and API_CATEGORY for the k8s API Category. It infers the API version from the version of the client object. Additionally, you can set READY_CONDITION and TERMINAL_CONDITIONS to be the name of a condition that indicates readiness, and a set of conditions indicating a steady state, respectively. ReadyNc$UbU$UR$)z5Returns the passed str if given, else the class KIND.)KIND)clskinds rKindKubernetesObject.Kinds#411rc$UbU$UR$)z=Returns the passed str if given, else the class API_CATEGORY.) API_CATEGORY)r5 api_categorys r ApiCategoryKubernetesObject.ApiCategorys(3<I9I9IIrc.UcU$SRX!5$)z4Returns the api version with group prefix if exists.z{}/{}format)r5 api_versionr;s r ApiVersionKubernetesObject.ApiVersions  >>, 44rcP[X RU55nU"U"US9X#5$)aXProduces a wrapped message with only the given spec. It is meant to be used as part of another message; it will error if you try to access the metadata or status. Arguments: spec: messages.Message, The spec to include messages_mod: the messages module kind: str, the resource kind Returns: A new k8s_object with only the given spec. )spec)getattrr7)r5rE messages_modr6r.s rSpecOnlyKubernetesObject.SpecOnlys(lHHTN3G wD!< 66rc|[X RU55nU"U"URURS9UU5$)z;Wraps a template object: spec and metadata only, no status.)rEmetadata)rFr7rErK)r5templaterGr6r.s rTemplateKubernetesObject.Templates=lHHTN3G X]]X->->?  rc*URU5nUR[US5U5nURnUR U5n[ [Xc55nX7lXWlX'Rl U"XvU5$![a N%f=f)aProduces a new wrapped message of the appropriate type. All the sub-objects in it are recursively initialized to the appropriate message types, and the kind, apiVersion, and namespace set. Arguments: client: the API client to use namespace: str, The namespace to create the object in kind: str, the resource kind api_category: str, the api group of the resource Returns: The newly created wrapped message. _VERSION) r<rBrFMESSAGES_MODULEr7r r6 apiVersionAttributeErrorrK namespace)r5clientrTr6r;rArGrets rNewKubernetesObject.News ??<0L..!D gl9 :C h"n 'LL s$ ''    s B BBc[X RU55n[X5(d [S5eXlX lg)Nz*Oops, trying to wrap wrong kind of message)rFr7r'r_m _messages)selfto_wraprGr6r.s r__init__KubernetesObject.__init__s5lIIdO4G g ' ' C DDG!NrcUR$)zReturn the messages module.)r[r\s rMessagesModuleKubernetesObject.MessagesModules >>rcPURR(d [S5eg)NzThis instance is spec-only.)rZrKrras rAssertFullObject!KubernetesObject.AssertFullObjects 77   4 55 rc.URR$rrZrKras r IsFullObjectKubernetesObject.IsFullObjects 77  rcNUR5 URR$r)rerZr6ras rr6KubernetesObject.kinds 77<<rcNUR5 URR$r)rerZrRras rrRKubernetesObject.apiVersions 77  rc.URR$r)rZrEras rrEKubernetesObject.specs 77<<rcNUR5 URR$r)rerZstatusras rrrKubernetesObject.statuss 77>>rcNUR5 URR$r)rerZrKras rrKKubernetesObject.metadatas 77  rc$XRlgrrhr\values rrKru s GGrcbUR5 URRR$rrerZrKr-ras rr-KubernetesObject.names$ 77    rcXUR5 XRRlgrrzrws rr-r{s!GGrc@URR[5$r) annotationsgetAUTHOR_ANNOTATIONras rauthorKubernetesObject.authors      1 22rc.URR$r)rKcreationTimestampras rcreation_timestamp#KubernetesObject.creation_timestamp s == * **rcbUR5 URRR$rrerZrKrTras rrTKubernetesObject.namespace$s$ 77   % %%rcXUR5 XRRlgrrrws rrTr)s!&GGrcbUR5 URRR$r)rerZrKresourceVersionras rresource_version!KubernetesObject.resource_version.$ 77   + ++rcUR5 URRRR S5$)N/)rerZrKselfLinklstripras r self_linkKubernetesObject.self_link3s/ 77   $ $ + +C 00rcbUR5 URRR$r)rerZrKuidras rrKubernetesObject.uid8s$ 77    rcbUR5 URRR$r)rerZrKownerReferencesras rownersKubernetesObject.owners=rrc([UR;$r) REGION_LABELlabelsras r is_managedKubernetesObject.is_managedBs 4;; &&rcHUR5 UR[$r)rerrras rregionKubernetesObject.regionFs ;;| $$rcbUR5 URRR$r)rerZrK generationras rrKubernetesObject.generationKs$ 77   & &&rc8XRRlgr)rZrKrrws rrrPs"'GGrc"UR5$r) GetConditionsras r conditionsKubernetesObject.conditionsTs    rc HUR5 URR(a!URRRnO/n[R "UU(aUO UR [URRSS5UR5$)NobservedGeneration) rerZrrrr ConditionsREADY_CONDITIONrFr)r\terminal_conditioncs rrKubernetesObject.GetConditionsXsq ww~~ ''.. # #a a    0d6J6J 4d;   rcvUR5 [URURR5$r)reAnnotationsFromMetadatar[rZrKras rr~KubernetesObject.annotationses) "4>>4773C3C DDrcvUR5 [URURR5$r)reLabelsFromMetadatar[rZrKras rrKubernetesObject.labelsjs) dnndgg.>.> ??rc[US5(deUR(a4URUR;aURUR$gg)Nr)rrrras rready_condition KubernetesObject.ready_conditionosK 4* + ++ + 4//4??B __T11 22Crcj[US5(deUR(aURS$g)Nrrrrrras rreadyKubernetesObject.readyus5 4* + ++ +   ! !( ++rcj[US5(deUR(aURS$g)NrlastTransitionTimerras rlast_transition_time%KubernetesObject.last_transition_time{s6 4* + ++ +   ! !"6 77rcNURU5 U$![a Us$f=f)zBChoose the best symbol (if it's in this encoding) or an alternate.)encode UnicodeError)r\bestaltencodings r _PickSymbolKubernetesObject._PickSymbols, kk( k  js  $$c(UR5S$)z6Return a symbol summarizing the status of this object.r)ReadySymbolAndColorras r ready_symbolKubernetesObject.ready_symbols  # # %a ((rc[R"5R5nURcUR SSU5S4$UR(aUR SSU5S4$g)zAReturn a tuple of ready_symbol and display color for this object.u….yellowu✔+green)Xred)r GetConsoleAttr GetEncodingrr)r\rs rr$KubernetesObject.ReadySymbolAndColorsl **,88:H zz   4c8 D     4c8 Dg MM rcURRURURURUR UR S9$)N)r6rTr-rrR)r[ObjectReferencer6rTr-rrRras rAsObjectReference"KubernetesObject.AsObjectReferencesA >> ) ) YY.. YY HH?? * rcUR$)z(Return the actual message we've wrapped.rZras rMessageKubernetesObject.Messages 77Nrc"UR5$r)rras rMakeSerializable!KubernetesObject.MakeSerializables <<>rc[URS5(aURR"U0UD6$[URURS-5"U0UD6$)NGoogleCloudRunV1Condition Condition)rr[rrFr6)r\rrs r MakeConditionKubernetesObject.MakeConditionsRt~~:;; ^^ 5 5t Fv FF T^^TYY%< =t Nv NNrcz[U[U55(a!UR5UR5:H$g)NF)r'typer)r\others r__eq__KubernetesObject.__eq__s-%d$$ \\^u}} .. rcrSR[U5R[UR55$)Nz{}({}))r@r__name__reprrZras r__repr__KubernetesObject.__repr__s% ??4:..TWW >>r)rZr[r)NN)4r __module__ __qualname____firstlineno____doc__r classmethodr7r<rBrHrMrWr^rbreripropertyr6rRrErrrKsetterr-rrrTrrrrrrrrrr~rrrrrrrrrrrrr__static_attributes__r+rrr0r0s /22JJ55 77"((<" 6            ?? ! !;;"" 3 3 + + & & '' , , 1 1     , , ' ' % % ' '((      E E @ @ 3 3  , ,  8 8  ) ) O  ?rr0cUR(d[U5R5Ul[URR[U5RR SSS9$Nkeyrx) key_field value_field)r~rAnnotationsValueKeyValueListAsDictionaryWrapperadditionalPropertiesAdditionalPropertyrGrKs rrrsW    ->>@H (// <))<<  rcUR(d[U5R5Ul[URR[U5RR SSS9$r)rr LabelsValuerrrrs rrrsR <(446HO (oo** <$$77  rc<\rSrSrSrSrSrSrSrSr Sr S r g ) LazyListWrapperiarWraps a list that does not exist at object creation time. We sometimes have a need to allow access to a list property of a nested message, when we're not sure if all the layers above the list exist yet. We want to arrange it so that when you write to the list, all the above messages are lazily created. When you create a LazyListWrapper, you pass in a create function, which must do whatever setup you need to do, and then return the list that it creates in an underlying message. As soon as you start adding items to the LazyListWrapper, it will do the setup for you. Until then, it won't create any underlying messages. cXlSUlgr_create_l)r\creates rr^LazyListWrapper.__init__sLDGrcVUR(aURU$[5err IndexErrorr\is r __getitem__LazyListWrapper.__getitem__s ww WWQZ ,rcdURcUR5UlX RU'gr)rr r\rvs r __setitem__LazyListWrapper.__setitem__s# ww dgGGAJrcTUR(aURU g[5errrs r __delitem__LazyListWrapper.__delitem__s ww ''!* LrcPUR(a[UR5$g)Nr)rlenras r__len__LazyListWrapper.__len__s ww \ rc~URcUR5UlURRX5 gr)rr insertrs rr%LazyListWrapper.inserts( ww dgGGNN1rr N) rrrrrr^rrrr"r%rr+rrr r s%     rr c^\rSrSrSrSSjrSrSrSrSr S r S r S r S r S rSrSrg)ListAsDictionaryWrapperizWraps repeated messages field with name in a dict-like object. Operations in these classes are O(n) for simplicity. This needs to match the live state of the underlying list of messages, including edits made by others. Nc>XlX lU=(d SUlg)aWraps list of messages to be accessible as a read-only dictionary. Arguments: to_wrap: List[Message], List of messages to treat as a dictionary. key_field: attribute to use as the keys of the dictionary filter_func: filter function to allow only considering certain messages from the wrapped list. This function should take a message as its only argument and return True if this message should be included. cg)NTr+)_s r2ListAsDictionaryWrapper.__init__..sTrN)rZ _key_field_filter)r\r]r filter_funcs rr^ ListAsDictionaryWrapper.__init__ sGO2>DLrc\UR5Hup#X!:XdM Us $ [U5e)z%Implements evaluation of `self[key]`.)itemsKeyError)r\rkitems rr#ListAsDictionaryWrapper.__getitem__s*::<    3-rc6[X RU5 [UR5HOup4[ X@R5U:XdM UR U5(d [ U5eX RU' g URRU5 gr)setattrr. enumeraterZrFr/r4append)r\rrxindexr6s rr#ListAsDictionaryWrapper.__setitem__so E??C( )   '3 .||D!!  *  GGNN5rc URHAn[X0R5U:XdMURU5(d [ U5eUs $ [ X RU5 URR U5 U$r)rZrFr.r/r4r9r;)r\rdefaultr6s r setdefault"ListAsDictionaryWrapper.setdefault(sd  '3 .||D!!    G__c*GGNN7 NrcSn[UR5H8up4[X@R5U:XdM UR U5(aUn O Uc [ U5eURU g)z)Implements evaluation of `del self[key]`.N)r:rZrFr.r/r4)r\rindex_to_deleter<r6s rr#ListAsDictionaryWrapper.__delitem__2sbO )   '3 . <<  !/ *  SM  rcB[SUR555$)z%Implements evaluation of `len(self)`.c3&# UHnSv M g7f)Nr+).0r+s r 2ListAsDictionaryWrapper.__len__..@s',Qq,s)sumr3ras rr"ListAsDictionaryWrapper.__len__>s '$**,' ''rc0SUR55$)z.Returns a generator yielding the message keys.c3*# UH oSv M g7f)rNr+)rHr6s rrI3ListAsDictionaryWrapper.__iter__..Ds - G s)r3ras r__iter__ ListAsDictionaryWrapper.__iter__Bs - --rcUR$rrras rr(ListAsDictionaryWrapper.MakeSerializableFs 77NrcSR[U5RSRSUR 5555$)Nz{}{{{}}}z, c3H# UHupSRX5v M g7f)z{}: {}Nr?)rHr5rs rrI3ListAsDictionaryWrapper.__repr__..LsALDA(//!''Ls ")r@rrjoinr3ras rr ListAsDictionaryWrapper.__repr__Is:    T  ADJJLAA rc[USS9$)Nnone_key) ListItemsViewras rr3ListAsDictionaryWrapper.itemsOs  ++rc[U5$r)ListValuesViewras rvaluesListAsDictionaryWrapper.valuesRs $ r)r/r.rZ)r-N)rrrrrr^rrr@rr"rPrrr3rarr+rrr(r(s> 3 !(. , rr(c:^\rSrSrSrSS.U4SjjrSrSrU=r$)r]iVz*Item iterator for ListAsDictionaryWrapper.Nr[c2>[TU]"U0UD6 Xlgr)superr^ _none_key)r\r\rr __class__s rr^ListItemsView.__init__Ys Gd%f%Nrc## URRHXnURRU5(dM%[XRR5nUc UR nX!4v MZ g7fr)_mappingrZr/rFr.rf)r\r6rs rrPListItemsView.__iter__]sX      t $ $dMM445 ;#k !s 8A68A6)rf) rrrrrr^rPr __classcell__rgs@rr]r]Vs2%)rr]c \rSrSrSrSrSrg)r`ifc6[U5H nX!:XdM g g)NTF)iter)r\rxrs r __contains__ListValuesView.__contains__hs $Z  rc#Z# URR5H upUv M g7fr)rjr3)r\r+rxs rrPListValuesView.__iter__ns#MM'') k*s)+r+N)rrrrrqrPrr+rrr`r`fs  rr`cT^\rSrSrSrSU4SjjrU4SjrU4SjrSrSr U=r $) risaWraps repeated messages field with name and value in a dict-like object. Properties which resemble dictionaries (e.g. environment variables, build template arguments) are represented in the underlying messages fields as a list of objects, each of which has a name and value field. This class wraps that list in a dict-like object that can be used to mutate the underlying fields in a more Python-idiomatic way. cB>[[U] XUS9 X lX@lg)aWrap a list of messages to be accessible as a dictionary. Arguments: to_wrap: List[Message], List of messages to treat as a dictionary. item_class: type of the underlying Message objects key_field: attribute to use as the keys of the dictionary value_field: attribute to use as the values of the dictionary filter_func: filter function to allow only considering certain messages from the wrapped list. This function should take a message as its only argument and return True if this message should be included. )rr0N)rerr^ _item_class _value_field)r\r] item_classrrr0rgs rr^(KeyValueListAsDictionaryWrapper.__init__}s-& )49+:"#rct>[[U] XR55n[ X0R U5 g)aImplements evaluation of `self[key] = value`. Args: key: value of the key field value: value of the value field Raises: KeyError: if a message with the same key value already exists, but is hidden by the filter func, this is raised to prevent accidental overwrites N)rerr@rwr9rx)r\rrxr6rgs rr+KeyValueListAsDictionaryWrapper.__setitem__s5 0$ B    D D##U+rc>UR"S0URU0D6n[[U]X5n[ X@R5$)Nr+)rwrxrerr@rF)r\rr? default_itemr6rgs rr@*KeyValueListAsDictionaryWrapper.setdefaultsI##Ct'8'8'&BCL 0$ B  D 4** ++rc[U5$r)KeyValueListItemsViewras rr3%KeyValueListAsDictionaryWrapper.itemss  &&r)rwrx)r-rxN) rrrrrr^rr@r3rrlrms@rrrss, $2,",''rrc(^\rSrSrU4SjrSrU=r$)ric#># [[U] 5H(upU[X RR 54v M* g7fr)rerrPrFrjrx)r\rr6rgs rrPKeyValueListItemsView.__iter__s80$@B  '$ : :; <<CsAAr+)rrrrrPrrlrms@rrrs ==rr)>r __future__rrrrabc collectionsapitools.base.protorpclitergooglecloudsdk.api_lib.runrgooglecloudsdk.core.consoler sixcollections_abcrS SERVING_GROUPAUTOSCALING_GROUPEVENTING_GROUP CLIENT_GROUP GOOGLE_GROUP RUN_GROUP RUNAPPS_GROUPINTERNAL_GROUPSrrCLIENT_NAME_ANNOTATIONCLIENT_VERSION_ANNOTATIONDESCRIPTION_ANNOTATIONLAUNCH_STAGE_ANNOTATIONBINAUTHZ_POLICY_ANNOTATIONBINAUTHZ_BREAKGLASS_ANNOTATION EXECUTION_ENVIRONMENT_ANNOTATIONCUSTOM_AUDIENCES_ANNOTATIONNETWORK_INTERFACES_ANNOTATION!CONTAINER_DEPENDENCIES_ANNOTATIONGPU_TYPE_NODE_SELECTORMULTI_REGION_REGIONS_ANNOTATIONMULTI_REGION_ID_LABELGCLB_DOMAIN_NAME_ANNOTATIONTHREAT_DETECTION_ANNOTATIONrrrr add_metaclassABCMetaobjectr0rrMutableSequencer MutableMappingr( ItemsViewr] ValuesViewr`rrr+rrrs?&%' /04  OO/ & -'# % (  "J.k) "^3%(99"^3#o5&)@@!*-O!O#,/G#G '*== ),A A$-0I$I!"^3"+j"8!$66+.AA'*==KK" 43;;t?vt? t?n ,o55,^Q o<<Q h O--  _// <'&=<'~=M=c / s EE$#E$