VSrSSKJr SSKJr SSKJr "SS\R5r g)z/Generated client library for pubsub version v1.)absolute_import)base_api)pubsub_v1_messagesc^\rSrSrSr\rSrSrSr SS/r Sr S r S r S rSrSrS rSU4S jjr"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5rSrU=r$)PubsubV1 z7Generated client library for service pubsub version v1.zhttps://pubsub.googleapis.com/z#https://pubsub.mtls.googleapis.com/pubsubz.https://www.googleapis.com/auth/cloud-platformz&https://www.googleapis.com/auth/pubsubv1 CLIENT_ID CLIENT_SECRETzgoogle-cloud-sdkNc >U=(d URn[[U]XX4UXgUU U U S9 UR U5UlUR U5UlURU5Ul URU5Ul URU5Ul URU5UlUR!U5Ulg)zCreate a new pubsub handle.) credentialsget_credentialshttpmodel log_request log_responsecredentials_argsdefault_global_paramsadditional_http_headersresponse_encodingN)BASE_URLsuperr__init__ProjectsSchemasServiceprojects_schemasProjectsSnapshotsServiceprojects_snapshotsProjectsSubscriptionsServiceprojects_subscriptionsProjectsTopicsSnapshotsServiceprojects_topics_snapshots"ProjectsTopicsSubscriptionsServiceprojects_topics_subscriptionsProjectsTopicsServiceprojects_topicsProjectsServiceprojects) selfurlrrrrrrrrrr __class__s Glib/googlecloudsdk/generated_clients/apis/pubsub/v1/pubsub_v1_client.pyrPubsubV1.__init__s  C (D" '%)3 7+#-!77=D";;DAD"&"C"CD"ID%)%H%H%ND")-)P)PQU)VD&55d;D((.DMc^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS S jr S \ lS S jr S \ lS S jr S\ lS Sjr S\ lS SjrS\lS SjrS\lS SjrS\lS SjrS\lS SjrS\lS SjrS\lS SjrS\lSrU=r$)!PubsubV1.ProjectsSchemasService2z0Service class for the projects_schemas resource.rcN>[[RU]U5 0UlgN)rrrr_upload_configsr)clientr+s r,r(PubsubV1.ProjectsSchemasService.__init__7s" H + +T;FC dr.cDURS5nURX1US9$)zCommits a new schema revision to an existing schema. Args: request: (PubsubProjectsSchemasCommitRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Schema) The response message. Commit global_paramsGetMethodConfig _RunMethodr)requestr;configs r,r9&PubsubV1.ProjectsSchemasService.Commit</##H-f __ 88r.cB[R"SSSS/S//SSSSS S 9 $) Nz3v1/projects/{projectsId}/schemas/{schemasId}:commitPOSTzpubsub.projects.schemas.commitnamezv1/{+name}:commitcommitSchemaRequest"PubsubProjectsSchemasCommitRequestSchemaF flat_path http_method method_idordered_params path_params query_params relative_path request_fieldrequest_type_nameresponse_type_namesupports_downloadr ApiMethodInfor.r,(PubsubV1.ProjectsSchemasService.Is48#9#9G2xH)+># $r.cDURS5nURX1US9$)zCreates a schema. Args: request: (PubsubProjectsSchemasCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Schema) The response message. Creater:r<r?s r,r\&PubsubV1.ProjectsSchemasService.CreateWrCr.cD[R"SSSS/S/S/SSSS S S 9 $) N v1/projects/{projectsId}/schemasrEzpubsub.projects.schemas.createparentschemaIdv1/{+parent}/schemasschema"PubsubProjectsSchemasCreateRequestrIFrJrVrXr.r,rYrZds68#9#942 zJ \,># $r.cDURS5nURX1US9$)zDeletes a schema. Args: request: (PubsubProjectsSchemasDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. Deleter:r<r?s r,rf&PubsubV1.ProjectsSchemasService.DeleterrCr.cB[R"SSSS/S//SSSSS S 9 $) N,v1/projects/{projectsId}/schemas/{schemasId}DELETEzpubsub.projects.schemas.deleterF v1/{+name}"PubsubProjectsSchemasDeleteRequestEmptyFrJrVrXr.r,rYrZs48#9#9@2xH">" $r.cDURS5nURX1US9$)zDeletes a specific schema revision. Args: request: (PubsubProjectsSchemasDeleteRevisionRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Schema) The response message. DeleteRevisionr:r<r?s r,rp.PubsubV1.ProjectsSchemasService.DeleteRevisions0##$45f __ 88r.cD[R"SSSS/S/S/SSSS S S 9 $) Nz;v1/projects/{projectsId}/schemas/{schemasId}:deleteRevisionrjz&pubsub.projects.schemas.deleteRevisionrF revisionIdzv1/{+name}:deleteRevisionrl*PubsubProjectsSchemasDeleteRevisionRequestrIFrJrVrXr.r,rYrZs68+A+AO:xH"^1F# ,r.cDURS5nURX1US9$)zGets a schema. Args: request: (PubsubProjectsSchemasGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Schema) The response message. Getr:r<r?s r,rv#PubsubV1.ProjectsSchemasService.Get/##E*f __ 88r.cD[R"SSSS/S/S/SSSS S S 9 $) NriGETzpubsub.projects.schemas.getrFviewrkrlPubsubProjectsSchemasGetRequestrIFrJrVrXr.r,rYrZs6 6 6@/xHX";# !r.cDURS5nURX1US9$)a>Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set. Args: request: (PubsubProjectsSchemasGetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. GetIamPolicyr:r<r?s r,r~,PubsubV1.ProjectsSchemasService.GetIamPolicy/##N3f __ 88r.cD[R"SSSS/S/S/SSSS S S 9 $) Nz9v1/projects/{projectsId}/schemas/{schemasId}:getIamPolicyrzz$pubsub.projects.schemas.getIamPolicyresourceoptions_requestedPolicyVersionv1/{+resource}:getIamPolicyrl(PubsubProjectsSchemasGetIamPolicyRequestPolicyFrJrVrXr.r,rYrZs7)?)?M8"|L673D# *r.cDURS5nURX1US9$)zLists schemas in a project. Args: request: (PubsubProjectsSchemasListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSchemasResponse) The response message. Listr:r<r?s r,r$PubsubV1.ProjectsSchemasService.List/##F+f __ 88r.cF[R"SSSS/S//SQSSSS S S 9 $) Nr_rzzpubsub.projects.schemas.listr`pageSize pageTokenr{rbrl PubsubProjectsSchemasListRequestListSchemasResponseFrJrVrXr.r,rYrZs4!7!740 zJ6,<0 "r.cDURS5nURX1US9$)aLists all schema revisions for the named schema. Args: request: (PubsubProjectsSchemasListRevisionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSchemaRevisionsResponse) The response message. ListRevisionsr:r<r?s r,r-PubsubV1.ProjectsSchemasService.ListRevisionss/##O4f __ 88r.cF[R"SSSS/S//SQSSSS S S 9 $) Nz:v1/projects/{projectsId}/schemas/{schemasId}:listRevisionsrzz%pubsub.projects.schemas.listRevisionsrFrzv1/{+name}:listRevisionsrl)PubsubProjectsSchemasListRevisionsRequestListSchemaRevisionsResponseFrJrVrXr.r,rYrZs4(*@*@N9xH60E8 +r.cDURS5nURX1US9$)aCreates a new schema revision that is a copy of the provided revision_id. Args: request: (PubsubProjectsSchemasRollbackRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Schema) The response message. Rollbackr:r<r?s r,r(PubsubV1.ProjectsSchemasService.Rollback/##J/f __ 88r.cB[R"SSSS/S//SSSSS S 9 $) Nz5v1/projects/{projectsId}/schemas/{schemasId}:rollbackrEz pubsub.projects.schemas.rollbackrFzv1/{+name}:rollbackrollbackSchemaRequest$PubsubProjectsSchemasRollbackRequestrIFrJrVrXr.r,rYrZ!s4X%;%;I4xH+-@# &r.cDURS5nURX1US9$)adSets the access control policy on the specified resource. Replaces any existing policy. Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors. Args: request: (PubsubProjectsSchemasSetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. SetIamPolicyr:r<r?s r,r,PubsubV1.ProjectsSchemasService.SetIamPolicy/rr.cB[R"SSSS/S//SSSSS S 9 $) Nz9v1/projects/{projectsId}/schemas/{schemasId}:setIamPolicyrEz$pubsub.projects.schemas.setIamPolicyrv1/{+resource}:setIamPolicysetIamPolicyRequest(PubsubProjectsSchemasSetIamPolicyRequestrFrJrVrXr.r,rYrZ<s4)?)?M8"|L3+D# *r.cDURS5nURX1US9$)a8Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a `NOT_FOUND` error. Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning. Args: request: (PubsubProjectsSchemasTestIamPermissionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestIamPermissionsResponse) The response message. TestIamPermissionsr:r<r?s r,r2PubsubV1.ProjectsSchemasService.TestIamPermissionsJ0##$89f __ 88r.cB[R"SSSS/S//SSSSS S 9 $) Nz?v1/projects/{projectsId}/schemas/{schemasId}:testIamPermissionsrEz*pubsub.projects.schemas.testIamPermissionsr!v1/{+resource}:testIamPermissionstestIamPermissionsRequest.PubsubProjectsSchemasTestIamPermissionsRequestTestIamPermissionsResponseFrJrVrXr.r,rYrZWs4x/E/ES>"|L91J7 0r.cDURS5nURX1US9$)zValidates a schema. Args: request: (PubsubProjectsSchemasValidateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ValidateSchemaResponse) The response message. Validater:r<r?s r,r(PubsubV1.ProjectsSchemasService.Validateerr.cB[R"SSSS/S//SSSSS S 9 $) Nz)v1/projects/{projectsId}/schemas:validaterEz pubsub.projects.schemas.validater`zv1/{+parent}/schemas:validatevalidateSchemaRequest$PubsubProjectsSchemasValidateRequestValidateSchemaResponseFrJrVrXr.r,rYrZrs4X%;%;=4 zJ5-@3 &r.cDURS5nURX1US9$)zValidates a message against a schema. Args: request: (PubsubProjectsSchemasValidateMessageRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ValidateMessageResponse) The response message. ValidateMessager:r<r?s r,r/PubsubV1.ProjectsSchemasService.ValidateMessages0##$56f __ 88r.cB[R"SSSS/S//SSSSS S 9 $) Nz0v1/projects/{projectsId}/schemas:validateMessagerEz'pubsub.projects.schemas.validateMessager`z$v1/{+parent}/schemas:validateMessagevalidateMessageRequest+PubsubProjectsSchemasValidateMessageRequestValidateMessageResponseFrJrVrXr.r,rYrZs4H,B,BD; zJ<.G4 -r.r4r3)__name__ __module__ __qualname____firstlineno____doc___NAMErr9 method_configr\rfrprvr~rrrrrrr__static_attributes__ __classcell__r+s@r,rr02s: E 8 F 8 F 8 F 8 $N  8 C 8 "L 8 D 8 #M 8 H 8 "L 8 ($ 8 H 8 %O!!r.rc^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSSjrS\lSrU=r$)!PubsubV1.ProjectsSnapshotsServiceiz2Service class for the projects_snapshots resource.rcN>[[RU]U5 0Ulgr3)rrrrr4r5s r,r*PubsubV1.ProjectsSnapshotsService.__init__s" H - -t=fE dr.cDURS5nURX1US9$)aCreates a snapshot from the requested subscription. Snapshots are used in [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. If the snapshot already exists, returns `ALREADY_EXISTS`. If the requested subscription doesn't exist, returns `NOT_FOUND`. If the backlog in the subscription is too old -- and the resulting snapshot would expire in less than 1 hour -- then `FAILED_PRECONDITION` is returned. See also the `Snapshot.expire_time` field. If the name is not provided in the request, the server will assign a random name for this snapshot on the same project as the subscription, conforming to the [resource name format] (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names). The generated name is populated in the returned Snapshot object. Note that for REST API requests, you must specify a name in the request. Args: request: (PubsubProjectsSnapshotsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Snapshot) The response message. r\r:r<r?s r,r\(PubsubV1.ProjectsSnapshotsService.CreaterCr.cB[R"SSSS/S//SSSSS S 9 $) N0v1/projects/{projectsId}/snapshots/{snapshotsId}PUTz pubsub.projects.snapshots.createrFrkcreateSnapshotRequest$PubsubProjectsSnapshotsCreateRequestSnapshotFrJrVrXr.r,rY*PubsubV1.ProjectsSnapshotsService.s48#9#9D4xH"-@% $r.cDURS5nURX1US9$)aRemoves an existing snapshot. Snapshots are used in [Seek] (https://cloud.google.com/pubsub/docs/replay-overview) operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. When the snapshot is deleted, all messages retained in the snapshot are immediately dropped. After a snapshot is deleted, a new one may be created with the same name, but the new one has no association with the old snapshot or its subscription, unless the same subscription is specified. Args: request: (PubsubProjectsSnapshotsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rfr:r<r?s r,rf(PubsubV1.ProjectsSnapshotsService.DeleterCr.cB[R"SSSS/S//SSSSS S 9 $) Nrrjz pubsub.projects.snapshots.deletesnapshotv1/{+snapshot}rl$PubsubProjectsSnapshotsDeleteRequestrnFrJrVrXr.r,rYrs48#9#9D4"|L&@" $r.cDURS5nURX1US9$)aGets the configuration details of a snapshot. Snapshots are used in [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. Args: request: (PubsubProjectsSnapshotsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Snapshot) The response message. rvr:r<r?s r,rv%PubsubV1.ProjectsSnapshotsService.Getrxr.cB[R"SSSS/S//SSSSS S 9 $) Nrrzzpubsub.projects.snapshots.getrrrl!PubsubProjectsSnapshotsGetRequestrFrJrVrXr.r,rYrs4 6 6D1"|L&=% !r.cDURS5nURX1US9$)a@Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set. Args: request: (PubsubProjectsSnapshotsGetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. r~r:r<r?s r,r~.PubsubV1.ProjectsSnapshotsService.GetIamPolicyrr.cD[R"SSSS/S/S/SSSS S S 9 $) Nz=v1/projects/{projectsId}/snapshots/{snapshotsId}:getIamPolicyrzz&pubsub.projects.snapshots.getIamPolicyrrrrl*PubsubProjectsSnapshotsGetIamPolicyRequestrFrJrVrXr.r,rYrs7)?)?Q:"|L673F# *r.cDURS5nURX1US9$)aLists the existing snapshots. Snapshots are used in [Seek]( https://cloud.google.com/pubsub/docs/replay-overview) operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. Args: request: (PubsubProjectsSnapshotsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSnapshotsResponse) The response message. rr:r<r?s r,r&PubsubV1.ProjectsSnapshotsService.Listrr.cF[R"SSSS/S/SS/SSS S S S 9 $) Nz"v1/projects/{projectsId}/snapshotsrzzpubsub.projects.snapshots.listprojectrrzv1/{+project}/snapshotsrl"PubsubProjectsSnapshotsListRequestListSnapshotsResponseFrJrVrXr.r,rYrs9!7!762!{K +./>2 "r.cDURS5nURX1US9$)a$Updates an existing snapshot by updating the fields specified in the update mask. Snapshots are used in [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. Args: request: (PubsubProjectsSnapshotsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Snapshot) The response message. Patchr:r<r?s r,r'PubsubV1.ProjectsSnapshotsService.Patch,/##G,f __ 88r.cB[R"SSSS/S//SSSSS S 9 $) NrPATCHzpubsub.projects.snapshots.patchrFrkupdateSnapshotRequest#PubsubProjectsSnapshotsPatchRequestrFrJrVrXr.r,rYr9s4("8"8D3xH"-?% #r.cDURS5nURX1US9$)afSets the access control policy on the specified resource. Replaces any existing policy. Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors. Args: request: (PubsubProjectsSnapshotsSetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rr:r<r?s r,r.PubsubV1.ProjectsSnapshotsService.SetIamPolicyGrr.cB[R"SSSS/S//SSSSS S 9 $) Nz=v1/projects/{projectsId}/snapshots/{snapshotsId}:setIamPolicyrEz&pubsub.projects.snapshots.setIamPolicyrrr*PubsubProjectsSnapshotsSetIamPolicyRequestrFrJrVrXr.r,rYrTs4)?)?Q:"|L3+F# *r.cDURS5nURX1US9$)a:Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a `NOT_FOUND` error. Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning. Args: request: (PubsubProjectsSnapshotsTestIamPermissionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestIamPermissionsResponse) The response message. rr:r<r?s r,r4PubsubV1.ProjectsSnapshotsService.TestIamPermissionsbrr.cB[R"SSSS/S//SSSSS S 9 $) NzCv1/projects/{projectsId}/snapshots/{snapshotsId}:testIamPermissionsrEz,pubsub.projects.snapshots.testIamPermissionsrrr0PubsubProjectsSnapshotsTestIamPermissionsRequestrFrJrVrXr.r,rYros4x/E/EW@"|L91L7 0r.rr3)rrrrrrrr\rrfrvr~rrrrrrrs@r,rrs< E 8 F 8 F 8 C 8 "L 8 D 8 E 8 "L 8 ($$r.rc^\rSrSrSrSrU4SjrS"SjrS\lS"Sjr S\ lS"S jr S \ lS"S jr S \ lS"S jr S\ lS"Sjr S\ lS"SjrS\lS"SjrS\lS"SjrS\lS"SjrS\lS"SjrS\lS"SjrS\lS"SjrS\lS"SjrS \lS!rU=r$)#%PubsubV1.ProjectsSubscriptionsServicei}z6Service class for the projects_subscriptions resource.r cN>[[RU]U5 0Ulgr3)rrrrr4r5s r,r.PubsubV1.ProjectsSubscriptionsService.__init__s" H 1 14A&I dr.cDURS5nURX1US9$)aAcknowledges the messages associated with the `ack_ids` in the `AcknowledgeRequest`. The Pub/Sub system can remove the relevant messages from the subscription. Acknowledging a message whose ack deadline has expired may succeed, but such a message may be redelivered later. Acknowledging a message more than once will not result in an error. Args: request: (PubsubProjectsSubscriptionsAcknowledgeRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. Acknowledger:r<r?s r,r1PubsubV1.ProjectsSubscriptionsService.Acknowledges/##M2f __ 88r.cB[R"SSSS/S//SSSSS S 9 $) NzDv1/projects/{projectsId}/subscriptions/{subscriptionsId}:acknowledgerEz)pubsub.projects.subscriptions.acknowledge subscriptionzv1/{+subscription}:acknowledgeacknowledgeRequest-PubsubProjectsSubscriptionsAcknowledgeRequestrnFrJrVrXr.r,rY.PubsubV1.ProjectsSubscriptionsService.s6(>(>X=&'#$6*I" )r.cDURS5nURX1US9$)a8Creates a subscription to a given topic. See the [resource name rules] (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names). If the subscription already exists, returns `ALREADY_EXISTS`. If the corresponding topic doesn't exist, returns `NOT_FOUND`. If the name is not provided in the request, the server will assign a random name for this subscription on the same project as the topic, conforming to the [resource name format] (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names). The generated name is populated in the returned Subscription object. Note that for REST API requests, you must specify a name in the request. Args: request: (Subscription) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Subscription) The response message. r\r:r<r?s r,r\,PubsubV1.ProjectsSubscriptionsService.CreaterCr.cB[R"SSSS/S//SSSSSS 9 $) N8v1/projects/{projectsId}/subscriptions/{subscriptionsId}rz$pubsub.projects.subscriptions.createrFrk SubscriptionFrJrVrXr.r,rYrs48#9#9L8xH"!() $r.cDURS5nURX1US9$)aDeletes an existing subscription. All messages retained in the subscription are immediately dropped. Calls to `Pull` after deletion will return `NOT_FOUND`. After a subscription is deleted, a new one may be created with the same name, but the new one has no association with the old subscription or its topic unless the same topic is specified. Args: request: (PubsubProjectsSubscriptionsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rfr:r<r?s r,rf,PubsubV1.ProjectsSubscriptionsService.DeleterCr.cB[R"SSSS/S//SSSSS S 9 $) Nrrjz$pubsub.projects.subscriptions.deleterv1/{+subscription}rl(PubsubProjectsSubscriptionsDeleteRequestrnFrJrVrXr.r,rYrs68#9#9L8&'#$*D" $r.cDURS5nURX1US9$)aDetaches a subscription from this topic. All messages retained in the subscription are dropped. Subsequent `Pull` and `StreamingPull` requests will return FAILED_PRECONDITION. If the subscription is a push subscription, pushes to the endpoint will stop. Args: request: (PubsubProjectsSubscriptionsDetachRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (DetachSubscriptionResponse) The response message. Detachr:r<r?s r,r,PubsubV1.ProjectsSubscriptionsService.DetachrCr.cB[R"SSSS/S//SSSSS S 9 $) Nz?v1/projects/{projectsId}/subscriptions/{subscriptionsId}:detachrEz$pubsub.projects.subscriptions.detachrzv1/{+subscription}:detachrl(PubsubProjectsSubscriptionsDetachRequestDetachSubscriptionResponseFrJrVrXr.r,rYrs68#9#9S8&'#$1D7 $r.cDURS5nURX1US9$)zGets the configuration details of a subscription. Args: request: (PubsubProjectsSubscriptionsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Subscription) The response message. rvr:r<r?s r,rv)PubsubV1.ProjectsSubscriptionsService.Getrxr.cB[R"SSSS/S//SSSSS S 9 $) Nrrzz!pubsub.projects.subscriptions.getrr rl%PubsubProjectsSubscriptionsGetRequestr FrJrVrXr.r,rYrs6 6 6L5&'#$*A) !r.cDURS5nURX1US9$)aDGets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set. Args: request: (PubsubProjectsSubscriptionsGetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. r~r:r<r?s r,r~2PubsubV1.ProjectsSubscriptionsService.GetIamPolicyrr.cD[R"SSSS/S/S/SSSS S S 9 $) NzEv1/projects/{projectsId}/subscriptions/{subscriptionsId}:getIamPolicyrzz*pubsub.projects.subscriptions.getIamPolicyrrrrl.PubsubProjectsSubscriptionsGetIamPolicyRequestrFrJrVrXr.r,rYrs7)?)?Y>"|L673J# *r.cDURS5nURX1US9$)zLists matching subscriptions. Args: request: (PubsubProjectsSubscriptionsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSubscriptionsResponse) The response message. rr:r<r?s r,r*PubsubV1.ProjectsSubscriptionsService.List)rr.cF[R"SSSS/S/SS/SSS S S S 9 $) Nz&v1/projects/{projectsId}/subscriptionsrzz"pubsub.projects.subscriptions.listrrrzv1/{+project}/subscriptionsrl&PubsubProjectsSubscriptionsListRequestListSubscriptionsResponseFrJrVrXr.r,rYr6s9!7!7:6!{K +.3B6 "r.cDURS5nURX1US9$)aModifies the ack deadline for a specific message. This method is useful to indicate that more time is needed to process a message by the subscriber, or to make the message available for redelivery if the processing was interrupted. Note that this does not modify the subscription-level `ackDeadlineSeconds` used for subsequent messages. Args: request: (PubsubProjectsSubscriptionsModifyAckDeadlineRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. ModifyAckDeadliner:r<r?s r,r#7PubsubV1.ProjectsSubscriptionsService.ModifyAckDeadlineDs0##$78f __ 88r.cB[R"SSSS/S//SSSSS S 9 $) NzJv1/projects/{projectsId}/subscriptions/{subscriptionsId}:modifyAckDeadlinerEz/pubsub.projects.subscriptions.modifyAckDeadlinerz$v1/{+subscription}:modifyAckDeadlinemodifyAckDeadlineRequest3PubsubProjectsSubscriptionsModifyAckDeadlineRequestrnFrJrVrXr.r,rYrQs6h.D.D^C&'#$<0O" /r.cDURS5nURX1US9$)a)Modifies the `PushConfig` for a specified subscription. This may be used to change a push subscription to a pull one (signified by an empty `PushConfig`) or vice versa, or change the endpoint URL and other attributes of a push subscription. Messages will accumulate for delivery continuously through the call regardless of changes to the `PushConfig`. Args: request: (PubsubProjectsSubscriptionsModifyPushConfigRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. ModifyPushConfigr:r<r?s r,r)6PubsubV1.ProjectsSubscriptionsService.ModifyPushConfig_s0##$67f __ 88r.cB[R"SSSS/S//SSSSS S 9 $) NzIv1/projects/{projectsId}/subscriptions/{subscriptionsId}:modifyPushConfigrEz.pubsub.projects.subscriptions.modifyPushConfigrz#v1/{+subscription}:modifyPushConfigmodifyPushConfigRequest2PubsubProjectsSubscriptionsModifyPushConfigRequestrnFrJrVrXr.r,rYrls6X-C-C]B&'#$;/N" .r.cDURS5nURX1US9$)arUpdates an existing subscription by updating the fields specified in the update mask. Note that certain properties of a subscription, such as its topic, are not modifiable. Args: request: (PubsubProjectsSubscriptionsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Subscription) The response message. rr:r<r?s r,r+PubsubV1.ProjectsSubscriptionsService.Patchzrr.cB[R"SSSS/S//SSSSS S 9 $) Nrrz#pubsub.projects.subscriptions.patchrFrkupdateSubscriptionRequest'PubsubProjectsSubscriptionsPatchRequestr FrJrVrXr.r,rYrs4("8"8L7xH"1C) #r.cDURS5nURX1US9$)zPulls messages from the server. Args: request: (PubsubProjectsSubscriptionsPullRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (PullResponse) The response message. Pullr:r<r?s r,r4*PubsubV1.ProjectsSubscriptionsService.Pullrr.cB[R"SSSS/S//SSSSS S 9 $) Nz=v1/projects/{projectsId}/subscriptions/{subscriptionsId}:pullrEz"pubsub.projects.subscriptions.pullrzv1/{+subscription}:pull pullRequest&PubsubProjectsSubscriptionsPullRequest PullResponseFrJrVrXr.r,rYr6!7!7Q6&'#$/#B) "r.cDURS5nURX1US9$)aSeeks an existing subscription to a point in time or to a given snapshot, whichever is provided in the request. Snapshots are used in [Seek] (https://cloud.google.com/pubsub/docs/replay-overview) operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. Note that both the subscription and the snapshot must be on the same topic. Args: request: (PubsubProjectsSubscriptionsSeekRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SeekResponse) The response message. Seekr:r<r?s r,r<*PubsubV1.ProjectsSubscriptionsService.Seekrr.cB[R"SSSS/S//SSSSS S 9 $) Nz=v1/projects/{projectsId}/subscriptions/{subscriptionsId}:seekrEz"pubsub.projects.subscriptions.seekrzv1/{+subscription}:seek seekRequest&PubsubProjectsSubscriptionsSeekRequest SeekResponseFrJrVrXr.r,rYrr:r.cDURS5nURX1US9$)ajSets the access control policy on the specified resource. Replaces any existing policy. Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors. Args: request: (PubsubProjectsSubscriptionsSetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rr:r<r?s r,r2PubsubV1.ProjectsSubscriptionsService.SetIamPolicyrr.cB[R"SSSS/S//SSSSS S 9 $) NzEv1/projects/{projectsId}/subscriptions/{subscriptionsId}:setIamPolicyrEz*pubsub.projects.subscriptions.setIamPolicyrrr.PubsubProjectsSubscriptionsSetIamPolicyRequestrFrJrVrXr.r,rYrs4)?)?Y>"|L3+J# *r.cDURS5nURX1US9$)a>Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a `NOT_FOUND` error. Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning. Args: request: (PubsubProjectsSubscriptionsTestIamPermissionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestIamPermissionsResponse) The response message. rr:r<r?s r,r8PubsubV1.ProjectsSubscriptionsService.TestIamPermissionsrr.cB[R"SSSS/S//SSSSS S 9 $) NzKv1/projects/{projectsId}/subscriptions/{subscriptionsId}:testIamPermissionsrEz0pubsub.projects.subscriptions.testIamPermissionsrrr4PubsubProjectsSubscriptionsTestIamPermissionsRequestrFrJrVrXr.r,rYrs4x/E/E_D"|L91P7 0r.rr3)rrrrrrrrrr\rfrrvr~rr#r)rr4r<rrrrrs@r,rr}s@ $E 8 !K 8 F 8 F 8 F 8 C 8 "L 8 D 8 '# 8 &" 8 E 8 D 8 D 8 "L 8 ($$r.rcJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) 'PubsubV1.ProjectsTopicsSnapshotsServiceiz9Service class for the projects_topics_snapshots resource.r"cN>[[RU]U5 0Ulgr3)rrr!rr4r5s r,r0PubsubV1.ProjectsTopicsSnapshotsService.__init__s" H 3 3TCFK dr.cDURS5nURX1US9$)aLists the names of the snapshots on this topic. Snapshots are used in [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. Args: request: (PubsubProjectsTopicsSnapshotsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListTopicSnapshotsResponse) The response message. rr:r<r?s r,r,PubsubV1.ProjectsTopicsSnapshotsService.List rr.cF[R"SSSS/S/SS/SSS S S S 9 $) Nz4v1/projects/{projectsId}/topics/{topicsId}/snapshotsrzz%pubsub.projects.topics.snapshots.listtopicrrzv1/{+topic}/snapshotsrl(PubsubProjectsTopicsSnapshotsListRequestListTopicSnapshotsResponseFrJrVrXr.r,rY0PubsubV1.ProjectsTopicsSnapshotsService.s9!7!7H9yI +.-D7 "r.rr3 rrrrrrrrrrrrs@r,r!rKs"C 'E 8 Dr.r!cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) +PubsubV1.ProjectsTopicsSubscriptionsServicei&z=Service class for the projects_topics_subscriptions resource.r$cN>[[RU]U5 0Ulgr3)rrr#rr4r5s r,r4PubsubV1.ProjectsTopicsSubscriptionsService.__init__+s" H 7 7GO dr.cDURS5nURX1US9$)aLists the names of the attached subscriptions on this topic. Args: request: (PubsubProjectsTopicsSubscriptionsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListTopicSubscriptionsResponse) The response message. rr:r<r?s r,r0PubsubV1.ProjectsTopicsSubscriptionsService.List0rr.cF[R"SSSS/S/SS/SSS S S S 9 $) Nz8v1/projects/{projectsId}/topics/{topicsId}/subscriptionsrzz)pubsub.projects.topics.subscriptions.listrQrrzv1/{+topic}/subscriptionsrl,PubsubProjectsTopicsSubscriptionsListRequestListTopicSubscriptionsResponseFrJrVrXr.r,rY4PubsubV1.ProjectsTopicsSubscriptionsService.=s9!7!7L=yI +.1H; "r.rr3rUrs@r,r#rW&s"G +E 8 Dr.r#c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSSjrS\lSSjrS\lSrU=r$)PubsubV1.ProjectsTopicsServiceiKz/Service class for the projects_topics resource.r&cN>[[RU]U5 0Ulgr3)rrr%rr4r5s r,r'PubsubV1.ProjectsTopicsService.__init__Ps" H * *D:6B dr.cDURS5nURX1US9$)a,Creates the given topic with the given name. See the [resource name rules] (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names). Args: request: (Topic) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Topic) The response message. r\r:r<r?s r,r\%PubsubV1.ProjectsTopicsService.CreateUrCr.cB[R"SSSS/S//SSSSSS 9 $) N*v1/projects/{projectsId}/topics/{topicsId}rzpubsub.projects.topics.createrFrkrTopicFrJrVrXr.r,rY'PubsubV1.ProjectsTopicsService.bs48#9#9>1xH"!!" $r.cDURS5nURX1US9$)aDeletes the topic with the given name. Returns `NOT_FOUND` if the topic does not exist. After a topic is deleted, a new topic may be created with the same name; this is an entirely new topic with none of the old configuration or subscriptions. Existing subscriptions to this topic are not deleted, but their `topic` field is set to `_deleted-topic_`. Args: request: (PubsubProjectsTopicsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rfr:r<r?s r,rf%PubsubV1.ProjectsTopicsService.DeleteprCr.cB[R"SSSS/S//SSSSS S 9 $) Nrgrjzpubsub.projects.topics.deleterQ v1/{+topic}rl!PubsubProjectsTopicsDeleteRequestrnFrJrVrXr.r,rYri}s48#9#9>1yI#=" $r.cDURS5nURX1US9$)zGets the configuration of a topic. Args: request: (PubsubProjectsTopicsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Topic) The response message. rvr:r<r?s r,rv"PubsubV1.ProjectsTopicsService.Getrxr.cB[R"SSSS/S//SSSSS S 9 $) Nrgrzzpubsub.projects.topics.getrQrmrlPubsubProjectsTopicsGetRequestrhFrJrVrXr.r,rYris4 6 6>.yI#:" !r.cDURS5nURX1US9$)a=Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set. Args: request: (PubsubProjectsTopicsGetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. r~r:r<r?s r,r~+PubsubV1.ProjectsTopicsService.GetIamPolicyrr.cD[R"SSSS/S/S/SSSS S S 9 $) Nz7v1/projects/{projectsId}/topics/{topicsId}:getIamPolicyrzz#pubsub.projects.topics.getIamPolicyrrrrl'PubsubProjectsTopicsGetIamPolicyRequestrFrJrVrXr.r,rYris7)?)?K7"|L673C# *r.cDURS5nURX1US9$)zLists matching topics. Args: request: (PubsubProjectsTopicsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListTopicsResponse) The response message. rr:r<r?s r,r#PubsubV1.ProjectsTopicsService.Listrr.cF[R"SSSS/S/SS/SSS S S S 9 $) Nzv1/projects/{projectsId}/topicsrzzpubsub.projects.topics.listrrrzv1/{+project}/topicsrlPubsubProjectsTopicsListRequestListTopicsResponseFrJrVrXr.r,rYris9!7!73/!{K +.,;/ "r.cDURS5nURX1US9$)aBUpdates an existing topic by updating the fields specified in the update mask. Note that certain properties of a topic are not modifiable. Args: request: (PubsubProjectsTopicsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Topic) The response message. rr:r<r?s r,r$PubsubV1.ProjectsTopicsService.Patchrr.cB[R"SSSS/S//SSSSS S 9 $) Nrgrzpubsub.projects.topics.patchrFrkupdateTopicRequest PubsubProjectsTopicsPatchRequestrhFrJrVrXr.r,rYris4("8"8>0xH"*<" #r.cDURS5nURX1US9$)aAdds one or more messages to the topic. Returns `NOT_FOUND` if the topic does not exist. Args: request: (PubsubProjectsTopicsPublishRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (PublishResponse) The response message. Publishr:r<r?s r,r&PubsubV1.ProjectsTopicsService.Publishs/##I.f __ 88r.cB[R"SSSS/S//SSSSS S 9 $) Nz2v1/projects/{projectsId}/topics/{topicsId}:publishrEzpubsub.projects.topics.publishrQzv1/{+topic}:publishpublishRequest"PubsubProjectsTopicsPublishRequestPublishResponseFrJrVrXr.r,rYris4H$:$:F2yI+&>, %r.cDURS5nURX1US9$)acSets the access control policy on the specified resource. Replaces any existing policy. Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors. Args: request: (PubsubProjectsTopicsSetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rr:r<r?s r,r+PubsubV1.ProjectsTopicsService.SetIamPolicyrr.cB[R"SSSS/S//SSSSS S 9 $) Nz7v1/projects/{projectsId}/topics/{topicsId}:setIamPolicyrEz#pubsub.projects.topics.setIamPolicyrrr'PubsubProjectsTopicsSetIamPolicyRequestrFrJrVrXr.r,rYris4)?)?K7"|L3+C# *r.cDURS5nURX1US9$)a7Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a `NOT_FOUND` error. Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning. Args: request: (PubsubProjectsTopicsTestIamPermissionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestIamPermissionsResponse) The response message. rr:r<r?s r,r1PubsubV1.ProjectsTopicsService.TestIamPermissions-rr.cB[R"SSSS/S//SSSSS S 9 $) Nz=v1/projects/{projectsId}/topics/{topicsId}:testIamPermissionsrEz)pubsub.projects.topics.testIamPermissionsrrr-PubsubProjectsTopicsTestIamPermissionsRequestrFrJrVrXr.r,rYri:s4x/E/EQ="|L91I7 0r.rr3)rrrrrrrr\rrfrvr~rrrrrrrrs@r,r%raKs9 E 8 F 8 F 8 C 8 "L 8 D 8 E 8 G 8 "L 8 ($$r.r%cd^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS r U=r $) PubsubV1.ProjectsServiceiHz(Service class for the projects resource.r(cN>[[RU]U5 0Ulgr3)rrr'rr4r5s r,r!PubsubV1.ProjectsService.__init__Ms" H $ $d4V< dr.cDURS5nURX1US9$)aTests applying MessageTransforms to a Pub/Sub message. Args: request: (PubsubProjectsTestMessageTransformsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestMessageTransformsResponse) The response message. TestMessageTransformsr:r<r?s r,r.PubsubV1.ProjectsService.TestMessageTransformsRs0##$;_s4(2H2HB9!{K;4F: 3r.cDURS5nURX1US9$)zValidates a MessageTransform. Args: request: (PubsubProjectsValidateMessageTransformRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ValidateMessageTransformResponse) The response message. ValidateMessageTransformr:r<r?s r,r1PubsubV1.ProjectsService.ValidateMessageTransformms0##$>?f __ 88r.cB[R"SSSS/S//SSSSS S 9 $) Nz1v1/projects/{projectsId}:validateMessageTransformrEz(pubsub.projects.validateMessageTransformrz&v1/{+project}:validateMessageTransformvalidateMessageTransformRequest-PubsubProjectsValidateMessageTransformRequest ValidateMessageTransformResponseFrJrVrXr.r,rYrzs4X5K5KE<!{K>7I= 6r.rr3) rrrrrrrrrrrrrs@r,r'rHs32 E 8 +' 8 .**r.r')r(rrr r&r"r$) rlNTNNFFNNNN)rrrrrmessagesMESSAGES_MODULEr MTLS_BASE_URL_PACKAGE_SCOPES_VERSION _CLIENT_ID_CLIENT_SECRET _USER_AGENT_CLIENT_CLASS_NAME _URL_VERSION_API_KEYrrBaseApiServicerrrr!r#r%r'rrrs@r,rr s?/ -(7- ( =?g h' (*"."+!, ()-6:/4<@?C /.gx66gR `!8!8`DBX%<%<BH #x'>'>#J#8+B+B#J{h55{z>//>>r.rN) r __future__rapitools.base.pyr/googlecloudsdk.generated_clients.apis.pubsub.v1rr BaseApiClientrrXr.r,rs'5'%Z|x%%|r.