pcloudPlatformScope _requesterprojects locationsclustersconnectClusters operationsschemaRegistriesgetlistaclsconsumerGroupstopicscreatedeletepatch addAclEntryremoveAclEntry connectorspauserestartresumestopcancel compatibilityconfigcontextsmodeschemassubjectscheckCompatibilityupdatetypesversions getSchema lookupVersion referencedbynetworkConfigstoJson aclEntriesetagname patternType resourceName resourceTypehost operationpermissionType principalacl aclCreated brokerIndexnodeIdrack memoryBytes vcpuCountcaPool referencesschema schemaTypeverbose isCompatiblemessages brokerDetailscapacityConfig createTime gcpConfig kafkaVersionlabelsrebalanceConfig satisfiesPzi satisfiesPzsstate tlsConfig updateOptions updateTime kafkaCluster accessConfig secretPathsadditionalSubnetsdnsDomainNames primarySubnetconfigstaskRestartPolicymetadataoffset partitionsschemaRegistryschemaRegistryIdid normalizeversionkmsKey nextPageToken unreachabledeletedsubnetdoneerrorresponse aclDeletedaliassubjectmaximumBackoffminimumBackofftaskRetryDisabledsslPrincipalMappingRules trustConfigpartitionCountreplicationFactor casConfigs$allowBrokerDownscaleOnClusterUpscale_ManagedKafkaApiProjectsResourceProjectsLocationsResource!ProjectsLocationsClustersResource%ProjectsLocationsClustersAclsResource/ProjectsLocationsClustersConsumerGroupsResource'ProjectsLocationsClustersTopicsResource(ProjectsLocationsConnectClustersResource2ProjectsLocationsConnectClustersConnectorsResource#ProjectsLocationsOperationsResource)ProjectsLocationsSchemaRegistriesResource6ProjectsLocationsSchemaRegistriesCompatibilityResource/ProjectsLocationsSchemaRegistriesConfigResource1ProjectsLocationsSchemaRegistriesContextsResource>ProjectsLocationsSchemaRegistriesContextsCompatibilityResource7ProjectsLocationsSchemaRegistriesContextsConfigResource5ProjectsLocationsSchemaRegistriesContextsModeResource8ProjectsLocationsSchemaRegistriesContextsSchemasResource@ProjectsLocationsSchemaRegistriesContextsSchemasSubjectsResource=ProjectsLocationsSchemaRegistriesContextsSchemasTypesResource@ProjectsLocationsSchemaRegistriesContextsSchemasVersionsResource9ProjectsLocationsSchemaRegistriesContextsSubjectsResourceAProjectsLocationsSchemaRegistriesContextsSubjectsVersionsResourceMProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyResource-ProjectsLocationsSchemaRegistriesModeResource0ProjectsLocationsSchemaRegistriesSchemasResource8ProjectsLocationsSchemaRegistriesSchemasSubjectsResource5ProjectsLocationsSchemaRegistriesSchemasTypesResource8ProjectsLocationsSchemaRegistriesSchemasVersionsResource1ProjectsLocationsSchemaRegistriesSubjectsResource9ProjectsLocationsSchemaRegistriesSubjectsVersionsResourceEProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyResource AccessConfigAclAclEntryAddAclEntryResponse BrokerDetailsCancelOperationRequestCapacityConfig!CertificateAuthorityServiceConfigCheckCompatibilityRequestCheckCompatibilityResponseClusterConnectAccessConfigConnectClusterConnectGcpConfigConnectNetworkConfig Connector ConsumerGroupConsumerPartitionMetadataConsumerTopicMetadataContextCreateSchemaRegistryRequestCreateVersionRequestCreateVersionResponseEmpty GcpConfigHttpBodyListAclsResponseListClustersResponseListConnectClustersResponseListConnectorsResponseListConsumerGroupsResponseListLocationsResponseListOperationsResponseListSchemaRegistriesResponseListTopicsResponseLocationLookupVersionRequest NetworkConfig OperationPauseConnectorRequestPauseConnectorResponseRebalanceConfigRemoveAclEntryResponseRestartConnectorRequestRestartConnectorResponseResumeConnectorRequestResumeConnectorResponseSchema SchemaConfig SchemaModeSchemaReferenceSchemaRegistry SchemaVersionStatusStopConnectorRequestStopConnectorResponseTaskRetryPolicy TlsConfigTopic TrustConfig UpdateOptionsUpdateSchemaConfigRequestUpdateSchemaModeRequestApiRequestErrorDetailedApiRequestError ApiRequesterClientStringrootUrl servicePathrequestHeaders$fieldsFutureListUri encodeFullrequest queryParamsfromJsonMapdynamicextraLocationTypesfilterpageSize pageTokenint clusterId requestIdjsonencodebodyvieworderBy updateMaskaclIdtopicIdconnectClusterId connectorIdreturnPartialSuccessbooldefaultToGlobalsubjectdeleted permanent subjectPrefixnetworkConfigsmapvaluetoList aclEntriesetagname patternType resourceName resourceTypehost operationpermissionType principalacl containsKey aclCreated brokerIndexnodeIdrack$Empty memoryBytes vcpuCountcaPool referencesschema schemaTypeverbose isCompatiblemessages brokerDetailscapacityConfig createTime gcpConfig kafkaVersionlabelsMapEntrykeyrebalanceConfig satisfiesPzi satisfiesPzsstate tlsConfig updateOptions updateTimeconfig kafkaCluster accessConfig secretPaths DeprecatedadditionalSubnetsdnsDomainNames primarySubnetconfigstaskRestartPolicytopicsmetadataoffset partitionssubjectsschemaRegistryschemaRegistryIdid normalizeversionkmsKey $HttpBodyacls nextPageTokenclusters unreachableconnectClusters connectorsconsumerGroups locations operationsschemaRegistries $Location00subnetObjectdoneerrorresponsemode aclDeletedalias compatibilitycontexts $Status00maximumBackoffminimumBackofftaskRetryDisabledsslPrincipalMappingRules trustConfigpartitionCountreplicationFactor casConfigs$allowBrokerDownscaleOnClusterUpscale q"#'8ZApiRequestErrorDetailedApiRequestErrorh:package:_discoveryapis_commons/_discoveryapis_commons.dartWjmasyncm dart:asyncuconvert dart:convertcore dart:corecommons:package:_discoveryapis_commons/_discoveryapis_commons.dart#&http&package:http/http.dart.../shared.dartG../src/user_agent.dartqGHmЀ)[ʂ*`aÂǂ*.uyV2h+z‡Q3}Lj͉!]+tLUVt,-Fghߌ(xÍ%&gh{׎#4F\uďŏ gijaՒ Pޒߓ(.] -3l !Q]j/5ј j17֙Bښ,MS;KQ؜gmȸθGTZ,FS45eq~4:TZ17tzXv|`ڿ@@%@v@@@AA:ATAmAAAAAB"BUBBCC:CACBCCCCCCCD%D]DdDhDiDDDDDDE;EEEEF4FFGGfGHHVHHIIImIJ J[JJJJJKKKfKsKyKKL L5LMLiLLLLMMYMMMMN N N=NINXNkNNNNNNOOBOCOOOOOPPPFPLPfPlPPQQgQQRRRhRxR~RRSSSSgSSSSTT!TQTTTTUUUFURU`UsUUUUVVVVMVSVVVVVWWLWjWWXXIXXY,YjYYZZdZZ[8[>[[[[[\\!\'\x\\\\] ]&]3]c]]^^^^S^T^^^^^^_$_(_)_?_E___e_``M```aaNa^adaaaaab?btbcc8c?c@cwcxcccccd9d=d>dldrddde-ezeef*f0f{ffffggggjggh)h^hehfhhhhhiiiZi^i_iiiiijjSjqjjkkPkjkpkll_lul{lllmm m^mkmqmmnn8nPnlnnnooMoooooop pp8p?peppppppq qq,q2qqqr<rrssgsst0ttuu"uiuouvv\vvvvvwwwhwuw{wxxx-xExbx|xxxy8ymytyuyyyyyz z,z3z~zzzz{{:{@{o{u{{{{|H|||}E}K}}}}}~4~A~G~~1KXOP9@DFG;A[a%v|Tag<|!-=^eesEK+8>&f $ELo [y kEw}^3UE(.ciS)iCx 8?o!'AGHf U(.y!r6Cs'./fgHOSUVNT OmKbh@MS $>Xe @GH `de6T )/hMYi39 [a9FL^=D4JB@ LR<eXGS`$*Y_y ]{l 28#t(5e !XY,023dd &tkDlrW¡?Î0tĢĨ -3ńőŗ?[uƘƴ Kǜ cdȔȠȮ:>?gmɇɍCaʧʭI˒*zkͯ.>Dhnο#XzϒϮQІЍЎ3:ыяѐ;j$*uӅӋӴӺ oԤG|ՃՄջռ&-Q։֐֔֕Qyת39u{=Cو&^dگڿR_e۶7Pj܂ܞܸ8nݬ$%stޤް޽NUYZߚߠBN ]A.BH38>(Ie} M<=myV-3bhLjPM]cBw?GHx"#>D^d7n{V ;GWx %+uqwS`f<|!-:[bf>DKhx~j4A078W^bc2dR{ ]jp.Fc} 9 n u v       - 4          ]   : @      ) 6 <   +ERABr~+267U[f.>Dw}2g-m+9LmtFLfl >06 Pt#X_`")V ]:@(5;'AN~ < = m y     !%!,!0!2!3!_!!!!!","2""##h#$$U$p$v$$$$%%,%m%s%%%%%&K&X&^&&''&'>'X'e''( (((U(V(((((()(),)-)U)[))*=*C*]*c**++ +T+d+j+++++,E,z,- ->-E-F-}-~-----.?.C.D.}....///Q/o//0000;0A00001+1{11112/202`2l2y222223>3D33333494?4j4p44445/5566c6667H7X7^777778J888889969P9]99::J::::::;D;E;u;;;;;<(>d>>?+?o???@@@C@I@x@~@@@A6A|AAAAB BBcBpBvBBC#CLCfCCCCD2D9D:DDDDDDEEE3EkErEvEwEEEEFF*F}FFFG3GCGIGiGoGGGH$HYHHII$I%I\I]IIIIIJJ"J#JKJQJkJqJJK(KFKKKKKLL#LtLLLM M1MIMcMpMMMMN$N%NUNaNnNNNNNNNOO"O<OBOOP!P'PuPPPQ;QhQRR>RRRS SS"SYS_SSSTTIT|TTTTUUAUvU}U~UUUV VV8V?VqVVVVVVWW WZW{WWWWWX.X4XNXTXXY5YYZ ZbZZZ[)[9[?[t[z[[[\/\d\\\\] ]9]y]]]]]^^*^8^K^l^s^^^^^^_!_J_K_____```V`l``a=aCaaaaab"b/b5bbbbccc_cccccddd dAdHdjddddddeeeZeweefWffffgCggggghhhnh{hhii)iAiai{iiij j/jdjkjljjjjjkkk7kokvkzk{kkkll3l9lSlYllmmEmmmnCnInnnnno(o5o;ooop p%p?pLp|ppppq0q1qaqmqzqqqqrrrrrrWrrrrss3s<sstt\ttu>uuuuuvvv0v6vvww_wewwwwwx?xLxRxxy&yfyyyyyz zz$zEzLzzzzzzz{9{{{{|B|R|X|{||||}6}k}}}}~ ~@~G~H~~~~~~QUWX ,GHS~0K16<&e;pwx .5ePq-C%+v nG|)0RB_?h<gtz":Zt(]de0host,2LR>MS2?E/IV:;kw $&'e-3MSaqwW.cjk7ovz{{Nl-3X^HMN~"#W][.L 8>(KpT[\8pw{}~,>A8Ytu}P,2SYC_w.cjk bfgB+1}IY_=r/e"/PW !e :@#%q1AGjp%Zy“«,gÝ!"R^kČē0YZśż:@Z`ư%CǛǡ%+|ȉȏ4Nhuɵ>?o{ʈʩʰPyz˾39z̾H_Kim}σ'-PVЧдк @_yёѫM҃Ҹҿ8DQry;<ԀԒ6WrsՋՑLֲֻ4R׻_خ>QW٢ٲٸ2?Eږ8Eۅ:;kw܇ܨܯ06lr݌ݒ[d@Fߒ߸߾Y4DJms(]|5p<=my6<kqHQQW7DJ9S`  FGw'.245dxNThqqw_lr&Hb|.56}~.fmqrEQ_}H8"(y3Ke BIJFJK $B [DJ4Wo)^ef2jquv ]iw^YioM=x ) 5 B c j      * 0 J P        $ p     " E K   5Tn(]denrtuFg _m VflJT[\imop89agKS39#)zQ3:Z=9q / ? E j p   !%!Z!!" "'"("_"`""""""#)#0#4#5#i#o####$ $m$%%@%^%%%&&&9&?&&&&')'L'q''''( (U(\(](((((()))9)q)x)|)~))))*-*y*++R+++, , ,9,?,Y,_,--1---.!.P.V.....///</B////0000=0}00001'1(1X1d1q111112!2'2U2[2u2{23/3M3334=4l4r444445M5Z5`556 6"6<6V6c667777Y7Z77777888!8"8c8888999B9H9~9999::~:;; ;r;x;;;<3<9<<<<<==!='=x====>>2>?>>>?%?,?-?t?u?????@6@:@<@=@{@@@@AAABAHA}AAAABBhBBBCC.C4CWC]CCCDDGDfDDDDEE#E$EpEqEEEEEF2F6F8F9FzFFFGGGGUG[GGGGHHHjHHHImIIIJ/J~JJJJK(K8K>KaKgKKKLLQLpLLLLLM#M^MMMMNNNINUNbNNNNNNOODOEOOOP0PKPLPdPjPPPPQ%QQR R+RRRS'SvSTTTTjTzTTTTUU U^UUUUVV VMVVVVWWW3W?WOWpWwWWWWWX4X:XTXZXXY#Y,YYYYZIZoZuZ[[^[[[[\\$\*\{\\\]]3]M]e]]]]^'^o^^^^^_$_0_=_^_e_____`"`(`B`H``aaaaabHbXb^bbbbbcAcvccccdd6dvdddddee)e7eJekereeeeeeffFfGfffggggMgnggggh hh)h/h|hhhipiiij7jGjMj}jjjjk8kmkkkkkl.lnlllllm#m/m=mPmqmxmmmmmn nnEnKnenknno?oHoop[pappqLqqqrrMr]rcrrrrrsAsvssssst0tqtttttuu"u2uSuZuuuuuvvvnvzvvwwxxx^xxyyyYyiyoyyyyzzRzzzzz{{A{|{{{{{|!|-|:|[|b|||||}} }:}@}Z}`}}~5~>~~QW=JP+8>2?:;kw&,lrW`OU=MSv|1fY'HOg +1fv| Z/dkl")y}5;(h{  )*[ JV/5(y*?@RXM'xA*+]c?[at89AVet"5a/jGc/DY|/?Ek(<BRlme 78\@fs7NZ[ ,R(Bj ">?`fyEQ%Oo?@q,2B^_AM$J<BY #$XY=ACDh*ABgm}3^yz  67Uj{"5h Fw"DQrCI01gs-67h7Gy%+;]^ "2JK}ƒ«± GHZ`Ð&,<`aĀĆęĴĵ 17Jlť5h~Ʈƴ,?EUuvǨǮ/CZkzȔȫ=Iɇɚ (?{ʢOˁˣO̟Ý1lΛ:J^ϘϾ 1jstХ+Q}ѝѹCa҇ҵ:[zӟӸBYxԟ (y՚ՠ78fg֖֢-k|׊סת׫ <@BCؖ  V\٫BH[vw`f}۾$4bcu{ܹ()HNa|}ݜݢݵ  B{ޮ 9OP߂߈ߛ߶߷ 4ETk G OZ9I].9f DMNIi#0Yr*OfHN^Knt X0cz TXZ[2!=CSg.LRCIY2e+CIJzVP:AEGH<BR3HIsy2CqJ`aDPE&:CDu/D[EBH!"MNw):f @osuv28Hab$%Zf+K:RXh   ' w    - @ Q ` i j       = K [ m s   Q      1 7 G k l     $Wnwx "#UyNT89-}!Q2U[(.>NO(RSlr <4:+IO_tu3?eVgu&/0ay1>On0cst&>VZ\]  o     !!C!I!Y!w!x!!"" "{""""""# ##M#r###$$$$P$|$$$$$%%%f%%&N&&':''(%(l() )W)))))**?*E*q*****+&+D+E+z+{++++, ,Y,g,~,,,,--B-------...c.r.x..../$/%/t/u////0#0a0r00011C1Z1c1d111222;2b222222233G3H3333444.4U4V4v44444455J5]555566B6|66667737a77778 88888<8[8889999R9p9q9999:):<:i::::;;%;&;W;;;;;;<"$>0>p>>>???(?g?p?q??@@Q@U@W@X@@@AAADAbAcAAAABB)BUBBBBCCCCCCiCCCCCDD<DeDDDDDE EEOEEFF(F)FDF\FqFFFFFG GCGVGGGGGH1HdH{HHHHI I6ICIjIIIIIIIJJ,J[J\JJJJKK1KcKKKKKKLLFLzL~LLLLMMMMUMsMtMMMMMN0N1N_NkNNNOOVOdO{OOOOPPEPIPKPLPPPPPQ/Q\QbQQQQQR"R(RDRJRZRrRsRRRRRRSSS*S+SPSVSfSSSTTGTbTcT|TTTTTTTUU UQUUUVVBVSVaVxVVVVWW?WeWWWWWXX=XVXwX~XXXXXYYOYYYYZEZZZZZZZZ[[K[L[}[[[[[\\(\:\\\\]]]N]_]`]]]^?^^^^_3_d_e___`*`V`k`l```aGaab0b~bbccFcGcccccdd<ddddee2e_eeeeef%fAf_ffffffgg.gKgRgVgXgYgygggggh"h:hhhnhhhhiiXiiiijjj=jnjojjjjjjkkk6k<kkkkl l%l&l]l^lllmm&m]mfmgmmmnnnnn8nbncnnnnnnooIoJojoyoooooppppApGpWpyppq q8qSqTqqqqqr r<rzrrrrss#s$sUs}sssst t-t4t8t:t;tttttuuu)u?u@uluruuv@vFvVvxvvw:wwx xpxxxxxyDyyyyyyz+z,zTz`zz{{ { {>{\{{{{{||!|%|'|(|w|{|}}h}~~V~d~w~+M3Yy4Plprs,2BZ[L(J-QRdjON$@swyz+UVpvIl&'<BRghz"H#:kBZ,Mf^bL=>{k*q 3{5;pv1Jflm&ktu<Ir fl%q KQa23st<` Pz)q>?QW 56ek IO_{|89Q~  ;]yEt{$6<L*oFnrtuLb&,{*0@st_hi 9jquwx +X^%Gp O?Omn Z.:y=2>^st3Okoq/// Managed Service for Apache Kafka API - v1 /// /// Manage Apache Kafka clusters and resources. /// /// For more information, see /// /// /// Create an instance of [ManagedKafkaApi] to access these resources: /// /// - [ProjectsResource] /// - [ProjectsLocationsResource] /// - [ProjectsLocationsClustersResource] /// - [ProjectsLocationsClustersAclsResource] /// - [ProjectsLocationsClustersConsumerGroupsResource] /// - [ProjectsLocationsClustersTopicsResource] /// - [ProjectsLocationsConnectClustersResource] /// - [ProjectsLocationsConnectClustersConnectorsResource] /// - [ProjectsLocationsOperationsResource] /// - [ProjectsLocationsSchemaRegistriesResource] /// - [ProjectsLocationsSchemaRegistriesCompatibilityResource] /// - [ProjectsLocationsSchemaRegistriesConfigResource] /// - [ProjectsLocationsSchemaRegistriesContextsResource] /// - [ProjectsLocationsSchemaRegistriesContextsCompatibilityResource] /// - [ProjectsLocationsSchemaRegistriesContextsConfigResource] /// - [ProjectsLocationsSchemaRegistriesContextsModeResource] /// - [ProjectsLocationsSchemaRegistriesContextsSchemasResource] /// - [ProjectsLocationsSchemaRegistriesContextsSchemasSubjectsResource] /// - [ProjectsLocationsSchemaRegistriesContextsSchemasTypesResource] /// - [ProjectsLocationsSchemaRegistriesContextsSchemasVersionsResource] /// - [ProjectsLocationsSchemaRegistriesContextsSubjectsResource] /// - [ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsResource] /// - /// [ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyResource] /// - [ProjectsLocationsSchemaRegistriesModeResource] /// - [ProjectsLocationsSchemaRegistriesSchemasResource] /// - [ProjectsLocationsSchemaRegistriesSchemasSubjectsResource] /// - [ProjectsLocationsSchemaRegistriesSchemasTypesResource] /// - [ProjectsLocationsSchemaRegistriesSchemasVersionsResource] /// - [ProjectsLocationsSchemaRegistriesSubjectsResource] /// - [ProjectsLocationsSchemaRegistriesSubjectsVersionsResource] /// - [ProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyResource]Vmt&-FhRjy<ێ !|,=Oejjɍ*r/// See, edit, configure, and delete your Google Cloud data and see the email /// address for your Google Account.%((>=//// Manage Apache Kafka clusters and resources."233H]R_""D%ǏWԒɒ֒M%f!!{Nl~<::FMMZ6/// Gets information about a location. /// /// Request parameters: /// /// [name] - Resource name for the location. /// Value must have pattern `^projects/\[^/\]+/locations/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Location]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.* '66C?/// Lists information about the supported locations for this service. /// /// This method can be called in two ways: * **List all public locations:** /// Use the path `GET /v1/locations`. * **List project-visible locations:** /// Use the path `GET /v1/projects/{project_id}/locations`. This may include /// public locations as well as private or other locations specifically /// visible to the project. /// /// Request parameters: /// /// [name] - The resource that owns the locations collection, if applicable. /// Value must have pattern `^projects/\[^/\]+$`. /// /// [extraLocationTypes] - Optional. Do not use this field. It is unsupported /// and is ignored unless explicitly documented otherwise. This is primarily /// for internal usage. /// /// [filter] - A filter to narrow down results to a preferred subset. The /// filtering language accepts strings like `"displayName=tokyo"`, and is /// documented in more detail in \[AIP-160\](https://google.aip.dev/160). /// /// [pageSize] - The maximum number of results to return. If not set, the /// service selects a default. /// /// [pageToken] - A page token received from the `next_page_token` field in /// the response. Send that page token to receive the subsequent page. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ListLocationsResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.jjqp񢟢Y$ %$33j]++pW{{ƪOo/// Creates a new cluster in a given project and location. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [parent] - Required. The parent region in which to create the cluster. /// Structured like `projects/{project}/locations/{location}`. /// Value must have pattern `^projects/\[^/\]+/locations/\[^/\]+$`. /// /// [clusterId] - Required. The ID to use for the cluster, which will become /// the final component of the cluster's name. The ID must be 1-63 characters /// long, and match the regular expression `[a-z]([-a-z0-9]*[a-z0-9])?` to /// comply with RFC 1035. This value is structured like: `my-cluster-id`. /// /// [requestId] - Optional. An optional request ID to identify requests. /// Specify a unique request ID to avoid duplication of requests. If a request /// times out or fails, retrying with the same ID allows the server to /// recognize the previous attempt. For at least 60 minutes, the server /// ignores duplicate requests bearing the same ID. For example, consider a /// situation where you make an initial request and the request times out. If /// you make the request again with the same request ID within 60 minutes of /// the last request, the server checks if an original operation with the same /// request ID was received. If so, the server ignores the second request. The /// request ID must be a valid UUID. A zero UUID is not supported /// (00000000-0000-0000-0000-000000000000). /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Operation]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.(77DOOS/// Deletes a single cluster. /// /// Request parameters: /// /// [name] - Required. The name of the cluster to delete. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+$`. /// /// [requestId] - Optional. An optional request ID to identify requests. /// Specify a unique request ID to avoid duplication of requests. If a request /// times out or fails, retrying with the same ID allows the server to /// recognize the previous attempt. For at least 60 minutes, the server /// ignores duplicate requests bearing the same ID. For example, consider a /// situation where you make an initial request and the request times out. If /// you make the request again with the same request ID within 60 minutes of /// the last request, the server checks if an original operation with the same /// request ID was received. If so, the server ignores the second request. The /// request ID must be a valid UUID. A zero UUID is not supported /// (00000000-0000-0000-0000-000000000000). /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Operation]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error. &00=/// Returns the properties of a single cluster. /// /// Request parameters: /// /// [name] - Required. The name of the cluster whose configuration to return. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+$`. /// /// [view] - Optional. Specifies the view of the Cluster resource to be /// returned. Defaults to CLUSTER_VIEW_BASIC. See the ClusterView enum for /// possible values. /// Possible string values are: /// - "CLUSTER_VIEW_UNSPECIFIED" : The default / unset value. The API will /// default to the BASIC view. /// - "CLUSTER_VIEW_BASIC" : Include the basic metadata of the Cluster. This /// is the default value (for both ListClusters and GetCluster). /// - "CLUSTER_VIEW_FULL" : Include everything, including data fetched from /// the Kafka cluster source of truth. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Cluster]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.A>A>AJAXAXAeAqAqA~AAAAAAAAAkA4/// Lists the clusters in a given project and location. /// /// Request parameters: /// /// [parent] - Required. The parent location whose clusters are to be listed. /// Structured like `projects/{project}/locations/{location}`. /// Value must have pattern `^projects/\[^/\]+/locations/\[^/\]+$`. /// /// [filter] - Optional. Filter expression for the result. /// /// [orderBy] - Optional. Order by fields for the result. /// /// [pageSize] - Optional. The maximum number of clusters to return. The /// service may return fewer than this value. If unspecified, server will pick /// an appropriate default. /// /// [pageToken] - Optional. A page token, received from a previous /// `ListClusters` call. Provide this to retrieve the subsequent page. When /// paginating, all other parameters provided to `ListClusters` must match the /// call that provided the page token. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ListClustersResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.L$L$L,L9L9LELQLQL^LmLmLzLLLDkDk|LG/// Updates the properties of a single cluster. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Identifier. The name of the cluster. Structured like: /// projects/{project_number}/locations/{location}/clusters/{cluster_id} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+$`. /// /// [requestId] - Optional. An optional request ID to identify requests. /// Specify a unique request ID to avoid duplication of requests. If a request /// times out or fails, retrying with the same ID allows the server to /// recognize the previous attempt. For at least 60 minutes, the server /// ignores duplicate requests bearing the same ID. For example, consider a /// situation where you make an initial request and the request times out. If /// you make the request again with the same request ID within 60 minutes of /// the last request, the server checks if an original operation with the same /// request ID was received. If so, the server ignores the second request. The /// request ID must be a valid UUID. A zero UUID is not supported /// (00000000-0000-0000-0000-000000000000). /// /// [updateMask] - Required. Field mask is used to specify the fields to be /// overwritten in the cluster resource by the update. The fields specified in /// the update_mask are relative to the resource, not the full request. A /// field will be overwritten if it is in the mask. The mask is required and a /// value of * will update all fields. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Operation]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.ݠݮ OEOjOkOkOOOOOEOE]O6O%O6SSSSSSSST OO`S/// Incremental update: Adds an acl entry to an acl. /// /// Creates the acl if it does not exist yet. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [acl] - Required. The name of the acl to add the acl entry to. Structured /// like: /// `projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id}`. /// The structure of `acl_id` defines the Resource Pattern (resource_type, /// resource_name, pattern_type) of the acl. See `Acl.name` for details. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+/acls/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [AddAclEntryResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.\\ \\\\\\]]]]V V \\/// Creates a new acl in the given project, location, and cluster. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [parent] - Required. The parent cluster in which to create the acl. /// Structured like /// `projects/{project}/locations/{location}/clusters/{cluster}`. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+$`. /// /// [aclId] - Required. The ID to use for the acl, which will become the final /// component of the acl's name. The structure of `acl_id` defines the /// Resource Pattern (resource_type, resource_name, pattern_type) of the acl. /// `acl_id` is structured like one of the following: For acls on the cluster: /// `cluster` For acls on a single resource within the cluster: /// `topic/{resource_name}` `consumerGroup/{resource_name}` /// `transactionalId/{resource_name}` For acls on all resources that match a /// prefix: `topicPrefixed/{resource_name}` /// `consumerGroupPrefixed/{resource_name}` /// `transactionalIdPrefixed/{resource_name}` For acls on all resources of a /// given type (i.e. the wildcard literal "*"): `allTopics` (represents `topic /// / * `) `allConsumerGroups` (represents `consumerGroup / * `) /// `allTransactionalIds` (represents `transactionalId / * `) /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Acl]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.bbbbbb_+_+b /// Deletes an acl. /// /// Request parameters: /// /// [name] - Required. The name of the acl to delete. Structured like: /// `projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id}`. /// The structure of `acl_id` defines the Resource Pattern (resource_type, /// resource_name, pattern_type) of the acl. See `Acl.name` for details. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+/acls/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Empty]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.ggggggd@d@g6/// Returns the properties of a single acl. /// /// Request parameters: /// /// [name] - Required. The name of the acl to return. Structured like: /// `projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id}`. /// The structure of `acl_id` defines the Resource Pattern (resource_type, /// resource_name, pattern_type) of the acl. See `Acl.name` for details. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+/acls/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Acl]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.n"n"n.n<n<nFnTnTnanpnpn}iaiaFn]/// Lists the acls in a given cluster. /// /// Request parameters: /// /// [parent] - Required. The parent cluster whose acls are to be listed. /// Structured like /// `projects/{project}/locations/{location}/clusters/{cluster}`. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+$`. /// /// [pageSize] - Optional. The maximum number of acls to return. The service /// may return fewer than this value. If unset or zero, all acls for the /// parent is returned. /// /// [pageToken] - Optional. A page token, received from a previous `ListAcls` /// call. Provide this to retrieve the subsequent page. When paginating, all /// other parameters provided to `ListAcls` must match the call that provided /// the page token. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ListAclsResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.x x x$x1x1x=xIxIxVxfxfxsppx /// Updates the properties of a single acl. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Identifier. The name for the acl. Represents a single Resource /// Pattern. Structured like: /// projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id} /// The structure of `acl_id` defines the Resource Pattern (resource_type, /// resource_name, pattern_type) of the acl. `acl_id` is structured like one /// of the following: For acls on the cluster: `cluster` For acls on a single /// resource within the cluster: `topic/{resource_name}` /// `consumerGroup/{resource_name}` `transactionalId/{resource_name}` For acls /// on all resources that match a prefix: `topicPrefixed/{resource_name}` /// `consumerGroupPrefixed/{resource_name}` /// `transactionalIdPrefixed/{resource_name}` For acls on all resources of a /// given type (i.e. the wildcard literal "*"): `allTopics` (represents `topic /// / * `) `allConsumerGroups` (represents `consumerGroup / * `) /// `allTransactionalIds` (represents `transactionalId / * `) /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+/acls/.*$`. /// /// [updateMask] - Optional. Field mask is used to specify the fields to be /// overwritten in the Acl resource by the update. The fields specified in the /// update_mask are relative to the resource, not the full request. A field /// will be overwritten if it is in the mask. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Acl]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.*55Bzz~/// Incremental update: Removes an acl entry from an acl. /// /// Deletes the acl if its acl entries become empty (i.e. if the removed entry /// was the last one in the acl). /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [acl] - Required. The name of the acl to remove the acl entry from. /// Structured like: /// `projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id}`. /// The structure of `acl_id` defines the Resource Pattern (resource_type, /// resource_name, pattern_type) of the acl. See `Acl.name` for details. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+/acls/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [RemoveAclEntryResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.NNZN g% */// Deletes a single consumer group. /// /// Request parameters: /// /// [name] - Required. The name of the consumer group to delete. /// `projects/{project}/locations/{location}/clusters/{cluster}/consumerGroups/{consumerGroup}`. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+/consumerGroups/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Empty]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error./// Returns the properties of a single consumer group. /// /// Request parameters: /// /// [name] - Required. The name of the consumer group whose configuration to /// return. /// `projects/{project}/locations/{location}/clusters/{cluster}/consumerGroups/{consumerGroup}`. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+/consumerGroups/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ConsumerGroup]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.~K/// Lists the consumer groups in a given cluster. /// /// Request parameters: /// /// [parent] - Required. The parent cluster whose consumer groups are to be /// listed. Structured like /// `projects/{project}/locations/{location}/clusters/{cluster}`. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+$`. /// /// [filter] - Optional. Filter expression for the result. Only supports /// filtering by topic name as a key in the `topics` map. /// /// [pageSize] - Optional. The maximum number of consumer groups to return. /// The service may return fewer than this value. If unset or zero, all /// consumer groups for the parent is returned. /// /// [pageToken] - Optional. A page token, received from a previous /// `ListConsumerGroups` call. Provide this to retrieve the subsequent page. /// When paginating, all other parameters provided to `ListConsumerGroups` /// must match the call that provided the page token. /// /// [view] - Optional. Specifies the view (BASIC or FULL) of the ConsumerGroup /// resource to be returned in the response. Defaults to FULL view. /// Possible string values are: /// - "CONSUMER_GROUP_VIEW_UNSPECIFIED" : The default / unset value. The API /// will default to the FULL view. /// - "CONSUMER_GROUP_VIEW_BASIC" : Include the name of the ConsumerGroup. /// This hides partition and topic metadata. /// - "CONSUMER_GROUP_VIEW_FULL" : Include everything, including partition and /// topic metadata. This is the default value. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ListConsumerGroupsResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error. -ń/// Updates the properties of a single consumer group. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Identifier. The name of the consumer group. The `consumer_group` /// segment is used when connecting directly to the cluster. Structured like: /// projects/{project}/locations/{location}/clusters/{cluster}/consumerGroups/{consumer_group} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+/consumerGroups/.*$`. /// /// [updateMask] - Required. Field mask is used to specify the fields to be /// overwritten in the ConsumerGroup resource by the update. The fields /// specified in the update_mask are relative to the resource, not the full /// request. A field will be overwritten if it is in the mask. The mask is /// required and a value of * will update all fields. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ConsumerGroup]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.GG M _% ((5BBON/// Creates a new topic in a given project and location. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [parent] - Required. The parent cluster in which to create the topic. /// Structured like /// `projects/{project}/locations/{location}/clusters/{cluster}`. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+$`. /// /// [topicId] - Required. The ID to use for the topic, which will become the /// final component of the topic's name. This value is structured like: /// `my-topic-name`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Topic]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.66BIIVggz//// Deletes a single topic. /// /// Request parameters: /// /// [name] - Required. The name of the topic to delete. /// `projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic}`. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+/topics/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Empty]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error. 儯/// Returns the properties of a single topic. /// /// Request parameters: /// /// [name] - Required. The name of the topic whose configuration to return. /// Structured like: /// projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic}. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+/topics/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Topic]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.iiuZ_k/// Lists the topics in a given cluster. /// /// Request parameters: /// /// [parent] - Required. The parent cluster whose topics are to be listed. /// Structured like /// `projects/{project}/locations/{location}/clusters/{cluster}`. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+$`. /// /// [pageSize] - Optional. The maximum number of topics to return. The service /// may return fewer than this value. If unset or zero, all topics for the /// parent is returned. /// /// [pageToken] - Optional. A page token, received from a previous /// `ListTopics` call. Provide this to retrieve the subsequent page. When /// paginating, all other parameters provided to `ListTopics` must match the /// call that provided the page token. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ListTopicsResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error. 9|/// Updates the properties of a single topic. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Identifier. The name of the topic. The `topic` segment is used /// when connecting directly to the cluster. Structured like: /// projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/clusters/\[^/\]+/topics/\[^/\]+$`. /// /// [updateMask] - Required. Field mask is used to specify the fields to be /// overwritten in the Topic resource by the update. The fields specified in /// the update_mask are relative to the resource, not the full request. A /// field will be overwritten if it is in the mask. The mask is required and a /// value of * will update all fields. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Topic]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.VV\FGG\ujw`f%CCR__kyyƆƜƜƩƸƸ7N/// Creates a new Kafka Connect cluster in a given project and location. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [parent] - Required. The parent project/location in which to create the /// Kafka Connect cluster. Structured like /// `projects/{project}/locations/{location}/`. /// Value must have pattern `^projects/\[^/\]+/locations/\[^/\]+$`. /// /// [connectClusterId] - Required. The ID to use for the Connect cluster, /// which will become the final component of the cluster's name. The ID must /// be 1-63 characters long, and match the regular expression /// `[a-z]([-a-z0-9]*[a-z0-9])?` to comply with RFC 1035. This value is /// structured like: `my-cluster-id`. /// /// [requestId] - Optional. An optional request ID to identify requests. /// Specify a unique request ID to avoid duplication of requests. If a request /// times out or fails, retrying with the same ID allows the server to /// recognize the previous attempt. For at least 60 minutes, the server /// ignores duplicate requests bearing the same ID. For example, consider a /// situation where you make an initial request and the request times out. If /// you make the request again with the same request ID within 60 minutes of /// the last request, the server checks if an original operation with the same /// request ID was received. If so, the server ignores the second request. The /// request ID must be a valid UUID. A zero UUID is not supported /// (00000000-0000-0000-0000-000000000000). /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Operation]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.~~ϊϖϖϣϲϲϿAAMr/// Deletes a single Connect cluster. /// /// Request parameters: /// /// [name] - Required. The name of the Kafka Connect cluster to delete. /// Structured like /// `projects/{project}/locations/{location}/connectClusters/{connect_cluster_id}`. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/connectClusters/\[^/\]+$`. /// /// [requestId] - Optional. An optional request ID to identify requests. /// Specify a unique request ID to avoid duplication of requests. If a request /// times out or fails, retrying with the same ID allows the server to /// recognize the previous attempt. For at least 60 minutes, the server /// ignores duplicate requests bearing the same ID. For example, consider a /// situation where you make an initial request and the request times out. If /// you make the request again with the same request ID within 60 minutes of /// the last request, the server checks if an original operation with the same /// request ID was received. If so, the server ignores the second request. The /// request ID must be a valid UUID. A zero UUID is not supported /// (00000000-0000-0000-0000-000000000000). /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Operation]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.ђђÂ/// Returns the properties of a single Kafka Connect cluster. /// /// Request parameters: /// /// [name] - Required. The name of the Kafka Connect cluster whose /// configuration to return. Structured like /// `projects/{project}/locations/{location}/connectClusters/{connect_cluster_id}`. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/connectClusters/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ConnectCluster]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.!!-;;HTTannx܆܆ܓܢܢܯ֗֗/// Lists the Kafka Connect clusters in a given project and location. /// /// Request parameters: /// /// [parent] - Required. The parent project/location whose Connect clusters /// are to be listed. Structured like /// `projects/{project}/locations/{location}`. /// Value must have pattern `^projects/\[^/\]+/locations/\[^/\]+$`. /// /// [filter] - Optional. Filter expression for the result. /// /// [orderBy] - Optional. Order by fields for the result. /// /// [pageSize] - Optional. The maximum number of Connect clusters to return. /// The service may return fewer than this value. If unspecified, server will /// pick an appropriate default. /// /// [pageToken] - Optional. A page token, received from a previous /// `ListConnectClusters` call. Provide this to retrieve the subsequent page. /// When paginating, all other parameters provided to `ListConnectClusters` /// must match the call that provided the page token. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ListConnectClustersResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.MM\iiu\\B}/// Updates the properties of a single Kafka Connect cluster. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Identifier. The name of the Kafka Connect cluster. Structured /// like: /// projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/connectClusters/\[^/\]+$`. /// /// [requestId] - Optional. An optional request ID to identify requests. /// Specify a unique request ID to avoid duplication of requests. If a request /// times out or fails, retrying with the same ID allows the server to /// recognize the previous attempt. For at least 60 minutes, the server /// ignores duplicate requests bearing the same ID. For example, consider a /// situation where you make an initial request and the request times out. If /// you make the request again with the same request ID within 60 minutes of /// the last request, the server checks if an original operation with the same /// request ID was received. If so, the server ignores the second request. The /// request ID must be a valid UUID. A zero UUID is not supported /// (00000000-0000-0000-0000-000000000000). /// /// [updateMask] - Required. Field mask is used to specify the fields to be /// overwritten in the cluster resource by the update. The fields specified in /// the update_mask are relative to the resource, not the full request. A /// field will be overwritten if it is in the mask. The mask is required and a /// value of * will update all fields. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Operation]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.339osX%s ,K/// Creates a new connector in a given Connect cluster. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [parent] - Required. The parent Connect cluster in which to create the /// connector. Structured like /// `projects/{project}/locations/{location}/connectClusters/{connect_cluster_id}`. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/connectClusters/\[^/\]+$`. /// /// [connectorId] - Required. The ID to use for the connector, which will /// become the final component of the connector's name. The ID must be 1-63 /// characters long, and match the regular expression /// `[a-z]([-a-z0-9]*[a-z0-9])?` to comply with RFC 1035. This value is /// structured like: `my-connector-id`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Connector]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.$$077D%%/// Deletes a connector. /// /// Request parameters: /// /// [name] - Required. The name of the connector to delete. Structured like: /// projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/connectClusters/\[^/\]+/connectors/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Empty]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error. *ӄ/// Returns the properties of a single connector. /// /// Request parameters: /// /// [name] - Required. The name of the connector whose configuration to /// return. Structured like: /// projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/connectClusters/\[^/\]+/connectors/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Connector]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.+Ƅ/// Lists the connectors in a given Connect cluster. /// /// Request parameters: /// /// [parent] - Required. The parent Connect cluster whose connectors are to be /// listed. Structured like /// `projects/{project}/locations/{location}/connectClusters/{connect_cluster_id}`. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/connectClusters/\[^/\]+$`. /// /// [pageSize] - Optional. The maximum number of connectors to return. The /// service may return fewer than this value. If unspecified, server will pick /// an appropriate default. /// /// [pageToken] - Optional. A page token, received from a previous /// `ListConnectors` call. Provide this to retrieve the subsequent page. When /// paginating, all other parameters provided to `ListConnectors` must match /// the call that provided the page token. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ListConnectorsResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.%22>JJWggtee#\/// Updates the properties of a connector. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Identifier. The name of the connector. Structured like: /// projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/connectClusters/\[^/\]+/connectors/\[^/\]+$`. /// /// [updateMask] - Required. Field mask is used to specify the fields to be /// overwritten in the cluster resource by the update. The fields specified in /// the update_mask are relative to the resource, not the full request. A /// field will be overwritten if it is in the mask. The mask is required and a /// value of * will update all fields. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Connector]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.   #//<   /// Pauses the connector and its tasks. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Required. The name of the connector to pause. Structured like: /// projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/connectClusters/\[^/\]+/connectors/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [PauseConnectorResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.99/// Restarts the connector. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Required. The name of the connector to restart. Structured like: /// projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/connectClusters/\[^/\]+/connectors/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [RestartConnectorResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.TTkxx腰H/// Resumes the connector and its tasks. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Required. The name of the connector to pause. Structured like: /// projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/connectClusters/\[^/\]+/connectors/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ResumeConnectorResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.++8/// Stops the connector. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Required. The name of the connector to stop. Structured like: /// projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/connectClusters/\[^/\]+/connectors/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [StopConnectorResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.!!!!!!!!!!![!|!a%!|''''*'*'6'B'B'O!!A&/// Starts asynchronous cancellation on a long-running operation. /// /// The server makes a best effort to cancel the operation, but success is not /// guaranteed. If the server doesn't support this method, it returns /// `google.rpc.Code.UNIMPLEMENTED`. Clients can use Operations.GetOperation /// or other methods to check whether the cancellation succeeded or whether /// the operation completed despite cancellation. On successful cancellation, /// the operation is not deleted; instead, it becomes an operation with an /// Operation.error value with a google.rpc.Status.code of `1`, corresponding /// to `Code.CANCELLED`. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - The name of the operation resource to be cancelled. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/operations/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Empty]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.,,,,,,)/)/, /// Deletes a long-running operation. /// /// This method indicates that the client is no longer interested in the /// operation result. It does not cancel the operation. If the server doesn't /// support this method, it returns `google.rpc.Code.UNIMPLEMENTED`. /// /// Request parameters: /// /// [name] - The name of the operation resource to be deleted. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/operations/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Empty]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.1I1I1U1\1\1i.F.F1E/// Gets the latest state of a long-running operation. /// /// Clients can use this method to poll the operation result at intervals as /// recommended by the API service. /// /// Request parameters: /// /// [name] - The name of the operation resource. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/operations/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Operation]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.888888888889999 9:9:9G22+8E/// Lists operations that match the specified filter in the request. /// /// If the server doesn't support this method, it returns `UNIMPLEMENTED`. /// /// Request parameters: /// /// [name] - The name of the operation's parent resource. /// Value must have pattern `^projects/\[^/\]+/locations/\[^/\]+$`. /// /// [filter] - The standard list filter. /// /// [pageSize] - The standard list page size. /// /// [pageToken] - The standard list page token. /// /// [returnPartialSuccess] - When set to `true`, operations that are reachable /// are returned as normal, and those that are unreachable are returned in the /// ListOperationsResponse.unreachable field. This can only be `true` when /// reading across collections. For example, when `parent` is set to /// `"projects/example/locations/-"`. This field is not supported by default /// and will result in an `UNIMPLEMENTED` error if set unless explicitly /// documented otherwise in service or product specific documentation. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ListOperationsResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.!3!3!9?????@@@??a*>*z>\>>>?-?-?cC'C'#CCCPCPC\CjCjCw@@YC/// Create a schema registry instance. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [parent] - Required. The parent whose schema registry instance is to be /// created. Structured like: `projects/{project}/locations/{location}` /// Value must have pattern `^projects/\[^/\]+/locations/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaRegistry]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.HvHvHHHHEyEyHo/// Delete a schema registry instance. /// /// Request parameters: /// /// [name] - Required. The name of the schema registry instance to delete. /// Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Empty]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.M5M5MAMMMMMZJ%J%M,/// Get the schema registry instance. /// /// Request parameters: /// /// [name] - Required. The name of the schema registry instance to return. /// Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaRegistry]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.TTTTTTTTTOOTv/// List schema registries. /// /// Request parameters: /// /// [parent] - Required. The parent whose schema registry instances are to be /// listed. Structured like: `projects/{project}/locations/{location}` /// Value must have pattern `^projects/\[^/\]+/locations/\[^/\]+$`. /// /// [view] - Optional. Specifies the view to return for the schema registry /// instances. If not specified, the default view is /// SCHEMA_REGISTRY_VIEW_BASIC. /// Possible string values are: /// - "SCHEMA_REGISTRY_VIEW_UNSPECIFIED" : The unset value. The API will /// default to SCHEMA_REGISTRY_VIEW_BASIC. /// - "SCHEMA_REGISTRY_VIEW_BASIC" : If SchemaRegistryView is not specified, /// this is the default value. Returns only the name of the schema registry. /// The contexts associated with it are not included. /// - "SCHEMA_REGISTRY_VIEW_FULL" : Returns the name of the schema registry /// and all the contexts associated with it. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [ListSchemaRegistriesResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.<(<(<.W"WXW^W^WsWWWW"W"sWV%W\\!\\\\\\\WWL\/// Check compatibility of a schema with all versions or a specific version of /// a subject. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Required. The name of the resource to check compatibility for. /// The format is either of following: * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/compatibility/subjects /// / * /versions: Check compatibility with one or more versions of the /// specified subject. * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/compatibility/subjects/{subject}/versions/{version}: /// Check compatibility with a specific version of the subject. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/compatibility/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [CheckCompatibilityResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.VV0V_M_|_}_}_____M_Mg_>_#%_>bbbbbc __b؂/// Delete schema config for a subject. /// /// Request parameters: /// /// [name] - Required. The resource name of subject to delete the config for. /// The format is * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config/{subject} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/config/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaConfig]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.i-i-i9iEiEiPieieirddi$$/// Get schema config at global level or for a subject. /// /// Request parameters: /// /// [name] - Required. The resource name to get the config for. It can be /// either of following: * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config: /// Get config at global level. * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config/{subject}: /// Get config for a specific subject. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/config/.*$`. /// /// [defaultToGlobal] - Optional. If true, the config will fall back to the /// config at the global level if no subject level config is found. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaConfig]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.oo!ppppp)p)p6k}k}oބ/// Update config at global level or for a subject. /// /// Creates a SchemaSubject-level SchemaConfig if it does not exist. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Required. The resource name to update the config for. It can be /// either of following: * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config: /// Update config at global level. * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config/{subject}: /// Update config for a specific subject. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/config/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaConfig]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.^^2^uuuuuuuuuuirtrY%rtrrrs>s>szssрt t^t^tttu2xxyyyyuux/// Get the context. /// /// Request parameters: /// /// [name] - Required. The name of the context to return. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Context]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.}}}}}}zz}/// List contexts for a schema registry. /// /// Request parameters: /// /// [parent] - Required. The parent of the contexts. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.rr9r# $=2?{%ii!JJ]Q/// Check compatibility of a schema with all versions or a specific version of /// a subject. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Required. The name of the resource to check compatibility for. /// The format is either of following: * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/compatibility/subjects /// / * /versions: Check compatibility with one or more versions of the /// specified subject. * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/compatibility/subjects/{subject}/versions/{version}: /// Check compatibility with a specific version of the subject. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/compatibility/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [CheckCompatibilityResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.XXQ^NTTiwt%/// Delete schema config for a subject. /// /// Request parameters: /// /// [name] - Required. The resource name of subject to delete the config for. /// The format is * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config/{subject} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/config/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaConfig]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.&&2>>I^^k5/// Get schema config at global level or for a subject. /// /// Request parameters: /// /// [name] - Required. The resource name to get the config for. It can be /// either of following: * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config: /// Get config at global level. * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config/{subject}: /// Get config for a specific subject. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/config/.*$`. /// /// [defaultToGlobal] - Optional. If true, the config will fall back to the /// config at the global level if no subject level config is found. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaConfig]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.!'33@vv /// Update config at global level or for a subject. /// /// Creates a SchemaSubject-level SchemaConfig if it does not exist. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Required. The resource name to update the config for. It can be /// either of following: * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config: /// Update config at global level. * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/config/{subject}: /// Update config for a specific subject. /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/config/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaConfig]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.zrg%rZ/// Delete schema mode for a subject. /// /// Request parameters: /// /// [name] - Required. The resource name of subject to delete the mode for. /// The format is * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/mode/{subject} /// * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{subject} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/mode/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaMode]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.ggszz}}c/// Get mode at global level or for a subject. /// /// Request parameters: /// /// [name] - Required. The resource name of the mode. The format is * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/mode/{subject}: /// mode for a schema registry, or * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{subject}: /// mode for a specific subject in a specific context /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/mode/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaMode]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.OOgtt%%UC/// Update mode at global level or for a subject. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Required. The resource name of the mode. The format is * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/mode/{subject}: /// mode for a schema registry, or * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{subject}: /// mode for a specific subject in a specific context /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/mode/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaMode]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.''U-6<<Qj_lu%뀷2CCcco{{wwZ/// Get the schema for the given schema id. /// /// Request parameters: /// /// [name] - Required. The name of the schema to return. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/schemas/ids/{schema}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/schemas/.*$`. /// /// [subject] - Optional. Used to limit the search for the schema ID to a /// specific subject, otherwise the schema ID will be searched for in all /// subjects in the given specified context. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Schema]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.iiA/// Get the schema string for the given schema id. /// /// The response will be the schema string. /// /// Request parameters: /// /// [name] - Required. The name of the schema to return. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/schemas/ids/{schema}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/schemas/.*$`. /// /// [subject] - Optional. Used to limit the search for the schema ID to a /// specific subject, otherwise the schema ID will be searched for in all /// subjects in the given specified context. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.~~.#cii~##}%}}‰——¢¯¯¼Bs}/// List subjects which reference a particular schema id. /// /// The response will be an array of subject names. /// /// Request parameters: /// /// [parent] - Required. The schema resource whose associated subjects are to /// be listed. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/schemas/ids/{schema}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/schemas/ids/{schema}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/schemas/.*$`. /// /// [deleted] - Optional. If true, the response will include soft-deleted /// subjects. The default is false. /// /// [subject] - Optional. The subject to filter the subjects by. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.:\řşşŴ\\zM2%M88DRR_څ)./// List the supported schema types. /// /// The response will be an array of schema types. /// /// Request parameters: /// /// [parent] - Required. The parent schema registry whose schema types are to /// be listed. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.|˼||}mR%mcco}}шѕѕѢѯѯѼY/// List the schema versions for the given schema id. /// /// The response will be an array of subject-version pairs as: /// \[{"subject":"subject1", "version":1}, {"subject":"subject2", /// "version":2}\]. /// /// Request parameters: /// /// [parent] - Required. The schema whose schema versions are to be listed. /// Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/schemas/ids/{schema}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/schemas/ids/{schema}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/schemas/.*$`. /// /// [deleted] - Optional. If true, the response will include soft-deleted /// versions of the schema, even if the subject is soft-deleted. The default /// is false. /// /// [subject] - Optional. The subject to filter the subjects by. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error. 4::Oh]jv/%/>>Ԇ""/uu/// Delete a subject. /// /// The response will be an array of versions of the deleted subject. /// /// Request parameters: /// /// [name] - Required. The name of the subject to delete. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/subjects/\[^/\]+$`. /// /// [permanent] - Optional. If true, the subject and all associated metadata /// including the schema ID will be deleted permanently. Otherwise, only the /// subject is soft-deleted. The default is false. Soft-deleted subjects can /// still be searched in ListSubjects API call with deleted=true query /// parameter. A soft-delete of a subject must be performed before a /// hard-delete. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.v/// List subjects in the schema registry. /// /// The response will be an array of subject names. /// /// Request parameters: /// /// [parent] - Required. The parent schema registry/context whose subjects are /// to be listed. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+$`. /// /// [deleted] - Optional. If true, the response will include soft-deleted /// subjects. The default is false. /// /// [subjectPrefix] - Optional. The context to filter the subjects by, in the /// format of `:.{context}:`. If unset, all subjects in the registry are /// returned. Set to empty string or add as '?subjectPrefix=' at the end of /// this request to list subjects in the default context. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.##/==J,/// Lookup a schema under the specified subject. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [parent] - Required. The subject to lookup the schema in. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/subjects/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaVersion]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.Зc~%뫀**?LLXffsj/// Register a new version under a given subject with the given schema. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [parent] - Required. The subject to create the version for. Structured /// like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/subjects/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [CreateVersionResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.77COOZiivtt+a/// Delete a version of a subject. /// /// The response will be the deleted version id. /// /// Request parameters: /// /// [name] - Required. The name of the subject version to delete. Structured /// like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}/versions/{version}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}/versions/{version}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/subjects/\[^/\]+/versions/\[^/\]+$`. /// /// [permanent] - Optional. If true, both the version and the referenced /// schema ID will be permanently deleted. The default is false. If false, the /// version will be deleted but the schema ID will be retained. Soft-deleted /// versions can still be searched in ListVersions API call with deleted=true /// query parameter. A soft-delete of a version must be performed before a /// hard-delete. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.[[gss~MM'R/// Get a versioned schema (schema with subject/version) of a subject. /// /// Request parameters: /// /// [name] - Required. The name of the subject to return versions. Structured /// like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}/versions/{version}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}/versions/{version}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/subjects/\[^/\]+/versions/\[^/\]+$`. /// /// [deleted] - Optional. If true, no matter if the subject/version is /// soft-deleted or not, it returns the version details. If false, it returns /// NOT_FOUND error if the subject/version is soft-deleted. The default is /// false. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaVersion]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.xxE/// Get the schema string only for a version of a subject. /// /// The response will be the schema string. /// /// Request parameters: /// /// [name] - Required. The name of the subject to return versions. Structured /// like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}/versions/{version}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}/versions/{version}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/subjects/\[^/\]+/versions/\[^/\]+$`. /// /// [deleted] - Optional. If true, no matter if the subject/version is /// soft-deleted or not, it returns the version details. If false, it returns /// NOT_FOUND error if the subject/version is soft-deleted. The default is /// false. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.XXdrr}  N?/// Get all versions of a subject. /// /// The response will be an array of versions of the subject. /// /// Request parameters: /// /// [parent] - Required. The subject whose versions are to be listed. /// Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/subjects/\[^/\]+$`. /// /// [deleted] - Optional. If true, the response will include soft-deleted /// versions of an active or soft-deleted subject. The default is false. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.55>;DJJ_xmz%/// Get a list of IDs of schemas that reference the schema with the given /// subject and version. /// /// Request parameters: /// /// [parent] - Required. The version to list referenced by. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}/versions/{version}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}/versions/{version}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/contexts/\[^/\]+/subjects/\[^/\]+/versions/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.uu{.#0e%;;aʃI/// Delete schema mode for a subject. /// /// Request parameters: /// /// [name] - Required. The resource name of subject to delete the mode for. /// The format is * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/mode/{subject} /// * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{subject} /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/mode/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaMode]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.!y!y!!!!!u/// Get mode at global level or for a subject. /// /// Request parameters: /// /// [name] - Required. The resource name of the mode. The format is * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/mode/{subject}: /// mode for a schema registry, or * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{subject}: /// mode for a specific subject in a specific context /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/mode/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaMode]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.'P'P'h'u'u''''#7#7D'D/// Update mode at global level or for a subject. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [name] - Required. The resource name of the mode. The format is * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/mode/{subject}: /// mode for a schema registry, or * /// projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{subject}: /// mode for a specific subject in a specific context /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/mode/.*$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaMode]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.pp v+++++,+,++h))%)))䀔*!*{*{*+ + +F///000 000', , /߃/// Get the schema for the given schema id. /// /// Request parameters: /// /// [name] - Required. The name of the schema to return. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/schemas/ids/{schema}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/schemas/.*$`. /// /// [subject] - Optional. Used to limit the search for the schema ID to a /// specific subject, otherwise the schema ID will be searched for in all /// subjects in the given specified context. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [Schema]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.6666&6&636@6@6M1105/// Get the schema string for the given schema id. /// /// The response will be the schema string. /// /// Request parameters: /// /// [name] - Required. The name of the schema to return. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/schemas/ids/{schema}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/schemas/.*$`. /// /// [subject] - Optional. Used to limit the search for the schema ID to a /// specific subject, otherwise the schema ID will be searched for in all /// subjects in the given specified context. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.)))8888888888u88e%8======>>>>>>)991=Ƅl/// List subjects which reference a particular schema id. /// /// The response will be an array of subject names. /// /// Request parameters: /// /// [parent] - Required. The schema resource whose associated subjects are to /// be listed. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/schemas/ids/{schema}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/schemas/ids/{schema}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/schemas/.*$`. /// /// [deleted] - Optional. If true, the response will include soft-deleted /// subjects. The default is false. /// /// [subject] - Optional. The subject to filter the subjects by. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.8"8"8(@@@@@AAA@@r@@}%@DjDjDvDDDAAD`/// List the supported schema types. /// /// The response will be an array of schema types. /// /// Request parameters: /// /// [parent] - Required. The parent schema registry whose schema types are to /// be listed. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.@=@=@CFFFFFGGGFFuFF|%FLtLtLLLLLLLLLLGGLj/// List the schema versions for the given schema id. /// /// The response will be an array of subject-version pairs as: /// \[{"subject":"subject1", "version":1}, {"subject":"subject2", /// "version":2}\]. /// /// Request parameters: /// /// [parent] - Required. The schema whose schema versions are to be listed. /// Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/schemas/ids/{schema}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/schemas/ids/{schema}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/schemas/.*$`. /// /// [deleted] - Optional. If true, the response will include soft-deleted /// versions of the schema, even if the subject is soft-deleted. The default /// is false. /// /// [subject] - Optional. The subject to filter the subjects by. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.F9F9F?OPPPP(PAP6PCOOiO8O%O8OGOGOUUUUUUUUUPNPN|U /// Delete a subject. /// /// The response will be an array of versions of the deleted subject. /// /// Request parameters: /// /// [name] - Required. The name of the subject to delete. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/subjects/\[^/\]+$`. /// /// [permanent] - Optional. If true, the subject and all associated metadata /// including the schema ID will be deleted permanently. Otherwise, only the /// subject is soft-deleted. The default is false. Soft-deleted subjects can /// still be searched in ListSubjects API call with deleted=true query /// parameter. A soft-delete of a subject must be performed before a /// hard-delete. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.]7]7]C]Q]Q]\]i]i]v]]]WW·]-/// List subjects in the schema registry. /// /// The response will be an array of subject names. /// /// Request parameters: /// /// [parent] - Required. The parent schema registry/context whose subjects are /// to be listed. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+$`. /// /// [deleted] - Optional. If true, the response will include soft-deleted /// subjects. The default is false. /// /// [subjectPrefix] - Optional. The context to filter the subjects by, in the /// format of `:.{context}:`. If unset, all subjects in the registry are /// returned. Set to empty string or add as '?subjectPrefix=' at the end of /// this request to list subjects in the default context. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.ccccccccc__c/// Lookup a schema under the specified subject. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [parent] - Required. The subject to lookup the schema in. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/subjects/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaVersion]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.NNNggKgQgQgfggtgggvf:f%f:fIfIfkkkkkkkkkggYk/// Register a new version under a given subject with the given schema. /// /// [request] - The metadata request object. /// /// Request parameters: /// /// [parent] - Required. The subject to create the version for. Structured /// like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/subjects/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [CreateVersionResponse]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.sssssssssmmsP/// Delete a version of a subject. /// /// The response will be the deleted version id. /// /// Request parameters: /// /// [name] - Required. The name of the subject version to delete. Structured /// like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}/versions/{version}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}/versions/{version}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/subjects/\[^/\]+/versions/\[^/\]+$`. /// /// [permanent] - Optional. If true, both the version and the referenced /// schema ID will be permanently deleted. The default is false. If false, the /// version will be deleted but the schema ID will be retained. Soft-deleted /// versions can still be searched in ListVersions API call with deleted=true /// query parameter. A soft-delete of a version must be performed before a /// hard-delete. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.zzzzzzzzzuuz/// Get a versioned schema (schema with subject/version) of a subject. /// /// Request parameters: /// /// [name] - Required. The name of the subject to return versions. Structured /// like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}/versions/{version}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}/versions/{version}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/subjects/\[^/\]+/versions/\[^/\]+$`. /// /// [deleted] - Optional. If true, no matter if the subject/version is /// soft-deleted or not, it returns the version details. If false, it returns /// NOT_FOUND error if the subject/version is soft-deleted. The default is /// false. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [SchemaVersion]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.)||ˇ4݄/// Get the schema string only for a version of a subject. /// /// The response will be the schema string. /// /// Request parameters: /// /// [name] - Required. The name of the subject to return versions. Structured /// like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}/versions/{version}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}/versions/{version}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/subjects/\[^/\]+/versions/\[^/\]+$`. /// /// [deleted] - Optional. If true, no matter if the subject/version is /// soft-deleted or not, it returns the version details. If false, it returns /// NOT_FOUND error if the subject/version is soft-deleted. The default is /// false. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error../// Get all versions of a subject. /// /// The response will be an array of versions of the subject. /// /// Request parameters: /// /// [parent] - Required. The subject whose versions are to be listed. /// Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/subjects/\[^/\]+$`. /// /// [deleted] - Optional. If true, the response will include soft-deleted /// versions of an active or soft-deleted subject. The default is false. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.eeۤe ekk  %/// Get a list of IDs of schemas that reference the schema with the given /// subject and version. /// /// Request parameters: /// /// [parent] - Required. The version to list referenced by. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/subjects/{subject}/versions/{version}` /// or /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subject}/versions/{version}` /// Value must have pattern /// `^projects/\[^/\]+/locations/\[^/\]+/schemaRegistries/\[^/\]+/subjects/\[^/\]+/versions/\[^/\]+$`. /// /// [$fields] - Selector specifying which fields to include in a partial /// response. /// /// Completes with a [HttpBody]. /// /// Completes with a [commons.ApiRequestError] if the API endpoint returned an /// error. /// /// If the used [http.Client] completes with an error when making a REST call, /// this method will complete with the same error.$   "&&>0@fYFWAG\`aetvy2̀/// Virtual Private Cloud (VPC) networks that must be granted direct access to /// the Kafka cluster. /// /// Minimum of 1 network is required. Maximum 10 networks can be specified. /// /// Required.,,P@5/// The configuration of access to the Kafka cluster.;>EEJZZ _ii nxx};;Q .03C !%&,B7YIWDJ\`ag~r+X|/// The ACL entries that apply to the resource pattern. /// /// The maximum number of allowed entries 100. /// /// Required.9:9/// `etag` is used for concurrency control. /// /// An `etag` is returned in the response to `GetAcl` and `CreateAcl`. Callers /// are required to put that etag in the request to `UpdateAcl` to ensure that /// their change will be applied to the same version of the acl that exists in /// the Kafka Cluster. A terminal 'T' character in the etag indicates that the /// AclEntries were truncated; more entries for the Acl exist on the Kafka /// Cluster, but can't be returned in the Acl due to repeated field limits. /// /// Optional.$B$/// Identifier. /// /// The name for the acl. Represents a single Resource Pattern. Structured /// like: /// projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id} /// The structure of `acl_id` defines the Resource Pattern (resource_type, /// resource_name, pattern_type) of the acl. `acl_id` is structured like one /// of the following: For acls on the cluster: `cluster` For acls on a single /// resource within the cluster: `topic/{resource_name}` /// `consumerGroup/{resource_name}` `transactionalId/{resource_name}` For acls /// on all resources that match a prefix: `topicPrefixed/{resource_name}` /// `consumerGroupPrefixed/{resource_name}` /// `transactionalIdPrefixed/{resource_name}` For acls on all resources of a /// given type (i.e. the wildcard literal "*"): `allTopics` (represents `topic /// / * `) `allConsumerGroups` (represents `consumerGroup / * `) /// `allTransactionalIds` (represents `transactionalId / * `)-g/// The ACL pattern type derived from the name. /// /// One of: LITERAL, PREFIXED. /// /// Output only./// The ACL resource name derived from the name. /// /// For cluster resource_type, this is always "kafka-cluster". Can be the /// wildcard literal "*". /// /// Output only.**~/// The ACL resource type derived from the name. /// /// One of: CLUSTER, TOPIC, GROUP, TRANSACTIONAL_ID. /// /// Output only.ŽP/// Represents the set of ACLs for a given Kafka Resource Pattern, which /// consists of resource_type, resource_name and pattern_type.:BDD IOOT__dtty::K/  1#K8I39NRSYmdtou1|`/// The host. /// /// Must be set to "*" for Managed Service for Apache Kafka. /// /// Required.aa/// The operation type. /// /// Allowed values are (case insensitive): ALL, READ, WRITE, CREATE, DELETE, /// ALTER, DESCRIBE, CLUSTER_ACTION, DESCRIBE_CONFIGS, ALTER_CONFIGS, and /// IDEMPOTENT_WRITE. See /// https://kafka.apache.org/documentation/#operations_resources_and_protocols /// for valid combinations of resource_type and operation for different Kafka /// API requests. /// /// Required.og/// The permission type. /// /// Accepted values are (case insensitive): ALLOW, DENY. /// /// Required.,4, /// The principal. /// /// Specified as Google Cloud account, with the Kafka StandardAuthorizer /// prefix "User:". For example: /// "User:test-kafka-client@test-project.iam.gserviceaccount.com". Can be the /// wildcard "User:*" to refer to all users. /// /// Required.Zԇ'$I/// Represents the access granted for a given Resource Pattern in an ACL.1.&*74^9>?JPK`cdlzrxms}U9U/// The updated acl.]\D/// Whether the acl was created as a result of adding the acl entry.!/// Response for AddAclEntry.  :+455>$KOdY{kyfl~,1P11/// The index of the broker. /// /// Output only.AM3/// The node id of the broker. /// /// Output only.H0/// The rack of the broker. /// /// Output only.6-/// Details of a broker in the Kafka cluster. 3'011:GK`Uwgubhz~(QQ/// The memory to provision for the cluster in bytes. /// /// The CPU:memory ratio (vCPU:GiB) must be between 1:1 and 1:8. Minimum: /// 3221225472 (3 GiB). /// /// Required.a|[/// The number of vCPUs to provision for the cluster. /// /// Minimum: 3. /// /// Required.ˀ@@Rw0/// A capacity configuration of a Kafka cluster.&GII N&&1[|[[o}/// The name of the CA pool to pull CA certificates from. /// /// Structured like: /// projects/{project}/locations/{location}/caPools/{ca_pool}. The CA pool /// does not need to be in the same project or location as the Kafka cluster. /// /// Required.rA/// A configuration for the Google Certificate Authority Service.9RYY^nn s 99n;} .03C 5&3!'8<=CUNh\fW]koptl?/// The schema references used by the schema. /// /// Optional.9B9(/// The schema payload /// /// Required.mD3m /// The schema type of the schema. /// /// Optional. /// Possible string values are: /// - "SCHEMA_TYPE_UNSPECIFIED" : No schema type. The default will be AVRO. /// - "AVRO" : Avro schema type. /// - "JSON" : JSON schema type. /// - "PROTOBUF" : Protobuf schema type.-|-/// If true, the response will contain the compatibility check result with /// reasons for failed checks. /// /// The default is false. /// /// Optional.NDDn#/// Request for CheckCompatibility.    $?3MVWW`%mq3{"#)*33N~`/// The compatibility check result. /// /// If true, the schema is compatible with the resource.I&/// Failure reasons if verbose = true.99]Ճ,$/// Response for CheckCompatibility. #338GGL^^ coo t~~ȃȘȘȝȯȯȴ ߁9#,--6"CGp^Q`Ʌxfvag{ɀɄɓɕɘ&ɨ45;<UGʇW\]hyiʉʗʘʠʷʲʸ(>/<*0AEFL`Wˍ bghstˏ˘˙ˡ˸˳˹ &>-<(.AEFL]W_̗pen`fswx{̕|̖̘̝̩̀́̉̍̎̚  2#e49:EWFgvw͖ͪͨ͑͗ͭͱͲ͵Ͷͺͻ "  %)*.E9]L[GM`deiytΊ΀Έ{΁΍ΑΒΘάΣVήγδοH7"#+/0XsfϤ)uz{φϖχϦϳϴϼ +C9YJWEK\`agV$Is/// Only populated when FULL view is requested. /// /// Details of each broker in the cluster. /// /// Output only.MhMC/// Capacity configuration for the Kafka cluster. /// /// Required.`]?/// The time when the cluster was created. /// /// Output only.?€?i/// Configuration properties for a Kafka cluster deployed to Google Cloud /// Platform. /// /// Required.Mn/// Only populated when FULL view is requested. /// /// The Kafka version of the cluster. /// /// Output only.?a?0/// Labels as key value pairs. /// /// Optional.Jꀊ/// Identifier. /// /// The name of the cluster. Structured like: /// projects/{project_number}/locations/{location}/clusters/{cluster_id}OkOD/// Rebalance configuration for the Kafka cluster. /// /// Optional.ĦcOĦ1/// Reserved for future use. /// /// Output only.ķO1/// Reserved for future use. /// /// Output only.w qwL/// The current state of the cluster. /// /// Output only. /// Possible string values are: /// - "STATE_UNSPECIFIED" : A state was not specified. /// - "CREATING" : The cluster is being created. /// - "ACTIVE" : The cluster is active. /// - "DELETING" : The cluster is being deleted. /// - "UPDATING" : The cluster is being updated.ƁY>/// TLS configuration for the Kafka cluster. /// /// Optional.f߀fo/// UpdateOptions represents options that control how updates to the cluster /// are applied. /// /// Optional.xbD/// The time when the cluster was last updated. /// /// Output only.vvTК=3/// An Apache Kafka cluster deployed in a location.:MOOT::+i|օֆֆ֏֜֠קָֺֻ֪׈yזחםמii@}'* '/// Virtual Private Cloud (VPC) networks that must be granted direct access to /// the Kafka Connect cluster. /// /// Minimum of 1 network is required. Maximum 10 networks can be specified. /// /// Required.׭׭΃s=/// The configuration of access to the Kafka Connect cluster.߹    !!&88 =II NXX]oot ߹߹J, .<=Eo\mW]rvwz{ WLlbsntUG6!"*./Wqexsy6+EAULSGMX\]czn|3$1%6:;Aఄ ؘpK/// Capacity configuration for the Kafka Connect cluster. /// /// Required.   /// Configurations for the worker that are overridden from the defaults. /// /// The key of the map is a Kafka Connect worker property name, for example: /// `exactly.once.source.support`. /// /// Optional.j]j?/// The time when the cluster was created. /// /// Output only.yq/// Configuration properties for a Kafka Connect cluster deployed to Google /// Cloud Platform. /// /// Required./// The name of the Kafka cluster this Kafka Connect cluster is attached to. /// /// Structured like: /// projects/{project}/locations/{location}/clusters/{cluster} /// /// Required. Immutable.ZaZ0/// Labels as key value pairs. /// /// Optional."e"/// Identifier. /// /// The name of the Kafka Connect cluster. Structured like: /// projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id}n+On1/// Reserved for future use. /// /// Output only.O1/// Reserved for future use. /// /// Output only.HӁzHU/// The current state of the Kafka Connect cluster. /// /// Output only. /// Possible string values are: /// - "STATE_UNSPECIFIED" : A state was not specified. /// - "CREATING" : The cluster is being created. /// - "ACTIVE" : The cluster is active. /// - "DELETING" : The cluster is being deleted. /// - "DETACHED" : The cluster is detached.ߪRbߪD/// The time when the cluster was last updated. /// /// Output only.PPAtCCP؅;/// An Apache Kafka Connect cluster deployed in a location.8 :4(d6;<GVHfyz  .! $()-<>AaB`opvwꁘuquI/// Access configuration for the Kafka Connect cluster. /// /// Required.醁#Ꞁ/// Secrets to load into workers. /// /// Exact SecretVersions from Secret Manager must be provided -- aliases are /// not supported. Up to 32 secrets may be loaded into one cluster. Format: /// projects//secrets//versions/ /// /// Optional.솀蕄_/// Configuration properties for a Kafka Connect cluster deployed to Google /// Cloud Platform.//4iL`ijjs<  ,.TG4E/5JNOSbdghLLaUVZ[ekˁZ/// Deprecated: Managed Kafka Connect clusters can now reach any endpoint /// accessible from the primary subnet without the need to define additional /// subnets. /// /// Please see /// https://cloud.google.com/managed-service-for-apache-kafka/docs/connect-cluster/create-connect-cluster#worker-subnet /// for more information. /// /// Optional.sၠsi/// Additional DNS domain names from the subnet's network to be made visible /// to the Connect Cluster. /// /// When using MirrorMaker2, it's necessary to add the bootstrap address's dns /// domain name of the target cluster to make it visible to the connector. For /// example: my-kafka-cluster.us-central1.managedkafka.my-project.cloud.goog /// /// Optional.T͂#/// VPC subnet to make available to the Kafka Connect cluster. /// /// Structured like: /// projects/{project}/regions/{region}/subnetworks/{subnet_id} It is used to /// create a Private Service Connect (PSC) interface for the Kafka Connect /// workers. It must be located in the same region as the Kafka Connect /// cluster. The CIDR range of the subnet must be within the IPv4 address /// ranges for private networks, as specified in RFC 1918. The primary subnet /// CIDR range must have a minimum size of /22 (1024 addresses). /// /// Required.Y[[m/// The configuration of a Virtual Private Cloud (VPC) network that can access /// the Kafka Connect cluster.    I!*344=TJN@_Xasgqbhvz{~  #4*2%+7;<B^M2`efqr$  4!!!+xx/// Connector config as keys/values. /// /// The keys of the map are connector property names, for example: /// `connector.class`, `tasks.max`, `key.converter`. /// /// Optional.BB/// Identifier. /// /// The name of the connector. Structured like: /// projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}YKY/// The current state of the connector. /// /// Output only. /// Possible string values are: /// - "STATE_UNSPECIFIED" : A state was not specified. /// - "UNASSIGNED" : The connector is not assigned to any tasks, usually /// transient. /// - "RUNNING" : The connector is running. /// - "PAUSED" : The connector has been paused. /// - "FAILED" : The connector has failed. See logs for why. /// - "RESTARTING" : The connector is restarting. /// - "STOPPED" : The connector has been stopped.clC/// Restarts the individual tasks of a Connector. /// /// Optional.FFNjHHN8/// A Kafka Connect connector in a given ConnectCluster.$133 8>> C$$(P]fggp)} PP^߁/// Identifier. /// /// The name of the consumer group. The `consumer_group` segment is used when /// connecting directly to the cluster. Structured like: /// projects/{project}/locations/{location}/clusters/{cluster}/consumerGroups/{consumer_group}&/// Metadata for this consumer group for all topics it has metadata for. /// /// The key of the map is a topic name, structured like: /// projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic} /// /// Optional.Հ./// A Kafka consumer group in a given cluster.   8'@IJJS`dvn}x~''AW|W`/// The associated metadata for this partition, or empty if it does not exist. /// /// Optional.df/// The current offset for this partition, or 0 if no offset has been /// committed. /// /// Required.؀vvH/// Metadata for a consumer group corresponding to a specific partition.)    f %  3 o H 9 F 4 : K O P S m T X Y a e f n p r u ]  N؁s/// Metadata for this consumer group and topic for all partition indexes it /// has metadata for. /// /// Optional. l l gD/// Metadata for a consumer group corresponding to a specific topic. n u w w  |    n n$      %  t            " !025U6Tcdjk     ] /// Identifier. /// /// The name of the context. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}/contexts/{context}` /// The context name {context} can contain the following: * Up to 255 /// characters. * Allowed characters: letters (uppercase or lowercase), /// numbers, and the following special characters: `.`, `-`, `_`, `+`, `%`, /// and `~`. a Y a2/// The subjects of the context. /// /// Optional.zz  / QX/// Context represents an independent schema grouping in a schema registry /// instance.;VXX]mmr;;J."#+UBS=CX\]`zaefnrse{`/// The schema registry instance to create. /// /// The name field is ignored. /// /// Required.& -&/// The schema registry instance ID to use for this schema registry. /// /// The ID must contain only letters (a-z, A-Z), numbers (0-9), and /// underscores (-). The maximum length is 63 characters. The ID must not /// start with a number. /// /// Required.##[1/// Request to create a schema registry instance.w  ww"##,Q9=,IGWPUKQZ^_bvm}x~sd   #)J4J/// The schema ID of the schema. /// /// If not specified, the schema ID will be generated by the server. If the /// schema ID is specified, it must not be used by an existing schema that is /// different from the schema to be created. /// /// Optional.Qo/// If true, the schema will be normalized before being stored. /// /// The default is false. /// /// Optional.FlF?/// The schema references used by the schema. /// /// Optional.UB(/// The schema payload /// /// Required. x L/// The type of the schema. /// /// It is optional. If not specified, the schema type will be AVRO. /// /// Optional. /// Possible string values are: /// - "SCHEMA_TYPE_UNSPECIFIED" : No schema type. The default will be AVRO. /// - "AVRO" : Avro schema type. /// - "JSON" : JSON schema type. /// - "PROTOBUF" : Protobuf schema type.kYk7/// The version to create. /// /// It is optional. If not specified, the version will be created with the max /// version ID of the subject increased by 1. If the version ID is specified, /// it will be used as the new version ID and must not be used by an existing /// version of the subject. /// /// Optional.22V/// Request for CreateVersion.vvv!Xo2?o0/// The unique identifier of the schema created.bi/// Response for CreateVersion.""""""" ""","""""#.##$#)##Y##+#0#1#<#K#=#[#g#h#p####################$#$##$$ $ $""7"!i!b!iA/// Access configuration for the Kafka cluster. /// /// Required."!z7"/// The Cloud KMS Key name to use for encryption. /// /// The key must be located in the same region as the cluster and cannot be /// changed. Structured like: /// projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoKeys/{crypto_key}. /// /// Optional. Immutable.$!$!$E  9!W/// Configuration properties for a Kafka cluster deployed to Google Cloud /// Platform.+G+W+Y+Y +^+d+d+i+G+G2+}+++++%++,++++++++++++++++,e,,V,s,t,z,{,,,,,,,,,,,+}+}H+**v*[/// The list of acls in the requested parent. /// /// The order of the acls is unspecified.+5*+5/// A token that can be sent as `page_token` to retrieve the next page of /// results. /// /// If this field is omitted, there are no more results.,,ɀ,))ۃ)/// Response for ListAcls./'/;/=/= /B/L/L/Q/`/`/e/'/'L/w/////<//1`////////////////0~00o000000000000000000110000111 1 111!1A1"1@1O1P1V1W/w/w/. -P. 1/// The list of Clusters in the requested parent....€/// A token that can be sent as `page_token` to retrieve the next page of /// results. /// /// If this field is omitted, there are no more results./.N/(/// Locations that could not be reached.1f1f)1-- -/// Response for ListClusters.4X4s4z4z44444444X4Xk444444<556555!5H5;5'595"5(5>5B5C5G5V5X5[55k5555666 6166/66 6468696?6U6J6W6z6m6]6k6X6^6p6t6u6y666666666644ǂ4362f369/// The list of Connect clusters in the requested parent.33J3/// A token that can be sent as `page_token` to retrieve the next page of /// results. /// /// If this field is omitted, there are no more results.4H4N4H(/// Locations that could not be reached.66ҁE6222%/// Response for ListConnectClusters.9s99999999s9s>999999%99;":9::':: ::: ::!:":&:5:7::::J:::::::; :; ::;;;;99o988]V83/// The list of connectors in the requested parent.9a89a/// A token that can be sent as `page_token` to retrieve the next page of /// results. /// /// If this field is omitted, there are no more results.;(;(;L888B /// Response for ListConnectors.==========F=> >>>>%>*>.?m>F>8>H>n>a>N>_>I>O>d>h>i>m>|>~>?>????$?%?=?0?V?D?T???E?Y?]?^?d==> <CDt&/// The standard List next-page token.DDmDJ/// A list of operations that matches the specified filter in the request.FD.F/// Unordered list. /// /// Unreachable resources. Populated when the request sets /// `ListOperationsRequest.return_partial_success` and reads across /// collections. For example, when attempting to list all resources across all /// supported locations.HH1HCCD#7/// The response message for Operations.ListOperations.J^JzJ|J|JJ^J^6JJJJJJJJKJJJKKJK JJKKKKK*K,K/KK?KKKKKJJGJJIJ PJI"/// The schema registry instances.KK〚LIII%/// Request for ListSchemaRegistries.MN N N NN!N! N&MM6N3NENNNONONX%NeNiONNsNNNNNNNNNNNNNNNNNNNNNNNNNObNOSOpOqOwOxN3N3PNFMdLMd/// A token that can be sent as `page_token` to retrieve the next page of /// results. /// /// If this field is omitted, there are no more results.MMv~M_/// The list of topics in the requested parent. /// /// The order of the topics is unspecified.OOOLLL/// Response for ListTopics.TeTyTT TTTTTTTTT TTTTTeTe}TTUUUU FUUVU/U(UBU6U@U1U7UEUIUJUNUbUYUwUiUuUdUjUzU~UUUUUUUUUUUUUUUUUUV_UVPVmVnVtVuVVVVVVVVVVVVVVVVVVVVVVTTTQPQӀ/// If true, soft-deleted versions will be included in lookup, no matter if /// the subject is active or soft-deleted. /// /// If false, soft-deleted versions will be excluded. The default is false. /// /// Optional.RgQ߀Rgr/// If true, the schema will be normalized before being looked up. /// /// The default is false. /// /// Optional.RRulR?/// The schema references used by the schema. /// /// Optional.S"RBS"(/// The schema payload /// /// Required.TVS-3TV /// The schema type of the schema. /// /// Optional. /// Possible string values are: /// - "SCHEMA_TYPE_UNSPECIFIED" : No schema type. The default will be AVRO. /// - "AVRO" : Avro schema type. /// - "JSON" : JSON schema type. /// - "PROTOBUF" : Protobuf schema type.VVWPPP/// Request for LookupVersion.ZZZZ ZZZZZ[[[[[[ [H['[![9[.[7[)[/[<[@[A[GZZ[ZZYZÁ/// Name of the VPC subnet in which to create Private Service Connect (PSC) /// endpoints for the Kafka brokers and bootstrap address. /// /// Structured like: /// projects/{project}/regions/{region}/subnetworks/{subnet_id} The subnet /// must be located in the same region as the Kafka cluster. The project may /// differ. Multiple subnets from the same parent network must not be /// specified. /// /// Required.[N[Nr[rXX=Xe/// The configuration of a Virtual Private Cloud (VPC) network that can access /// the Kafka cluster.cIcRcTcT cYc_c_ cdckck cpczcz ccc ccIcILccccccoccecccccccccccdcd)dddddddd+d1d2d:dd[dQdYdLdRd^dbdcdfddgdkdldtdxdydddde*ddddddddddddddeeeeeeeee,e>e:eNeEeLe@eFeQeUeVe\eoegeeeqeveweeeeeeeeeeeeeeeeeeeeccYc\\<\/// If the value is `false`, it means the operation is still in progress. /// /// If `true`, the operation is completed, and either `error` or `response` is /// available.]X]Y]XI/// The error result of the operation in case of failure or cancellation._Z]b_Z/// Service-specific metadata associated with the operation. /// /// It typically contains progress information and common metadata such as /// create time. Some services might not provide such metadata. Any method /// that returns a long-running operation should document the metadata type, /// if any. /// /// The values for Object must be JSON objects. It can consist of `num`, /// `String`, `bool` and `null` as well as `Map` and `List` values.`e_g`e/// The server-assigned name, which is only unique within the same service /// that originally returns it. /// /// If you use the default HTTP mapping, the `name` should be a resource name /// ending with `operations/{unique_id}`.c<`ncl@l@lElJlJlOl(l(4l`lvllll.llmclllmllllllllllmlllllllllmlllmmmm m8m.mNm?mLm:m@mQmUmVmZl`l`lwkk!pka/// The updated acl. /// /// Returned if the removed acl entry was not the last entry in the acl.lkls/// Returned with value true if the removed acl entry was the last entry in /// the acl, resulting in acl deletion.mimimjj߃5k /// Response for RemoveAclEntry.qVq\q^q^qcqoqo qtq|q|qqVqV8qqqqqq0qqs qqqqqqqqqqqqqrrrrrrrrrrrrrrrrrrrrrrrs rsrrs sssqqqoo{lo?/// The schema references used by the schema. /// /// Optional.po-p/// The schema payload.qGp3qG /// The schema type of the schema. /// /// Optional. /// Possible string values are: /// - "SCHEMA_TYPE_UNSPECIFIED" : No schema type. The default will be AVRO. /// - "AVRO" : Avro schema type. /// - "JSON" : JSON schema type. /// - "PROTOBUF" : Protobuf schema type.s&s&sJoJoJop/// Schema for a Kafka message.yyyy yzzz zzzyy?z.z:zCzDzDzM$zZz^{ zmzhz~ztz|zozuzzzzzzzzzzzzzzzzzzzzzzzzz{z.z.z;u8tu8s/// The subject to which this subject is an alias of. /// /// Only applicable for subject config. /// /// Optional.xuBZx/// The compatibility type of the schema. /// /// The default value is BACKWARD. If unset in a SchemaSubject-level /// SchemaConfig, defaults to the global value. If unset in a /// SchemaRegistry-level SchemaConfig, reverts to the default value. /// /// Required. /// Possible string values are: /// - "NONE" : No compatibility check. /// - "BACKWARD" : Backwards compatible with the most recent version. /// - "BACKWARD_TRANSITIVE" : Backwards compatible with all previous versions. /// - "FORWARD" : Forwards compatible with the most recent version. /// - "FORWARD_TRANSITIVE" : Forwards compatible with all previous versions. /// - "FULL" : Backwards and forwards compatible with the most recent version. /// - "FULL_TRANSITIVE" : Backwards and forwards compatible with all previous /// versions.yxEy݁"/// If true, the schema will be normalized before being stored or looked up. /// /// The default is false. If unset in a SchemaSubject-level SchemaConfig, the /// global value will be used. If unset in a SchemaRegistry-level /// SchemaConfig, reverts to the default value. /// /// Optional.{{{3t;t;tZ/// SchemaConfig represents configuration for a schema registry or a specific /// subject. T~y/// The mode type of a schema registry (READWRITE by default) or of a subject /// (unset by default, which means use the global schema registry setting). /// /// Required. /// Possible string values are: /// - "NONE" : The default / unset value. The subject mode is NONE/unset by /// default, which means use the global schema registry mode. This should not /// be used for setting the mode. /// - "READONLY" : READONLY mode. /// - "READWRITE" : READWRITE mode. /// - "IMPORT" : IMPORT mode.j)|(|(I~j;/// SchemaMode represents the mode of a schema registry or a specific subject. /// /// Four modes are supported: * NONE: deprecated. This was the default mode for /// a subject, but now the default is unset (which means use the global schema /// registry setting) * READONLY: The schema registry is in read-only mode. * /// READWRITE: The schema registry is in read-write mode, which allows limited /// write operations on the schema. * IMPORT: The schema registry is in import /// mode, which allows more editing operations on the schema for data importing /// purposes.   9 $+';29-3>BCI[Tnbl]cquv|H0/// The name of the reference. /// /// Required.Q NQ3/// The subject of the reference. /// /// Required.]K3/// The version of the reference. /// /// Required.ss"//// SchemaReference is a reference to a schema.  +%*",L?2=-3BFGKZ\_`~GmGF/// The contexts of the schema registry instance. /// /// Output only.T^@/// Identifier. /// /// The name of the schema registry instance. Structured like: /// `projects/{project}/locations/{location}/schemaRegistries/{schema_registry}` /// The instance name {schema_registry} can contain the following: * Up to 255 /// characters. * Letters (uppercase or lowercase), numbers, and underscores.р1/// SchemaRegistry is a schema registry instance.jw~~   jjQ  ,*:38.4=ABEZP\~qbo]ctxy}!/067HBZOXJP]abh}s 7$/// The schema ID. /// /// Required.IlI?/// The schema references used by the schema. /// /// Optional.XC)/// The schema payload. /// /// Required.3Ɂ /// The schema type of the schema. /// /// Optional. /// Possible string values are: /// - "SCHEMA_TYPE_UNSPECIFIED" : No schema type. The default will be AVRO. /// - "AVRO" : Avro schema type. /// - "JSON" : JSON schema type. /// - "PROTOBUF" : Protobuf schema type.L1/// The subject of the version. /// /// Required.^)<^$/// The version ID /// /// Required.7zzO/// Version of a schema.!55:NNSeo~$q#?.\FZAG_cdhoo5܀/// The maximum amount of time to wait before retrying a failed task. /// /// This sets an upper bound for the backoff delay. /// /// Optional./// The minimum amount of time to wait before retrying a failed task. /// /// This sets a lower bound for the backoff delay. /// /// Optional.Y6/// If true, task retry is disabled. /// /// Optional.ww]>>!/// Task Retry Policy is implemented on a best-effort basis. /// /// The default policy retries tasks with a minimum_backoff of 60 seconds, and a /// maximum_backoff of 12 hours. You can disable the policy by setting the /// task_retry_disabled field to true. Retry delay will be exponential based on /// provided minimum and maximum backoffs. /// https://en.wikipedia.org/wiki/Exponential_backoff. Note that the delay /// between consecutive task restarts may not always precisely match the /// configured settings. This can happen when the ConnectCluster is in /// rebalancing state or if the ConnectCluster is unresponsive etc. The default /// values for minimum and maximum backoffs are 60 seconds and 12 hours /// respectively.5>@@E__d55=v.H !,:-JUV^upvvvcpkp//// A list of rules for mapping from SSL principal names to short names. /// /// These are applied in order by Kafka. Refer to the Apache Kafka /// documentation for `ssl.principal.mapping.rules` for the precise formatting /// details and syntax. Example: /// "RULE:^CN=(.*?),OU=ServiceUsers.*$/$1@example.com/,DEFAULT" This is a /// static Kafka broker configuration. Setting or modifying this field will /// trigger a rolling restart of the Kafka brokers to apply the change. An /// empty string means no rules are applied (Kafka default). /// /// Optional.%%/// The configuration of the broker truststore. /// /// If specified, clients can use mTLS for authentication. /// /// Optional.݁؆0/// The TLS configuration for the Kafka cluster.;@BB GPP U[[`ppu;;N?NM]Ymdk_eptu{{5+5/// Configurations for the topic that are overridden from the cluster /// defaults. /// /// The key of the map is a Kafka topic property name, for example: /// `cleanup.policy`, `compression.type`. /// /// Optional./A//// Identifier. /// /// The name of the topic. The `topic` segment is used when connecting /// directly to the cluster. Structured like: /// projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic}k8Ak/// The number of partitions this topic has. /// /// The partition count can only be increased, not decreased. Please note that /// if partitions are increased for a topic that has a key, the partitioning /// logic or the ordering of the messages will be affected. /// /// Required.%~%/// The number of replicas of each partition. /// /// A replication factor of 3 is recommended for high availability. /// /// Required. Immutable.  r0!%/// A Kafka topic in a given cluster. #%(8=|ހ|e/// Configuration for the Google Certificate Authority Service. /// /// Maximum 10. /// /// Optional.E/// Sources of CA certificates to install in the broker's truststore.v)vv;eP'N"(SWX\Md M/// If true, allows an update operation that increases the total vCPU and/or /// memory allocation of the cluster to significantly decrease the per-broker /// vCPU and/or memory allocation. /// /// This can result in reduced performance and availability. By default, the /// update operation will fail if an upscale request results in a vCPU or /// memory allocation for the brokers that is smaller than 90% of the current /// broker size. /// /// Optional.kk uuR/// UpdateOptions specifies options that influence how a cluster update is /// applied. /// /// These options control the behavior of the update process, rather than /// defining the desired end-state of a cluster.@'48OBhVfQWkopv^->^/// The compatibility type of the schemas. /// /// Cannot be unset for a SchemaRegistry-level SchemaConfig. If unset on a /// SchemaSubject-level SchemaConfig, removes the compatibility field for the /// SchemaConfig. /// /// Required. /// Possible string values are: /// - "NONE" : No compatibility check. /// - "BACKWARD" : Backwards compatible with the most recent version. /// - "BACKWARD_TRANSITIVE" : Backwards compatible with all previous versions. /// - "FORWARD" : Forwards compatible with the most recent version. /// - "FORWARD_TRANSITIVE" : Forwards compatible with all previous versions. /// - "FULL" : Backwards and forwards compatible with the most recent version. /// - "FULL_TRANSITIVE" : Backwards and forwards compatible with all previous /// versions.pB/// If true, the schema will be normalized before being stored or looked up. /// /// The default is false. Cannot be unset for a SchemaRegistry-level /// SchemaConfig. If unset on a SchemaSubject-level SchemaConfig, removes the /// normalize field for the SchemaConfig. /// /// Optional.xx/// Request for updating schema config. /// /// On a SchemaSubject-level SchemaConfig, an unset field will be removed from /// the SchemaConfig.v vv%am灊md/// The mode type. /// /// Required. /// Possible string values are: /// - "NONE" : The default / unset value. The subject mode is NONE/unset by /// default, which means use the global schema registry mode. This should not /// be used for setting the mode. /// - "READONLY" : READONLY mode. /// - "READWRITE" : READWRITE mode. /// - "IMPORT" : IMPORT mode.j(9/// Request for updating schema registry or subject mode. `7/// The request message for Operations.CancelOperation.]]H 0/// A generic empty message that you can re-use to avoid defining duplicated /// empty messages in your APIs. /// /// A typical example is to use it as the request or the response type of an API /// method. For instance: service Foo { rpc Bar(google.protobuf.Empty) returns /// (google.protobuf.Empty); }$$)Ą/// Message that represents an arbitrary HTTP body. /// /// It should only be used for payload formats that can't be represented as /// JSON, such as raw binary or an HTML page. This message can be used both in /// streaming and non-streaming API methods in the request as well as the /// response. It can be used as a top-level request field, which is convenient /// if one wants to extract parameters from either the URL or HTTP template into /// the request fields and also want access to the raw HTTP body. Example: /// message GetResourceRequest { // A unique request id. string request_id = 1; /// // The raw HTTP body is bound to this field. google.api.HttpBody http_body = /// 2; } service ResourceService { rpc GetResource(GetResourceRequest) returns /// (google.api.HttpBody); rpc UpdateResource(google.api.HttpBody) returns /// (google.protobuf.Empty); } Example with streaming methods: service /// CaldavService { rpc GetCalendar(stream google.api.HttpBody) returns (stream /// google.api.HttpBody); rpc UpdateCalendar(stream google.api.HttpBody) returns /// (stream google.api.HttpBody); } Use of this type only changes how the /// request and response bodies are handled, all other features will continue to /// work unchanged.PLPLWP7/// A resource that represents a Google Cloud location.gYgYGg/// Request for PauseConnector.ggIg /// Response for PauseConnector.nnKn@!/// Request for RestartConnector.ncncMn"/// Response for RestartConnector.nnIn /// Request for ResumeConnector.nnKo'!/// Response for ResumeConnector.ˁ/// The `Status` type defines a logical error model that is suitable for /// different programming environments, including REST APIs and RPC APIs. /// /// It is used by [gRPC](https://github.com/grpc). Each `Status` message /// contains three pieces of data: error code, error message, and error details. /// You can find out more about this error model and how to work with it in the /// [API Design Guide](https://cloud.google.com/apis/design/errors).E/// Request for StopConnector.G/// Response for StopConnector.GHmЀ)[ʂ*`aÂǂ*.uyV2h+z‡Q3}Lj͉!]+tLUVt,-Fghߌ(xÍ%&gh{׎#4F\uďŏ gijaՒ Pޒߓ(.] -3l !Q]j/5ј j17֙Bښ,MS;KQ؜gmȸθGTZ,FS45eq~4:TZ17tzXv|`ڿ@@%@v@@@AA:ATAmAAAAAB"BUBBCC:CACBCCCCCCCD%D]DdDhDiDDDDDDE;EEEEF4FFGGfGHHVHHIIImIJ J[JJJJJKKKfKsKyKKL L5LMLiLLLLMMYMMMMN N N=NINXNkNNNNNNOOBOCOOOOOPPPFPLPfPlPPQQgQQRRRhRxR~RRSSSSgSSSSTT!TQTTTTUUUFURU`UsUUUUVVVVMVSVVVVVWWLWjWWXXIXXY,YjYYZZdZZ[8[>[[[[[\\!\'\x\\\\] ]&]3]c]]^^^^S^T^^^^^^_$_(_)_?_E___e_``M```aaNa^adaaaaab?btbcc8c?c@cwcxcccccd9d=d>dldrddde-ezeef*f0f{ffffggggjggh)h^hehfhhhhhiiiZi^i_iiiiijjSjqjjkkPkjkpkll_lul{lllmm m^mkmqmmnn8nPnlnnnooMoooooop pp8p?peppppppq qq,q2qqqr<rrssgsst0ttuu"uiuouvv\vvvvvwwwhwuw{wxxx-xExbx|xxxy8ymytyuyyyyyz z,z3z~zzzz{{:{@{o{u{{{{|H|||}E}K}}}}}~4~A~G~~1KXOP9@DFG;A[a%v|Tag<|!-=^eesEK+8>&f $ELo [y kEw}^3UE(.ciS)iCx 8?o!'AGHf U(.y!r6Cs'./fgHOSUVNT OmKbh@MS $>Xe @GH `de6T )/hMYi39 [a9FL^=D4JB@ LR<eXGS`$*Y_y ]{l 28#t(5e !XY,023dd &tkDlrW¡?Î0tĢĨ -3ńőŗ?[uƘƴ Kǜ cdȔȠȮ:>?gmɇɍCaʧʭI˒*zkͯ.>Dhnο#XzϒϮQІЍЎ3:ыяѐ;j$*uӅӋӴӺ oԤG|ՃՄջռ&-Q։֐֔֕Qyת39u{=Cو&^dگڿR_e۶7Pj܂ܞܸ8nݬ$%stޤް޽NUYZߚߠBN ]A.BH38>(Ie} M<=myV-3bhLjPM]cBw?GHx"#>D^d7n{V ;GWx %+uqwS`f<|!-:[bf>DKhx~j4A078W^bc2dR{ ]jp.Fc} 9 n u v       - 4          ]   : @      ) 6 <   +ERABr~+267U[f.>Dw}2g-m+9LmtFLfl >06 Pt#X_`")V ]:@(5;'AN~ < = m y     !%!,!0!2!3!_!!!!!","2""##h#$$U$p$v$$$$%%,%m%s%%%%%&K&X&^&&''&'>'X'e''( (((U(V(((((()(),)-)U)[))*=*C*]*c**++ +T+d+j+++++,E,z,- ->-E-F-}-~-----.?.C.D.}....///Q/o//0000;0A00001+1{11112/202`2l2y222223>3D33333494?4j4p44445/5566c6667H7X7^777778J888889969P9]99::J::::::;D;E;u;;;;;<(>d>>?+?o???@@@C@I@x@~@@@A6A|AAAAB BBcBpBvBBC#CLCfCCCCD2D9D:DDDDDDEEE3EkErEvEwEEEEFF*F}FFFG3GCGIGiGoGGGH$HYHHII$I%I\I]IIIIIJJ"J#JKJQJkJqJJK(KFKKKKKLL#LtLLLM M1MIMcMpMMMMN$N%NUNaNnNNNNNNNOO"O<OBOOP!P'PuPPPQ;QhQRR>RRRS SS"SYS_SSSTTIT|TTTTUUAUvU}U~UUUV VV8V?VqVVVVVVWW WZW{WWWWWX.X4XNXTXXY5YYZ ZbZZZ[)[9[?[t[z[[[\/\d\\\\] ]9]y]]]]]^^*^8^K^l^s^^^^^^_!_J_K_____```V`l``a=aCaaaaab"b/b5bbbbccc_cccccddd dAdHdjddddddeeeZeweefWffffgCggggghhhnh{hhii)iAiai{iiij j/jdjkjljjjjjkkk7kokvkzk{kkkll3l9lSlYllmmEmmmnCnInnnnno(o5o;ooop p%p?pLp|ppppq0q1qaqmqzqqqqrrrrrrWrrrrss3s<sstt\ttu>uuuuuvvv0v6vvww_wewwwwwx?xLxRxxy&yfyyyyyz zz$zEzLzzzzzzz{9{{{{|B|R|X|{||||}6}k}}}}~ ~@~G~H~~~~~~QUWX ,GHS~0K16<&e;pwx .5ePq-C%+v nG|)0RB_?h<gtz":Zt(]de0host,2LR>MS2?E/IV:;kw $&'e-3MSaqwW.cjk7ovz{{Nl-3X^HMN~"#W][.L 8>(KpT[\8pw{}~,>A8Ytu}P,2SYC_w.cjk bfgB+1}IY_=r/e"/PW !e :@#%q1AGjp%Zy“«,gÝ!"R^kČē0YZśż:@Z`ư%CǛǡ%+|ȉȏ4Nhuɵ>?o{ʈʩʰPyz˾39z̾H_Kim}σ'-PVЧдк @_yёѫM҃Ҹҿ8DQry;<ԀԒ6WrsՋՑLֲֻ4R׻_خ>QW٢ٲٸ2?Eږ8Eۅ:;kw܇ܨܯ06lr݌ݒ[d@Fߒ߸߾Y4DJms(]|5p<=my6<kqHQQW7DJ9S`  FGw'.245dxNThqqw_lr&Hb|.56}~.fmqrEQ_}H8"(y3Ke BIJFJK $B [DJ4Wo)^ef2jquv ]iw^YioM=x ) 5 B c j      * 0 J P        $ p     " E K   5Tn(]denrtuFg _m VflJT[\imop89agKS39#)zQ3:Z=9q / ? E j p   !%!Z!!" "'"("_"`""""""#)#0#4#5#i#o####$ $m$%%@%^%%%&&&9&?&&&&')'L'q''''( (U(\(](((((()))9)q)x)|)~))))*-*y*++R+++, , ,9,?,Y,_,--1---.!.P.V.....///</B////0000=0}00001'1(1X1d1q111112!2'2U2[2u2{23/3M3334=4l4r444445M5Z5`556 6"6<6V6c667777Y7Z77777888!8"8c8888999B9H9~9999::~:;; ;r;x;;;<3<9<<<<<==!='=x====>>2>?>>>?%?,?-?t?u?????@6@:@<@=@{@@@@AAABAHA}AAAABBhBBBCC.C4CWC]CCCDDGDfDDDDEE#E$EpEqEEEEEF2F6F8F9FzFFFGGGGUG[GGGGHHHjHHHImIIIJ/J~JJJJK(K8K>KaKgKKKLLQLpLLLLLM#M^MMMMNNNINUNbNNNNNNOODOEOOOP0PKPLPdPjPPPPQ%QQR R+RRRS'SvSTTTTjTzTTTTUU U^UUUUVV VMVVVVWWW3W?WOWpWwWWWWWX4X:XTXZXXY#Y,YYYYZIZoZuZ[[^[[[[\\$\*\{\\\]]3]M]e]]]]^'^o^^^^^_$_0_=_^_e_____`"`(`B`H``aaaaabHbXb^bbbbbcAcvccccdd6dvdddddee)e7eJekereeeeeeffFfGfffggggMgnggggh hh)h/h|hhhipiiij7jGjMj}jjjjk8kmkkkkkl.lnlllllm#m/m=mPmqmxmmmmmn nnEnKnenknno?oHoop[pappqLqqqrrMr]rcrrrrrsAsvssssst0tqtttttuu"u2uSuZuuuuuvvvnvzvvwwxxx^xxyyyYyiyoyyyyzzRzzzzz{{A{|{{{{{|!|-|:|[|b|||||}} }:}@}Z}`}}~5~>~~QW=JP+8>2?:;kw&,lrW`OU=MSv|1fY'HOg +1fv| Z/dkl")y}5;(h{  )*[ JV/5(y*?@RXM'xA*+]c?[at89AVet"5a/jGc/DY|/?Ek(<BRlme 78\@fs7NZ[ ,R(Bj ">?`fyEQ%Oo?@q,2B^_AM$J<BY #$XY=ACDh*ABgm}3^yz  67Uj{"5h Fw"DQrCI01gs-67h7Gy%+;]^ "2JK}ƒ«± GHZ`Ð&,<`aĀĆęĴĵ 17Jlť5h~Ʈƴ,?EUuvǨǮ/CZkzȔȫ=Iɇɚ (?{ʢOˁˣO̟Ý1lΛ:J^ϘϾ 1jstХ+Q}ѝѹCa҇ҵ:[zӟӸBYxԟ (y՚ՠ78fg֖֢-k|׊סת׫ <@BCؖ  V\٫BH[vw`f}۾$4bcu{ܹ()HNa|}ݜݢݵ  B{ޮ 9OP߂߈ߛ߶߷ 4ETk G OZ9I].9f DMNIi#0Yr*OfHN^Knt X0cz TXZ[2!=CSg.LRCIY2e+CIJzVP:AEGH<BR3HIsy2CqJ`aDPE&:CDu/D[EBH!"MNw):f @osuv28Hab$%Zf+K:RXh   ' w    - @ Q ` i j       = K [ m s   Q      1 7 G k l     $Wnwx "#UyNT89-}!Q2U[(.>NO(RSlr <4:+IO_tu3?eVgu&/0ay1>On0cst&>VZ\]  o     !!C!I!Y!w!x!!"" "{""""""# ##M#r###$$$$P$|$$$$$%%%f%%&N&&':''(%(l() )W)))))**?*E*q*****+&+D+E+z+{++++, ,Y,g,~,,,,--B-------...c.r.x..../$/%/t/u////0#0a0r00011C1Z1c1d111222;2b222222233G3H3333444.4U4V4v44444455J5]555566B6|66667737a77778 88888<8[8889999R9p9q9999:):<:i::::;;%;&;W;;;;;;<"$>0>p>>>???(?g?p?q??@@Q@U@W@X@@@AAADAbAcAAAABB)BUBBBBCCCCCCiCCCCCDD<DeDDDDDE EEOEEFF(F)FDF\FqFFFFFG GCGVGGGGGH1HdH{HHHHI I6ICIjIIIIIIIJJ,J[J\JJJJKK1KcKKKKKKLLFLzL~LLLLMMMMUMsMtMMMMMN0N1N_NkNNNOOVOdO{OOOOPPEPIPKPLPPPPPQ/Q\QbQQQQQR"R(RDRJRZRrRsRRRRRRSSS*S+SPSVSfSSSTTGTbTcT|TTTTTTTUU UQUUUVVBVSVaVxVVVVWW?WeWWWWWXX=XVXwX~XXXXXYYOYYYYZEZZZZZZZZ[[K[L[}[[[[[\\(\:\\\\]]]N]_]`]]]^?^^^^_3_d_e___`*`V`k`l```aGaab0b~bbccFcGcccccdd<ddddee2e_eeeeef%fAf_ffffffgg.gKgRgVgXgYgygggggh"h:hhhnhhhhiiXiiiijjj=jnjojjjjjjkkk6k<kkkkl l%l&l]l^lllmm&m]mfmgmmmnnnnn8nbncnnnnnnooIoJojoyoooooppppApGpWpyppq q8qSqTqqqqqr r<rzrrrrss#s$sUs}sssst t-t4t8t:t;tttttuuu)u?u@uluruuv@vFvVvxvvw:wwx xpxxxxxyDyyyyyyz+z,zTz`zz{{ { {>{\{{{{{||!|%|'|(|w|{|}}h}~~V~d~w~+M3Yy4Plprs,2BZ[L(J-QRdjON$@swyz+UVpvIl&'<BRghz"H#:kBZ,Mf^bL=>{k*q 3{5;pv1Jflm&ktu<Ir fl%q KQa23st<` Pz)q>?QW 56ek IO_{|89Q~  ;]yEt{$6<L*oFnrtuLb&,{*0@st_hi 9jquwx +X^%Gp O?Omn Z.:y=2>^st3OkoqRManagedKafkaApiProjectsResourceProjectsLocationsResource!ProjectsLocationsClustersResource%ProjectsLocationsClustersAclsResource/ProjectsLocationsClustersConsumerGroupsResource'ProjectsLocationsClustersTopicsResource(ProjectsLocationsConnectClustersResource2ProjectsLocationsConnectClustersConnectorsResource#ProjectsLocationsOperationsResource)ProjectsLocationsSchemaRegistriesResource6ProjectsLocationsSchemaRegistriesCompatibilityResource/ProjectsLocationsSchemaRegistriesConfigResource1ProjectsLocationsSchemaRegistriesContextsResource>ProjectsLocationsSchemaRegistriesContextsCompatibilityResource7ProjectsLocationsSchemaRegistriesContextsConfigResource5ProjectsLocationsSchemaRegistriesContextsModeResource8ProjectsLocationsSchemaRegistriesContextsSchemasResource@ProjectsLocationsSchemaRegistriesContextsSchemasSubjectsResource=ProjectsLocationsSchemaRegistriesContextsSchemasTypesResource@ProjectsLocationsSchemaRegistriesContextsSchemasVersionsResource9ProjectsLocationsSchemaRegistriesContextsSubjectsResourceAProjectsLocationsSchemaRegistriesContextsSubjectsVersionsResourceMProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyResource-ProjectsLocationsSchemaRegistriesModeResource0ProjectsLocationsSchemaRegistriesSchemasResource8ProjectsLocationsSchemaRegistriesSchemasSubjectsResource5ProjectsLocationsSchemaRegistriesSchemasTypesResource8ProjectsLocationsSchemaRegistriesSchemasVersionsResource1ProjectsLocationsSchemaRegistriesSubjectsResource9ProjectsLocationsSchemaRegistriesSubjectsVersionsResourceEProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyResource AccessConfigAclAclEntryAddAclEntryResponse BrokerDetailsCapacityConfig!CertificateAuthorityServiceConfigCheckCompatibilityRequestCheckCompatibilityResponseClusterConnectAccessConfigConnectClusterConnectGcpConfigConnectNetworkConfig Connector ConsumerGroupConsumerPartitionMetadataConsumerTopicMetadataContextCreateSchemaRegistryRequestCreateVersionRequestCreateVersionResponse GcpConfigListAclsResponseListClustersResponseListConnectClustersResponseListConnectorsResponseListConsumerGroupsResponseListLocationsResponseListOperationsResponseListSchemaRegistriesResponseListTopicsResponseLookupVersionRequest NetworkConfig OperationRebalanceConfigRemoveAclEntryResponseSchema SchemaConfig SchemaModeSchemaReferenceSchemaRegistry SchemaVersionTaskRetryPolicy TlsConfigTopic TrustConfig UpdateOptionsUpdateSchemaConfigRequestUpdateSchemaModeRequest