VdZddlmZddlmZddlmZGddejZ y)z/Generated client library for pubsub version v1.)absolute_import)base_api)pubsub_v1_messagesceZdZdZeZdZdZdZddgZ dZ dZ d Z d Z dZdZd Z dfd ZGd dej&ZGddej&ZGddej&ZGddej&ZGddej&ZGddej&ZGddej&ZxZS)PubsubV1z7Generated 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 |xs |j}tt|||||||||| | |  |j ||_|j ||_|j||_ |j||_ |j||_ |j||_|j!||_y)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) selfurlr rrrrrrrrr __class__s Glib/googlecloudsdk/generated_clients/apis/pubsub/v1/pubsub_v1_client.pyrzPubsubV1.__init__s  C (D" 'd%l)3 7+#-!77=D";;DAD"&"C"CD"ID%)%H%H%ND")-)P)PQU)VD&55d;D((.DMc^eZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _ddZ de _ddZ de _ddZde_ddZde_ddZde_ddZde_ddZde_ddZde_xZS)PubsubV1.ProjectsSchemasServicez0Service class for the projects_schemas resource.rcNttj||i|_yN)rrrr_upload_configsr(clientr*s r+rz(PubsubV1.ProjectsSchemasService.__init__7s" H + +T;FC dr,cL|jd}|j|||S)aCommits 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(requestr7configs r+r5z&PubsubV1.ProjectsSchemasService.Commit<1##H-f __ '88r,c Ftjddddgdggddddd S) 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+z(PubsubV1.ProjectsSchemasService.Is48#9#9G2xH)+># $r,cL|jd}|j|||S)zCreates a schema. Args: request: (PubsubProjectsSchemasCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Schema) The response message. Creater6r8r;s r+rVz&PubsubV1.ProjectsSchemasService.CreateWr>r,c Htjddddgdgdgdddd d S) N v1/projects/{projectsId}/schemasr@zpubsub.projects.schemas.createparentschemaIdv1/{+parent}/schemasschema"PubsubProjectsSchemasCreateRequestrDFrErQrSr,r+rTz(PubsubV1.ProjectsSchemasService.ds68#9#942 zJ \,># $r,cL|jd}|j|||S)zDeletes a schema. Args: request: (PubsubProjectsSchemasDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. Deleter6r8r;s r+r_z&PubsubV1.ProjectsSchemasService.Deleterr>r,c Ftjddddgdggddddd S) N,v1/projects/{projectsId}/schemas/{schemasId}DELETEzpubsub.projects.schemas.deleterA v1/{+name}"PubsubProjectsSchemasDeleteRequestEmptyFrErQrSr,r+rTz(PubsubV1.ProjectsSchemasService.s48#9#9@2xH">" $r,cL|jd}|j|||S)a Deletes a specific schema revision. Args: request: (PubsubProjectsSchemasDeleteRevisionRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Schema) The response message. DeleteRevisionr6r8r;s r+rhz.PubsubV1.ProjectsSchemasService.DeleteRevisions2##$45f __ '88r,c Htjddddgdgdgdddd d S) Nz;v1/projects/{projectsId}/schemas/{schemasId}:deleteRevisionrbz&pubsub.projects.schemas.deleteRevisionrA revisionIdzv1/{+name}:deleteRevisionrd*PubsubProjectsSchemasDeleteRevisionRequestrDFrErQrSr,r+rTz(PubsubV1.ProjectsSchemasService.s68+A+AO:xH"^1F# ,r,cL|jd}|j|||S)zGets a schema. Args: request: (PubsubProjectsSchemasGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Schema) The response message. Getr6r8r;s r+rmz#PubsubV1.ProjectsSchemasService.Get1##E*f __ '88r,c Htjddddgdgdgdddd d S) NraGETzpubsub.projects.schemas.getrAviewrcrdPubsubProjectsSchemasGetRequestrDFrErQrSr,r+rTz(PubsubV1.ProjectsSchemasService.s6 6 6@/xHX";# !r,cL|jd}|j|||S)abGets 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. GetIamPolicyr6r8r;s r+rtz,PubsubV1.ProjectsSchemasService.GetIamPolicy1##N3f __ '88r,c Htjddddgdgdgdddd d S) Nz9v1/projects/{projectsId}/schemas/{schemasId}:getIamPolicyrpz$pubsub.projects.schemas.getIamPolicyresourceoptions_requestedPolicyVersionv1/{+resource}:getIamPolicyrd(PubsubProjectsSchemasGetIamPolicyRequestPolicyFrErQrSr,r+rTz(PubsubV1.ProjectsSchemasService.s7)?)?M8"|L673D# *r,cL|jd}|j|||S)aLists schemas in a project. Args: request: (PubsubProjectsSchemasListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSchemasResponse) The response message. Listr6r8r;s r+r}z$PubsubV1.ProjectsSchemasService.List1##F+f __ '88r,c Jtjddddgdggddddd d S) NrXrpzpubsub.projects.schemas.listrYpageSize pageTokenrqr[rd PubsubProjectsSchemasListRequestListSchemasResponseFrErQrSr,r+rTz(PubsubV1.ProjectsSchemasService.s4!7!740 zJ6,<0 "r,cL|jd}|j|||S)a+Lists all schema revisions for the named schema. Args: request: (PubsubProjectsSchemasListRevisionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSchemaRevisionsResponse) The response message. ListRevisionsr6r8r;s r+rz-PubsubV1.ProjectsSchemasService.ListRevisionss1##O4f __ '88r,c Jtjddddgdggddddd d S) Nz:v1/projects/{projectsId}/schemas/{schemasId}:listRevisionsrpz%pubsub.projects.schemas.listRevisionsrArzv1/{+name}:listRevisionsrd)PubsubProjectsSchemasListRevisionsRequestListSchemaRevisionsResponseFrErQrSr,r+rTz(PubsubV1.ProjectsSchemasService.s4(*@*@N9xH60E8 +r,cL|jd}|j|||S)a*Creates 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. Rollbackr6r8r;s r+rz(PubsubV1.ProjectsSchemasService.Rollback1##J/f __ '88r,c Ftjddddgdggddddd S) Nz5v1/projects/{projectsId}/schemas/{schemasId}:rollbackr@z pubsub.projects.schemas.rollbackrAzv1/{+name}:rollbackrollbackSchemaRequest$PubsubProjectsSchemasRollbackRequestrDFrErQrSr,r+rTz(PubsubV1.ProjectsSchemasService.!s4X%;%;I4xH+-@# &r,cL|jd}|j|||S)aSets 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. SetIamPolicyr6r8r;s r+rz,PubsubV1.ProjectsSchemasService.SetIamPolicy/rur,c Ftjddddgdggddddd S) Nz9v1/projects/{projectsId}/schemas/{schemasId}:setIamPolicyr@z$pubsub.projects.schemas.setIamPolicyrwv1/{+resource}:setIamPolicysetIamPolicyRequest(PubsubProjectsSchemasSetIamPolicyRequestr{FrErQrSr,r+rTz(PubsubV1.ProjectsSchemasService.<s4)?)?M8"|L3+D# *r,cL|jd}|j|||S)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: (PubsubProjectsSchemasTestIamPermissionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestIamPermissionsResponse) The response message. TestIamPermissionsr6r8r;s r+rz2PubsubV1.ProjectsSchemasService.TestIamPermissionsJ2##$89f __ '88r,c Ftjddddgdggddddd S) Nz?v1/projects/{projectsId}/schemas/{schemasId}:testIamPermissionsr@z*pubsub.projects.schemas.testIamPermissionsrw!v1/{+resource}:testIamPermissionstestIamPermissionsRequest.PubsubProjectsSchemasTestIamPermissionsRequestTestIamPermissionsResponseFrErQrSr,r+rTz(PubsubV1.ProjectsSchemasService.Ws4x/E/ES>"|L91J7 0r,cL|jd}|j|||S)aValidates a schema. Args: request: (PubsubProjectsSchemasValidateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ValidateSchemaResponse) The response message. Validater6r8r;s r+rz(PubsubV1.ProjectsSchemasService.Validateerr,c Ftjddddgdggddddd S) Nz)v1/projects/{projectsId}/schemas:validater@z pubsub.projects.schemas.validaterYzv1/{+parent}/schemas:validatevalidateSchemaRequest$PubsubProjectsSchemasValidateRequestValidateSchemaResponseFrErQrSr,r+rTz(PubsubV1.ProjectsSchemasService.rs4X%;%;=4 zJ5-@3 &r,cL|jd}|j|||S)aValidates a message against a schema. Args: request: (PubsubProjectsSchemasValidateMessageRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ValidateMessageResponse) The response message. ValidateMessager6r8r;s r+rz/PubsubV1.ProjectsSchemasService.ValidateMessages2##$56f __ '88r,c Ftjddddgdggddddd S) Nz0v1/projects/{projectsId}/schemas:validateMessager@z'pubsub.projects.schemas.validateMessagerYz$v1/{+parent}/schemas:validateMessagevalidateMessageRequest+PubsubProjectsSchemasValidateMessageRequestValidateMessageResponseFrErQrSr,r+rTz(PubsubV1.ProjectsSchemasService.s4H,B,BD; zJ<.G4 -r,r0)__name__ __module__ __qualname____doc___NAMErr5 method_configrVr_rhrmrtr}rrrrrr __classcell__r*s@r+rr.2s: 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,rceZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _ddZ de _ddZ de _ddZde_xZS)!PubsubV1.ProjectsSnapshotsServicez2Service class for the projects_snapshots resource.rcNttj||i|_yr0)rrrrr1r2s r+rz*PubsubV1.ProjectsSnapshotsService.__init__s" H - -t=fE dr,cL|jd}|j|||S)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. rVr6r8r;s r+rVz(PubsubV1.ProjectsSnapshotsService.Creater>r,c Ftjddddgdggddddd S) N0v1/projects/{projectsId}/snapshots/{snapshotsId}PUTz pubsub.projects.snapshots.createrArccreateSnapshotRequest$PubsubProjectsSnapshotsCreateRequestSnapshotFrErQrSr,r+rTz*PubsubV1.ProjectsSnapshotsService.s48#9#9D4xH"-@% $r,cL|jd}|j|||S)a3Removes 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. r_r6r8r;s r+r_z(PubsubV1.ProjectsSnapshotsService.Deleter>r,c Ftjddddgdggddddd S) Nrrbz pubsub.projects.snapshots.deletesnapshotv1/{+snapshot}rd$PubsubProjectsSnapshotsDeleteRequestrfFrErQrSr,r+rTz*PubsubV1.ProjectsSnapshotsService.s48#9#9D4"|L&@" $r,cL|jd}|j|||S)a"Gets 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. rmr6r8r;s r+rmz%PubsubV1.ProjectsSnapshotsService.Getrnr,c Ftjddddgdggddddd S) Nrrpzpubsub.projects.snapshots.getrrrd!PubsubProjectsSnapshotsGetRequestrFrErQrSr,r+rTz*PubsubV1.ProjectsSnapshotsService.s4 6 6D1"|L&=% !r,cL|jd}|j|||S)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: (PubsubProjectsSnapshotsGetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rtr6r8r;s r+rtz.PubsubV1.ProjectsSnapshotsService.GetIamPolicyrur,c Htjddddgdgdgdddd d S) Nz=v1/projects/{projectsId}/snapshots/{snapshotsId}:getIamPolicyrpz&pubsub.projects.snapshots.getIamPolicyrwrxryrd*PubsubProjectsSnapshotsGetIamPolicyRequestr{FrErQrSr,r+rTz*PubsubV1.ProjectsSnapshotsService.s7)?)?Q:"|L673F# *r,cL|jd}|j|||S)a!Lists 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. r}r6r8r;s r+r}z&PubsubV1.ProjectsSnapshotsService.Listr~r,c Jtjddddgdgddgddd d d S) Nz"v1/projects/{projectsId}/snapshotsrpzpubsub.projects.snapshots.listprojectrrzv1/{+project}/snapshotsrd"PubsubProjectsSnapshotsListRequestListSnapshotsResponseFrErQrSr,r+rTz*PubsubV1.ProjectsSnapshotsService.s9!7!762!{K +./>2 "r,cL|jd}|j|||S)aHUpdates 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. Patchr6r8r;s r+rz'PubsubV1.ProjectsSnapshotsService.Patch,1##G,f __ '88r,c Ftjddddgdggddddd S) NrPATCHzpubsub.projects.snapshots.patchrArcupdateSnapshotRequest#PubsubProjectsSnapshotsPatchRequestrFrErQrSr,r+rTz*PubsubV1.ProjectsSnapshotsService.9s4("8"8D3xH"-?% #r,cL|jd}|j|||S)aSets 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. rr6r8r;s r+rz.PubsubV1.ProjectsSnapshotsService.SetIamPolicyGrur,c Ftjddddgdggddddd S) Nz=v1/projects/{projectsId}/snapshots/{snapshotsId}:setIamPolicyr@z&pubsub.projects.snapshots.setIamPolicyrwrr*PubsubProjectsSnapshotsSetIamPolicyRequestr{FrErQrSr,r+rTz*PubsubV1.ProjectsSnapshotsService.Ts4)?)?Q:"|L3+F# *r,cL|jd}|j|||S)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. rr6r8r;s r+rz4PubsubV1.ProjectsSnapshotsService.TestIamPermissionsbrr,c Ftjddddgdggddddd S) NzCv1/projects/{projectsId}/snapshots/{snapshotsId}:testIamPermissionsr@z,pubsub.projects.snapshots.testIamPermissionsrwrr0PubsubProjectsSnapshotsTestIamPermissionsRequestrFrErQrSr,r+rTz*PubsubV1.ProjectsSnapshotsService.os4x/E/EW@"|L91L7 0r,r0)rrrrrrrVrr_rmrtr}rrrrrs@r+rrs< E 8 F 8 F 8 C 8 "L 8 D 8 E 8 "L 8 ($$r,rcveZdZdZdZfdZd dZde_d dZde_d dZ d e _d d Z d e _d d Z d e _d dZ de _d dZ de _d dZde_d dZde_d dZde_d dZde_d dZde_d dZde_d dZde_xZS)!%PubsubV1.ProjectsSubscriptionsServicez6Service class for the projects_subscriptions resource.rcNttj||i|_yr0)rrrrr1r2s r+rz.PubsubV1.ProjectsSubscriptionsService.__init__s" H 1 14A&I dr,cL|jd}|j|||S)a=Acknowledges 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. Acknowledger6r8r;s r+rz1PubsubV1.ProjectsSubscriptionsService.Acknowledges1##M2f __ '88r,c Ftjddddgdggddddd S) NzDv1/projects/{projectsId}/subscriptions/{subscriptionsId}:acknowledger@z)pubsub.projects.subscriptions.acknowledge subscriptionzv1/{+subscription}:acknowledgeacknowledgeRequest-PubsubProjectsSubscriptionsAcknowledgeRequestrfFrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.s6(>(>X=&'#$6*I" )r,cL|jd}|j|||S)a\Creates 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. rVr6r8r;s r+rVz,PubsubV1.ProjectsSubscriptionsService.Creater>r,c Ftjddddgdggddddd S) N8v1/projects/{projectsId}/subscriptions/{subscriptionsId}rz$pubsub.projects.subscriptions.createrArc SubscriptionFrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.s48#9#9L8xH"!() $r,cL|jd}|j|||S)a<Deletes 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. r_r6r8r;s r+r_z,PubsubV1.ProjectsSubscriptionsService.Deleter>r,c Ftjddddgdggddddd S) Nrrbz$pubsub.projects.subscriptions.deleterv1/{+subscription}rd(PubsubProjectsSubscriptionsDeleteRequestrfFrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.s68#9#9L8&'#$*D" $r,cL|jd}|j|||S)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. Detachr6r8r;s r+rz,PubsubV1.ProjectsSubscriptionsService.Detachr>r,c Ftjddddgdggddddd S) Nz?v1/projects/{projectsId}/subscriptions/{subscriptionsId}:detachr@z$pubsub.projects.subscriptions.detachrzv1/{+subscription}:detachrd(PubsubProjectsSubscriptionsDetachRequestDetachSubscriptionResponseFrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.s68#9#9S8&'#$1D7 $r,cL|jd}|j|||S)aGets the configuration details of a subscription. Args: request: (PubsubProjectsSubscriptionsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Subscription) The response message. rmr6r8r;s r+rmz)PubsubV1.ProjectsSubscriptionsService.Getrnr,c Ftjddddgdggddddd S) Nrrpz!pubsub.projects.subscriptions.getrrrd%PubsubProjectsSubscriptionsGetRequestrFrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.s6 6 6L5&'#$*A) !r,cL|jd}|j|||S)ahGets 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. rtr6r8r;s r+rtz2PubsubV1.ProjectsSubscriptionsService.GetIamPolicyrur,c Htjddddgdgdgdddd d S) NzEv1/projects/{projectsId}/subscriptions/{subscriptionsId}:getIamPolicyrpz*pubsub.projects.subscriptions.getIamPolicyrwrxryrd.PubsubProjectsSubscriptionsGetIamPolicyRequestr{FrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.s7)?)?Y>"|L673J# *r,cL|jd}|j|||S)aLists matching subscriptions. Args: request: (PubsubProjectsSubscriptionsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSubscriptionsResponse) The response message. r}r6r8r;s r+r}z*PubsubV1.ProjectsSubscriptionsService.List)r~r,c Jtjddddgdgddgddd d d S) Nz&v1/projects/{projectsId}/subscriptionsrpz"pubsub.projects.subscriptions.listrrrzv1/{+project}/subscriptionsrd&PubsubProjectsSubscriptionsListRequestListSubscriptionsResponseFrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.6s9!7!7:6!{K +.3B6 "r,cL|jd}|j|||S)a?Modifies 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. ModifyAckDeadliner6r8r;s r+rz7PubsubV1.ProjectsSubscriptionsService.ModifyAckDeadlineDs2##$78f __ '88r,c Ftjddddgdggddddd S) NzJv1/projects/{projectsId}/subscriptions/{subscriptionsId}:modifyAckDeadliner@z/pubsub.projects.subscriptions.modifyAckDeadlinerz$v1/{+subscription}:modifyAckDeadlinemodifyAckDeadlineRequest3PubsubProjectsSubscriptionsModifyAckDeadlineRequestrfFrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.Qs6h.D.D^C&'#$<0O" /r,cL|jd}|j|||S)aMModifies 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. ModifyPushConfigr6r8r;s r+rz6PubsubV1.ProjectsSubscriptionsService.ModifyPushConfig_s2##$67f __ '88r,c Ftjddddgdggddddd S) NzIv1/projects/{projectsId}/subscriptions/{subscriptionsId}:modifyPushConfigr@z.pubsub.projects.subscriptions.modifyPushConfigrz#v1/{+subscription}:modifyPushConfigmodifyPushConfigRequest2PubsubProjectsSubscriptionsModifyPushConfigRequestrfFrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.ls6X-C-C]B&'#$;/N" .r,cL|jd}|j|||S)aUpdates 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. rr6r8r;s r+rz+PubsubV1.ProjectsSubscriptionsService.Patchzrr,c Ftjddddgdggddddd S) Nrrz#pubsub.projects.subscriptions.patchrArcupdateSubscriptionRequest'PubsubProjectsSubscriptionsPatchRequestrFrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.s4("8"8L7xH"1C) #r,cL|jd}|j|||S)aPulls messages from the server. Args: request: (PubsubProjectsSubscriptionsPullRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (PullResponse) The response message. Pullr6r8r;s r+r z*PubsubV1.ProjectsSubscriptionsService.Pullr~r,c Ftjddddgdggddddd S) Nz=v1/projects/{projectsId}/subscriptions/{subscriptionsId}:pullr@z"pubsub.projects.subscriptions.pullrzv1/{+subscription}:pull pullRequest&PubsubProjectsSubscriptionsPullRequest PullResponseFrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.6!7!7Q6&'#$/#B) "r,cL|jd}|j|||S)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. Seekr6r8r;s r+rz*PubsubV1.ProjectsSubscriptionsService.Seekr~r,c Ftjddddgdggddddd S) Nz=v1/projects/{projectsId}/subscriptions/{subscriptionsId}:seekr@z"pubsub.projects.subscriptions.seekrzv1/{+subscription}:seek seekRequest&PubsubProjectsSubscriptionsSeekRequest SeekResponseFrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.rr,cL|jd}|j|||S)aSets 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. rr6r8r;s r+rz2PubsubV1.ProjectsSubscriptionsService.SetIamPolicyrur,c Ftjddddgdggddddd S) NzEv1/projects/{projectsId}/subscriptions/{subscriptionsId}:setIamPolicyr@z*pubsub.projects.subscriptions.setIamPolicyrwrr.PubsubProjectsSubscriptionsSetIamPolicyRequestr{FrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.s4)?)?Y>"|L3+J# *r,cL|jd}|j|||S)abReturns 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. rr6r8r;s r+rz8PubsubV1.ProjectsSubscriptionsService.TestIamPermissionsrr,c Ftjddddgdggddddd S) NzKv1/projects/{projectsId}/subscriptions/{subscriptionsId}:testIamPermissionsr@z0pubsub.projects.subscriptions.testIamPermissionsrwrr4PubsubProjectsSubscriptionsTestIamPermissionsRequestrFrErQrSr,r+rTz.PubsubV1.ProjectsSubscriptionsService.s4x/E/E_D"|L91P7 0r,r0)rrrrrrrrrVr_rrmrtr}rrrr 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,rc>eZdZdZdZfdZddZde_xZS)'PubsubV1.ProjectsTopicsSnapshotsServicez9Service class for the projects_topics_snapshots resource.r!cNttj||i|_yr0)rrr rr1r2s r+rz0PubsubV1.ProjectsTopicsSnapshotsService.__init__s" H 3 3TCFK dr,cL|jd}|j|||S)a=Lists 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. r}r6r8r;s r+r}z,PubsubV1.ProjectsTopicsSnapshotsService.List r~r,c Jtjddddgdgddgddd d d S) Nz4v1/projects/{projectsId}/topics/{topicsId}/snapshotsrpz%pubsub.projects.topics.snapshots.listtopicrrzv1/{+topic}/snapshotsrd(PubsubProjectsTopicsSnapshotsListRequestListTopicSnapshotsResponseFrErQrSr,r+rTz0PubsubV1.ProjectsTopicsSnapshotsService.s9!7!7H9yI +.-D7 "r,r0 rrrrrrr}rrrs@r+r rs"C 'E 8 Dr,r c>eZdZdZdZfdZddZde_xZS)+PubsubV1.ProjectsTopicsSubscriptionsServicez=Service class for the projects_topics_subscriptions resource.r#cNttj||i|_yr0)rrr"rr1r2s r+rz4PubsubV1.ProjectsTopicsSubscriptionsService.__init__+s" H 7 7GO dr,cL|jd}|j|||S)a=Lists 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. r}r6r8r;s r+r}z0PubsubV1.ProjectsTopicsSubscriptionsService.List0r~r,c Jtjddddgdgddgddd d d S) Nz8v1/projects/{projectsId}/topics/{topicsId}/subscriptionsrpz)pubsub.projects.topics.subscriptions.listr rrzv1/{+topic}/subscriptionsrd,PubsubProjectsTopicsSubscriptionsListRequestListTopicSubscriptionsResponseFrErQrSr,r+rTz4PubsubV1.ProjectsTopicsSubscriptionsService.=s9!7!7L=yI +.1H; "r,r0r#rs@r+r"r%&s"G +E 8 Dr,r"ceZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _ddZ de _ddZ de _ddZde_ddZde_xZS)PubsubV1.ProjectsTopicsServicez/Service class for the projects_topics resource.r%cNttj||i|_yr0)rrr$rr1r2s r+rz'PubsubV1.ProjectsTopicsService.__init__Ps" H * *D:6B dr,cL|jd}|j|||S)aPCreates 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. rVr6r8r;s r+rVz%PubsubV1.ProjectsTopicsService.CreateUr>r,c Ftjddddgdggddddd S) N*v1/projects/{projectsId}/topics/{topicsId}rzpubsub.projects.topics.createrArcrTopicFrErQrSr,r+rTz'PubsubV1.ProjectsTopicsService.bs48#9#9>1xH"!!" $r,cL|jd}|j|||S)a;Deletes 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. r_r6r8r;s r+r_z%PubsubV1.ProjectsTopicsService.Deletepr>r,c Ftjddddgdggddddd S) Nr0rbzpubsub.projects.topics.deleter  v1/{+topic}rd!PubsubProjectsTopicsDeleteRequestrfFrErQrSr,r+rTz'PubsubV1.ProjectsTopicsService.}s48#9#9>1yI#=" $r,cL|jd}|j|||S)zGets the configuration of a topic. Args: request: (PubsubProjectsTopicsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Topic) The response message. rmr6r8r;s r+rmz"PubsubV1.ProjectsTopicsService.Getrnr,c Ftjddddgdggddddd S) Nr0rpzpubsub.projects.topics.getr r4rdPubsubProjectsTopicsGetRequestr1FrErQrSr,r+rTz'PubsubV1.ProjectsTopicsService.s4 6 6>.yI#:" !r,cL|jd}|j|||S)aaGets 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. rtr6r8r;s r+rtz+PubsubV1.ProjectsTopicsService.GetIamPolicyrur,c Htjddddgdgdgdddd d S) Nz7v1/projects/{projectsId}/topics/{topicsId}:getIamPolicyrpz#pubsub.projects.topics.getIamPolicyrwrxryrd'PubsubProjectsTopicsGetIamPolicyRequestr{FrErQrSr,r+rTz'PubsubV1.ProjectsTopicsService.s7)?)?K7"|L673C# *r,cL|jd}|j|||S)zLists matching topics. Args: request: (PubsubProjectsTopicsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListTopicsResponse) The response message. r}r6r8r;s r+r}z#PubsubV1.ProjectsTopicsService.Listr~r,c Jtjddddgdgddgddd d d S) Nzv1/projects/{projectsId}/topicsrpzpubsub.projects.topics.listrrrzv1/{+project}/topicsrdPubsubProjectsTopicsListRequestListTopicsResponseFrErQrSr,r+rTz'PubsubV1.ProjectsTopicsService.s9!7!73/!{K +.,;/ "r,cL|jd}|j|||S)afUpdates 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. rr6r8r;s r+rz$PubsubV1.ProjectsTopicsService.Patchrr,c Ftjddddgdggddddd S) Nr0rzpubsub.projects.topics.patchrArcupdateTopicRequest PubsubProjectsTopicsPatchRequestr1FrErQrSr,r+rTz'PubsubV1.ProjectsTopicsService.s4("8"8>0xH"*<" #r,cL|jd}|j|||S)a@Adds 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. Publishr6r8r;s r+rEz&PubsubV1.ProjectsTopicsService.Publishs1##I.f __ '88r,c Ftjddddgdggddddd S) Nz2v1/projects/{projectsId}/topics/{topicsId}:publishr@zpubsub.projects.topics.publishr zv1/{+topic}:publishpublishRequest"PubsubProjectsTopicsPublishRequestPublishResponseFrErQrSr,r+rTz'PubsubV1.ProjectsTopicsService.s4H$:$:F2yI+&>, %r,cL|jd}|j|||S)aSets 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. rr6r8r;s r+rz+PubsubV1.ProjectsTopicsService.SetIamPolicyrur,c Ftjddddgdggddddd S) Nz7v1/projects/{projectsId}/topics/{topicsId}:setIamPolicyr@z#pubsub.projects.topics.setIamPolicyrwrr'PubsubProjectsTopicsSetIamPolicyRequestr{FrErQrSr,r+rTz'PubsubV1.ProjectsTopicsService.s4)?)?K7"|L3+C# *r,cL|jd}|j|||S)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: (PubsubProjectsTopicsTestIamPermissionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestIamPermissionsResponse) The response message. rr6r8r;s r+rz1PubsubV1.ProjectsTopicsService.TestIamPermissions-rr,c Ftjddddgdggddddd S) Nz=v1/projects/{projectsId}/topics/{topicsId}:testIamPermissionsr@z)pubsub.projects.topics.testIamPermissionsrwrr-PubsubProjectsTopicsTestIamPermissionsRequestrFrErQrSr,r+rTz'PubsubV1.ProjectsTopicsService.:s4x/E/EQ="|L91I7 0r,r0)rrrrrrrVrr_rmrtr}rrErrrrs@r+r$r,Ks9 E 8 F 8 F 8 C 8 "L 8 D 8 E 8 G 8 "L 8 ($$r,r$cVeZdZdZdZfdZddZde_ddZde_xZ S) PubsubV1.ProjectsServicez(Service class for the projects resource.r'cNttj||i|_yr0)rrr&rr1r2s r+rz!PubsubV1.ProjectsService.__init__Ms" H $ $d4V< dr,cL|jd}|j|||S)a4Tests applying MessageTransforms to a Pub/Sub message. Args: request: (PubsubProjectsTestMessageTransformsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestMessageTransformsResponse) The response message. TestMessageTransformsr6r8r;s r+rTz.PubsubV1.ProjectsService.TestMessageTransformsRs2##$;_s4(2H2HB9!{K;4F: 3r,cL|jd}|j|||S)a!Validates a MessageTransform. Args: request: (PubsubProjectsValidateMessageTransformRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ValidateMessageTransformResponse) The response message. ValidateMessageTransformr6r8r;s r+rZz1PubsubV1.ProjectsService.ValidateMessageTransformms2##$>?f __ '88r,c Ftjddddgdggddddd S) Nz1v1/projects/{projectsId}:validateMessageTransformr@z(pubsub.projects.validateMessageTransformrz&v1/{+project}:validateMessageTransformvalidateMessageTransformRequest-PubsubProjectsValidateMessageTransformRequest ValidateMessageTransformResponseFrErQrSr,r+rTz!PubsubV1.ProjectsService.zs4X5K5KE<!{K>7I= 6r,r0) rrrrrrrTrrZrrs@r+r&rQHs32 E 8 +' 8 .**r,r&) rdNTNNFFNNNN)rrrrmessagesMESSAGES_MODULEr MTLS_BASE_URL_PACKAGE_SCOPES_VERSION _CLIENT_ID_CLIENT_SECRET _USER_AGENT_CLIENT_CLASS_NAME _URL_VERSION_API_KEYrrBaseApiServicerrrr r"r$r&rrs@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_ BaseApiClientrrSr,r+rps'5'%Z|x%%|r,