SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SS K J r SS KJr SS KJr "S S \R"5rSr"SS\ 5rg)z$Utilities for Eventarc Channels API.)absolute_import)division)unicode_literals) list_pager)common)common_publishing)EventarcClientBase)apis) exceptions) resourcesc\rSrSrSrSrg)NoFieldsSpecifiedErrorz:Error when no fields were specified for a Patch operation.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r/lib/googlecloudsdk/api_lib/eventarc/channels.pyrrsBrrcr[RRURSS9nUR 5$)Nz$eventarc.projects.locations.channels) collection)r REGISTRYParseRelativeNamenameSelfLink)resourcechannelss r GetChannelURIr!"s7    1 1mm F2H(    rcf^\rSrSrSrU4SjrSSjrSrSrSr Sr S r S r S r S rS rU=r$)ChannelClientV1(z@Channel Client for interaction with v1 of Eventarc Channels API.c>[[U] [R[R S5 [ R"[R[R 5nURUl URUl [ R"[R[R 5nURUl URUlg)Nchannel)superr#__init__rAPI_NAME API_VERSION_1r GetClientInstanceMESSAGES_MODULE _messagesprojects_locations_channels_servicer_publishing_messages_publishing_service)selfclientpublishing_client __class__s rr(ChannelClientV1.__init__+s /4)&//6;O;O*35 # #FOOV5I5I JF++DN66DM../@/I/I/@/N/NP!2 A AD0LLDrcURRUR5R5UUR 5US9nUR R U5$)a!Creates a new Channel. Args: channel_ref: Resource, the Channel to create. channel_message: Channel, the channel message that holds channel's name, provider, etc. dry_run: If set, the changes will not be commited, only validated Returns: A long-running operation for create. )parentr& channelId validateOnly)r-.EventarcProjectsLocationsChannelsCreateRequestParent RelativeNameNamer/Create)r2 channel_refchannel_messagedry_run create_reqs rr?ChannelClientV1.Create<s\NN!!#002""$ OJ ==   ++rcURRUR5S9nURR U5$)zDeletes the specified Channel. Args: channel_ref: Resource, the Channel to delete. Returns: A long-running operation for delete. r)r-.EventarcProjectsLocationsChannelsDeleteRequestr=r/Delete)r2r@ delete_reqs rrHChannelClientV1.DeleteOs?NN  % % 'O)J ==   ++rcURRUR5S9nURR U5$)zqGets the requested Channel. Args: channel_ref: Resource, the Channel to get. Returns: The Channel message. rF)r-+EventarcProjectsLocationsChannelsGetRequestr=r/Get)r2r@get_reqs rrMChannelClientV1.Get\s?nnHH  % % 'I)G ==  W %%rc URRUR5US9n[R"UR USUUSS9$)aJList available channels in location. Args: location_ref: Resource, the location to list Channels in. limit: int or None, the total number of results to return. page_size: int, the number of entries in each batch (affects requests made, but not the yielded results). Returns: A generator of Channels in the location. )r8pageSizer rQ)servicerequestfieldlimit batch_sizebatch_size_attribute)r-,EventarcProjectsLocationsChannelsListRequestr=r YieldFromListr/)r2 location_refrU page_sizelist_reqs rListChannelClientV1.ListisV~~JJ((*YK@H  # # '  ))rcURRUR5UUS9nURR U5$)a-Updates the specified Channel. Args: channel_ref: Resource, the Channel to update. channel_message: Channel, the channel message that holds channel's name, provider, etc. update_mask: str, a comma-separated list of Channel fields to update. Returns: A long-running operation for update. )rr& updateMask)r--EventarcProjectsLocationsChannelsPatchRequestr=r/Patch)r2r@rA update_mask patch_reqs rrbChannelClientV1.PatchsGLL  % % 'M I ==  y ))rc([R"URRRU5nURRU/S9nURR UR 5US9nURRU5 g)zPublish to a Channel. Args: channel_ref: Resource, the channel to publish to. cloud_event: A CloudEvent representation to be passed as the request body. )events)r&3googleCloudEventarcPublishingV1PublishEventsRequestN) rTransformEventsForPublishingr03GoogleCloudEventarcPublishingV1PublishEventsRequestEventsValueListEntry?EventarcpublishingProjectsLocationsChannelsPublishEventsRequestr=r1 PublishEvents)r2r@ cloud_eventevents_value_list_entrypublish_events_request publish_reqs rPublishChannelClientV1.Publishs0LL !! < <  {, "66jj'(k*++kk((*> ! !  % % '%   "  &2%>%>%@ "  rc/nU(aURS5 U(aURS5 U(aURS5 U(d [S5eSRU5$)a=Builds an update mask for updating a channel. Args: crypto_key: bool, whether to update the crypto key. clear_crypto_key: bool, whether to clear the crypto key. labels: bool, whether to update the labels. Returns: The update mask as a string. Raises: NoFieldsSpecifiedError: No fields are being updated. rurwz*Must specify at least one field to update.,)appendrjoin)r2 crypto_keyclear_crypto_keyrwrcs rBuildUpdateMaskChannelClientV1.BuildUpdateMasksZK)) "  "#O PP 88K  rcBURRR$)N)r-rx LabelsValue)r2s rLabelsValueClsChannelClientV1.LabelsValueClss >> ! ! - --r)r-r0r1r/)F)rrrrrr(r?rHrMr]rbrrr{rrr __classcell__)r5s@rr#r#(s>HM",& , &),*$80 !4..rr#N)r __future__rrrapitools.base.pyrgooglecloudsdk.api_lib.eventarcrr$googlecloudsdk.api_lib.eventarc.baser googlecloudsdk.api_lib.utilr googlecloudsdk.corer r Errorrr!r#rrrrsP+&''2=C,*)CZ--C e.(e.r