LVdZddlmZddlmZddlmZGddejZ y)z5Generated client library for managedkafka version v1.)absolute_import)base_api)managedkafka_v1_messagescveZdZdZeZdZdZdZdgZ dZ dZ dZ d Z dZdZd Z dJfd ZGd d ej&ZGddej&ZGddej&ZGddej&ZGddej&ZGddej&ZGddej&ZGddej&ZGddej&ZGddej&ZGd d!ej&ZGd"d#ej&ZGd$d%ej&Z Gd&d'ej&Z!Gd(d)ej&Z"Gd*d+ej&Z#Gd,d-ej&Z$Gd.d/ej&Z%Gd0d1ej&Z&Gd2d3ej&Z'Gd4d5ej&Z(Gd6d7ej&Z)Gd8d9ej&Z*Gd:d;ej&Z+Gd<d=ej&Z,Gd>d?ej&Z-Gd@dAej&Z.GdBdCej&Z/GdDdEej&Z0GdFdGej&Z1GdHdIej&Z2xZ3S)KManagedkafkaV1z=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 |xs |j}tt|||||||||| | |  |j ||_|j ||_|j||_ |j||_ |j||_ |j||_|j!||_|j%||_|j)||_|j-||_|j1||_|j5||_|j9||_|j=||_|jA||_!|jE||_#|jI||_%|jM||_'|jQ||_)|jU||_+|jY||_-|j]||_/|ja||_1|je||_3|ji||_5|jm||_7|jq||_9|ju||_;|jy||_=|j}||_?|j||_Ay)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) selfurlr rrrrrrrrr __class__s Slib/googlecloudsdk/generated_clients/apis/managedkafka/v1/managedkafka_v1_client.pyrzManagedkafkaV1.__init__sJ  C .$( 'd%l)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((.DMceZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _ddZ de _ddZ de _xZS)3ManagedkafkaV1.ProjectsLocationsClustersAclsServicez@Service class for the projects_locations_clusters_acls resource.rcNttj||i|_yN)rrrr_upload_configsrXclientrZs r[rzzas4(>(>tMwG- W0 )r\cL|jd}|j|||S)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. Createrfrhrks r[rz:ManagedkafkaV1.ProjectsLocationsClustersAclsService.Createo1##H-f __ '88r\c Htjddddgdgdgdddd d S) NKv1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}/aclsroz4managedkafka.projects.locations.clusters.acls.createparentaclIdv1/{+parent}/aclsrp6ManagedkafkaProjectsLocationsClustersAclsCreateRequestAclFrtrrr\r[rz|s68#9#9_H zJY)R  $r\cL|jd}|j|||S)aDeletes an acl. Args: request: (ManagedkafkaProjectsLocationsClustersAclsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. Deleterfrhrks r[rz:ManagedkafkaV1.ProjectsLocationsClustersAclsService.Deleterr\c Ftjddddgdggddddd S) NTv1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}/acls/{aclsId}DELETEz4managedkafka.projects.locations.clusters.acls.deletename v1/{+name}6ManagedkafkaProjectsLocationsClustersAclsDeleteRequestEmptyFrtrrr\r[rzs48#9#9hHxH"R" $r\cL|jd}|j|||S)aReturns the properties of a single acl. Args: request: (ManagedkafkaProjectsLocationsClustersAclsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Acl) The response message. Getrfrhrks r[rz7ManagedkafkaV1.ProjectsLocationsClustersAclsService.Get1##E*f __ '88r\c Ftjddddgdggddddd S) NrGETz1managedkafka.projects.locations.clusters.acls.getrrr3ManagedkafkaProjectsLocationsClustersAclsGetRequestrFrtrrr\r[rzs4 6 6hExH"O  !r\cL|jd}|j|||S)aLists the acls in a given cluster. Args: request: (ManagedkafkaProjectsLocationsClustersAclsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListAclsResponse) The response message. Listrfrhrks r[rz8ManagedkafkaV1.ProjectsLocationsClustersAclsService.List1##F+f __ '88r\c Jtjddddgdgddgddd d d S) Nrrz2managedkafka.projects.locations.clusters.acls.listrpageSize pageTokenrr4ManagedkafkaProjectsLocationsClustersAclsListRequestListAclsResponseFrtrrr\r[rzs9!7!7_F zJ +.)P- "r\cL|jd}|j|||S)aUpdates the properties of a single acl. Args: request: (ManagedkafkaProjectsLocationsClustersAclsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Acl) The response message. Patchrfrhrks r[rz9ManagedkafkaV1.ProjectsLocationsClustersAclsService.Patch1##G,f __ '88r\c Htjddddgdgdgdddd d S) NrPATCHz3managedkafka.projects.locations.clusters.acls.patchr updateMaskrrp5ManagedkafkaProjectsLocationsClustersAclsPatchRequestrFrtrrr\r[rzs6("8"8hGxH"^"Q  #r\cL|jd}|j|||S)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. RemoveAclEntryrfrhrks r[rzBManagedkafkaV1.ProjectsLocationsClustersAclsService.RemoveAclEntrys2##$45f __ '88r\c Ftjddddgdggddddd S) Nzcv1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}/acls/{aclsId}:removeAclEntryrozManagedkafkaProjectsLocationsClustersAclsRemoveAclEntryRequestRemoveAclEntryResponseFrtrrr\r[rzs48+A+AwPwG0 Z3 ,r\r`)__name__ __module__ __qualname____doc___NAMErre method_configrrrrrr __classcell__rZs@r[rr^Js|J .E 8 !K 8 F 8 F 8 C 8 D 8 E 8 $N  r\rceZdZdZdZfdZd dZde_d dZde_d dZ d e _d d Z d e _xZ S) =ManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsServicezJService class for the projects_locations_clusters_consumerGroups resource.rcNttj||i|_yr`)rrrrrarbs r[rzFManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.__init__# N I I4YZ`a dr\cL|jd}|j|||S)aDeletes a single consumer group. Args: request: (ManagedkafkaProjectsLocationsClustersConsumerGroupsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrfrhrks r[rzDManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.Deleterr\c Ftjddddgdggddddd S) Nhv1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}/consumerGroups/{consumerGroupsId}rz>managedkafka.projects.locations.clusters.consumerGroups.deleterrr@ManagedkafkaProjectsLocationsClustersConsumerGroupsDeleteRequestrFrtrrr\r[rzFManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.(s48#9#9|RxH"\" $r\cL|jd}|j|||S)a3Returns the properties of a single consumer group. Args: request: (ManagedkafkaProjectsLocationsClustersConsumerGroupsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ConsumerGroup) The response message. rrfrhrks r[rzAManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.Get6rr\c Ftjddddgdggddddd S) Nrrz;managedkafka.projects.locations.clusters.consumerGroups.getrrr=ManagedkafkaProjectsLocationsClustersConsumerGroupsGetRequest ConsumerGroupFrtrrr\r[rzFManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.Cs4 6 6|OxH"Y* !r\cL|jd}|j|||S)a<Lists the consumer groups in a given cluster. Args: request: (ManagedkafkaProjectsLocationsClustersConsumerGroupsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListConsumerGroupsResponse) The response message. rrfrhrks r[rzBManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.ListQrr\c Jtjddddgdggddddd d S) NzUv1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}/consumerGroupsrzManagedkafkaProjectsLocationsClustersConsumerGroupsListRequestListConsumerGroupsResponseFrtrrr\r[rzFManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.^s4!7!7iP zJ@3Z7 "r\cL|jd}|j|||S)a5Updates the properties of a single consumer group. Args: request: (ManagedkafkaProjectsLocationsClustersConsumerGroupsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ConsumerGroup) The response message. rrfrhrks r[rzCManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.Patchlrr\c Htjddddgdgdgdddd d S) Nrrz=managedkafka.projects.locations.clusters.consumerGroups.patchrrr consumerGroup?ManagedkafkaProjectsLocationsClustersConsumerGroupsPatchRequestrFrtrrr\r[rzFManagedkafkaV1.ProjectsLocationsClustersConsumerGroupsService.ys6("8"8|QxH"^"%[* #r\r`) rrrrrrrrrrrrrs@r[rrsOT 8E 8 F 8 C 8 D 8 Er\rceZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _xZ S)5ManagedkafkaV1.ProjectsLocationsClustersTopicsServicezBService class for the projects_locations_clusters_topics resource.rcNttj||i|_yr`)rrrrrarbs r[rz>ManagedkafkaV1.ProjectsLocationsClustersTopicsService.__init__s# N A A4QRXY dr\cL|jd}|j|||S)a(Creates 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. rrfrhrks r[rzManagedkafkaV1.ProjectsLocationsClustersTopicsService.s68#9#9aJ zJ[+T" $r\cL|jd}|j|||S)a Deletes a single topic. Args: request: (ManagedkafkaProjectsLocationsClustersTopicsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrfrhrks r[rzManagedkafkaV1.ProjectsLocationsClustersTopicsService.s48#9#9lJxH"T" $r\cL|jd}|j|||S)aReturns the properties of a single topic. Args: request: (ManagedkafkaProjectsLocationsClustersTopicsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Topic) The response message. rrfrhrks r[rz9ManagedkafkaV1.ProjectsLocationsClustersTopicsService.Getrr\c Ftjddddgdggddddd S) Nrrz3managedkafka.projects.locations.clusters.topics.getrrr5ManagedkafkaProjectsLocationsClustersTopicsGetRequestrFrtrrr\r[rz>ManagedkafkaV1.ProjectsLocationsClustersTopicsService.s4 6 6lGxH"Q" !r\cL|jd}|j|||S)a#Lists the topics in a given cluster. Args: request: (ManagedkafkaProjectsLocationsClustersTopicsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListTopicsResponse) The response message. rrfrhrks r[rz:ManagedkafkaV1.ProjectsLocationsClustersTopicsService.Listrr\c Jtjddddgdgddgddd d d S) Nrrz4managedkafka.projects.locations.clusters.topics.listrrrrr6ManagedkafkaProjectsLocationsClustersTopicsListRequestListTopicsResponseFrtrrr\r[rz>ManagedkafkaV1.ProjectsLocationsClustersTopicsService.s9!7!7aH zJ +.+R/ "r\cL|jd}|j|||S)aUpdates the properties of a single topic. Args: request: (ManagedkafkaProjectsLocationsClustersTopicsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Topic) The response message. rrfrhrks r[rz;ManagedkafkaV1.ProjectsLocationsClustersTopicsService.Patchrr\c Htjddddgdgdgdddd d S) Nrrz5managedkafka.projects.locations.clusters.topics.patchrrrr7ManagedkafkaProjectsLocationsClustersTopicsPatchRequestrFrtrrr\r[rz>ManagedkafkaV1.ProjectsLocationsClustersTopicsService. s6("8"8lIxH"^"S" #r\r` rrrrrrrrrrrrrrs@r[rr^L 0E 8 F 8 F 8 C 8 D 8 Er\rceZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _xZ S)/ManagedkafkaV1.ProjectsLocationsClustersServicez;Service class for the projects_locations_clusters resource.r!cNttj||i|_yr`)rrr rrarbs r[rz8ManagedkafkaV1.ProjectsLocationsClustersService.__init__s" N ; ;TKFS dr\cL|jd}|j|||S)a(Creates 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. rrfrhrks r[rz6ManagedkafkaV1.ProjectsLocationsClustersService.Create"rr\c Jtjddddgdgddgddd d d S) N9v1/projects/{projectsId}/locations/{locationsId}/clustersroz/managedkafka.projects.locations.clusters.creater clusterId requestIdv1/{+parent}/clusterscluster2ManagedkafkaProjectsLocationsClustersCreateRequest OperationFrtrrr\r[rz8ManagedkafkaV1.ProjectsLocationsClustersService./s98#9#9MC zJ!;/-N& $r\cL|jd}|j|||S)a Deletes a single cluster. Args: request: (ManagedkafkaProjectsLocationsClustersDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrfrhrks r[rz6ManagedkafkaV1.ProjectsLocationsClustersService.Delete=rr\c Htjddddgdgdgdddd d S) NFv1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}rz/managedkafka.projects.locations.clusters.deleterrrr2ManagedkafkaProjectsLocationsClustersDeleteRequestrFrtrrr\r[rz8ManagedkafkaV1.ProjectsLocationsClustersService.Js68#9#9ZCxH!]"N& $r\cL|jd}|j|||S)aReturns the properties of a single cluster. Args: request: (ManagedkafkaProjectsLocationsClustersGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Cluster) The response message. rrfrhrks r[rz3ManagedkafkaV1.ProjectsLocationsClustersService.GetXrr\c Htjddddgdgdgdddd d S) Nrrz,managedkafka.projects.locations.clusters.getrrrr/ManagedkafkaProjectsLocationsClustersGetRequestClusterFrtrrr\r[rz8ManagedkafkaV1.ProjectsLocationsClustersService.es6 6 6Z@xHX"K$ !r\cL|jd}|j|||S)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. rrfrhrks r[rz4ManagedkafkaV1.ProjectsLocationsClustersService.Listsrr\c Jtjddddgdggddddd d S) Nrrz-managedkafka.projects.locations.clusters.listrrorderByrrrr0ManagedkafkaProjectsLocationsClustersListRequestListClustersResponseFrtrrr\r[rz8ManagedkafkaV1.ProjectsLocationsClustersService.s4!7!7MA zJC-L1 "r\cL|jd}|j|||S)aUpdates the properties of a single cluster. Args: request: (ManagedkafkaProjectsLocationsClustersPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrfrhrks r[rz5ManagedkafkaV1.ProjectsLocationsClustersService.Patchrr\c Jtjddddgdgddgddd d d S) Nrrz.managedkafka.projects.locations.clusters.patchrrrrr1ManagedkafkaProjectsLocationsClustersPatchRequestrFrtrrr\r[rz8ManagedkafkaV1.ProjectsLocationsClustersService.s9("8"8ZBxH!<0"M& #r\r`rrs@r[r rs^E )E 8 F 8 F 8 C 8 D 8 Er\r ceZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _ddZ de _ddZ de _ddZde_ddZde_xZS)@ManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsServicezMService class for the projects_locations_connectClusters_connectors resource.r#cNttj||i|_yr`)rrr"rrarbs r[rzIManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.__init__s# N L Ld\]cd dr\cL|jd}|j|||S)a6Creates 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. rrfrhrks r[rzGManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Createrr\c Htjddddgdgdgdddd d S) N_v1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}/connectorsrozAmanagedkafka.projects.locations.connectClusters.connectors.creater connectorIdv1/{+parent}/connectors connectorCManagedkafkaProjectsLocationsConnectClustersConnectorsCreateRequest ConnectorFrtrrr\r[rzIManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.s68#9#9sU zJ#_/!_& $r\cL|jd}|j|||S)aDeletes a connector. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrfrhrks r[rzGManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Deleterr\c Ftjddddgdggddddd S) Nnv1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}/connectors/{connectorsId}rzAmanagedkafka.projects.locations.connectClusters.connectors.deleterrrCManagedkafkaProjectsLocationsConnectClustersConnectorsDeleteRequestrFrtrrr\r[rzIManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.s78#9#9CUxH"_" $r\cL|jd}|j|||S)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. rrfrhrks r[rzDManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Getrr\c Ftjddddgdggddddd S) Nrrz>managedkafka.projects.locations.connectClusters.connectors.getrrr@ManagedkafkaProjectsLocationsConnectClustersConnectorsGetRequestrFrtrrr\r[rzIManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.s7 6 6CRxH"\& !r\cL|jd}|j|||S)a>Lists the connectors in a given Connect cluster. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListConnectorsResponse) The response message. rrfrhrks r[rzEManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Listrr\c Jtjddddgdgddgddd d d S) Nr rz?managedkafka.projects.locations.connectClusters.connectors.listrrrrrAManagedkafkaProjectsLocationsConnectClustersConnectorsListRequestListConnectorsResponseFrtrrr\r[rzIManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.s9!7!7sS zJ +./]3 "r\cL|jd}|j|||S)a(Updates the properties of a connector. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Connector) The response message. rrfrhrks r[rzFManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Patchrr\c Htjddddgdgdgdddd d S) Nrrz@managedkafka.projects.locations.connectClusters.connectors.patchrrrrBManagedkafkaProjectsLocationsConnectClustersConnectorsPatchRequestrFrtrrr\r[rzIManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.,s9("8"8CTxH"^"!^& #r\cL|jd}|j|||S)a2Pauses the connector and its tasks. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsPauseRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (PauseConnectorResponse) The response message. Pauserfrhrks r[r"zFManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Pause:rr\c Ftjddddgdggddddd S) Nztv1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}/connectors/{connectorsId}:pauseroz@managedkafka.projects.locations.connectClusters.connectors.pauserzv1/{+name}:pausepauseConnectorRequestBManagedkafkaProjectsLocationsConnectClustersConnectorsPauseRequestPauseConnectorResponseFrtrrr\r[rzIManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Gs7("8"8ITxH(-^3 #r\cL|jd}|j|||S)a*Restarts the connector. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsRestartRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (RestartConnectorResponse) The response message. Restartrfrhrks r[r(zHManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.RestartUs1##I.f __ '88r\c Ftjddddgdggddddd S) Nzvv1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}/connectors/{connectorsId}:restartrozBmanagedkafka.projects.locations.connectClusters.connectors.restartrzv1/{+name}:restartrestartConnectorRequestDManagedkafkaProjectsLocationsConnectClustersConnectorsRestartRequestRestartConnectorResponseFrtrrr\r[rzIManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.bs7H$:$:KVxH*/`5 %r\cL|jd}|j|||S)a5Resumes the connector and its tasks. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsResumeRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ResumeConnectorResponse) The response message. Resumerfrhrks r[r.zGManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Resumeprr\c Ftjddddgdggddddd S) Nzuv1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}/connectors/{connectorsId}:resumerozAmanagedkafka.projects.locations.connectClusters.connectors.resumerzv1/{+name}:resumeresumeConnectorRequestCManagedkafkaProjectsLocationsConnectClustersConnectorsResumeRequestResumeConnectorResponseFrtrrr\r[rzIManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.}s78#9#9JUxH)._4 $r\cL|jd}|j|||S)a!Stops the connector. Args: request: (ManagedkafkaProjectsLocationsConnectClustersConnectorsStopRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (StopConnectorResponse) The response message. Stoprfrhrks r[r4zEManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.Stoprr\c Ftjddddgdggddddd S) Nzsv1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}/connectors/{connectorsId}:stoproz?managedkafka.projects.locations.connectClusters.connectors.stoprzv1/{+name}:stopstopConnectorRequestAManagedkafkaProjectsLocationsConnectClustersConnectorsStopRequestStopConnectorResponseFrtrrr\r[rzIManagedkafkaV1.ProjectsLocationsConnectClustersConnectorsService.s7!7!7HSxH',]2 "r\r`)rrrrrrrrrrrrr"r(r.r4rrs@r[r"r sW ;E 8 F 8 F 8 C 8 D 8 E 8 E 8 G 8 F 8 Dr\r"ceZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _xZ S)6ManagedkafkaV1.ProjectsLocationsConnectClustersServicezBService class for the projects_locations_connectClusters resource.r%cNttj||i|_yr`)rrr$rrarbs r[rz?ManagedkafkaV1.ProjectsLocationsConnectClustersService.__init__s# N B BDRSYZ dr\cL|jd}|j|||S)a=Creates 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. rrfrhrks r[rz=ManagedkafkaV1.ProjectsLocationsConnectClustersService.Createrr\c Jtjddddgdgddgddd d d S) N@v1/projects/{projectsId}/locations/{locationsId}/connectClustersroz6managedkafka.projects.locations.connectClusters.createrconnectClusterIdrv1/{+parent}/connectClustersconnectCluster9ManagedkafkaProjectsLocationsConnectClustersCreateRequestrFrtrrr\r[rz?ManagedkafkaV1.ProjectsLocationsConnectClustersService.s98#9#9TJ zJ(+64&U& $r\cL|jd}|j|||S)aDeletes a single Connect cluster. Args: request: (ManagedkafkaProjectsLocationsConnectClustersDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrfrhrks r[rz=ManagedkafkaV1.ProjectsLocationsConnectClustersService.Deleterr\c Htjddddgdgdgdddd d S) NTv1/projects/{projectsId}/locations/{locationsId}/connectClusters/{connectClustersId}rz6managedkafka.projects.locations.connectClusters.deleterrrr9ManagedkafkaProjectsLocationsConnectClustersDeleteRequestrFrtrrr\r[rz?ManagedkafkaV1.ProjectsLocationsConnectClustersService.s68#9#9hJxH!]"U& $r\cL|jd}|j|||S)a4Returns 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. rrfrhrks r[rz:ManagedkafkaV1.ProjectsLocationsConnectClustersService.Getrr\c Ftjddddgdggddddd S) NrErz3managedkafka.projects.locations.connectClusters.getrrr6ManagedkafkaProjectsLocationsConnectClustersGetRequestConnectClusterFrtrrr\r[rz?ManagedkafkaV1.ProjectsLocationsConnectClustersService.s4 6 6hGxH"R+ !r\cL|jd}|j|||S)aJLists 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. rrfrhrks r[rz;ManagedkafkaV1.ProjectsLocationsConnectClustersService.Listrr\c Jtjddddgdggddddd d S) Nr>rz4managedkafka.projects.locations.connectClusters.listrrr@r7ManagedkafkaProjectsLocationsConnectClustersListRequestListConnectClustersResponseFrtrrr\r[rz?ManagedkafkaV1.ProjectsLocationsConnectClustersService.s4!7!7TH zJC4S8 "r\cL|jd}|j|||S)a1Updates 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. rrfrhrks r[rz)s9("8"8hIxH!<0"&T& #r\r`rrs@r[r$r:rr\r$ceZdZdZdZfdZd dZde_d dZde_d dZ d e _d d Z d e _xZ S) 1ManagedkafkaV1.ProjectsLocationsOperationsServicez=Service class for the projects_locations_operations resource.r'cNttj||i|_yr`)rrr&rrarbs r[rz:ManagedkafkaV1.ProjectsLocationsOperationsService.__init__<s" N = =tMfU dr\cL|jd}|j|||S)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`. Args: request: (ManagedkafkaProjectsLocationsOperationsCancelRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. Cancelrfrhrks r[rVz8ManagedkafkaV1.ProjectsLocationsOperationsService.CancelArr\c Ftjddddgdggddddd S) NzQv1/projects/{projectsId}/locations/{locationsId}/operations/{operationsId}:cancelroz1managedkafka.projects.locations.operations.cancelrzv1/{+name}:cancelcancelOperationRequest4ManagedkafkaProjectsLocationsOperationsCancelRequestrFrtrrr\r[rz:ManagedkafkaV1.ProjectsLocationsOperationsService.Ns48#9#9eExH).P" $r\cL|jd}|j|||S)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. rrfrhrks r[rz8ManagedkafkaV1.ProjectsLocationsOperationsService.Delete\rr\c Ftjddddgdggddddd S) NJv1/projects/{projectsId}/locations/{locationsId}/operations/{operationsId}rz1managedkafka.projects.locations.operations.deleterrr4ManagedkafkaProjectsLocationsOperationsDeleteRequestrFrtrrr\r[rz:ManagedkafkaV1.ProjectsLocationsOperationsService.is48#9#9^ExH"P" $r\cL|jd}|j|||S)aGets 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. rrfrhrks r[rz5ManagedkafkaV1.ProjectsLocationsOperationsService.Getwrr\c Ftjddddgdggddddd S) Nr\rz.managedkafka.projects.locations.operations.getrrr1ManagedkafkaProjectsLocationsOperationsGetRequestrFrtrrr\r[rz:ManagedkafkaV1.ProjectsLocationsOperationsService.s4 6 6^BxH"M& !r\cL|jd}|j|||S)aLists 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. rrfrhrks r[rz6ManagedkafkaV1.ProjectsLocationsOperationsService.Listrr\c Jtjddddgdggddddd d S) Nz;v1/projects/{projectsId}/locations/{locationsId}/operationsrz/managedkafka.projects.locations.operations.listr)rrrzv1/{+name}/operationsr2ManagedkafkaProjectsLocationsOperationsListRequestListOperationsResponseFrtrrr\r[rz:ManagedkafkaV1.ProjectsLocationsOperationsService.s4!7!7OCxH8-N3 "r\r`) rrrrrrrVrrrrrrs@r[r&rS7sOG +E 8 F 8 F 8 C 8 Dr\r&c>eZdZdZdZfdZddZde_xZS)DManagedkafkaV1.ProjectsLocationsSchemaRegistriesCompatibilityServicezQService class for the projects_locations_schemaRegistries_compatibility resource.r)cNttj||i|_yr`)rrr(rrarbs r[rzMManagedkafkaV1.ProjectsLocationsSchemaRegistriesCompatibilityService.__init__s$ N P PRV`agh dr\cL|jd}|j|||S)ayCheck 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. CheckCompatibilityrfrhrks r[rizWManagedkafkaV1.ProjectsLocationsSchemaRegistriesCompatibilityService.CheckCompatibility2##$89f __ '88r\c Ftjddddgdggddddd S) Nzvv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/compatibility/{compatibilityId}rozQmanagedkafka.projects.locations.schemaRegistries.compatibility.checkCompatibilityrrcheckCompatibilityRequestSManagedkafkaProjectsLocationsSchemaRegistriesCompatibilityCheckCompatibilityRequestCheckCompatibilityResponseFrtrrr\r[rzMManagedkafkaV1.ProjectsLocationsSchemaRegistriesCompatibilityService.s7x/E/EKexH"1o7 0r\r` rrrrrrrirrrs@r[r(rfs#[ ?E 8 ($$r\r(cneZdZdZdZfdZd dZde_d dZde_d dZ d e _xZ S) =ManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigServicezJService class for the projects_locations_schemaRegistries_config resource.r+cNttj||i|_yr`)rrr*rrarbs r[rzFManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigService.__init__rr\cL|jd}|j|||S)a&Delete schema config for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesConfigDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaConfig) The response message. rrfrhrks r[rzDManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigService.Deleterr\c Ftjddddgdggddddd S) Nhv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/config/{configId}rz>managedkafka.projects.locations.schemaRegistries.config.deleterrr@ManagedkafkaProjectsLocationsSchemaRegistriesConfigDeleteRequest SchemaConfigFrtrrr\r[rzFManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigService.s48#9#9|RxH"\) $r\cL|jd}|j|||S)a3Get 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. rrfrhrks r[rzAManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigService.Getrr\c Htjddddgdgdgdddd d S) Nrurz;managedkafka.projects.locations.schemaRegistries.config.getrdefaultToGlobalrr=ManagedkafkaProjectsLocationsSchemaRegistriesConfigGetRequestrwFrtrrr\r[rzFManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigService.s7 6 6|OxH'("Y) !r\cL|jd}|j|||S)asUpdate 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. Updaterfrhrks r[r}zDManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigService.Updaterr\c Ftjddddgdggddddd S) NruPUTz>managedkafka.projects.locations.schemaRegistries.config.updaterrupdateSchemaConfigRequest@ManagedkafkaProjectsLocationsSchemaRegistriesConfigUpdateRequestrwFrtrrr\r[rzFManagedkafkaV1.ProjectsLocationsSchemaRegistriesConfigService.s48#9#9|RxH"1\) $r\r` rrrrrrrrrr}rrs@r[r*rqs@T 8E 8 F 8 C 8 Fr\r*c>eZdZdZdZfdZddZde_xZS)LManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsCompatibilityServicezZService class for the projects_locations_schemaRegistries_contexts_compatibility resource.r-cNttj||i|_yr`)rrr,rrarbs r[rzUManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsCompatibilityService.__init__2s$ N X XZ^hiop dr\cL|jd}|j|||S)aCheck 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. rirfrhrks r[riz_ManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsCompatibilityService.CheckCompatibility7rjr\c Ftjddddgdggddddd S) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/compatibility/{compatibilityId}rozZmanagedkafka.projects.locations.schemaRegistries.contexts.compatibility.checkCompatibilityrrrl[ManagedkafkaProjectsLocationsSchemaRegistriesContextsCompatibilityCheckCompatibilityRequestrnFrtrrr\r[rzUManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsCompatibilityService.Ds7x/E/EanxH"1w7 0r\r`rors@r[r,r-s#d HE 8 ($$r\r,cneZdZdZdZfdZd dZde_d dZde_d dZ d e _xZ S) EManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigServicezSService class for the projects_locations_schemaRegistries_contexts_config resource.r/cNttj||i|_yr`)rrr.rrarbs r[rzNManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigService.__init__Ws$ N Q QSWabhi dr\cL|jd}|j|||S)a.Delete schema config for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaConfig) The response message. rrfrhrks r[rzLManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigService.Delete\rr\c Ftjddddgdggddddd S) N~v1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/config/{configId}rzGmanagedkafka.projects.locations.schemaRegistries.contexts.config.deleterrrHManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigDeleteRequestrwFrtrrr\r[rzNManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigService.is78#9#9S[xH"d) $r\cL|jd}|j|||S)a;Get 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. rrfrhrks r[rzIManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigService.Getwrr\c Htjddddgdgdgdddd d S) NrrzDmanagedkafka.projects.locations.schemaRegistries.contexts.config.getrrzrrEManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigGetRequestrwFrtrrr\r[rzNManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigService.s: 6 6SXxH'("a) !r\cL|jd}|j|||S)a{Update 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. r}rfrhrks r[r}zLManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigService.Updaterr\c Ftjddddgdggddddd S) NrrzGmanagedkafka.projects.locations.schemaRegistries.contexts.config.updaterrrHManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigUpdateRequestrwFrtrrr\r[rzNManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsConfigService.s78#9#9S[xH"1d) $r\r`rrs@r[r.rRs@] AE 8 F 8 C 8 Fr\r.cneZdZdZdZfdZd dZde_d dZde_d dZ d e _xZ S) CManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeServicezQService class for the projects_locations_schemaRegistries_contexts_mode resource.r1cNttj||i|_yr`)rrr0rrarbs r[rzLManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeService.__init__$ N O OQU_`fg dr\cL|jd}|j|||S)a(Delete schema mode for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsModeDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaMode) The response message. rrfrhrks r[rzJManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeService.Deleterr\c Ftjddddgdggddddd S) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/mode/{modeId}rzEmanagedkafka.projects.locations.schemaRegistries.contexts.mode.deleterrrFManagedkafkaProjectsLocationsSchemaRegistriesContextsModeDeleteRequest SchemaModeFrtrrr\r[rzLManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeService.s78#9#9OYxH"b' $r\cL|jd}|j|||S)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. rrfrhrks r[rzGManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeService.Getrr\c Ftjddddgdggddddd S) NrrzBmanagedkafka.projects.locations.schemaRegistries.contexts.mode.getrrrCManagedkafkaProjectsLocationsSchemaRegistriesContextsModeGetRequestrFrtrrr\r[rzLManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeService.s7 6 6OVxH"_' !r\cL|jd}|j|||S)a4Update 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. r}rfrhrks r[r}zJManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeService.Updaterr\c Ftjddddgdggddddd S) NrrzEmanagedkafka.projects.locations.schemaRegistries.contexts.mode.updaterrupdateSchemaModeRequestFManagedkafkaProjectsLocationsSchemaRegistriesContextsModeUpdateRequestrFrtrrr\r[rzLManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsModeService.s78#9#9OYxH"/b' $r\r`rrs@r[r0rs@[ ?E 8 F 8 C 8 Fr\r0c>eZdZdZdZfdZddZde_xZS)NManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasSubjectsServicez]Service class for the projects_locations_schemaRegistries_contexts_schemas_subjects resource.r3cNttj||i|_yr`)rrr2rrarbs r[rzWManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasSubjectsService.__init__ $ N Z Z\`jkqr dr\cL|jd}|j|||S)asList 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. rrfrhrks r[rzSManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasSubjectsService.Listrr\c Jtjddddgdgddgddd d d S) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/schemas/{schemasId}/subjectsrzOmanagedkafka.projects.locations.schemaRegistries.contexts.schemas.subjects.listrdeletedsubjectv1/{+parent}/subjectsrOManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasSubjectsListRequestHttpBodyFrtrrr\r[rzWManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasSubjectsService.<!7!7^c zJ+-k% "r\r` rrrrrrrrrrs@r[r2r"g KE 8 Dr\r2c>eZdZdZdZfdZddZde_xZS)KManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasTypesServicezZService class for the projects_locations_schemaRegistries_contexts_schemas_types resource.r5cNttj||i|_yr`)rrr4rrarbs r[rzTManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasTypesService.__init__2s$ N W WY]ghno dr\cL|jd}|j|||S)aZList 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. rrfrhrks r[rzPManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasTypesService.List7rr\c Ftjddddgdggddddd S) Nzzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/schemas/typesrzLmanagedkafka.projects.locations.schemaRegistries.contexts.schemas.types.listrv1/{+parent}/schemas/typesrLManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasTypesListRequestrFrtrrr\r[rzTManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasTypesService.Ds7!7!7O` zJ2h% "r\r`rrs@r[r4r-s"d HE 8 Dr\r4c>eZdZdZdZfdZddZde_xZS)NManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasVersionsServicez]Service class for the projects_locations_schemaRegistries_contexts_schemas_versions resource.r7cNttj||i|_yr`)rrr6rrarbs r[rzWManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasVersionsService.__init__Wrr\cL|jd}|j|||S)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. rrfrhrks r[rzSManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasVersionsService.List\rr\c Jtjddddgdgddgddd d d S) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/schemas/{schemasId}/versionsrzOmanagedkafka.projects.locations.schemaRegistries.contexts.schemas.versions.listrrrv1/{+parent}/versionsrOManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasVersionsListRequestrFrtrrr\r[rzWManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasVersionsService.irr\r`rrs@r[r6rRrr\r6cVeZdZdZdZfdZddZde_ddZde_xZ S) FManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasServicezTService class for the projects_locations_schemaRegistries_contexts_schemas resource.r9cNttj||i|_yr`)rrr8rrarbs r[rzOManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasService.__init__|$ N R RTXbcij dr\cL|jd}|j|||S)a*Get the schema for the given schema id. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Schema) The response message. rrfrhrks r[rzJManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasService.Getrr\c Htjddddgdgdgdddd d S) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/schemas/{schemasId}rzEmanagedkafka.projects.locations.schemaRegistries.contexts.schemas.getrrrrFManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetRequestSchemaFrtrrr\r[rzOManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasService.s9 6 6UYxH["b# !r\cL|jd}|j|||S)aaGet 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. GetSchemarfrhrks r[rzPManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasService.GetSchema1##K0f __ '88r\c Htjddddgdgdgdddd d S) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/schemas/{schemasId}/schemarzKmanagedkafka.projects.locations.schemaRegistries.contexts.schemas.getSchemarrv1/{+name}/schemarLManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetSchemaRequestrFrtrrr\r[rzOManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSchemasService.s9h&<&<\_xH[)h% 'r\r` rrrrrrrrrrrs@r[r8rws1^ BE 8 C 8 Ir\r8c>eZdZdZdZfdZddZde_xZS)[ManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyServicezkService class for the projects_locations_schemaRegistries_contexts_subjects_versions_referencedby resource.r;cNttj||i|_yr`)rrr:rrarbs r[rzdManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyService.__init__s$ N g gimwx~ dr\cL|jd}|j|||S)auGet 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. rrfrhrks r[rz`ManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyService.Listrr\c Ftjddddgdggddddd S) 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\ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyListRequestrFrtrrr\r[rzdManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyService.s7!7!7zq zJ1x% "r\r`rrs@r[r:rs"u YE 8 Dr\r:ceZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _xZ S)OManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsServicez^Service class for the projects_locations_schemaRegistries_contexts_subjects_versions resource.r=cNttj||i|_yr`)rrr<rrarbs r[rzXManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.__init__s$ N [ []aklrs dr\cL|jd}|j|||S)aaRegister 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. rrfrhrks r[rzVManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.Createrr\c Ftjddddgdggddddd S) Nv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/subjects/{subjectsId}/versionsrozRmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.createrrcreateVersionRequestRManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsCreateRequestCreateVersionResponseFrtrrr\r[rzXManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.s78#9#9`f zJ-,n2 $r\cL|jd}|j|||S)a\Delete 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. rrfrhrks r[rzVManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.Deleterr\c Htjddddgdgdgdddd d S) Nv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/subjects/{subjectsId}/versions/{versionsId}rzRmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.deleter permanentrrRManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsDeleteRequestrFrtrrr\r[rzXManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.s98#9#9mfxH!]"n% $r\cL|jd}|j|||S)aUGet 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. rrfrhrks r[rzSManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.Getrr\c Htjddddgdgdgdddd d S) NrrzOmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.getrrrrOManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsGetRequest SchemaVersionFrtrrr\r[rzXManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.)s9 6 6mcxH["k* !r\cL|jd}|j|||S)arGet 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. rrfrhrks r[rzYManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.GetSchema7rr\c Htjddddgdgdgdddd d S) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/subjects/{subjectsId}/versions/{versionsId}/schemarzUmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.getSchemarrrrUManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsGetSchemaRequestrFrtrrr\r[rzXManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.Ds9h&<&<tixH[)q% 'r\cL|jd}|j|||S)agGet 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. rrfrhrks r[rzTManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService.ListRrr\c Htjddddgdgdgdddd d S) NrrzPmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.versions.listrrrrPManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsListRequestrFrtrrr\r[rzXManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsVersionsService._s9!7!7`d zJ[-l% "r\r` rrrrrrrrrrrrrrs@r[r<rs^h LE 8 F 8 F 8 C 8 I 8 Dr\r<cneZdZdZdZfdZd dZde_d dZde_d dZ d e _xZ S) GManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsServicezUService class for the projects_locations_schemaRegistries_contexts_subjects resource.r?cNttj||i|_yr`)rrr>rrarbs r[rzPManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsService.__init__r$ N S SUYcdjk dr\cL|jd}|j|||S)a\Delete 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. rrfrhrks r[rzNManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsService.Deletewrr\c Htjddddgdgdgdddd d S) Nv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/subjects/{subjectsId}rzImanagedkafka.projects.locations.schemaRegistries.contexts.subjects.deleterrrrJManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsDeleteRequestrFrtrrr\r[rzPManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsService.98#9#9W]xH!]"f% $r\cL|jd}|j|||S)a\List 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. rrfrhrks r[rzLManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsService.Listrr\c Jtjddddgdgddgddd d d S) Nzuv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}/subjectsrzGmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.listrr subjectPrefixrrHManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsListRequestrFrtrrr\r[rzPManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsService.s<!7!7J[ zJ1-d% "r\cL|jd}|j|||S)aALookup a schema under the specified subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsLookupVersionRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaVersion) The response message. LookupVersionrfrhrks r[rzUManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsService.LookupVersion1##O4f __ '88r\c Ftjddddgdggddddd S) NrrozPmanagedkafka.projects.locations.schemaRegistries.contexts.subjects.lookupVersionr v1/{+parent}lookupVersionRequestQManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsLookupVersionRequestrFrtrrr\r[rzPManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsSubjectsService.s7(*@*@Wd zJ$,m* +r\r` rrrrrrrrrrrrs@r[r>rms@_ CE 8 F 8 D 8 #Mr\r>cVeZdZdZdZfdZddZde_ddZde_xZ S) ?ManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsServicezLService class for the projects_locations_schemaRegistries_contexts resource.rAcNttj||i|_yr`)rrr@rrarbs r[rzHManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsService.__init__# N K KT[\bc dr\cL|jd}|j|||S)a Get the context. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Context) The response message. rrfrhrks r[rzCManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsService.Getrr\c Ftjddddgdggddddd S) Nzlv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contexts/{contextsId}rz=managedkafka.projects.locations.schemaRegistries.contexts.getrrr?ManagedkafkaProjectsLocationsSchemaRegistriesContextsGetRequestContextFrtrrr\r[rzHManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsService.s7 6 6AQxH"[$ !r\cL|jd}|j|||S)a#List contexts for a schema registry. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesContextsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (HttpBody) The response message. rrfrhrks r[rzDManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsService.Listrr\c Ftjddddgdggddddd S) Nz_v1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/contextsrz>managedkafka.projects.locations.schemaRegistries.contexts.listrzv1/{+parent}/contextsr@ManagedkafkaProjectsLocationsSchemaRegistriesContextsListRequestrFrtrrr\r[rzHManagedkafkaV1.ProjectsLocationsSchemaRegistriesContextsService.s4!7!7sR zJ-\% "r\r` rrrrrrrrrrrs@r[r@rs1V :E 8 C 8 Dr\r@cneZdZdZdZfdZd dZde_d dZde_d dZ d e _xZ S) ;ManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeServicezHService class for the projects_locations_schemaRegistries_mode resource.rCcNttj||i|_yr`)rrrBrrarbs r[rzDManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeService.__init__ s# N G GWX^_ dr\cL|jd}|j|||S)a Delete schema mode for a subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesModeDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaMode) The response message. rrfrhrks r[rzBManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeService.Deleterr\c Ftjddddgdggddddd S) Ndv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/mode/{modeId}rzManagedkafkaProjectsLocationsSchemaRegistriesModeDeleteRequestrFrtrrr\r[rzDManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeService.s48#9#9xPxH"Z' $r\cL|jd}|j|||S)a&Get 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. rrfrhrks r[rz?ManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeService.Get-rr\c Ftjddddgdggddddd S) Nrrz9managedkafka.projects.locations.schemaRegistries.mode.getrrr;ManagedkafkaProjectsLocationsSchemaRegistriesModeGetRequestrFrtrrr\r[rzDManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeService.:s4 6 6xMxH"W' !r\cL|jd}|j|||S)a,Update 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. r}rfrhrks r[r}zBManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeService.UpdateHrr\c Ftjddddgdggddddd S) NrrzManagedkafkaProjectsLocationsSchemaRegistriesModeUpdateRequestrFrtrrr\r[rzDManagedkafkaV1.ProjectsLocationsSchemaRegistriesModeService.Us48#9#9xPxH"/Z' $r\r`rrs@r[rBrs@R 6E 8 F 8 C 8 Fr\rBc>eZdZdZdZfdZddZde_xZS)FManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasSubjectsServicezTService class for the projects_locations_schemaRegistries_schemas_subjects resource.rEcNttj||i|_yr`)rrrDrrarbs r[rzOManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasSubjectsService.__init__hrr\cL|jd}|j|||S)akList 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. rrfrhrks r[rzKManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasSubjectsService.Listmrr\c Jtjddddgdgddgddd d d S) Nzsv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/schemas/{schemasId}/subjectsrzFmanagedkafka.projects.locations.schemaRegistries.schemas.subjects.listrrrrrGManagedkafkaProjectsLocationsSchemaRegistriesSchemasSubjectsListRequestrFrtrrr\r[rzOManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasSubjectsService.z<!7!7HZ zJ+-c% "r\r`rrs@r[rDr c"^ BE 8 Dr\rDc>eZdZdZdZfdZddZde_xZS)CManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasTypesServicezQService class for the projects_locations_schemaRegistries_schemas_types resource.rGcNttj||i|_yr`)rrrFrrarbs r[rzLManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasTypesService.__init__rr\cL|jd}|j|||S)aRList 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. rrfrhrks r[rzHManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasTypesService.Listrr\c Ftjddddgdggddddd S) Nzdv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/schemas/typesrzCmanagedkafka.projects.locations.schemaRegistries.schemas.types.listrrrDManagedkafkaProjectsLocationsSchemaRegistriesSchemasTypesListRequestrFrtrrr\r[rzLManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasTypesService.s4!7!7xW zJ2`% "r\r`rrs@r[rFr(s"[ ?E 8 Dr\rFc>eZdZdZdZfdZddZde_xZS)FManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasVersionsServicezTService class for the projects_locations_schemaRegistries_schemas_versions resource.rIcNttj||i|_yr`)rrrHrrarbs r[rzOManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasVersionsService.__init__rr\cL|jd}|j|||S)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. rrfrhrks r[rzKManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasVersionsService.Listrr\c Jtjddddgdgddgddd d d S) Nzsv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/schemas/{schemasId}/versionsrzFmanagedkafka.projects.locations.schemaRegistries.schemas.versions.listrrrrrGManagedkafkaProjectsLocationsSchemaRegistriesSchemasVersionsListRequestrFrtrrr\r[rzOManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasVersionsService.r%r\r`rrs@r[rHr.r&r\rHcVeZdZdZdZfdZddZde_ddZde_xZ S) >ManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasServicezKService class for the projects_locations_schemaRegistries_schemas resource.rKcNttj||i|_yr`)rrrJrrarbs r[rzGManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasService.__init__s# N J JDZ[ab dr\cL|jd}|j|||S)a"Get the schema for the given schema id. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Schema) The response message. rrfrhrks r[rzBManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasService.Getrr\c Htjddddgdgdgdddd d S) Nzjv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/schemas/{schemasId}rzManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetRequestrFrtrrr\r[rzGManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasService.s6 6 6~PxH["Z# !r\cL|jd}|j|||S)aYGet 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. rrfrhrks r[rzHManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasService.GetSchemarr\c Htjddddgdgdgdddd d S) Nzqv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/schemas/{schemasId}/schemarzBmanagedkafka.projects.locations.schemaRegistries.schemas.getSchemarrrrDManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetSchemaRequestrFrtrrr\r[rzGManagedkafkaV1.ProjectsLocationsSchemaRegistriesSchemasService. s9h&<&<FVxH[)`% 'r\r`rrs@r[rJr4s1U 9E 8 C 8 Ir\rJc>eZdZdZdZfdZddZde_xZS)SManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyServicezbService class for the projects_locations_schemaRegistries_subjects_versions_referencedby resource.rMcNttj||i|_yr`)rrrLrrarbs r[rz\ManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyService.__init__ s$ N _ _aeopvw dr\cL|jd}|j|||S)amGet 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. rrfrhrks r[rzXManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyService.List rr\c Ftjddddgdggddddd S) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/subjects/{subjectsId}/versions/{versionsId}/referencedbyrzTmanagedkafka.projects.locations.schemaRegistries.subjects.versions.referencedby.listrrrTManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyListRequestrFrtrrr\r[rz\ManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyService.) s7!7!7dh zJ1p% "r\r`rrs@r[rLr= s"l PE 8 Dr\rLceZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _xZ S)GManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsServicezUService class for the projects_locations_schemaRegistries_subjects_versions resource.rOcNttj||i|_yr`)rrrNrrarbs r[rzPManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.__init__< rr\cL|jd}|j|||S)aYRegister 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. rrfrhrks r[rzNManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.CreateA rr\c Ftjddddgdggddddd S) Nuv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/subjects/{subjectsId}/versionsrozImanagedkafka.projects.locations.schemaRegistries.subjects.versions.createrrrJManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsCreateRequestrFrtrrr\r[rzPManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.N s78#9#9J] zJ-,f2 $r\cL|jd}|j|||S)aTDelete 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. rrfrhrks r[rzNManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.Delete\ rr\c Htjddddgdgdgdddd d S) Nv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/subjects/{subjectsId}/versions/{versionsId}rzImanagedkafka.projects.locations.schemaRegistries.subjects.versions.deleterrrrJManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsDeleteRequestrFrtrrr\r[rzPManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.i rr\cL|jd}|j|||S)aMGet 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. rrfrhrks r[rzKManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.Getw rr\c Htjddddgdgdgdddd d S) NrKrzFmanagedkafka.projects.locations.schemaRegistries.subjects.versions.getrrrrGManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsGetRequestrFrtrrr\r[rzPManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService. s9 6 6WZxH["c* !r\cL|jd}|j|||S)ajGet 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. rrfrhrks r[rzQManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.GetSchema rr\c Htjddddgdgdgdddd d S) Nzv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/subjects/{subjectsId}/versions/{versionsId}/schemarzLmanagedkafka.projects.locations.schemaRegistries.subjects.versions.getSchemarrrrMManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsGetSchemaRequestrFrtrrr\r[rzPManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService. s9h&<&<^`xH[)i% 'r\cL|jd}|j|||S)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. rrfrhrks r[rzLManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService.List rr\c Htjddddgdgdgdddd d S) NrGrzGmanagedkafka.projects.locations.schemaRegistries.subjects.versions.listrrrrHManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsListRequestrFrtrrr\r[rzPManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsVersionsService. s9!7!7J[ zJ[-d% "r\r`rrs@r[rNrC7 s^_ CE 8 F 8 F 8 C 8 I 8 Dr\rNcneZdZdZdZfdZd dZde_d dZde_d dZ d e _xZ S) ?ManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsServicezLService class for the projects_locations_schemaRegistries_subjects resource.rQcNttj||i|_yr`)rrrPrrarbs r[rzHManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsService.__init__ r r\cL|jd}|j|||S)aTDelete 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. rrfrhrks r[rzFManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsService.Delete rr\c Htjddddgdgdgdddd d S) Nlv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/subjects/{subjectsId}rz@managedkafka.projects.locations.schemaRegistries.subjects.deleterrrrBManagedkafkaProjectsLocationsSchemaRegistriesSubjectsDeleteRequestrFrtrrr\r[rzHManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsService. s98#9#9ATxH!]"^% $r\cL|jd}|j|||S)aTList 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. rrfrhrks r[rzDManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsService.List rr\c Jtjddddgdgddgddd d d S) Nz_v1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}/subjectsrz>managedkafka.projects.locations.schemaRegistries.subjects.listrrrrr@ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsListRequestrFrtrrr\r[rzHManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsService. s9!7!7sR zJ1-\% "r\cL|jd}|j|||S)a9Lookup a schema under the specified subject. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsLookupVersionRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaVersion) The response message. rrfrhrks r[rzMManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsService.LookupVersion rr\c Ftjddddgdggddddd S) Nr[rozGmanagedkafka.projects.locations.schemaRegistries.subjects.lookupVersionrrrIManagedkafkaProjectsLocationsSchemaRegistriesSubjectsLookupVersionRequestrFrtrrr\r[rzHManagedkafkaV1.ProjectsLocationsSchemaRegistriesSubjectsService. s7(*@*@A[ zJ$,e* +r\r`rrs@r[rPrW s@V :E 8 F 8 D 8 #Mr\rPceZdZdZdZfdZd dZde_d dZde_d dZ d e _d d Z d e _xZ S) 7ManagedkafkaV1.ProjectsLocationsSchemaRegistriesServicezCService class for the projects_locations_schemaRegistries resource.rScNttj||i|_yr`)rrrRrrarbs r[rz@ManagedkafkaV1.ProjectsLocationsSchemaRegistriesService.__init__( s# N C CTSTZ[ dr\cL|jd}|j|||S)a!Create a schema registry instance. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaRegistry) The response message. rrfrhrks r[rz>ManagedkafkaV1.ProjectsLocationsSchemaRegistriesService.Create- rr\c Ftjddddgdggddddd S) NAv1/projects/{projectsId}/locations/{locationsId}/schemaRegistriesroz7managedkafka.projects.locations.schemaRegistries.createrv1/{+parent}/schemaRegistriescreateSchemaRegistryRequest:ManagedkafkaProjectsLocationsSchemaRegistriesCreateRequestSchemaRegistryFrtrrr\r[rz@ManagedkafkaV1.ProjectsLocationsSchemaRegistriesService.: s48#9#9UK zJ53V+ $r\cL|jd}|j|||S)aDelete a schema registry instance. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrfrhrks r[rz>ManagedkafkaV1.ProjectsLocationsSchemaRegistriesService.DeleteH rr\c Ftjddddgdggddddd S) NVv1/projects/{projectsId}/locations/{locationsId}/schemaRegistries/{schemaRegistriesId}rz7managedkafka.projects.locations.schemaRegistries.deleterrr:ManagedkafkaProjectsLocationsSchemaRegistriesDeleteRequestrFrtrrr\r[rz@ManagedkafkaV1.ProjectsLocationsSchemaRegistriesService.U s48#9#9jKxH"V" $r\cL|jd}|j|||S)aGet the schema registry instance. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SchemaRegistry) The response message. rrfrhrks r[rz;ManagedkafkaV1.ProjectsLocationsSchemaRegistriesService.Getc rr\c Ftjddddgdggddddd S) Nrorz4managedkafka.projects.locations.schemaRegistries.getrrr7ManagedkafkaProjectsLocationsSchemaRegistriesGetRequestrlFrtrrr\r[rz@ManagedkafkaV1.ProjectsLocationsSchemaRegistriesService.p s4 6 6jHxH"S+ !r\cL|jd}|j|||S)a"List schema registries. Args: request: (ManagedkafkaProjectsLocationsSchemaRegistriesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSchemaRegistriesResponse) The response message. rrfrhrks r[rz s6!7!7UI zJX5T9 "r\r`) rrrrrrrrrrrrrs@r[rRrd# sOM 1E 8 F 8 F 8 C 8 Dr\rRcVeZdZdZdZfdZddZde_ddZde_xZ S) 'ManagedkafkaV1.ProjectsLocationsServicez2Service class for the projects_locations resource.rUcNttj||i|_yr`)rrrTrrarbs r[rz0ManagedkafkaV1.ProjectsLocationsService.__init__ s" N 3 3TCFK dr\cL|jd}|j|||S)aGets information about a location. Args: request: (ManagedkafkaProjectsLocationsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Location) The response message. rrfrhrks r[rz+ManagedkafkaV1.ProjectsLocationsService.Get rr\c Ftjddddgdggddddd S) Nz0v1/projects/{projectsId}/locations/{locationsId}rz#managedkafka.projects.locations.getrrr'ManagedkafkaProjectsLocationsGetRequestLocationFrtrrr\r[rz0ManagedkafkaV1.ProjectsLocationsService. s4 6 6D7xH"C% !r\cL|jd}|j|||S)a5Lists 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. rrfrhrks r[rz,ManagedkafkaV1.ProjectsLocationsService.List rr\c Jtjddddgdggddddd d S) Nz"v1/projects/{projectsId}/locationsrz$managedkafka.projects.locations.listr)extraLocationTypesrrrzv1/{+name}/locationsr(ManagedkafkaProjectsLocationsListRequestListLocationsResponseFrtrrr\r[rz0ManagedkafkaV1.ProjectsLocationsService. s4!7!768xHN,D2 "r\r`rrs@r[rTry s1< E 8 C 8 Dr\rTc&eZdZdZdZfdZxZS)ManagedkafkaV1.ProjectsServicez(Service class for the projects resource.rWcNttj||i|_yr`)rrrVrrarbs r[rz'ManagedkafkaV1.ProjectsService.__init__ s" N * *D:6B dr\)rrrrrrrrs@r[rVr s2 E  r\rV) rNTNNFFNNNN)4rrrrmessagesMESSAGES_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.r0r2r4r6r8r:r<r>r@rBrDrFrHrJrLrNrPrRrTrVrrs@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[rs';'%fW+ X++W+ r\