2(SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SS K J r SS K Jr SS K Jr "S S \R 5rSr"SS\R&5rg)z(Utilities for Eventarc MessageBuses API.)absolute_import)division)unicode_literals) list_pager)base)common)common_publishing)apis) exceptions) resourcesc\rSrSrSrSrg)NoFieldsSpecifiedErrorz:Error when no fields were specified for a Patch operation.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r4lib/googlecloudsdk/api_lib/eventarc/message_buses.pyrrsBrrcr[RRURSS9nUR 5$)Nz(eventarc.projects.locations.messageBuses) collection)r REGISTRYParseRelativeNamenameSelfLink)resource message_busess rGetMessageBusURIr!"s8$$66mm J7-    !!rc^\rSrSrSrU4SjrSSjrSrSrSr Sr S r S r S r S rS rSrSr\S5rSrU=r$)MessageBusClientV1)zGMessageBus Client for interaction with v1 of Eventarc MessageBuses API.c>[[U] [R[R S5 [ R"[R[R 5nURUl URUl [ R"[R[R 5nURUl URUlg)Nz message bus)superr#__init__rAPI_NAME API_VERSION_1r GetClientInstanceMESSAGES_MODULE _messagesprojects_locations_messageBuses_servicer _publishing_messages_publishing_service)selfclientpublishing_client __class__s rr'MessageBusClientV1.__init__,s d,--}  # #FOOV5I5I JF++DN::DM..""$5$C$C!2 A AD0PPDrcURRUR5R5UUR 5US9nUR R U5$)a?Creates a new MessageBus. Args: message_bus_ref: Resource, the MessageBus to create. message_bus_message: MessageBus, the messageBus message that holds messageBus' name, crypto key name, etc. dry_run: If set, the changes will not be committed, only validated Returns: A long-running operation for create. )parent messageBus messageBusId validateOnly)r,2EventarcProjectsLocationsMessageBusesCreateRequestParent RelativeNameNamer.Create)r1message_bus_refmessage_bus_messagedry_run create_reqs rr?MessageBusClientV1.Create?s_ II"))+88:*(--/ J  ==   ++rcURRUR5S9nURR U5$)z~Gets the requested MessageBus. Args: message_bus_ref: Resource, the MessageBus to get. Returns: The MessageBus message. r)r,/EventarcProjectsLocationsMessageBusesGetRequestr=r.Get)r1r@get_reqs rrHMessageBusClientV1.GetUsAnnLL  ) ) +MG ==  W %%rc URRUR5US9n[R"UR USUUSS9$)aVList available messageBuses in location. Args: location_ref: Resource, the location to list MessageBuses 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 MessageBuses in the location. r7pageSize messageBusesrM)servicerequestfieldlimit batch_sizebatch_size_attribute)r,0EventarcProjectsLocationsMessageBusesListRequestr=r YieldFromListr.)r1 location_refrR page_sizelist_reqs rListMessageBusClientV1.ListcsW~~NN((*YOH  # # '  rcURRUR5UUS9nURR U5$)aMUpdates the specified MessageBus. Args: message_bus_ref: Resource, the MessageBus to update. message_bus_message: MessageBus, the messageBus message that holds messageBus' name, crypto key name, etc. update_mask: str, a comma-separated list of MessageBus fields to update. Returns: A long-running operation for update. )rr8 updateMask)r,1EventarcProjectsLocationsMessageBusesPatchRequestr=r.Patch)r1r@rA update_mask patch_reqs rr_MessageBusClientV1.Patch{sJ HH --/*" I  ==  y ))rcURRUR5S9nURR U5$)zDeletes the specified MessageBus. Args: message_bus_ref: Resource, the MessageBus to delete. Returns: A long-running operation for delete. rF)r,2EventarcProjectsLocationsMessageBusesDeleteRequestr=r.Delete)r1r@ delete_reqs rreMessageBusClientV1.DeletesD II --/ J  ==   ++rc URRUR5URRUR XEXgU5UUU (aU R5OSS9S9n UR R U 5 g)aPublish a Cloud Event to a MessageBus. Args: message_bus_ref: Resource, the message bus to publish to. json_message: str, the json string to publish. avro_message: byte, the avro payload to publish. event_id: str, the id of the event. event_type: str, the type of the event. event_source: str, the source of the event. event_data: str, the data of the event. event_attributes: dict, the attributes of the event. destination_enrollment_ref: Resource, the enrollment to deliver the event to. N) protoMessage avroMessage jsonMessagedestinationEnrollment)r8-googleCloudEventarcPublishingV1PublishRequest)r/=EventarcpublishingProjectsLocationsMessageBusesPublishRequestr=-GoogleCloudEventarcPublishingV1PublishRequest_BuildCloudEventProtoMessager0Publish) r1r@ json_message avro_messageevent_id event_type event_source event_dataevent_attributesdestination_enrollment_ref publish_reqs rrqMessageBusClientV1.Publishs6++ii"//16:6O6O6}6}::l@P%$.+7797~ 7 jK" $$[1rc URRUR5US9n[R"UR SUSUUSS9$)z@List available enrollments attached to the specified messageBus.rLListEnrollments enrollmentsrM)rOmethodrPrQrRrSrT)r,;EventarcProjectsLocationsMessageBusesListEnrollmentsRequestr=rrVr.)r1r@rRrXrYs rr}"MessageBusClientV1.ListEnrollmentssX~~YY++- ZH  # #  ' rcSnUb<URRURRRU5S9nURRUR 5UUUS9$)N) logSeverity)r loggingConfig cryptoKeyNamelabels)r, LoggingConfigLogSeverityValueValuesEnum MessageBusr=)r1r@logging_configcrypto_key_namerlogging_config_enums rBuildMessageBus"MessageBusClientV1.BuildMessageBussx! NN88nn22MM 9 >> $ $  ) ) +)% % rc/nU(aURS5 U(dU(aURS5 U(aURS5 U(d [S5eSRU5$)aBuilds an update mask for updating a MessageBus. Args: logging_config: bool, whether to update the logging config. 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. rrrz*Must specify at least one field to update.,)appendrjoin)r1r crypto_keyclear_crypto_keyrr`s rBuildUpdateMask"MessageBusClientV1.BuildUpdateMasks]$K)%) "  "#O PP 88K  rcBURRR$)zReturns the labels value class.)r,r LabelsValuer1s rLabelsValueClass#MessageBusClientV1.LabelsValueClass s >> $ $ 0 00rc vUb UbUbUcgURRUUUSUURU5S9$)Nz1.0)idtypesource specVersiontextData attributes)r/)GoogleCloudEventarcPublishingV1CloudEvent_BuildCloudEventAttributes)r1rtrurvrwrxs rrp/MessageBusClientV1._BuildCloudEventProtoMessages\          $ $ N N  223CD O rc (UcgURRRUR5VVs/sHJup#URRRR UURR US9S9PML snnS9$s snnf)N)ceString)keyvalue)additionalProperties)r/rAttributesValueitemsAdditionalPropertyAGoogleCloudEventarcPublishingV1CloudEventCloudEventAttributeValue)r1rxrrs rr-MessageBusClientV1._BuildCloudEventAttributes#s   $ $ N N ^ ^/446 7   % % O O _ _ r r//qq"r s  7  _   sAB cg)Nz message-busesrrs r_resource_label_plural)MessageBusClientV1._resource_label_plural2s r)r,r/r0r.)F)rrrrrr'r?rHrZr_rerqr}rrrrprpropertyrr __classcell__)r4s@rr#r#)s]OQ&,, &0**, ,2\ "!<1&   rr#N)r __future__rrrapitools.base.pyrgooglecloudsdk.api_lib.eventarcrrr googlecloudsdk.api_lib.utilr googlecloudsdk.corer r Errorrr!EventarcClientBaser#rrrrsU/&''02=,*)CZ--C"K00Kr