dVSrSSKJr SSKJr SSKJr "SS\R5r g)z5Generated client library for managedkafka version v1.)absolute_import)base_api)managedkafka_v1_messagesc^\rSrSrSr\rSrSrSr S/r Sr Sr S r S rSrSrS rSLU4S jjr"S S\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS \R(5r"S!S"\R(5r"S#S$\R(5r "S%S&\R(5r!"S'S(\R(5r""S)S*\R(5r#"S+S,\R(5r$"S-S.\R(5r%"S/S0\R(5r&"S1S2\R(5r'"S3S4\R(5r("S5S6\R(5r)"S7S8\R(5r*"S9S:\R(5r+"S;S<\R(5r,"S=S>\R(5r-"S?S@\R(5r."SASB\R(5r/"SCSD\R(5r0"SESF\R(5r1"SGSH\R(5r2"SISJ\R(5r3SKr4U=r5$)MManagedkafkaV1 z=Generated client library for service managedkafka version v1.z$https://managedkafka.googleapis.com/z)https://managedkafka.mtls.googleapis.com/ managedkafkaz.https://www.googleapis.com/auth/cloud-platformv1 CLIENT_ID CLIENT_SECRETzgoogle-cloud-sdkNc >U=(d URn[[U]XX4UXgUU U U S9 UR U5UlUR U5UlURU5Ul URU5Ul URU5Ul URU5UlUR!U5UlUR%U5UlUR)U5UlUR-U5UlUR1U5UlUR5U5UlUR9U5UlUR=U5UlURAU5Ul!UREU5Ul#URIU5Ul%URMU5Ul'URQU5Ul)URUU5Ul+URYU5Ul-UR]U5Ul/URaU5Ul1UReU5Ul3URiU5Ul5URmU5Ul7URqU5Ul9URuU5Ul;URyU5Ul=UR}U5Ul?URU5UlAg)z!Create a new managedkafka handle.) credentialsget_credentialshttpmodel log_request log_responsecredentials_argsdefault_global_paramsadditional_http_headersresponse_encodingN)BBASE_URLsuperr__init__$ProjectsLocationsClustersAclsService projects_locations_clusters_acls.ProjectsLocationsClustersConsumerGroupsService*projects_locations_clusters_consumerGroups&ProjectsLocationsClustersTopicsService"projects_locations_clusters_topics ProjectsLocationsClustersServiceprojects_locations_clusters1ProjectsLocationsConnectClustersConnectorsService-projects_locations_connectClusters_connectors'ProjectsLocationsConnectClustersService"projects_locations_connectClusters"ProjectsLocationsOperationsServiceprojects_locations_operations5ProjectsLocationsSchemaRegistriesCompatibilityService1projects_locations_schemaRegistries_compatibility.ProjectsLocationsSchemaRegistriesConfigService*projects_locations_schemaRegistries_config=ProjectsLocationsSchemaRegistriesContextsCompatibilityService:projects_locations_schemaRegistries_contexts_compatibility6ProjectsLocationsSchemaRegistriesContextsConfigService3projects_locations_schemaRegistries_contexts_config4ProjectsLocationsSchemaRegistriesContextsModeService1projects_locations_schemaRegistries_contexts_mode?ProjectsLocationsSchemaRegistriesContextsSchemasSubjectsService=projects_locations_schemaRegistries_contexts_schemas_subjectsprojects_locations_schemaRegistries_contexts_subjects_versions8ProjectsLocationsSchemaRegistriesContextsSubjectsService5projects_locations_schemaRegistries_contexts_subjects0ProjectsLocationsSchemaRegistriesContextsService,projects_locations_schemaRegistries_contexts,ProjectsLocationsSchemaRegistriesModeService(projects_locations_schemaRegistries_mode7ProjectsLocationsSchemaRegistriesSchemasSubjectsService4projects_locations_schemaRegistries_schemas_subjects4ProjectsLocationsSchemaRegistriesSchemasTypesService1projects_locations_schemaRegistries_schemas_types7ProjectsLocationsSchemaRegistriesSchemasVersionsService4projects_locations_schemaRegistries_schemas_versions/ProjectsLocationsSchemaRegistriesSchemasService+projects_locations_schemaRegistries_schemasDProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyServiceBprojects_locations_schemaRegistries_subjects_versions_referencedby8ProjectsLocationsSchemaRegistriesSubjectsVersionsService5projects_locations_schemaRegistries_subjects_versions0ProjectsLocationsSchemaRegistriesSubjectsService,projects_locations_schemaRegistries_subjects(ProjectsLocationsSchemaRegistriesService#projects_locations_schemaRegistriesProjectsLocationsServiceprojects_locationsProjectsServiceprojects) selfurlrrrrrrrrrr __class__s Slib/googlecloudsdk/generated_clients/apis/managedkafka/v1/managedkafka_v1_client.pyrManagedkafkaV1.__init__sD  C .$( '%)3 7+)--1,U,UVZ,[D)6:6i6ijn6oD3.2.Y.YZ^._D+'+'L'LT'RD$9=9o9opt9uD6.2.Z.Z[_.`D+)-)P)PQU)VD&=A=w=wx|=}D:6:6i6ijn6oD3FJGIGIJNGODC?C?z?z{@AD<=A=v=vw{=|D:IMJNJNOSJTDFFJGHGHIMGNDCIMJNJNOSJTDF@D@|@|~BACD=W[XiXijnXoDTJNKPKPQUKVDGAEA~A~@DBED>8<8m8mnr8sD5484e4efj4kD1@D@|@|~BACD==A=v=vw{=|D:@D@|@|~BACD=7;7k7klp7qD4NROXOXY]O^DKAEA~A~@DBED>8<8m8mnr8sD5/3/\/\]a/bD,";;DAD((.DMc^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSrU=r$)3ManagedkafkaV1.ProjectsLocationsClustersAclsServiceJz@Service class for the projects_locations_clusters_acls resource.rcN>[[RU]U5 0UlgN)rrrr_upload_configsrYclientr[s r\ras4(>(>tMwG- W0 )r^cDURS5nURX1US9$)a Creates a new acl in the given project, location, and cluster. Args: request: (ManagedkafkaProjectsLocationsClustersAclsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Acl) The response message. Createrjrlros r\r:ManagedkafkaV1.ProjectsLocationsClustersAclsService.Createo/##H-f __ 88r^cD[R"SSSS/S/S/SSSS S S 9 $) NKv1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}/aclsrtz4managedkafka.projects.locations.clusters.acls.createparentaclIdv1/{+parent}/aclsru6ManagedkafkaProjectsLocationsClustersAclsCreateRequestAclFryrrr^r\rr|s68#9#9_H zJY)R  $r^cDURS5nURX1US9$)zDeletes an acl. Args: request: (ManagedkafkaProjectsLocationsClustersAclsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. Deleterjrlros r\r:ManagedkafkaV1.ProjectsLocationsClustersAclsService.Deleterr^cB[R"SSSS/S//SSSSS S 9 $) NTv1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}/acls/{aclsId}DELETEz4managedkafka.projects.locations.clusters.acls.deletename v1/{+name}6ManagedkafkaProjectsLocationsClustersAclsDeleteRequestEmptyFryrrr^r\rrs48#9#9hHxH"R" $r^cDURS5nURX1US9$)zReturns the properties of a single acl. Args: request: (ManagedkafkaProjectsLocationsClustersAclsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Acl) The response message. Getrjrlros r\r7ManagedkafkaV1.ProjectsLocationsClustersAclsService.Get/##E*f __ 88r^cB[R"SSSS/S//SSSSS S 9 $) NrGETz1managedkafka.projects.locations.clusters.acls.getrrr3ManagedkafkaProjectsLocationsClustersAclsGetRequestrFryrrr^r\rrs4 6 6hExH"O  !r^cDURS5nURX1US9$)zLists the acls in a given cluster. Args: request: (ManagedkafkaProjectsLocationsClustersAclsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListAclsResponse) The response message. Listrjrlros r\r8ManagedkafkaV1.ProjectsLocationsClustersAclsService.List/##F+f __ 88r^cF[R"SSSS/S/SS/SSS S S S 9 $) Nrrz2managedkafka.projects.locations.clusters.acls.listrpageSize pageTokenrr4ManagedkafkaProjectsLocationsClustersAclsListRequestListAclsResponseFryrrr^r\rrs9!7!7_F zJ +.)P- "r^cDURS5nURX1US9$)zUpdates the properties of a single acl. Args: request: (ManagedkafkaProjectsLocationsClustersAclsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Acl) The response message. Patchrjrlros r\r9ManagedkafkaV1.ProjectsLocationsClustersAclsService.Patch/##G,f __ 88r^cD[R"SSSS/S/S/SSSS S S 9 $) NrPATCHz3managedkafka.projects.locations.clusters.acls.patchr updateMaskrru5ManagedkafkaProjectsLocationsClustersAclsPatchRequestrFryrrr^r\rrs6("8"8hGxH"^"Q  #r^cDURS5nURX1US9$)aIncremental 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). Args: request: (ManagedkafkaProjectsLocationsClustersAclsRemoveAclEntryRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (RemoveAclEntryResponse) The response message. RemoveAclEntryrjrlros r\rBManagedkafkaV1.ProjectsLocationsClustersAclsService.RemoveAclEntrys0##$45f __ 88r^cB[R"SSSS/S//SSSSS S 9 $) Nzcv1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}/acls/{aclsId}:removeAclEntryrtzManagedkafkaProjectsLocationsClustersAclsRemoveAclEntryRequestRemoveAclEntryResponseFryrrr^r\rrs48+A+AwPwG0 Z3 ,r^rdrc)__name__ __module__ __qualname____firstlineno____doc___NAMErri method_configrrrrrr__static_attributes__ __classcell__r[s@r\rr`Js|J .E 8 !K 8 F 8 F 8 C 8 D 8 E 8 $N  r^rc^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lS r U=r $)=ManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsServiceizJService class for the projects_locations_clusters_consumerGroups resource.rcN>[[RU]U5 0Ulgrc)rrrrrdres r\rFManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.__init__# N I I4YZ`a dr^cDURS5nURX1US9$)zDeletes a single consumer group. Args: request: (ManagedkafkaProjectsLocationsClustersConsumerGroupsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrjrlros r\rDManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.Deleterr^cB[R"SSSS/S//SSSSS S 9 $) Nhv1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}/consumerGroups/{consumerGroupsId}rz>managedkafka.projects.locations.clusters.consumerGroups.deleterrr@ManagedkafkaProjectsLocationsClustersConsumerGroupsDeleteRequestrFryrrr^r\rFManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.(s48#9#9|RxH"\" $r^cDURS5nURX1US9$)aReturns the properties of a single consumer group. Args: request: (ManagedkafkaProjectsLocationsClustersConsumerGroupsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ConsumerGroup) The response message. rrjrlros r\rAManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.Get6rr^cB[R"SSSS/S//SSSSS S 9 $) Nrrz;managedkafka.projects.locations.clusters.consumerGroups.getrrr=ManagedkafkaProjectsLocationsClustersConsumerGroupsGetRequest ConsumerGroupFryrrr^r\rrCs4 6 6|OxH"Y* !r^cDURS5nURX1US9$)aLists the consumer groups in a given cluster. Args: request: (ManagedkafkaProjectsLocationsClustersConsumerGroupsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListConsumerGroupsResponse) The response message. rrjrlros r\rBManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.ListQrr^cF[R"SSSS/S//SQSSSS S S 9 $) NzUv1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}/consumerGroupsrzManagedkafkaProjectsLocationsClustersConsumerGroupsListRequestListConsumerGroupsResponseFryrrr^r\rr^s4!7!7iP zJ@3Z7 "r^cDURS5nURX1US9$)aUpdates the properties of a single consumer group. Args: request: (ManagedkafkaProjectsLocationsClustersConsumerGroupsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ConsumerGroup) The response message. rrjrlros r\rCManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.Patchlrr^cD[R"SSSS/S/S/SSSS S S 9 $) Nrrz=managedkafka.projects.locations.clusters.consumerGroups.patchrrr consumerGroup?ManagedkafkaProjectsLocationsClustersConsumerGroupsPatchRequestrFryrrr^r\rrys6("8"8|QxH"^"%[* #r^rrc)rrrrrrrrrrrrrrrs@r\rrsOT 8E 8 F 8 C 8 D 8 Er^rc^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSr U=r$)5ManagedkafkaV1.ProjectsLocationsClustersTopicsServiceizBService class for the projects_locations_clusters_topics resource.r cN>[[RU]U5 0Ulgrc)rrrrrdres r\r>ManagedkafkaV1.ProjectsLocationsClustersTopicsService.__init__s# N A A4QRXY dr^cDURS5nURX1US9$)aCreates a new topic in a given project and location. Args: request: (ManagedkafkaProjectsLocationsClustersTopicsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Topic) The response message. rrjrlros r\rManagedkafkaV1.ProjectsLocationsClustersTopicsService.s68#9#9aJ zJ[+T" $r^cDURS5nURX1US9$)zDeletes a single topic. Args: request: (ManagedkafkaProjectsLocationsClustersTopicsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrjrlros r\r[[RU]U5 0Ulgrc)rrr!rrdres r\r8ManagedkafkaV1.ProjectsLocationsClustersService.__init__s" N ; ;TKFS dr^cDURS5nURX1US9$)aCreates a new cluster in a given project and location. Args: request: (ManagedkafkaProjectsLocationsClustersCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrjrlros r\r6ManagedkafkaV1.ProjectsLocationsClustersService.Create"rr^cF[R"SSSS/S/SS/SSS S S S 9 $) N9v1/projects/{projectsId}/locations/{locationsId}/clustersrtz/managedkafka.projects.locations.clusters.creater clusterId requestIdv1/{+parent}/clusterscluster2ManagedkafkaProjectsLocationsClustersCreateRequest OperationFryrrr^r\r8ManagedkafkaV1.ProjectsLocationsClustersService./s98#9#9MC zJ!;/-N& $r^cDURS5nURX1US9$)zDeletes a single cluster. Args: request: (ManagedkafkaProjectsLocationsClustersDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrjrlros r\r6ManagedkafkaV1.ProjectsLocationsClustersService.Delete=rr^cD[R"SSSS/S/S/SSSS S S 9 $) NFv1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}rz/managedkafka.projects.locations.clusters.deleterrrr2ManagedkafkaProjectsLocationsClustersDeleteRequestrFryrrr^r\rrJs68#9#9ZCxH!]"N& $r^cDURS5nURX1US9$)zReturns the properties of a single cluster. Args: request: (ManagedkafkaProjectsLocationsClustersGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Cluster) The response message. rrjrlros r\r3ManagedkafkaV1.ProjectsLocationsClustersService.GetXrr^cD[R"SSSS/S/S/SSSS S S 9 $) Nrrz,managedkafka.projects.locations.clusters.getrrrr/ManagedkafkaProjectsLocationsClustersGetRequestClusterFryrrr^r\rres6 6 6Z@xHX"K$ !r^cDURS5nURX1US9$)a Lists the clusters in a given project and location. Args: request: (ManagedkafkaProjectsLocationsClustersListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListClustersResponse) The response message. rrjrlros r\r4ManagedkafkaV1.ProjectsLocationsClustersService.Listsrr^cF[R"SSSS/S//SQSSSS S S 9 $) Nrrz-managedkafka.projects.locations.clusters.listrrorderByrrrr0ManagedkafkaProjectsLocationsClustersListRequestListClustersResponseFryrrr^r\rrs4!7!7MA zJC-L1 "r^cDURS5nURX1US9$)zUpdates the properties of a single cluster. Args: request: (ManagedkafkaProjectsLocationsClustersPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrjrlros r\r5ManagedkafkaV1.ProjectsLocationsClustersService.Patchrr^cF[R"SSSS/S/SS/SSS S S S 9 $) Nrrz.managedkafka.projects.locations.clusters.patchrrrrr1ManagedkafkaProjectsLocationsClustersPatchRequestrFryrrr^r\rrs9("8"8ZBxH!<0"M& #r^rrcrrs@r\r!rs^E )E 8 F 8 F 8 C 8 D 8 Er^r!c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSSjrS\lSSjrS\lSrU=r$)@ManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsServiceizMService class for the projects_locations_connectClusters_connectors resource.r$cN>[[RU]U5 0Ulgrc)rrr#rrdres r\rIManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.__init__s# N L Ld\]cd dr^cDURS5nURX1US9$)aCreates a new connector in a given Connect cluster. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Connector) The response message. rrjrlros r\rGManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Createrr^cD[R"SSSS/S/S/SSSS S S 9 $) N_v1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}/connectorsrtzAmanagedkafka.projects.locations.connectClusters.connectors.creater connectorIdv1/{+parent}/connectors connectorCManagedkafkaProjectsLocationsConnectClustersConnectorsCreateRequest ConnectorFryrrr^r\rIManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.s68#9#9sU zJ#_/!_& $r^cDURS5nURX1US9$)zDeletes a connector. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrjrlros r\rGManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Deleterr^cB[R"SSSS/S//SSSSS S 9 $) Nnv1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}/connectors/{connectorsId}rzAmanagedkafka.projects.locations.connectClusters.connectors.deleterrrCManagedkafkaProjectsLocationsConnectClustersConnectorsDeleteRequestrFryrrr^r\rr8s78#9#9CUxH"_" $r^cDURS5nURX1US9$)a Returns the properties of a single connector. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Connector) The response message. rrjrlros r\rDManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Getrr^cB[R"SSSS/S//SSSSS S 9 $) Nr<rz>managedkafka.projects.locations.connectClusters.connectors.getrrr@ManagedkafkaProjectsLocationsConnectClustersConnectorsGetRequestr7Fryrrr^r\rr8s7 6 6CRxH"\& !r^cDURS5nURX1US9$)aLists the connectors in a given Connect cluster. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListConnectorsResponse) The response message. rrjrlros r\rEManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Listrr^cF[R"SSSS/S/SS/SSS S S S 9 $) Nr2rz?managedkafka.projects.locations.connectClusters.connectors.listrrrr4rAManagedkafkaProjectsLocationsConnectClustersConnectorsListRequestListConnectorsResponseFryrrr^r\rr8s9!7!7sS zJ +./]3 "r^cDURS5nURX1US9$)aUpdates the properties of a connector. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Connector) The response message. rrjrlros r\rFManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Patchrr^cD[R"SSSS/S/S/SSSS S S 9 $) Nr<rz@managedkafka.projects.locations.connectClusters.connectors.patchrrrr5BManagedkafkaProjectsLocationsConnectClustersConnectorsPatchRequestr7Fryrrr^r\rr8,s9("8"8CTxH"^"!^& #r^cDURS5nURX1US9$)aPauses the connector and its tasks. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsPauseRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (PauseConnectorResponse) The response message. Pauserjrlros r\rLFManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Pause:rr^cB[R"SSSS/S//SSSSS S 9 $) Nztv1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}/connectors/{connectorsId}:pausertz@managedkafka.projects.locations.connectClusters.connectors.pauserzv1/{+name}:pausepauseConnectorRequestBManagedkafkaProjectsLocationsConnectClustersConnectorsPauseRequestPauseConnectorResponseFryrrr^r\rr8Gs7("8"8ITxH(-^3 #r^cDURS5nURX1US9$)aRestarts the connector. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsRestartRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (RestartConnectorResponse) The response message. Restartrjrlros r\rSHManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.RestartUs/##I.f __ 88r^cB[R"SSSS/S//SSSSS S 9 $) Nzvv1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}/connectors/{connectorsId}:restartrtzBmanagedkafka.projects.locations.connectClusters.connectors.restartrzv1/{+name}:restartrestartConnectorRequestDManagedkafkaProjectsLocationsConnectClustersConnectorsRestartRequestRestartConnectorResponseFryrrr^r\rr8bs7H$:$:KVxH*/`5 %r^cDURS5nURX1US9$)aResumes the connector and its tasks. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsResumeRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ResumeConnectorResponse) The response message. Resumerjrlros r\rZGManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Resumeprr^cB[R"SSSS/S//SSSSS S 9 $) Nzuv1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}/connectors/{connectorsId}:resumertzAmanagedkafka.projects.locations.connectClusters.connectors.resumerzv1/{+name}:resumeresumeConnectorRequestCManagedkafkaProjectsLocationsConnectClustersConnectorsResumeRequestResumeConnectorResponseFryrrr^r\rr8}s78#9#9JUxH)._4 $r^cDURS5nURX1US9$)zStops the connector. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsStopRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (StopConnectorResponse) The response message. Stoprjrlros r\raEManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Stoprr^cB[R"SSSS/S//SSSSS S 9 $) Nzsv1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}/connectors/{connectorsId}:stoprtz?managedkafka.projects.locations.connectClusters.connectors.stoprzv1/{+name}:stopstopConnectorRequestAManagedkafkaProjectsLocationsConnectClustersConnectorsStopRequestStopConnectorResponseFryrrr^r\rr8s7!7!7HSxH',]2 "r^rrc)rrrrrrrrrrrrrrLrSrZrarrrs@r\r#r,sW ;E 8 F 8 F 8 C 8 D 8 E 8 E 8 G 8 F 8 Dr^r#c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSr U=r$)6ManagedkafkaV1.ProjectsLocationsConnectClustersServiceizBService class for the projects_locations_connectClusters resource.r&cN>[[RU]U5 0Ulgrc)rrr%rrdres r\r?ManagedkafkaV1.ProjectsLocationsConnectClustersService.__init__s# N B BDRSYZ dr^cDURS5nURX1US9$)aCreates a new Kafka Connect cluster in a given project and location. Args: request: (ManagedkafkaProjectsLocationsConnectClustersCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrjrlros r\r=ManagedkafkaV1.ProjectsLocationsConnectClustersService.Createrr^cF[R"SSSS/S/SS/SSS S S S 9 $) N@v1/projects/{projectsId}/locations/{locationsId}/connectClustersrtz6managedkafka.projects.locations.connectClusters.createrconnectClusterIdrv1/{+parent}/connectClustersconnectCluster9ManagedkafkaProjectsLocationsConnectClustersCreateRequestrFryrrr^r\r?ManagedkafkaV1.ProjectsLocationsConnectClustersService.s98#9#9TJ zJ(+64&U& $r^cDURS5nURX1US9$)zDeletes a single Connect cluster. Args: request: (ManagedkafkaProjectsLocationsConnectClustersDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrjrlros r\r=ManagedkafkaV1.ProjectsLocationsConnectClustersService.Deleterr^cD[R"SSSS/S/S/SSSS S S 9 $) NTv1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}rz6managedkafka.projects.locations.connectClusters.deleterrrr9ManagedkafkaProjectsLocationsConnectClustersDeleteRequestrFryrrr^r\rrss68#9#9hJxH!]"U& $r^cDURS5nURX1US9$)aReturns the properties of a single Kafka Connect cluster. Args: request: (ManagedkafkaProjectsLocationsConnectClustersGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ConnectCluster) The response message. rrjrlros r\r:ManagedkafkaV1.ProjectsLocationsConnectClustersService.Getrr^cB[R"SSSS/S//SSSSS S 9 $) Nrwrz3managedkafka.projects.locations.connectClusters.getrrr6ManagedkafkaProjectsLocationsConnectClustersGetRequestConnectClusterFryrrr^r\rrss4 6 6hGxH"R+ !r^cDURS5nURX1US9$)a&Lists the Kafka Connect clusters in a given project and location. Args: request: (ManagedkafkaProjectsLocationsConnectClustersListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListConnectClustersResponse) The response message. rrjrlros r\r;ManagedkafkaV1.ProjectsLocationsConnectClustersService.Listrr^cF[R"SSSS/S//SQSSSS S S 9 $) Nrnrz4managedkafka.projects.locations.connectClusters.listrr#rpr7ManagedkafkaProjectsLocationsConnectClustersListRequestListConnectClustersResponseFryrrr^r\rrss4!7!7TH zJC4S8 "r^cDURS5nURX1US9$)a Updates the properties of a single Kafka Connect cluster. Args: request: (ManagedkafkaProjectsLocationsConnectClustersPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrjrlros r\r[[RU]U5 0Ulgrc)rrr'rrdres r\r:ManagedkafkaV1.ProjectsLocationsOperationsService.__init__<s" N = =tMfU dr^cDURS5nURX1US9$)aStarts 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`. Args: request: (ManagedkafkaProjectsLocationsOperationsCancelRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. Cancelrjrlros r\r8ManagedkafkaV1.ProjectsLocationsOperationsService.CancelArr^cB[R"SSSS/S//SSSSS S 9 $) NzQv1/projects/{projectsId}/locations/{locationsId}/operations/{operationsId}:cancelrtz1managedkafka.projects.locations.operations.cancelrzv1/{+name}:cancelcancelOperationRequest4ManagedkafkaProjectsLocationsOperationsCancelRequestrFryrrr^r\r:ManagedkafkaV1.ProjectsLocationsOperationsService.Ns48#9#9eExH).P" $r^cDURS5nURX1US9$)aDeletes 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`. Args: request: (ManagedkafkaProjectsLocationsOperationsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrjrlros r\r8ManagedkafkaV1.ProjectsLocationsOperationsService.Delete\rr^cB[R"SSSS/S//SSSSS S 9 $) NJv1/projects/{projectsId}/locations/{locationsId}/operations/{operationsId}rz1managedkafka.projects.locations.operations.deleterrr4ManagedkafkaProjectsLocationsOperationsDeleteRequestrFryrrr^r\rris48#9#9^ExH"P" $r^cDURS5nURX1US9$)ahGets 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. Args: request: (ManagedkafkaProjectsLocationsOperationsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrjrlros r\r5ManagedkafkaV1.ProjectsLocationsOperationsService.Getwrr^cB[R"SSSS/S//SSSSS S 9 $) Nrrz.managedkafka.projects.locations.operations.getrrr1ManagedkafkaProjectsLocationsOperationsGetRequestrFryrrr^r\rrs4 6 6^BxH"M& !r^cDURS5nURX1US9$)abLists operations that match the specified filter in the request. If the server doesn't support this method, it returns `UNIMPLEMENTED`. Args: request: (ManagedkafkaProjectsLocationsOperationsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListOperationsResponse) The response message. rrjrlros r\r6ManagedkafkaV1.ProjectsLocationsOperationsService.Listrr^cF[R"SSSS/S//SQSSSS S S 9 $) Nz;v1/projects/{projectsId}/locations/{locationsId}/operationsrz/managedkafka.projects.locations.operations.listr)rrrreturnPartialSuccesszv1/{+name}/operationsr2ManagedkafkaProjectsLocationsOperationsListRequestListOperationsResponseFryrrr^r\rrs4!7!7OCxHP-N3 "r^rrc)rrrrrrrrrrrrrrrs@r\r'r7sOG +E 8 F 8 F 8 C 8 Dr^r'cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) DManagedkafkaV1.ProjectsLocationsSchemaRegistriesCompatibilityServiceizQService class for the projects_locations_schemaRegistries_compatibility resource.r*cN>[[RU]U5 0Ulgrc)rrr)rrdres r\rMManagedkafkaV1.ProjectsLocationsSchemaRegistriesCompatibilityService.__init__s$ N P PRV`agh dr^cDURS5nURX1US9$)aUCheck compatibility of a schema with all versions or a specific version of a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesCompatibilityCheckCompatibilityRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (CheckCompatibilityResponse) The response message. CheckCompatibilityrjrlros r\rWManagedkafkaV1.ProjectsLocationsSchemaRegistriesCompatibilityService.CheckCompatibility0##$89f __ 88r^cB[R"SSSS/S//SSSSS S 9 $) Nzvv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/compatibility/{compatibilityId}rtzQmanagedkafka.projects.locations.schemaRegistries.compatibility.checkCompatibilityrrcheckCompatibilityRequestSManagedkafkaProjectsLocationsSchemaRegistriesCompatibilityCheckCompatibilityRequestCheckCompatibilityResponseFryrrr^r\rMManagedkafkaV1.ProjectsLocationsSchemaRegistriesCompatibilityService.s7x/E/EKexH"1o7 0r^rrc rrrrrrrrrrrrs@r\r)rs#[ ?E 8 ($$r^r)c~^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS S jr S \ lS r U=r $) =ManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigServiceizJService class for the projects_locations_schemaRegistries_config resource.r,cN>[[RU]U5 0Ulgrc)rrr+rrdres r\rFManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigService.__init__rr^cDURS5nURX1US9$)aDelete schema config for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesConfigDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaConfig) The response message. rrjrlros r\rDManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigService.Deleterr^cB[R"SSSS/S//SSSSS S 9 $) Nhv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/config/{configId}rz>managedkafka.projects.locations.schemaRegistries.config.deleterrr@ManagedkafkaProjectsLocationsSchemaRegistriesConfigDeleteRequest SchemaConfigFryrrr^r\rFManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigService.s48#9#9|RxH"\) $r^cDURS5nURX1US9$)aGet schema config at global level or for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesConfigGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaConfig) The response message. rrjrlros r\rAManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigService.Getrr^cD[R"SSSS/S/S/SSSS S S 9 $) Nrrz;managedkafka.projects.locations.schemaRegistries.config.getrdefaultToGlobalrr=ManagedkafkaProjectsLocationsSchemaRegistriesConfigGetRequestrFryrrr^r\rrs7 6 6|OxH'("Y) !r^cDURS5nURX1US9$)aOUpdate config at global level or for a subject. Creates a SchemaSubject-level SchemaConfig if it does not exist. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesConfigUpdateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaConfig) The response message. Updaterjrlros r\rDManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigService.Updaterr^cB[R"SSSS/S//SSSSS S 9 $) NrPUTz>managedkafka.projects.locations.schemaRegistries.config.updaterrupdateSchemaConfigRequest@ManagedkafkaProjectsLocationsSchemaRegistriesConfigUpdateRequestrFryrrr^r\rrs48#9#9|RxH"1\) $r^rrc rrrrrrrrrrrrrrs@r\r+rs@T 8E 8 F 8 C 8 Fr^r+cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) LManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsCompatibilityServicei-zZService class for the projects_locations_schemaRegistries_contexts_compatibility resource.r.cN>[[RU]U5 0Ulgrc)rrr-rrdres r\rUManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsCompatibilityService.__init__2s$ N X XZ^hiop dr^cDURS5nURX1US9$)a]Check compatibility of a schema with all versions or a specific version of a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsCompatibilityCheckCompatibilityRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (CheckCompatibilityResponse) The response message. rrjrlros r\r_ManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsCompatibilityService.CheckCompatibility7rr^cB[R"SSSS/S//SSSSS S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/compatibility/{compatibilityId}rtzZmanagedkafka.projects.locations.schemaRegistries.contexts.compatibility.checkCompatibilityrrr[ManagedkafkaProjectsLocationsSchemaRegistriesContextsCompatibilityCheckCompatibilityRequestrFryrrr^r\rUManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsCompatibilityService.Ds7x/E/EanxH"1w7 0r^rrcrrs@r\r-r-s#d HE 8 ($$r^r-c~^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS S jr S \ lS r U=r $) EManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigServiceiRzSService class for the projects_locations_schemaRegistries_contexts_config resource.r0cN>[[RU]U5 0Ulgrc)rrr/rrdres r\rNManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigService.__init__Ws$ N Q QSWabhi dr^cDURS5nURX1US9$)a Delete schema config for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaConfig) The response message. rrjrlros r\rLManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigService.Delete\rr^cB[R"SSSS/S//SSSSS S 9 $) N~v1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/config/{configId}rzGmanagedkafka.projects.locations.schemaRegistries.contexts.config.deleterrrHManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigDeleteRequestrFryrrr^r\rNManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigService.is78#9#9S[xH"d) $r^cDURS5nURX1US9$)aGet schema config at global level or for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaConfig) The response message. rrjrlros r\rIManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigService.Getwrr^cD[R"SSSS/S/S/SSSS S S 9 $) NrrzDmanagedkafka.projects.locations.schemaRegistries.contexts.config.getrrrrEManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigGetRequestrFryrrr^r\rrs: 6 6SXxH'("a) !r^cDURS5nURX1US9$)aWUpdate config at global level or for a subject. Creates a SchemaSubject-level SchemaConfig if it does not exist. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigUpdateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaConfig) The response message. rrjrlros r\rLManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigService.Updaterr^cB[R"SSSS/S//SSSSS S 9 $) NrrzGmanagedkafka.projects.locations.schemaRegistries.contexts.config.updaterrrHManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigUpdateRequestrFryrrr^r\rrs78#9#9S[xH"1d) $r^rrcrrs@r\r/rRs@] AE 8 F 8 C 8 Fr^r/c~^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS S jr S \ lS r U=r $) CManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeServiceizQService class for the projects_locations_schemaRegistries_contexts_mode resource.r2cN>[[RU]U5 0Ulgrc)rrr1rrdres r\rLManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeService.__init__$ N O OQU_`fg dr^cDURS5nURX1US9$)aDelete schema mode for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsModeDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaMode) The response message. rrjrlros r\rJManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeService.Deleterr^cB[R"SSSS/S//SSSSS S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/mode/{modeId}rzEmanagedkafka.projects.locations.schemaRegistries.contexts.mode.deleterrrFManagedkafkaProjectsLocationsSchemaRegistriesContextsModeDeleteRequest SchemaModeFryrrr^r\rLManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeService.s78#9#9OYxH"b' $r^cDURS5nURX1US9$)a Get mode at global level or for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsModeGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaMode) The response message. rrjrlros r\rGManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeService.Getrr^cB[R"SSSS/S//SSSSS S 9 $) NrrzBmanagedkafka.projects.locations.schemaRegistries.contexts.mode.getrrrCManagedkafkaProjectsLocationsSchemaRegistriesContextsModeGetRequestrFryrrr^r\rrs7 6 6OVxH"_' !r^cDURS5nURX1US9$)aUpdate mode at global level or for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsModeUpdateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaMode) The response message. rrjrlros r\rJManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeService.Updaterr^cB[R"SSSS/S//SSSSS S 9 $) NrrzEmanagedkafka.projects.locations.schemaRegistries.contexts.mode.updaterrupdateSchemaModeRequestFManagedkafkaProjectsLocationsSchemaRegistriesContextsModeUpdateRequestrFryrrr^r\rrs78#9#9OYxH"/b' $r^rrcrrs@r\r1rs@[ ?E 8 F 8 C 8 Fr^r1cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) NManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasSubjectsServiceiz]Service class for the projects_locations_schemaRegistries_contexts_schemas_subjects resource.r4cN>[[RU]U5 0Ulgrc)rrr3rrdres r\rWManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasSubjectsService.__init__ $ N Z Z\`jkqr dr^cDURS5nURX1US9$)aOList subjects which reference a particular schema id. The response will be an array of subject names. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasSubjectsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rSManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasSubjectsService.Listrr^cF[R"SSSS/S/SS/SSS S S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/schemas/{schemasId}/subjectsrzOmanagedkafka.projects.locations.schemaRegistries.contexts.schemas.subjects.listrdeletedsubjectv1/{+parent}/subjectsrOManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasSubjectsListRequestHttpBodyFryrrr^r\rWManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasSubjectsService.<!7!7^c zJ+-k% "r^rrc rrrrrrrrrrrrs@r\r3r"g KE 8 Dr^r3cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) KManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasTypesServicei-zZService class for the projects_locations_schemaRegistries_contexts_schemas_types resource.r6cN>[[RU]U5 0Ulgrc)rrr5rrdres r\rTManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasTypesService.__init__2s$ N W WY]ghno dr^cDURS5nURX1US9$)a6List the supported schema types. The response will be an array of schema types. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasTypesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rPManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasTypesService.List7rr^cB[R"SSSS/S//SSSSS S 9 $) Nzzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/schemas/typesrzLmanagedkafka.projects.locations.schemaRegistries.contexts.schemas.types.listrv1/{+parent}/schemas/typesrLManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasTypesListRequestrFryrrr^r\rTManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasTypesService.Ds7!7!7O` zJ2h% "r^rrcrrs@r\r5r -s"d HE 8 Dr^r5cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) NManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasVersionsServiceiRz]Service class for the projects_locations_schemaRegistries_contexts_schemas_versions resource.r8cN>[[RU]U5 0Ulgrc)rrr7rrdres r\rWManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasVersionsService.__init__Wrr^cDURS5nURX1US9$)aList 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}]. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasVersionsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rSManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasVersionsService.List\rr^cF[R"SSSS/S/SS/SSS S S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/schemas/{schemasId}/versionsrzOmanagedkafka.projects.locations.schemaRegistries.contexts.schemas.versions.listrrrv1/{+parent}/versionsrOManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasVersionsListRequestrFryrrr^r\rWManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasVersionsService.irr^rrcrrs@r\r7rRrr^r7cd^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS r U=r $) FManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasServiceiwzTService class for the projects_locations_schemaRegistries_contexts_schemas resource.r:cN>[[RU]U5 0Ulgrc)rrr9rrdres r\rOManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasService.__init__|$ N R RTXbcij dr^cDURS5nURX1US9$)aGet the schema for the given schema id. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Schema) The response message. rrjrlros r\rJManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasService.Getrr^cD[R"SSSS/S/S/SSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/schemas/{schemasId}rzEmanagedkafka.projects.locations.schemaRegistries.contexts.schemas.getrrrrFManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetRequestSchemaFryrrr^r\rOManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasService.s9 6 6UYxH["b# !r^cDURS5nURX1US9$)a=Get the schema string for the given schema id. The response will be the schema string. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetSchemaRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. GetSchemarjrlros r\r(PManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasService.GetSchema/##K0f __ 88r^cD[R"SSSS/S/S/SSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/schemas/{schemasId}/schemarzKmanagedkafka.projects.locations.schemaRegistries.contexts.schemas.getSchemarrv1/{+name}/schemarLManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetSchemaRequestrFryrrr^r\rr&s9h&<&<\_xH[)h% 'r^rrc rrrrrrrrrr(rrrs@r\r9rws1^ BE 8 C 8 Ir^r9cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) [ManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyServiceizkService class for the projects_locations_schemaRegistries_contexts_subjects_versions_referencedby resource.r<cN>[[RU]U5 0Ulgrc)rrr;rrdres r\rdManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyService.__init__s$ N g gimwx~ dr^cDURS5nURX1US9$)aQGet a list of IDs of schemas that reference the schema with the given subject and version. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\r`ManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyService.Listrr^cB[R"SSSS/S//SSSSS S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/subjects/{subjectsId}/versions/{versionsId}/referencedbyrz]managedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.referencedby.listrv1/{+parent}/referencedbyr\ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyListRequestrFryrrr^r\rdManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyService.s7!7!7zq zJ1x% "r^rrcrrs@r\r;r0s"u YE 8 Dr^r;c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSr U=r$)OManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsServiceiz^Service class for the projects_locations_schemaRegistries_contexts_subjects_versions resource.r>cN>[[RU]U5 0Ulgrc)rrr=rrdres r\rXManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.__init__s$ N [ []aklrs dr^cDURS5nURX1US9$)a=Register a new version under a given subject with the given schema. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (CreateVersionResponse) The response message. rrjrlros r\rVManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.Createrr^cB[R"SSSS/S//SSSSS S 9 $) Nv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/subjects/{subjectsId}/versionsrtzRmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.createrrcreateVersionRequestRManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsCreateRequestCreateVersionResponseFryrrr^r\rXManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.s78#9#9`f zJ-,n2 $r^cDURS5nURX1US9$)a8Delete a version of a subject. The response will be the deleted version id. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rVManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.Deleterr^cD[R"SSSS/S/S/SSSS S S 9 $) Nv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/subjects/{subjectsId}/versions/{versionsId}rzRmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.deleter permanentrrRManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsDeleteRequestrFryrrr^r\rrDs98#9#9mfxH!]"n% $r^cDURS5nURX1US9$)a1Get a versioned schema (schema with subject/version) of a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaVersion) The response message. rrjrlros r\rSManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.Getrr^cD[R"SSSS/S/S/SSSS S S 9 $) NrHrzOmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.getrrrrOManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsGetRequest SchemaVersionFryrrr^r\rrD)s9 6 6mcxH["k* !r^cDURS5nURX1US9$)aNGet the schema string only for a version of a subject. The response will be the schema string. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsGetSchemaRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. r(rjrlros r\r(YManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.GetSchema7r*r^cD[R"SSSS/S/S/SSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/subjects/{subjectsId}/versions/{versionsId}/schemarzUmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.getSchemarrr,rUManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsGetSchemaRequestrFryrrr^r\rrDDs9h&<&<tixH[)q% 'r^cDURS5nURX1US9$)aCGet all versions of a subject. The response will be an array of versions of the subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rTManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.ListRrr^cD[R"SSSS/S/S/SSSS S S 9 $) Nr@rzPmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.listrrrrPManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsListRequestrFryrrr^r\rrD_s9!7!7`d zJ[-l% "r^rrcrrrrrrrrrrrr(rrrrs@r\r=r:s^h LE 8 F 8 F 8 C 8 I 8 Dr^r=c~^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS S jr S \ lS r U=r $) GManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsServiceimzUService class for the projects_locations_schemaRegistries_contexts_subjects resource.r@cN>[[RU]U5 0Ulgrc)rrr?rrdres r\rPManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsService.__init__r$ N S SUYcdjk dr^cDURS5nURX1US9$)a8Delete a subject. The response will be an array of versions of the deleted subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rNManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsService.Deletewrr^cD[R"SSSS/S/S/SSSS S S 9 $) Nv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/subjects/{subjectsId}rzImanagedkafka.projects.locations.schemaRegistries.contexts.subjects.deleterrIrrJManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsDeleteRequestrFryrrr^r\rPManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsService.98#9#9W]xH!]"f% $r^cDURS5nURX1US9$)a8List subjects in the schema registry. The response will be an array of subject names. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rLManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsService.Listrr^cF[R"SSSS/S/SS/SSS S S S 9 $) Nzuv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/subjectsrzGmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.listrr subjectPrefixrrHManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsListRequestrFryrrr^r\rrcs<!7!7J[ zJ1-d% "r^cDURS5nURX1US9$)aLookup a schema under the specified subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsLookupVersionRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaVersion) The response message. LookupVersionrjrlros r\rkUManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsService.LookupVersion/##O4f __ 88r^cB[R"SSSS/S//SSSSS S 9 $) NrartzPmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.lookupVersionr v1/{+parent}lookupVersionRequestQManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsLookupVersionRequestrOFryrrr^r\rrcs7(*@*@Wd zJ$,m* +r^rrc rrrrrrrrrrrkrrrs@r\r?rZms@_ CE 8 F 8 D 8 #Mr^r?cd^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS r U=r $) ?ManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsServiceizLService class for the projects_locations_schemaRegistries_contexts resource.rBcN>[[RU]U5 0Ulgrc)rrrArrdres r\rHManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsService.__init__# N K KT[\bc dr^cDURS5nURX1US9$)zGet the context. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Context) The response message. rrjrlros r\rCManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsService.Getrr^cB[R"SSSS/S//SSSSS S 9 $) Nzlv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}rz=managedkafka.projects.locations.schemaRegistries.contexts.getrrr?ManagedkafkaProjectsLocationsSchemaRegistriesContextsGetRequestContextFryrrr^r\rHManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsService.s7 6 6AQxH"[$ !r^cDURS5nURX1US9$)zList contexts for a schema registry. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rDManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsService.Listrr^cB[R"SSSS/S//SSSSS S 9 $) Nz_v1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contextsrz>managedkafka.projects.locations.schemaRegistries.contexts.listrzv1/{+parent}/contextsr@ManagedkafkaProjectsLocationsSchemaRegistriesContextsListRequestrFryrrr^r\rr}s4!7!7sR zJ-\% "r^rrc rrrrrrrrrrrrrs@r\rArts1V :E 8 C 8 Dr^rAc~^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS S jr S \ lS r U=r $) ;ManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeServiceizHService class for the projects_locations_schemaRegistries_mode resource.rDcN>[[RU]U5 0Ulgrc)rrrCrrdres r\rDManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeService.__init__ s# N G GWX^_ dr^cDURS5nURX1US9$)zDelete schema mode for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesModeDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaMode) The response message. rrjrlros r\rBManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeService.Deleterr^cB[R"SSSS/S//SSSSS S 9 $) Ndv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/mode/{modeId}rzManagedkafkaProjectsLocationsSchemaRegistriesModeDeleteRequestrFryrrr^r\rDManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeService.s48#9#9xPxH"Z' $r^cDURS5nURX1US9$)aGet mode at global level or for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesModeGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaMode) The response message. rrjrlros r\r?ManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeService.Get-rr^cB[R"SSSS/S//SSSSS S 9 $) Nrrz9managedkafka.projects.locations.schemaRegistries.mode.getrrr;ManagedkafkaProjectsLocationsSchemaRegistriesModeGetRequestrFryrrr^r\rr:s4 6 6xMxH"W' !r^cDURS5nURX1US9$)aUpdate mode at global level or for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesModeUpdateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaMode) The response message. rrjrlros r\rBManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeService.UpdateHrr^cB[R"SSSS/S//SSSSS S 9 $) NrrzManagedkafkaProjectsLocationsSchemaRegistriesModeUpdateRequestrFryrrr^r\rrUs48#9#9xPxH"/Z' $r^rrcrrs@r\rCrs@R 6E 8 F 8 C 8 Fr^rCcJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) FManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasSubjectsServiceiczTService class for the projects_locations_schemaRegistries_schemas_subjects resource.rFcN>[[RU]U5 0Ulgrc)rrrErrdres r\rOManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasSubjectsService.__init__hr r^cDURS5nURX1US9$)aGList subjects which reference a particular schema id. The response will be an array of subject names. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSchemasSubjectsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rKManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasSubjectsService.Listmrr^cF[R"SSSS/S/SS/SSS S S S 9 $) Nzsv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/schemas/{schemasId}/subjectsrzFmanagedkafka.projects.locations.schemaRegistries.schemas.subjects.listrrrrrGManagedkafkaProjectsLocationsSchemaRegistriesSchemasSubjectsListRequestrFryrrr^r\rOManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasSubjectsService.z<!7!7HZ zJ+-c% "r^rrcrrs@r\rErc"^ BE 8 Dr^rEcJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) CManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasTypesServiceizQService class for the projects_locations_schemaRegistries_schemas_types resource.rHcN>[[RU]U5 0Ulgrc)rrrGrrdres r\rLManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasTypesService.__init__rr^cDURS5nURX1US9$)a.List the supported schema types. The response will be an array of schema types. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSchemasTypesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rHManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasTypesService.Listrr^cB[R"SSSS/S//SSSSS S 9 $) Nzdv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/schemas/typesrzCmanagedkafka.projects.locations.schemaRegistries.schemas.types.listrrrDManagedkafkaProjectsLocationsSchemaRegistriesSchemasTypesListRequestrFryrrr^r\rLManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasTypesService.s4!7!7xW zJ2`% "r^rrcrrs@r\rGrs"[ ?E 8 Dr^rGcJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) FManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasVersionsServiceizTService class for the projects_locations_schemaRegistries_schemas_versions resource.rJcN>[[RU]U5 0Ulgrc)rrrIrrdres r\rOManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasVersionsService.__init__r r^cDURS5nURX1US9$)aList 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}]. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSchemasVersionsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rKManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasVersionsService.Listrr^cF[R"SSSS/S/SS/SSS S S S 9 $) Nzsv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/schemas/{schemasId}/versionsrzFmanagedkafka.projects.locations.schemaRegistries.schemas.versions.listrrrrrGManagedkafkaProjectsLocationsSchemaRegistriesSchemasVersionsListRequestrFryrrr^r\rOManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasVersionsService.rr^rrcrrs@r\rIrrr^rIcd^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS r U=r $) >ManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasServiceizKService class for the projects_locations_schemaRegistries_schemas resource.rLcN>[[RU]U5 0Ulgrc)rrrKrrdres r\rGManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasService.__init__s# N J JDZ[ab dr^cDURS5nURX1US9$)zGet the schema for the given schema id. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Schema) The response message. rrjrlros r\rBManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasService.Getrr^cD[R"SSSS/S/S/SSSS S S 9 $) Nzjv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/schemas/{schemasId}rzManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetRequestr%Fryrrr^r\rGManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasService.s6 6 6~PxH["Z# !r^cDURS5nURX1US9$)a5Get the schema string for the given schema id. The response will be the schema string. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetSchemaRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. r(rjrlros r\r(HManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasService.GetSchemar*r^cD[R"SSSS/S/S/SSSS S S 9 $) Nzqv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/schemas/{schemasId}/schemarzBmanagedkafka.projects.locations.schemaRegistries.schemas.getSchemarrr,rDManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetSchemaRequestrFryrrr^r\rr s9h&<&<FVxH[)`% 'r^rrcr.rs@r\rKrs1U 9E 8 C 8 Ir^rKcJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) SManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyServicei zbService class for the projects_locations_schemaRegistries_subjects_versions_referencedby resource.rNcN>[[RU]U5 0Ulgrc)rrrMrrdres r\r\ManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyService.__init__ s$ N _ _aeopvw dr^cDURS5nURX1US9$)aIGet a list of IDs of schemas that reference the schema with the given subject and version. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rXManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyService.List rr^cB[R"SSSS/S//SSSSS S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/subjects/{subjectsId}/versions/{versionsId}/referencedbyrzTmanagedkafka.projects.locations.schemaRegistries.subjects.versions.referencedby.listrr6rTManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyListRequestrFryrrr^r\r\ManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyService.) s7!7!7dh zJ1p% "r^rrcrrs@r\rMr s"l PE 8 Dr^rMc^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSr U=r$)GManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsServicei7 zUService class for the projects_locations_schemaRegistries_subjects_versions resource.rPcN>[[RU]U5 0Ulgrc)rrrOrrdres r\rPManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.__init__< r]r^cDURS5nURX1US9$)a5Register a new version under a given subject with the given schema. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (CreateVersionResponse) The response message. rrjrlros r\rNManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.CreateA rr^cB[R"SSSS/S//SSSSS S 9 $) Nuv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/subjects/{subjectsId}/versionsrtzImanagedkafka.projects.locations.schemaRegistries.subjects.versions.createrrrAJManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsCreateRequestrCFryrrr^r\rPManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.N s78#9#9J] zJ-,f2 $r^cDURS5nURX1US9$)a0Delete a version of a subject. The response will be the deleted version id. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rNManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.Delete\ rr^cD[R"SSSS/S/S/SSSS S S 9 $) Nv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/subjects/{subjectsId}/versions/{versionsId}rzImanagedkafka.projects.locations.schemaRegistries.subjects.versions.deleterrIrrJManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsDeleteRequestrFryrrr^r\rri rdr^cDURS5nURX1US9$)a)Get a versioned schema (schema with subject/version) of a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaVersion) The response message. rrjrlros r\rKManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.Getw rr^cD[R"SSSS/S/S/SSSS S S 9 $) NrrzFmanagedkafka.projects.locations.schemaRegistries.subjects.versions.getrrrrGManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsGetRequestrOFryrrr^r\rr s9 6 6WZxH["c* !r^cDURS5nURX1US9$)aFGet the schema string only for a version of a subject. The response will be the schema string. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsGetSchemaRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. r(rjrlros r\r(QManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.GetSchema r*r^cD[R"SSSS/S/S/SSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/subjects/{subjectsId}/versions/{versionsId}/schemarzLmanagedkafka.projects.locations.schemaRegistries.subjects.versions.getSchemarrr,rMManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsGetSchemaRequestrFryrrr^r\rr s9h&<&<^`xH[)i% 'r^cDURS5nURX1US9$)a;Get all versions of a subject. The response will be an array of versions of the subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rLManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.List rr^cD[R"SSSS/S/S/SSSS S S 9 $) NrrzGmanagedkafka.projects.locations.schemaRegistries.subjects.versions.listrrrrHManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsListRequestrFryrrr^r\rr s9!7!7J[ zJ[-d% "r^rrcrXrs@r\rOr7 s^_ CE 8 F 8 F 8 C 8 I 8 Dr^rOc~^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS S jr S \ lS r U=r $) ?ManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsServicei zLService class for the projects_locations_schemaRegistries_subjects resource.rRcN>[[RU]U5 0Ulgrc)rrrQrrdres r\rHManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsService.__init__ rwr^cDURS5nURX1US9$)a0Delete a subject. The response will be an array of versions of the deleted subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rFManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsService.Delete rr^cD[R"SSSS/S/S/SSSS S S 9 $) Nlv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/subjects/{subjectsId}rz@managedkafka.projects.locations.schemaRegistries.subjects.deleterrIrrBManagedkafkaProjectsLocationsSchemaRegistriesSubjectsDeleteRequestrFryrrr^r\rHManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsService. s98#9#9ATxH!]"^% $r^cDURS5nURX1US9$)a0List subjects in the schema registry. The response will be an array of subject names. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrjrlros r\rDManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsService.List rr^cF[R"SSSS/S/SS/SSS S S S 9 $) Nz_v1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/subjectsrz>managedkafka.projects.locations.schemaRegistries.subjects.listrrrhrr@ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsListRequestrFryrrr^r\rr s9!7!7sR zJ1-\% "r^cDURS5nURX1US9$)aLookup a schema under the specified subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsLookupVersionRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaVersion) The response message. rkrjrlros r\rkMManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsService.LookupVersion rmr^cB[R"SSSS/S//SSSSS S 9 $) NrrtzGmanagedkafka.projects.locations.schemaRegistries.subjects.lookupVersionrrorpIManagedkafkaProjectsLocationsSchemaRegistriesSubjectsLookupVersionRequestrOFryrrr^r\rr s7(*@*@A[ zJ$,e* +r^rrcrrrs@r\rQr s@V :E 8 F 8 D 8 #Mr^rQc^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lS r U=r $)7ManagedkafkaV1.ProjectsLocationsSchemaRegistriesServicei# zCService class for the projects_locations_schemaRegistries resource.rTcN>[[RU]U5 0Ulgrc)rrrSrrdres r\r@ManagedkafkaV1.ProjectsLocationsSchemaRegistriesService.__init__( s# N C CTSTZ[ dr^cDURS5nURX1US9$)zCreate a schema registry instance. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaRegistry) The response message. rrjrlros r\r>ManagedkafkaV1.ProjectsLocationsSchemaRegistriesService.Create- rr^cB[R"SSSS/S//SSSSS S 9 $) NAv1/projects/{projectsId}/locations/{locationsId}/schemaRegistriesrtz7managedkafka.projects.locations.schemaRegistries.createrv1/{+parent}/schemaRegistriescreateSchemaRegistryRequest:ManagedkafkaProjectsLocationsSchemaRegistriesCreateRequestSchemaRegistryFryrrr^r\r@ManagedkafkaV1.ProjectsLocationsSchemaRegistriesService.: s48#9#9UK zJ53V+ $r^cDURS5nURX1US9$)zDelete a schema registry instance. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrjrlros r\r>ManagedkafkaV1.ProjectsLocationsSchemaRegistriesService.DeleteH rr^cB[R"SSSS/S//SSSSS S 9 $) NVv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}rz7managedkafka.projects.locations.schemaRegistries.deleterrr:ManagedkafkaProjectsLocationsSchemaRegistriesDeleteRequestrFryrrr^r\rrU s48#9#9jKxH"V" $r^cDURS5nURX1US9$)zGet the schema registry instance. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaRegistry) The response message. rrjrlros r\r;ManagedkafkaV1.ProjectsLocationsSchemaRegistriesService.Getc rr^cB[R"SSSS/S//SSSSS S 9 $) Nrrz4managedkafka.projects.locations.schemaRegistries.getrrr7ManagedkafkaProjectsLocationsSchemaRegistriesGetRequestrFryrrr^r\rrp s4 6 6jHxH"S+ !r^cDURS5nURX1US9$)zList schema registries. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSchemaRegistriesResponse) The response message. rrjrlros r\r[[RU]U5 0Ulgrc)rrrUrrdres r\r0ManagedkafkaV1.ProjectsLocationsService.__init__ s" N 3 3TCFK dr^cDURS5nURX1US9$)zGets information about a location. Args: request: (ManagedkafkaProjectsLocationsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Location) The response message. rrjrlros r\r+ManagedkafkaV1.ProjectsLocationsService.Get rr^cB[R"SSSS/S//SSSSS S 9 $) Nz0v1/projects/{projectsId}/locations/{locationsId}rz#managedkafka.projects.locations.getrrr'ManagedkafkaProjectsLocationsGetRequestLocationFryrrr^r\r0ManagedkafkaV1.ProjectsLocationsService. s4 6 6D7xH"C% !r^cDURS5nURX1US9$)aLists information about the supported locations for this service. Args: request: (ManagedkafkaProjectsLocationsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListLocationsResponse) The response message. rrjrlros r\r,ManagedkafkaV1.ProjectsLocationsService.List rr^cF[R"SSSS/S//SQSSSS S S 9 $) Nz"v1/projects/{projectsId}/locationsrz$managedkafka.projects.locations.listr)extraLocationTypesrrrzv1/{+name}/locationsr(ManagedkafkaProjectsLocationsListRequestListLocationsResponseFryrrr^r\rr s4!7!768xHN,D2 "r^rrcrrs@r\rUr s1< E 8 C 8 Dr^rUc0^\rSrSrSrSrU4SjrSrU=r$)ManagedkafkaV1.ProjectsServicei z(Service class for the projects resource.rXcN>[[RU]U5 0Ulgrc)rrrWrrdres r\r'ManagedkafkaV1.ProjectsService.__init__ s" N * *D:6B dr^r) rrrrrrrrrrs@r\rWr! s2 E  r^rW)rXrVr"rrr r&r$r(rTr*r,rBr.r0r2r:r4r6r8r@r>r<rDrLrFrHrJrRrPrN) rNTNNFFNNNN)6rrrrrmessagesMESSAGES_MODULEr MTLS_BASE_URL_PACKAGE_SCOPES_VERSION _CLIENT_ID_CLIENT_SECRET _USER_AGENT_CLIENT_CLASS_NAME _URL_VERSION_API_KEYrrBaseApiServicerrrr!r#r%r'r)r+r-r/r1r3r5r7r9r;r=r?rArCrErGrIrKrMrOrQrSrUrWrrrs@r\rr sE/ 3(=- ( = >' (*"."+', ()-6:/4<@?C -/^EX-D-DENtx7N7NtlOx/F/FObO)@)@Ob{(:Q:Q{zO0G0GObt8+B+Btl#h>U>U#JYx7N7NYv#hF]F]#JYx?V?VYvYX=T=TYv#H_H_#J#XE\E\#J#H_H_#J>@W@W>@#U]UlUl#JOI`I`ObYAXAXYv>9P9P>@YX5L5LYv#@W@W#J#X=T=T#J#@W@W#J>8O8O>@#XMdMd#JOAXAXObY9P9PYvt1H1Htl>!8!8>@ //  r^rN) r __future__rapitools.base.pyr5googlecloudsdk.generated_clients.apis.managedkafka.v1rr$ BaseApiClientrrr^r\r5s';'%fW+ X++W+ r^