SrSSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SSK J r "S S \ R5rS r"S S \5rg)z$Utilities for Eventarc Channels API.) 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.pyr r sBrr cr[RRURSS9nUR 5$)Nz$eventarc.projects.locations.channels) collection)r REGISTRYParseRelativeNamenameSelfLink)resourcechannelss r GetChannelURIrs7    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_1rGetClientInstanceMESSAGES_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)r/ channel_refchannel_messagedry_run create_reqs rr<ChannelClientV1.Create9s\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)r/r= delete_reqs rrEChannelClientV1.DeleteLs?NN  % % 'O)J ==   ++rcURRUR5S9nURR U5$)zqGets the requested Channel. Args: channel_ref: Resource, the Channel to get. Returns: The Channel message. rC)r*+EventarcProjectsLocationsChannelsGetRequestr:r,Get)r/r=get_reqs rrJChannelClientV1.GetYs?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. )r5pageSizerrN)servicerequestfieldlimit batch_sizebatch_size_attribute)r*,EventarcProjectsLocationsChannelsListRequestr:r YieldFromListr,)r/ location_refrR page_sizelist_reqs rListChannelClientV1.ListfsV~~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)r/r=r> update_mask patch_reqs rr_ChannelClientV1.Patch|sGLL  % % '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) rTransformEventsForPublishingr-3GoogleCloudEventarcPublishingV1PublishEventsRequestEventsValueListEntry?EventarcpublishingProjectsLocationsChannelsPublishEventsRequestr:r. PublishEvents)r/r= 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. rrrtz*Must specify at least one field to update.,)appendr join)r/ crypto_keyclear_crypto_keyrtr`s rBuildUpdateMaskChannelClientV1.BuildUpdateMasksZK)) "  "#O PP 88K  rcBURRR$)N)r*ru LabelsValue)r/s rLabelsValueClsChannelClientV1.LabelsValueClss >> ! ! - --r)r*r-r.r,)F)rrrrrr%r<rErJrZr_rorxrrr __classcell__)r2s@rr r %s>HM",& , &),*$80 !4..rr N)rapitools.base.pyrgooglecloudsdk.api_lib.eventarcrr$googlecloudsdk.api_lib.eventarc.basergooglecloudsdk.api_lib.utilrgooglecloudsdk.corerr Errorr rr r rrrsI+(2=C,*)CZ--C e.(e.r