7SrSSKJr SSKJr SSKJr SSKrSSKJr SSKJ r SSKJ r SS K J r SS K Jr SS K Jr "S S \R 5r"SS\R 5r"SS\R 5r"SS\R 5r"SS\R 5r"SS\R 5r"SS\R 5rSr"SS\ R25rg)z(Utilities for Eventarc KafkaSources API.)absolute_import)division)unicode_literalsN) list_pager)base)common)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/kafka_sources.pyr r sBrr c\rSrSrSrSrg)!InvalidNetworkConfigArgumentError#zJError when the Kafka Source's network configuration arguments are invalid.rNrrrrrr#sRrrc\rSrSrSrSrg)InvalidDestinationArgumentError'z>Error when the Kafka Source's destination argument is invalid.rNrrrrrr'sFrrc\rSrSrSrSrg)(InvalidAuthenticationMethodArgumentError+zCError when the Kafka Source's authentication arguments are invalid.rNrrrrr r +sKrr c\rSrSrSrSrg)InvalidBrokerUrisArgumentError/zDError when the Kafka Source's bootstrap_servers argument is invalid.rNrrrrr#r#/sLrr#c\rSrSrSrSrg)InvalidTopicsArgumentError3z9Error when the Kafka Source's topics argument is invalid.rNrrrrr&r&3sArr&c\rSrSrSrSrg)!InvalidInitialOffsetArgumentError7zAError when the Kafka Source's initial offset argument is invalid.rNrrrrr)r)7sIrr)cr[RRURSS9nUR 5$)Nz(eventarc.projects.locations.kafkaSources) collection)r REGISTRYParseRelativeNamenameSelfLink)resource kafka_sourcess rGetKafkaSourceURIr3;s8$$66mm J7-    !!rc^\rSrSrSrU4SjrSSjrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrSrU=r$)KafkaSourceClientV1BzJKafka Source Client for interaction with v1 of Eventarc Kafka Sources API.c>[[U] [R[R S5 [ R"[R[R 5nURUl URUl g)N kafkaSource) superr5__init__rAPI_NAME API_VERSION_1r GetClientInstanceMESSAGES_MODULE _messagesprojects_locations_kafkaSources_service)selfclient __class__s rr:KafkaSourceClientV1.__init__Es\ t---}  # #FOOV5I5I JF++DN::DMrcURRUR5R5UUR 5US9nUR R U5$)aCreates a Kafka Source. Args: kafka_source_ref: Resource, the Kafka Source to create. kafka_source_message: Kafka Source, the Kafka Source message that holds Kafka source's name, destinations, mediations, input payload format, logging config, retry policy, crypto key name, etc. dry_run: If set, the changes will not be committed, only validated Returns: A long-running operation for create. )parentr8 kafkaSourceId validateOnly)r?2EventarcProjectsLocationsKafkaSourcesCreateRequestParent RelativeNameNamerACreate)rBkafka_source_refkafka_source_messagedry_run create_reqs rrNKafkaSourceClientV1.CreatePs_ II#**,99;,*//1 J  ==   ++rc URRUR5US9n[R"UR USUUSS9$)aYList available Kafka Sources in location. Args: location_ref: Resource, the location to list Kafka Sources 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 Kafka Sources in the location. )rGpageSize kafkaSourcesrU)servicerequestfieldlimit batch_sizebatch_size_attribute)r?0EventarcProjectsLocationsKafkaSourcesListRequestrLr YieldFromListrA)rB location_refrZ page_sizelist_reqs rListKafkaSourceClientV1.ListgsW~~NN((*YOH  # # '  rcURRUR5S9nURR U5$)zGets the requested Kafka Source. Args: kafka_source_ref: Resource, the Kafka Source to get. Returns: The Kafka Source message. r/)r?/EventarcProjectsLocationsKafkaSourcesGetRequestrLrAGet)rBrOget_reqs rrgKafkaSourceClientV1.GetsAnnLL  * * ,MG ==  W %%rcURRUR5UUS9nURR U5$)aUpdates the specified Kafka Source. Args: kafka_source_ref: Resource, the Kafka Source to update. kafka_source_message: Kafka Source, the Kafka Source message that holds Kafka Source's name, destinations, mediations, input payload format, logging config, retry policy, crypto key name, etc. update_mask: str, a comma-separated list of Kafka Source fields to update. Returns: A long-running operation for update. )r/ kafka_source updateMask)r?1EventarcProjectsLocationsKafkaSourcesPatchRequestrLrAPatch)rBrOrP update_mask patch_reqs rrnKafkaSourceClientV1.PatchsJ HH!..0-" I  ==  y ))rcURRUR5S9nURR U5$)zDeletes the specified Kafka Source. Args: kafka_source_ref: Resource, the Kafka Source to delete. Returns: A long-running operation for delete. re)r?2EventarcProjectsLocationsKafkaSourcesDeleteRequestrLrADelete)rBrO delete_reqs rrtKafkaSourceClientV1.DeletesD II!..0 J  ==   ++rc ZURRUR5URU5UR U5UR U5UR UUUUU 5URX5URX5URU 5URU 5US9 $)N) r/ brokerUrisconsumerGroupIdtopicsauthenticationConfig networkConfig destination initialOffset loggingConfiglabels) r? KafkaSourcerL_BuildBrokerUris_BuildConsumerGroupID _BuildTopics_BuildAuthenticationConfig_BuildNetworkConfig_BuildDestination_BuildInitialOffset_BuildLoggingConfig)rBrObootstrap_serversconsumer_group_idrzsasl_mechanism sasl_username sasl_passwordtls_client_certificatetls_client_keynetwork_attachment message_businitial_offsetlogging_configrs rBuildKafkaSource$KafkaSourceClientV1.BuildKafkaSources" >> % %  * * ,(():;223DE  (!<<    "   ..  **+;I..~>..~>% & rc /n U(aU RS5 U(dU(dU(aU RS5 U(aU RS5 U(aU RS5 U(dU(dU(dU (aU RS5 U (dU (aU RS5 U (aU RS5 U (d [S5eS RU 5$) aBuilds an update mask for updating a Kafka Source. Args: destinations: bool, whether to update the destinations. input_payload_format_json: bool, whether to update the input_payload_format_json. input_payload_format_avro_schema_definition: bool, whether to update the input_payload_format_avro_schema_definition. input_payload_format_protobuf_schema_definition: bool, whether to update the input_payload_format_protobuf_schema_definition. mediations: bool, whether to update the mediations. logging_config: bool, whether to update the logging_config. max_retry_attempts: bool, whether to update the max_retry_attempts. min_retry_delay: bool, whether to update the min_retry_delay. max_retry_delay: bool, whether to update the max_retry_delay. 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. destinationsinputPayloadFormat mediationsr retryPolicy cryptoKeyNamerz*Must specify at least one field to update.,)appendr join)rBrinput_payload_format_json+input_payload_format_avro_schema_definition/input_payload_format_protobuf_schema_definitionrrmax_retry_attemptsmin_retry_delaymax_retry_delay crypto_keyclear_crypto_keyrros rBuildUpdateMask#KafkaSourceClientV1.BuildUpdateMasksRK(! 6 :-.&)   '%) "  "#O PP 88K  rcBURRR$)N)r?r LabelsValue)rBs rLabelsValueClass$KafkaSourceClientV1.LabelsValueClasss >> % % 1 11rc4Uc [S5e[U5$)Nz+Must specify at least one bootstrap server.)r#list)rBrs rr$KafkaSourceClientV1._BuildBrokerUris"s& * 7  ! ""rc4Uc [S5e[U5$)Nz Must specify at least one topic.)r&r)rBrzs rr KafkaSourceClientV1._BuildTopics)s ~ &'I JJ <rc\Uc [S5eSURSURSU3$)Nzmessage_bus must be set projects/z /locations/z/messageBuses/)r projectsId locationsId)rBrOrs rr%KafkaSourceClientV1._BuildDestination.s@ +,E FF '223;?O?[?[>\\jkvjw xxrcUc [S5eURRSURSURSU3S9$)Nznetwork_attachment must be setrz /regions/z/networkAttachments/)networkAttachment)rr? NetworkConfigrr)rBrOrs rr'KafkaSourceClientV1._BuildNetworkConfig3sd! -.N OO >> ' '%&6&A&A%B)L\LhLhKii}Q~RS ( rc<UcS[R"53$U$)Nz eventarc-)uuiduuid4)rBrs rr)KafkaSourceClientV1._BuildConsumerGroupID:s!  '' rc<UcgUS:waUS:wa [S5eU$)Nnewestoldestz.initial_offset must be one of newest or oldest)r))rBrs rr'KafkaSourceClientV1._BuildInitialOffset?s2 !n&@ - :  rc USLUSL-USL-nUSLUSL-nUS:aUS:a [S5eUS:aSUS:wa [S5eURRURRUR U5UUS9SS9$US:aZUS:wa [S5eURRSURR URR UUS 9S 9S9$[S5e) NrzExactly one of the following authentication methods must be set: - SASL Authentication (--sasl-mechanism, --sasl-username, --sasl-password) - TLS Authentication (--tls-client-certificate, --tls-client-key)zpWhen using SASL Authentication, all three arguments sasl_mechanism, sasl_username, and sasl_password must be set) mechanismusernameSecretpasswordSecret)saslAuth mutualTlsAuthzYWhen using TLS Authentication, both tls_client_certificate and tls_client_key must be set)clientCertificate clientKey)secretManagerResources)r r?AuthenticationConfigSaslAuthConfig_ConvertSaslMechanismToEnumMutualTlsAuthConfigMutualTlsSecrets)rBrrrrr num_args_sasl num_args_mtlss rr.KafkaSourceClientV1._BuildAuthenticationConfigHsh t #  $ &  $ & ,47d"Mq]Q. 4  q ! 6 L  ^^ 0 0>>0088H**1  1q ! 6 *  ^^ 0 0::%)^^%D%D$:*&E&; 1 3  rcUcgURRURRRU5S9$)N) logSeverity)r? LoggingConfigLogSeverityValueValuesEnum)rBrs rr'KafkaSourceClientV1._BuildLoggingConfigsB  >> ' 'NN00KK   ( rcUS:Xa%URRRS5$US:Xa%URRRS5$US:Xa%URRRS5$[S5e)z)Convert human-readable mechanism to enum.PLAINz SCRAM-SHA-256SHA_256z SCRAM-SHA-512SHA_512zDsasl_mechanism must be one of PLAIN, SCRAM_SHA_256, or SCRAM_SHA_512)r?rMechanismValueValuesEnumr )rBrs rr/KafkaSourceClientV1._ConvertSaslMechanismToEnums}G ^^ * * C CG LLO# ^^ * * C CI NNO# ^^ * * C CI NN 2  r)r?rA)F)rrrrrr:rNrbrgrnrtrrrrrrrrrrrrr __classcell__)rDs@rr5r5BsjR ;,.0 &*,, $LD!L2# y  ;z  rr5)r __future__rrrrapitools.base.pyrgooglecloudsdk.api_lib.eventarcrrgooglecloudsdk.api_lib.utilr googlecloudsdk.corer r Errorr rrr r#r&r)r3EventarcClientBaser5rrrrs/&' '02,*)CZ--CS (8(8SGj&6&6GLz/?/?LMZ%5%5MB!1!1BJ (8(8J"W$11Wr