#pSrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SS KJ r SS K J r "S S \ R5r"S S\ R5r"SS\ R5r"SS\ R5r"SS\ R5r"SS\ R5rg)aVResource display taps. A tapper is an object that converts an iterable into another iterable. It applies the Tap method as each item is iterated on, and applies the Done method just before the iteration stops. A Tapper may delete items from an iterable and/or inject new items into an iterable. Tappers are useful for monitoring or modifying an iterable without consuming it all at once. For example one could always: items = list(iterable_items) for item in items: do_something(item) # pass items to the next consumer However, if an iterable consumed a lot of resources (say a generator with a zillion items) then the list() statement would instantiate all of the items and strain memory. A tapper avoids this by dealing with each item as it is generated. There is a tapper for each of the --filter, --flatten, --limit, and --page flags. )absolute_import)division)unicode_literals)log)resource_filter)resource_printer_base)resource_projector)resource_property) peek_iterablec*\rSrSrSrSrSrSrSrg)Filterer4zyA Tapper class that filters out resources not matching an expression. Attributes: _match: The resource filter method. c[R"XS9Ul[R"UR5Ulg)zConstructor. Args: expression: The resource filter expression string. defaults: The resource format and filter default projection. )defaultsN)rCompile_compiled_expression GetAllKeys _missing_keys)self expressionrs +lib/googlecloudsdk/calliope/display_taps.py__init__Filterer.__init__;s5!0 7 7!D)33D4M4MNDc^[R"U5mU=R[U4SjUR55-sl[R "U5(agUR RT5$)zReturns True if resource matches the filter expression. Args: resource: The resource to filter. Returns: True if resource matches the filter expression. c3d># UH%n[R"TU5(dM!Uv M' g7fN)r ResourceContainsKey).0keyserialized_resources r Filterer.Tap..Qs+%C  0 01Dc J %s 0 0T)r MakeSerializablersetrIsResourceMarkerrEvaluate)rresourcer!s @rTap Filterer.TapGso-==hG#%% --h77   $ $ - -.A BBrcRSnUR(aU"UR5 gg)Nc SR[U5Vs/sH"nSR[[U55PM$ sn5n[R "SU-5 gs snf)Nz, .z=The following filter keys were not present in any resource : )joinsortedmapstrrwarning) missing_keysr missing_keys_strs rWarnMissingKeys&Filterer.Done..WarnMissingKeys[sX.4\.B C.Bs388CSM ".B C kk I   Ds)A#)r)rr5s rDone Filterer.DoneZs% d(()r)rrN __name__ __module__ __qualname____firstlineno____doc__rr)r7__static_attributes__rrr r 4s OC& *rr c$\rSrSrSrSrSrSrg) FlattenerhaOA Tapper class that flattens a resource key slice to separate records. A serialized copy of the resource is modified in place. This means the same resource object is returned for each flattened slice item. This is OK because the downstream is not guaranteed uniqueness. Attributes: _child_name: The flattened value to set is _parent_key[_child_name]. _key: The parsed resource key of the slice to flatten. _parent_key: The parent of _key, None for the resource itself. _items: The items to flatten in the current resource. _resource: The serialized copy of the current resource. cUSSUlUR(aURSOSUlUR(aURSSOSUlSUlSUlg)zEConstructor. Args: key: The resource key of the slice to flatten. N)_key _child_name _parent_key_items _resource)rr s rrFlattener.__init__wsOADI(, tyy}tD)-tyy"~DDKDNrcURc[R"U5Ul[R "URUR 5Ul[UR[5(d(URnSUl[R"USS9$UR(dSUlgURRS5nUR(a,[R "URUR5nO URnX#UR'[R"[R"UR55$)zReturns the next slice item in resource. Args: resource: The resource to flatten. Returns: True if the next slice is not a list, False if there are no more items, or Injector(resource) which is the resource with the next slice flattened. NTreplaceFr)rIr r$rJr GetrF isinstancelistr TapInjectorpoprHrG)rr(itemparents rr) Flattener.Taps {{)::8Ddn%))$..$))Ddk  T * *{{ ((t<< ;;dk  ;;??1 D  $$T^^T5E5EFf~~f#4    $ $++DNN; r)rGrIrFrHrJNr:r;r<r=r>rr)r?r@rrrBrBhs  rrBc$\rSrSrSrSrSrSrg)LimiterzA Tapper class that filters out resources after a limit is reached. Attributes: _limit: The resource count limit. _count: The resource count. cXlSUlgNr)_limit_count)rlimits rrLimiter.__init__sKDKrc[R"U5(agU=RS- slURUR:*=(d S$)zReturns True if the limit has not been reached yet, None otherwise. Args: resource: The resource to limit. Returns: True if the limit has not been reached yet, None otherwise to stop iterations. TN)rr&r^r]rr(s rr) Limiter.Taps>--h77 KK1K ;;$++ % --r)r^r]NrWr@rrrYrYs .rrYc$\rSrSrSrSrSrSrg)PagerzA Tapper class that injects a PageMarker after each page of resources. Attributes: _page_size: The number of resources per page. _count: The current page resource count. cXlSUlgr\) _page_sizer^)r page_sizes rrPager.__init__sODKrc[R"U5(agU=RS- slURUR:a0SUl[R "[R "55$g)zInjects a PageMarker if the current page limit has been reached. Args: resource: The resource to limit. Returns: TapInjector(PageMarker) if the page current page limit has been reached, otherwise True to retain the current resource. Trbr)rr&r^rir rR PageMarkerrcs rr) Pager.Taps[--h77 KK1K {{T__$dk  & &'<'G'G'I JJ r)r^riNrWr@rrrfrfsrrfc*\rSrSrSrSrSrSrSrg) UriCacherzA Tapper class that caches URIs based on the cache update op. Attributes: _transform_uri: The uri() transform function. _update_cache_op: The non-None return value from UpdateUriCache(). _uris: The list of changed URIs, None if it is corrupt. c*X lXl/Ulgr_transform_uri_update_cache_op_uris)rupdate_cache_op transform_uris rrUriCacher.__init__s'+DJrc[R"U5(agURb:URUSS9nU(aURR U5 gSUlg)zAppends the URI for resource to the list of cache changes. Sets self._uris to None if a URI could not be retrieved for any resource. Args: resource: The resource from which the URI is extracted. Returns: True - all resources are seen downstream. TN undefined)rr&rvrtappendrr(uris rr) UriCacher.Taps]--h77  zz   D  9c  #  rcjURb&URRUR5 ggr)rvruUpdate)rs rr7UriCacher.Dones) zz ""4::.rrsNr9r@rrrprps */rrpc$\rSrSrSrSrSrSrg) UriReplaceriz{A Tapper class that replaces each resource item with its URI. Attributes: _transform_uri: The uri() transform function. cXlgrrt)rrxs rrUriReplacer.__init__s'rc[R"U5(agURUSS9nU(dg[R"USS9$)zReplaces resource with its URI or skips the resource if it has no URI. Args: resource: The resource to replace with its URI. Returns: TapInjector(URI, replace=True) if the resource has a URI or False to skip the resource. TNr{FrM)rr&rtr rRr~s rr)UriReplacer.TapsF--h77    h$  7C    $ $S$ 77rrNrWr@rrrrs (8rrN)r> __future__rrrgooglecloudsdk.corergooglecloudsdk.core.resourcerrr r googlecloudsdk.core.utilr r)r rBrYrfrprr@rrrs 0''#8>;:21*}  1*h9 !!9x.m.8M  >%/ !!%/P8-##8r