R8SrSSKrSSKJr SSKJr SSKJr SSKJ r SSK Jr SSK J r SSK J r \ R"S S 5rS rS rS rSrSrSrSrSrSrSrSrSrSrSrSrSrSr Sr!Sr"Sr#Sr$S r%S!\&4S"jr'S!\&4S#jr(S(S$jr)S%r*S&r+S'r,g))zDA library used to support Managed Service for Apache Kafka commands.N)encoding) exceptions)core)apis)log) properties managedkafkav190929192z /contexts/z /subjects/z/mode/z/config/c@US:a[R"SS5eU$)zValidate CPU >= 3.z--cpuzCPU must be at least 3)rBadArgumentException)cpus 4lib/googlecloudsdk/command_lib/managed_kafka/util.py ValidateCPUr&s"1W  ) )'3K LL *cUR(dU$UR(d0UlSn[URU5Ul[ XU5$)zPrepare the update request with the information from the subnet flag. Args: _: resource parameter required but unused variable. args: list of flags. request: the payload to return. Returns: The updated request with the subnet. %gcpConfig.accessConfig.networkConfigs)subnetsclusterAppendUpdateMask updateMaskMapSubnetsToNetworkConfig)_argsrequestsubnet_update_masks rPrepareUpdateWithSubnetsr-sI  N GO>'(:(:G N    N GO:'(:(:'+N) 00AA(K+'0k9+$>+ ! X{##(:(:-6Kq *DK&' rc[RRUR5nS[R "U[ RR50Ul SUl U$)zLoad the topics JSON from the argument to the request. Args: _: resource parameter required but unused variable. args: list of flags. request: the payload to return. Returns: The updated request with topics. topics) ryamlload topics_filerr2r3 ConsumerGroup TopicsValue consumerGroupr)rrrr^s r UpdateTopicsresV 99>>$** +&&& (((44'  ' .rcUR(dUR(dU$URR(d0URlS/0URRlUR(dS/0nOUR//S.nUR (d/Ul[ UR 5US'UR(d/Ul[ UR5US'URRRRR[R"U[R55 [U[R5(au[R "SSUR"5Ul[R "SSUR"5Ul[R "SSUR"5UlU$) zMaps subnets and DNS names to the network config API field. Args: _: resource parameter required but unused variable. args: list of flags. request: the payload to return. Returns: The updated request with networkConfig in the JSON format. r-dns_domain_names)primary_subnetadditional_subnetsrgriz7gcpConfig\.accessConfig\.networkConfigs\.dnsDomainNamesrz6gcpConfig\.accessConfig\.networkConfigs\.primarySubnetz:gcpConfig\.accessConfig\.networkConfigs\.additionalSubnets)rhdns_nameconnectClusterr/r0additional_subnetlistr-r1rr2r3ConnectNetworkConfig isinstance8ManagedkafkaProjectsLocationsConnectClustersPatchRequestresubr)rrrr5s rMapConnectParamsToNetworkConfigrss   T]] N    ) )')G$3CR2H'""/  ("-N-- N   D)-d.D.D)E.%& DM'+DMM':.#$ ""//>>EE^X-J-JK GG B/G A/G E/G .rcUR(ag[RRUR5n[R "U[ RR5URl UR=(d< [RRRRR5nURn[ R""SUR5(dFUR$=(d UR&R)S5SnSUSUSUR3nXRRlU$)zLoad the config JSON from the argument to the request and build the kafka cluster resource path. Args: _: resource parameter required but unused variable. args: list of flags. request: the payload to return. Returns: z$projects/.+/locations/.+/clusters/.+rGrz projects/z /locations/z /clusters/) config_filerr_r`rr2r3ConnectCluster ConfigValuerkconfigrPrrOrQ kafka_clusterrqmatchrYconnect_clusterrN kafkaCluster)rrrrxrPkafka_cluster_pathrYs rPrepareConnectClusterCreater~5s  YY^^D,, -F$,$:$:''33%G! LL EDOO2277??CCE')) 94;M;M N N}}B 4 4 : :3 ? BH G9KzDG )3G )'*<*./ "" D ) ) 7 783>./*2*@*@   +G' .rcUR(d0UlUR(a[RR UR5n[ R "U[RR5URl [URS5Ul 0nUR(a%[URR5S-US'UR (a%[UR R5S-US'U(a4[ R "U[R"5URlU$)zLoad the config JSON from the argument to the request, and parse out the task restart policy. Args: _: resource parameter required but unused variable. args: list of flags. request: the payload to return. Returns: rrrr)rrurr_r`rr2r3rrrrrrrrrrrrs r-ConnectorUpdateReadConfigAndTaskRestartPolicyrs    G  YY^^D,, -F ( 6 6""//!G*'*<*./ "" D ) ) 7 783>./*2*@*@   +G' .rcUR(aURRS5nURS5 /nURR 5HupPUR SUS35 M [ SRU5SRU55UlUR(a[ URS5UlU$)zUnnest the configs dictionary to the update mask. Args: _: resource parameter required but unused variable. args: list of flags. request: the payload to return. Returns: The new update mask with the configs. r'rz configs["z"]) rrrNremoveitemsr1rjoinr)rrrr* configs_listkeys r PatchConfigsrs \\$$**3/Ky!L,,$$&IcU"-.') sxx 5G )'*<* >>  x""66???  x""66===  rcU[RRR:XagU[RRR:XagU[RRR :XagU[RRR :XagU[RRR:XagU[RRR:Xagg)zParse the compatibility enum to a string. Args: compatibility: The compatibility enum of the schema registry or subject. Returns: The compatibility string. BACKWARDBACKWARD_TRANSITIVEFORWARDFORWARD_TRANSITIVEFULLFULL_TRANSITIVEr) r3 SchemaConfigCompatibilityValueValuesEnumrrrrrr) compatibilitys rParseCompatibilityrs    ; ; D DE     ; ; O OP !    ; ; C CD     ; ; N NO --JJOOO     ; ; K KL  rcvU=(d1 [RRRR SS9$)NT)required)rrOrrPrQ) project_ids r ParseProjectrs-  Hz((--559949HHrcp[R"SS5n[R"SS5nUnU[U3nU(aa[R R SU-5 URUS9nURRUS9 [R"USS9 g [R R SU-5 UR%US9nUR&RUS9 [R"USS9 g ![Ran[R"U[5n[R R UR 5 SUR ;a$[R"US R#U5S 9eS nAg S nAff=f![Ran[R"U[5n[R R UR 5 SUR ;a$[R"US R#U5S 9eS nAg S nAff=f) a3Called when the user runs gcloud managed-kafka schema-registries subject delete ... Args: subject: The subject of the attribute to delete. subject_run_resource: The subject resource path. context: The context of the schema registry if provided. Returns: The updated subject with its mode deleted. r r zDeleting subject mode for [%s].rArzmode. It is now unset.detailsResource not foundSubject {} not found. error_formatN)rGetMessagesModuleGetClientInstanceSUBJECTS_MODE_RESOURCE_PATHrstatusPrintFManagedkafkaProjectsLocationsSchemaRegistriesContextsModeDeleteRequest1projects_locations_schemaRegistries_contexts_modeDeleteUpdatedResourceapitools_exceptionsHttpNotFoundErrorr HttpExceptionHTTP_ERROR_FORMATmessageformat>ManagedkafkaProjectsLocationsSchemaRegistriesModeDeleteRequest(projects_locations_schemaRegistries_mode) subjectsubject_run_resourcecontextrclientschema_registry_resourcere api_errors rDeleteSubjectModers   " ">4 8'  ! !.$ 7&1 ""#>"?yI  JJ6@A\\ %]G   >>EEF '+CDJJ6@ANN) O    55<4 8'  ! !.$ 7& $ %&C%DWI N$ JJ87BC^^ _G   @@GGH '+EFJJ87BCVV WG   77>>w>O '+EF  0 0 **1.?@i jjy(() !2!2 2&& 3::7C   3   0 0 **1.?@i jjy(() !2!2 2&& 3::7C   3 s24.D.FFA8FFH31A8H..H3z;ResponseError: code={status_code}, message={status_message})N)-__doc__rqapitools.base.pyrrrgooglecloudsdkrgooglecloudsdk.api_lib.utilrgooglecloudsdk.calliopegooglecloudsdk.corerrrr3rVrXCONTEXTS_RESOURCE_PATHSUBJECTS_RESOURCE_PATHrrrrr%rrr#rCrEr@rersr~rrrrrrrrrrrr)rrrsK %>,.#*  ! !.$ 7   %%& * 54!1H C.:  :6*9x6@!H"J4s(%%PI7 t. dBr