OdSSKJr SSKrSSKrSSKrSSKJrJrJrJ r J r J r J r J r JrJr SSKJr SSKJr SSKJr SSKJr SSKJr SS KJr SS KJr SS K J!r! SS K"J#r# SS K$J%r% SSK&J'r' \\RP\RRRT4r+SSK.J/r/ SSK.J0r0 SSK1J2r2 SSK1J3r3 SSK4J5r5 SSK6J7r7 SSK6J8r8 SSK9r9SSK:J;r;Jr> SSK?J@r@ SSKAJBrB "SS\C5rD"SS\DS9rE\RR\RS 9rSKS&S&\.RdRf\.RdRfS.S9.S0\&\-\4R~\ 4S\&\S:\&\@\4RS2\6S3\7S4\8\9\\4S \4R4S;jjjrCSKS&\.RdRf\.RdRfS.S<.S0\&\-\4R\ 4S\&\S2\6S3\7S4\8\9\\4S \4Rj4 S=jjjrESKS&\.RdRf\.RdRfS.S>.S0\&\-\4R\ 4S \&\S2\6S3\7S4\8\9\\4S \GR4 S?jjjrISKS&\.RdRf\.RdRfS.S<.S0\&\-\4R\ 4S\&\S2\6S3\7S4\8\9\\4S \GR4 S@jjjrLSKS&\.RdRf\.RdRfS.S<.S0\&\-\4R\ 4S\&\S2\6S3\7S4\8\9\\4S \GR4 SAjjjrOSKS&\.RdRf\.RdRfS.S<.S0\&\-\4R\ 4S\&\S2\6S3\7S4\8\9\\4S S&4 SBjjjrQSK\.RdRf\.RdRfS.SC.S0\&\-\4R\ 4S2\6S3\7S4\8\9\\4S \4R4 SDjjjrTSLSEjrUSFrVSK\.RdRf\.RdRfS.SC.S0\&\WRS2\6S3\7S4\8\9\\4S \YR4 SGjjjr[SK\.RdRf\.RdRfS.SC.S0\&\WRS2\6S3\7S4\8\9\\4S \YR4 SHjjjr]SK\.RdRf\.RdRfS.SC.S0\&\WRS2\6S3\7S4\8\9\\4S \WR4 SIjjjr`SJrag&)MPublisherClientez\The service that an application uses to manipulate topics, and to send messages to a topic. cU(dU$[R"S5nURU5nUR5up4pVU(dU(dU$U(aUR SS5$UR SS5$)a$Converts api endpoint to mTLS endpoint. Convert "*.sandbox.googleapis.com" and "*.googleapis.com" to "*.mtls.sandbox.googleapis.com" and "*.mtls.googleapis.com" respectively. Args: api_endpoint (Optional[str]): the api endpoint to convert. Returns: str: converted mTLS api endpoint. z[(?P[^.]+)(?P\.mtls)?(?P\.sandbox)?(?P\.googleapis\.com)?zsandbox.googleapis.comzmtls.sandbox.googleapis.comz.googleapis.comz.mtls.googleapis.com)recompilematchgroupsreplace) api_endpointmtls_endpoint_remnamersandbox googledomains r4_get_default_mtls_endpoint*PublisherClient._get_default_mtls_endpointjs :: j   " "< 0,-HHJ)G |  ''(*G ##$57MNNr7)z.https://www.googleapis.com/auth/cloud-platformz&https://www.googleapis.com/auth/pubsubzpubsub.googleapis.com:443zpubsub.googleapis.cominfocX[RRU5nXCS'U"U0UD6$)a9Creates an instance of this client using the provided credentials info. Args: info (dict): The service account private key info. args: Additional arguments to pass to the constructor. kwargs: Additional arguments to pass to the constructor. Returns: PublisherClient: The constructed client. r)r Credentialsfrom_service_account_info)r3rRargskwargsrs r4rU)PublisherClient.from_service_account_infos2&11KKDQ +}D#F##r7filenamecX[RRU5nXCS'U"U0UD6$)aUCreates an instance of this client using the provided credentials file. Args: filename (str): The path to the service account private key json file. args: Additional arguments to pass to the constructor. kwargs: Additional arguments to pass to the constructor. Returns: PublisherClient: The constructed client. r)rrTfrom_service_account_file)r3rYrVrWrs r4r[)PublisherClient.from_service_account_files2&11KKHU +}D#F##r7r-cUR$)zReturns the transport used by the client instance. Returns: PublisherTransport: The transport used by the client instance.  _transportselfs r4 transportPublisherClient.transportsr7projectschemac"SRUUS9$)z(Returns a fully-qualified schema string.z#projects/{project}/schemas/{schema}rdreformatrgs r4 schema_pathPublisherClient.schema_paths" 5;;<  r7pathcb[R"SU5nU(aUR5$0$)z1Parses a schema path into its component segments.z3^projects/(?P.+?)/schemas/(?P.+?)$rErG groupdictrlrLs r4parse_schema_path!PublisherClient.parse_schema_paths( HHKT R !q{{})r)r7 subscriptionc"SRUUS9$)z.Returns a fully-qualified subscription string.z/projects/{project}/subscriptions/{subscription}rdrsrhrus r4subscription_path!PublisherClient.subscription_paths$ AGG%H  r7cb[R"SU5nU(aUR5$0$)z7Parses a subscription path into its component segments.z?^projects/(?P.+?)/subscriptions/(?P.+?)$rnrps r4parse_subscription_path'PublisherClient.parse_subscription_paths- HH NPT !"q{{})r)r7topicc"SRUUS9$)z'Returns a fully-qualified topic string.z!projects/{project}/topics/{topic}rdr{rhr}s r4 topic_pathPublisherClient.topic_paths" 399:  r7cb[R"SU5nU(aUR5$0$)z0Parses a topic path into its component segments.z1^projects/(?P.+?)/topics/(?P.+?)$rnrps r4parse_topic_path PublisherClient.parse_topic_paths( HHI4 P !q{{})r)r7billing_accountc SRUS9$)z1Returns a fully-qualified billing_account string.z!billingAccounts/{billing_account}rrhrs r4common_billing_account_path+PublisherClient.common_billing_account_paths 399+:  r7cb[R"SU5nU(aUR5$0$)z9Parse a billing_account path into its component segments.z*^billingAccounts/(?P.+?)$rnrps r4!parse_common_billing_account_path1PublisherClient.parse_common_billing_account_paths( HHBD I !q{{})r)r7folderc SRUS9$)z(Returns a fully-qualified folder string.zfolders/{folder}rrhrs r4common_folder_path"PublisherClient.common_folder_path s "(()  r7cb[R"SU5nU(aUR5$0$)z0Parse a folder path into its component segments.z^folders/(?P.+?)$rnrps r4parse_common_folder_path(PublisherClient.parse_common_folder_paths( HH14 8 !q{{})r)r7 organizationc SRUS9$)z.Returns a fully-qualified organization string.zorganizations/{organization}rrhrs r4common_organization_path(PublisherClient.common_organization_paths .44%5  r7cb[R"SU5nU(aUR5$0$)z6Parse a organization path into its component segments.z%^organizations/(?P.+?)$rnrps r4parse_common_organization_path.PublisherClient.parse_common_organization_path"s( HH=t D !q{{})r)r7c SRUS9$)z)Returns a fully-qualified project string.zprojects/{project}rdrhrs r4common_project_path#PublisherClient.common_project_path(s $**+  r7cb[R"SU5nU(aUR5$0$)z1Parse a project path into its component segments.z^projects/(?P.+?)$rnrps r4parse_common_project_path)PublisherClient.parse_common_project_path1s( HH3T : !q{{})r)r7locationc"SRUUS9$)z*Returns a fully-qualified location string.z'projects/{project}/locations/{location}rdrrhrs r4common_location_path$PublisherClient.common_location_path7s# 9??@  r7cb[R"SU5nU(aUR5$0$)z2Parse a location path into its component segments.z7^projects/(?P.+?)/locations/(?P.+?)$rnrps r4parse_common_location_path*PublisherClient.parse_common_location_pathBs) HHOQU V !q{{})r)r7NrcUc[R"5n[R"SS5n[R"SS5nUS;a [ S5eUS;a [ S 5eSnUS :XaMUR (a UR nO/[R"5(a[R"5nURbURnXT4$US :Xd US:XaU(aURnXT4$URnXT4$) a'Return the API endpoint and client cert source for mutual TLS. The client cert source is determined in the following order: (1) if `GOOGLE_API_USE_CLIENT_CERTIFICATE` environment variable is not "true", the client cert source is None. (2) if `client_options.client_cert_source` is provided, use the provided one; if the default client cert source exists, use the default one; otherwise the client cert source is None. The API endpoint is determined in the following order: (1) if `client_options.api_endpoint` if provided, use the provided one. (2) if `GOOGLE_API_USE_CLIENT_CERTIFICATE` environment variable is "always", use the default mTLS endpoint; if the environment variable is "never", use the default API endpoint; otherwise if client cert source exists, use the default mTLS endpoint, otherwise use the default API endpoint. More details can be found at https://google.aip.dev/auth/4114. Args: client_options (google.api_core.client_options.ClientOptions): Custom options for the client. Only the `api_endpoint` and `client_cert_source` properties may be used in this method. Returns: Tuple[str, Callable[[], Tuple[bytes, bytes]]]: returns the API endpoint and the client cert source to use. Raises: google.auth.exceptions.MutualTLSChannelError: If any errors happen. N!GOOGLE_API_USE_CLIENT_CERTIFICATEfalseGOOGLE_API_USE_MTLS_ENDPOINTauto)truerzYEnvironment variable `GOOGLE_API_USE_CLIENT_CERTIFICATE` must be either `true` or `false`)rneveralwayszWEnvironment variable `GOOGLE_API_USE_MTLS_ENDPOINT` must be `never`, `auto` or `always`rr) client_options_lib ClientOptionsosgetenv ValueErrorrclient_cert_sourcerhas_default_client_cert_sourcedefault_client_cert_sourcerJDEFAULT_MTLS_ENDPOINTDEFAULT_ENDPOINT)r3ruse_client_certuse_mtls_endpointrrJs r4!get_mtls_endpoint_and_cert_source1PublisherClient.get_mtls_endpoint_and_cert_sourceHsD  !/==?N))$GQII&DfM "3 3k  $? ?'i  " f $00%3%F%F"4466%)%D%D%F"  & & 2)66L//( *  ',>44L////L//r7)rrbr client_inforrbrc n[U[5(a[R"U5nUc[R"5n[ [RU5nUR U5upV[USS5nU(aU(a [S5e[U[5(aMU(dUR(dU(a [S5eUR(a [S5eX l gSSK nU(aJ[URR S5(a%URR R#U5n[%U5R'U5n [(R*R-S5n U (am[/U [%U5R0S 5(a[2R4"U S 9n O[2R6R5U S 9n [8R:"XS 9n U "UURUURUUR<US UR>S 9 Ul g)aInstantiates the publisher client. Args: credentials (Optional[google.auth.credentials.Credentials]): The authorization credentials to attach to requests. These credentials identify the application to the service; if none are specified, the client will attempt to ascertain the credentials from the environment. transport (Union[str, PublisherTransport]): The transport to use. If set to None, a transport is chosen automatically. client_options (Optional[Union[google.api_core.client_options.ClientOptions, dict]]): Custom options for the client. It won't take effect if a ``transport`` instance is provided. (1) The ``api_endpoint`` property can be used to override the default endpoint provided by the client. GOOGLE_API_USE_MTLS_ENDPOINT environment variable can also be used to override the endpoint: "always" (always use the default mTLS endpoint), "never" (always use the default regular endpoint) and "auto" (auto switch to the default mTLS endpoint if client certificate is present, this is the default value). However, the ``api_endpoint`` property takes precedence if provided. (2) If GOOGLE_API_USE_CLIENT_CERTIFICATE environment variable is "true", then the ``client_cert_source`` property can be used to provide client certificate for mutual TLS transport. If not provided, the default SSL client certificate will be used if present. If GOOGLE_API_USE_CLIENT_CERTIFICATE is "false" or not set, no client certificate will be used. client_info (google.api_core.gapic_v1.client_info.ClientInfo): The client info used to send a user-agent string along with API requests. If ``None``, then default info will be used. Generally, you only need to set this if you're developing your own client library. Raises: google.auth.exceptions.MutualTLSChannelError: If mutual TLS transport creation failed for any reason. Napi_keyz=client_options.api_key and credentials are mutually exclusivezFWhen providing a transport instance, provide its credentials directly.zAWhen providing a transport instance, provide its scopes directly.rget_api_key_credentialsPUBSUB_EMULATOR_HOSTr))target)channelT) rcredentials_filehostscopesclient_cert_source_for_mtlsquota_project_idralways_use_jwt_access api_audience) isinstancedictr from_dictrr rgetattrrr!rrr_google.auth._defaulthasattrauth_defaultrtyper5renvironget issubclassr/r)insecure_channelaio functoolspartialrr) rarrbrrrJclient_cert_source_func api_key_valuegoogle Transport emulator_hostrs r4__init__PublisherClient.__init__sZ nd + +/99.IN  !/==?N0>>O040V0V 1 -   4@ [O  i!3 4 4n== 8$$  (O ' $$&?""%kk22JJ! T 66yAIJJNN+ABMid)G)G)OPP"33=IG"hh77}7MG%--iI ''!/!@!@!%,,,C!/!@!@'&*+88 DOr7r8)rMrrmetadatarequestrMrrrc[U/5nUbU(a [S5e[U[R5(d[R"U5nUbX!lUR RUR Rn[U5[RRSUR 4454-nU"UUUUS9nU$)aCreates the given topic with the given name. See the [resource name rules] (https://cloud.google.com/pubsub/docs/admin#resource_names). .. code-block:: python # This snippet has been automatically generated and should be regarded as a # code template only. # It will require modifications to work: # - It may require correct/in-range values for request initialization. # - It may require specifying regional endpoints when creating the service # client as shown in: # https://googleapis.dev/python/google-api-core/latest/client_options.html from google import pubsub_v1 def sample_create_topic(): # Create a client client = pubsub_v1.PublisherClient() # Initialize request argument(s) request = pubsub_v1.Topic( name="name_value", ) # Make the request response = client.create_topic(request=request) # Handle the response print(response) Args: request (Union[google.pubsub_v1.types.Topic, dict]): The request object. A topic resource. name (str): Required. The name of the topic. It must have the format ``"projects/{project}/topics/{topic}"``. ``{topic}`` must start with a letter, and contain only letters (``[A-Za-z]``), numbers (``[0-9]``), dashes (``-``), underscores (``_``), periods (``.``), tildes (``~``), plus (``+``) or percent signs (``%``). It must be between 3 and 255 characters in length, and it must not start with ``"goog"``. This corresponds to the ``name`` field on the ``request`` instance; if ``request`` is provided, this should not be set. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (TimeoutType): The timeout for this request. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Returns: google.pubsub_v1.types.Topic: A topic resource. \If the `request` argument is set, then none of the individual field arguments should be set.rMrrr) anyrrrTopicrMr__wrapped_methods create_topictuplerrouting_headerto_grpc_metadata) rarrMrrrhas_flattened_paramsrpcresponses r4rPublisherClient.create_topicsJ #D6{  #7@ '6<<00ll7+G# oo..t/K/KL?  # # 4 4vw||6L5N O&      r7)r{ update_maskrrrrc[X#/5nUbU(a [S5e[U[R5(d([R"U5nUbX!lUbX1lURRURRn[U5[RRSUR R4454-nU"UUUUS9n U $)a Updates an existing topic. Note that certain properties of a topic are not modifiable. .. code-block:: python # This snippet has been automatically generated and should be regarded as a # code template only. # It will require modifications to work: # - It may require correct/in-range values for request initialization. # - It may require specifying regional endpoints when creating the service # client as shown in: # https://googleapis.dev/python/google-api-core/latest/client_options.html from google import pubsub_v1 def sample_update_topic(): # Create a client client = pubsub_v1.PublisherClient() # Initialize request argument(s) topic = pubsub_v1.Topic() topic.name = "name_value" request = pubsub_v1.UpdateTopicRequest( topic=topic, ) # Make the request response = client.update_topic(request=request) # Handle the response print(response) Args: request (Union[google.pubsub_v1.types.UpdateTopicRequest, dict]): The request object. Request for the UpdateTopic method. topic (google.pubsub_v1.types.Topic): Required. The updated topic object. This corresponds to the ``topic`` field on the ``request`` instance; if ``request`` is provided, this should not be set. update_mask (google.protobuf.field_mask_pb2.FieldMask): Required. Indicates which fields in the provided topic to update. Must be specified and non-empty. Note that if ``update_mask`` contains "message_storage_policy" but the ``message_storage_policy`` is not set in the ``topic`` provided above, then the updated value is determined by the policy configured at the project or organization level. This corresponds to the ``update_mask`` field on the ``request`` instance; if ``request`` is provided, this should not be set. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (TimeoutType): The timeout for this request. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Returns: google.pubsub_v1.types.Topic: A topic resource. rz topic.namer)rrrrUpdateTopicRequestr{rr_r update_topicrrrrrM) rarr{rrrrrrrs r4rPublisherClient.update_topicdsX #E#78  #7@ '6#<#<==//8G % &&1#oo..t/K/KL?  # # 4 4 2 235 &     r7)r{messagesrrrrc[X#/5nUbU(a [S5e[U[R5(d([R"U5nUbX!lUbX1lURRURRn[U5[RRSUR 4454-nU"UUUUS9n U $)aAdds one or more messages to the topic. Returns ``NOT_FOUND`` if the topic does not exist. .. code-block:: python # This snippet has been automatically generated and should be regarded as a # code template only. # It will require modifications to work: # - It may require correct/in-range values for request initialization. # - It may require specifying regional endpoints when creating the service # client as shown in: # https://googleapis.dev/python/google-api-core/latest/client_options.html from google import pubsub_v1 def sample_publish(): # Create a client client = pubsub_v1.PublisherClient() # Initialize request argument(s) request = pubsub_v1.PublishRequest( topic="topic_value", ) # Make the request response = client.publish(request=request) # Handle the response print(response) Args: request (Union[google.pubsub_v1.types.PublishRequest, dict]): The request object. Request for the Publish method. topic (str): Required. The messages in the request will be published on this topic. Format is ``projects/{project}/topics/{topic}``. This corresponds to the ``topic`` field on the ``request`` instance; if ``request`` is provided, this should not be set. messages (MutableSequence[google.pubsub_v1.types.PubsubMessage]): Required. The messages to publish. This corresponds to the ``messages`` field on the ``request`` instance; if ``request`` is provided, this should not be set. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (TimeoutType): The timeout for this request. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Returns: google.pubsub_v1.types.PublishResponse: Response for the Publish method. rr{r)rrrrPublishRequestr{rr_rpublishrrrr) rarr{rrrrrrrs r4rPublisherClient.publishsJ #E#45  #7@ '6#8#899++G4G % ##+ oo..t/F/FG?  # # 4 4w 6N5P Q&      r7)r{rrrc[U/5nUbU(a [S5e[U[R5(d[R"U5nUbX!lUR RUR Rn[U5[RRSUR 4454-nU"UUUUS9nU$)a^Gets the configuration of a topic. .. code-block:: python # This snippet has been automatically generated and should be regarded as a # code template only. # It will require modifications to work: # - It may require correct/in-range values for request initialization. # - It may require specifying regional endpoints when creating the service # client as shown in: # https://googleapis.dev/python/google-api-core/latest/client_options.html from google import pubsub_v1 def sample_get_topic(): # Create a client client = pubsub_v1.PublisherClient() # Initialize request argument(s) request = pubsub_v1.GetTopicRequest( topic="topic_value", ) # Make the request response = client.get_topic(request=request) # Handle the response print(response) Args: request (Union[google.pubsub_v1.types.GetTopicRequest, dict]): The request object. Request for the GetTopic method. topic (str): Required. The name of the topic to get. Format is ``projects/{project}/topics/{topic}``. This corresponds to the ``topic`` field on the ``request`` instance; if ``request`` is provided, this should not be set. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (TimeoutType): The timeout for this request. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Returns: google.pubsub_v1.types.Topic: A topic resource. rr{r) rrrrGetTopicRequestr{r_r get_topicrrrr rarr{rrrrrrs r4rPublisherClient.get_topicIsz #E7|  #7@ '6#9#9::,,W5G % oo..t/H/HI?  # # 4 4w 6N5P Q&      r7)rdrrrc[U/5nUbU(a [S5e[U[R5(d[R"U5nUbX!lUR RUR Rn[U5[RRSUR 4454-nU"UUUUS9n[R"UUUUS9nU$)a7Lists matching topics. .. code-block:: python # This snippet has been automatically generated and should be regarded as a # code template only. # It will require modifications to work: # - It may require correct/in-range values for request initialization. # - It may require specifying regional endpoints when creating the service # client as shown in: # https://googleapis.dev/python/google-api-core/latest/client_options.html from google import pubsub_v1 def sample_list_topics(): # Create a client client = pubsub_v1.PublisherClient() # Initialize request argument(s) request = pubsub_v1.ListTopicsRequest( project="project_value", ) # Make the request page_result = client.list_topics(request=request) # Handle the response for response in page_result: print(response) Args: request (Union[google.pubsub_v1.types.ListTopicsRequest, dict]): The request object. Request for the ``ListTopics`` method. project (str): Required. The name of the project in which to list topics. Format is ``projects/{project-id}``. This corresponds to the ``project`` field on the ``request`` instance; if ``request`` is provided, this should not be set. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (TimeoutType): The timeout for this request. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Returns: google.pubsub_v1.services.publisher.pagers.ListTopicsPager: Response for the ListTopics method. Iterating over this object will yield results and resolve additional pages automatically. rrdrmethodrrr)rrrrListTopicsRequestrdr_r list_topicsrrrrrListTopicsPager) rarrdrrrrrrs r4rPublisherClient.list_topicssD #G9~  #7@ '6#;#;<<..w7G"")oo..t/J/JK?  # # 4 4y'//6R5T U&      ))  r7c[U/5nUbU(a [S5e[U[R5(d[R"U5nUbX!lUR RUR Rn[U5[RRSUR 4454-nU"UUUUS9n[R"UUUUS9nU$)aLists the names of the attached subscriptions on this topic. .. code-block:: python # This snippet has been automatically generated and should be regarded as a # code template only. # It will require modifications to work: # - It may require correct/in-range values for request initialization. # - It may require specifying regional endpoints when creating the service # client as shown in: # https://googleapis.dev/python/google-api-core/latest/client_options.html from google import pubsub_v1 def sample_list_topic_subscriptions(): # Create a client client = pubsub_v1.PublisherClient() # Initialize request argument(s) request = pubsub_v1.ListTopicSubscriptionsRequest( topic="topic_value", ) # Make the request page_result = client.list_topic_subscriptions(request=request) # Handle the response for response in page_result: print(response) Args: request (Union[google.pubsub_v1.types.ListTopicSubscriptionsRequest, dict]): The request object. Request for the ``ListTopicSubscriptions`` method. topic (str): Required. The name of the topic that subscriptions are attached to. Format is ``projects/{project}/topics/{topic}``. This corresponds to the ``topic`` field on the ``request`` instance; if ``request`` is provided, this should not be set. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (TimeoutType): The timeout for this request. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Returns: google.pubsub_v1.services.publisher.pagers.ListTopicSubscriptionsPager: Response for the ListTopicSubscriptions method. Iterating over this object will yield results and resolve additional pages automatically. rr{rr)rrrrListTopicSubscriptionsRequestr{r_rlist_topic_subscriptionsrrrrrListTopicSubscriptionsPagerrs r4r (PublisherClient.list_topic_subscriptionssH #E7|  #7@ '6#G#GHH::7CG % oo..t/W/WX?  # # 4 4w 6N5P Q&      55  r7c[U/5nUbU(a [S5e[U[R5(d[R"U5nUbX!lUR RUR Rn[U5[RRSUR 4454-nU"UUUUS9n[R"UUUUS9nU$)aLists the names of the snapshots on this topic. Snapshots are used in `Seek `__ 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. .. code-block:: python # This snippet has been automatically generated and should be regarded as a # code template only. # It will require modifications to work: # - It may require correct/in-range values for request initialization. # - It may require specifying regional endpoints when creating the service # client as shown in: # https://googleapis.dev/python/google-api-core/latest/client_options.html from google import pubsub_v1 def sample_list_topic_snapshots(): # Create a client client = pubsub_v1.PublisherClient() # Initialize request argument(s) request = pubsub_v1.ListTopicSnapshotsRequest( topic="topic_value", ) # Make the request page_result = client.list_topic_snapshots(request=request) # Handle the response for response in page_result: print(response) Args: request (Union[google.pubsub_v1.types.ListTopicSnapshotsRequest, dict]): The request object. Request for the ``ListTopicSnapshots`` method. topic (str): Required. The name of the topic that snapshots are attached to. Format is ``projects/{project}/topics/{topic}``. This corresponds to the ``topic`` field on the ``request`` instance; if ``request`` is provided, this should not be set. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (TimeoutType): The timeout for this request. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Returns: google.pubsub_v1.services.publisher.pagers.ListTopicSnapshotsPager: Response for the ListTopicSnapshots method. Iterating over this object will yield results and resolve additional pages automatically. rr{rr)rrrrListTopicSnapshotsRequestr{r_rlist_topic_snapshotsrrrrrListTopicSnapshotsPagerrs r4r$PublisherClient.list_topic_snapshotssP #E7|  #7@ '6#C#CDD66w?G % oo..t/S/ST?  # # 4 4w 6N5P Q&      11  r7c[U/5nUbU(a [S5e[U[R5(d[R"U5nUbX!lUR RUR Rn[U5[RRSUR 4454-nU"UUUUS9 g)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_``. .. code-block:: python # This snippet has been automatically generated and should be regarded as a # code template only. # It will require modifications to work: # - It may require correct/in-range values for request initialization. # - It may require specifying regional endpoints when creating the service # client as shown in: # https://googleapis.dev/python/google-api-core/latest/client_options.html from google import pubsub_v1 def sample_delete_topic(): # Create a client client = pubsub_v1.PublisherClient() # Initialize request argument(s) request = pubsub_v1.DeleteTopicRequest( topic="topic_value", ) # Make the request client.delete_topic(request=request) Args: request (Union[google.pubsub_v1.types.DeleteTopicRequest, dict]): The request object. Request for the ``DeleteTopic`` method. topic (str): Required. Name of the topic to delete. Format is ``projects/{project}/topics/{topic}``. This corresponds to the ``topic`` field on the ``request`` instance; if ``request`` is provided, this should not be set. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (TimeoutType): The timeout for this request. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Nrr{r) rrrrDeleteTopicRequestr{r_r delete_topicrrrr)rarr{rrrrrs r4rPublisherClient.delete_topic sv #E7|  #7@ '6#<#<==//8G % oo..t/K/KL?  # # 4 4w 6N5P Q&     r7rcN[U[R5(d[R"U5nURRURR n[ U5[RRSUR4454-nU"UUUUS9nU$)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. .. code-block:: python # This snippet has been automatically generated and should be regarded as a # code template only. # It will require modifications to work: # - It may require correct/in-range values for request initialization. # - It may require specifying regional endpoints when creating the service # client as shown in: # https://googleapis.dev/python/google-api-core/latest/client_options.html from google import pubsub_v1 def sample_detach_subscription(): # Create a client client = pubsub_v1.PublisherClient() # Initialize request argument(s) request = pubsub_v1.DetachSubscriptionRequest( subscription="subscription_value", ) # Make the request response = client.detach_subscription(request=request) # Handle the response print(response) Args: request (Union[google.pubsub_v1.types.DetachSubscriptionRequest, dict]): The request object. Request for the DetachSubscription method. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (TimeoutType): The timeout for this request. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Returns: google.pubsub_v1.types.DetachSubscriptionResponse: Response for the DetachSubscription method. Reserved for future use. rsr) rrDetachSubscriptionRequestr_rdetach_subscriptionrrrrrsrarrrrrrs r4r#PublisherClient.detach_subscriptionjs|'6#C#CDD66w?Goo..t/R/RS?  # # 4 4 '"6"679 &     r7cU$r9r8r`s r4 __enter__PublisherClient.__enter__s r7c8URR5 g)zReleases underlying transport's resources. .. warning:: ONLY use as a context manager if the transport is NOT shared with other clients! Exiting the with block will CLOSE the transport and may cause errors in other clients! N)rbclose)rarvalue tracebacks r4__exit__PublisherClient.__exit__s r7cN[U[5(a[R"S0UD6n[R R URRS[S9n[U5[RRSUR4454-nU"UUUUS9nU$)a Sets the IAM access control policy on the specified function. Replaces any existing policy. Args: request (:class:`~.iam_policy_pb2.SetIamPolicyRequest`): The request object. Request message for `SetIamPolicy` method. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (TimeoutType): The timeout for this request. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Returns: ~.policy_pb2.Policy: Defines an Identity and Access Management (IAM) policy. It is used to specify access control policies for Cloud Platform resources. A ``Policy`` is a collection of ``bindings``. A ``binding`` binds one or more ``members`` to a single ``role``. Members can be user accounts, service accounts, Google groups, and domains (such as G Suite). A ``role`` is a named list of permissions (defined by IAM or configured by users). A ``binding`` can optionally specify a ``condition``, which is a logic expression that further constrains the role binding based on attributes about the request and/or target resource. **JSON Example** :: { "bindings": [ { "role": "roles/resourcemanager.organizationAdmin", "members": [ "user:mike@example.com", "group:admins@example.com", "domain:google.com", "serviceAccount:my-project-id@appspot.gserviceaccount.com" ] }, { "role": "roles/resourcemanager.organizationViewer", "members": ["user:eve@example.com"], "condition": { "title": "expirable access", "description": "Does not grant access after Sep 2020", "expression": "request.time < timestamp('2020-10-01T00:00:00.000Z')", } } ] } **YAML Example** :: bindings: - members: - user:mike@example.com - group:admins@example.com - domain:google.com - serviceAccount:my-project-id@appspot.gserviceaccount.com role: roles/resourcemanager.organizationAdmin - members: - user:eve@example.com role: roles/resourcemanager.organizationViewer condition: title: expirable access description: Does not grant access after Sep 2020 expression: request.time < timestamp('2020-10-01T00:00:00.000Z') For a description of IAM and its features, see the `IAM developer's guide `__. Ndefault_timeoutrresourcerr8)rrrSetIamPolicyRequestrr wrap_methodr_set_iam_policyr"rrrr*rs r4r-PublisherClient.set_iam_policysz gt $ $$88C7CGoo)) OO * * +* ?  # # 4 4z7CSCS6T5V W&      r7cN[U[5(a[R"S0UD6n[R R URRS[S9n[U5[RRSUR4454-nU"UUUUS9nU$)a Gets the IAM access control policy for a function. Returns an empty policy if the function exists and does not have a policy set. Args: request (:class:`~.iam_policy_pb2.GetIamPolicyRequest`): The request object. Request message for `GetIamPolicy` method. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (TimeoutType): The timeout for this request. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Returns: ~.policy_pb2.Policy: Defines an Identity and Access Management (IAM) policy. It is used to specify access control policies for Cloud Platform resources. A ``Policy`` is a collection of ``bindings``. A ``binding`` binds one or more ``members`` to a single ``role``. Members can be user accounts, service accounts, Google groups, and domains (such as G Suite). A ``role`` is a named list of permissions (defined by IAM or configured by users). A ``binding`` can optionally specify a ``condition``, which is a logic expression that further constrains the role binding based on attributes about the request and/or target resource. **JSON Example** :: { "bindings": [ { "role": "roles/resourcemanager.organizationAdmin", "members": [ "user:mike@example.com", "group:admins@example.com", "domain:google.com", "serviceAccount:my-project-id@appspot.gserviceaccount.com" ] }, { "role": "roles/resourcemanager.organizationViewer", "members": ["user:eve@example.com"], "condition": { "title": "expirable access", "description": "Does not grant access after Sep 2020", "expression": "request.time < timestamp('2020-10-01T00:00:00.000Z')", } } ] } **YAML Example** :: bindings: - members: - user:mike@example.com - group:admins@example.com - domain:google.com - serviceAccount:my-project-id@appspot.gserviceaccount.com role: roles/resourcemanager.organizationAdmin - members: - user:eve@example.com role: roles/resourcemanager.organizationViewer condition: title: expirable access description: Does not grant access after Sep 2020 expression: request.time < timestamp('2020-10-01T00:00:00.000Z') For a description of IAM and its features, see the `IAM developer's guide `__. Nr(r*rr8)rrrGetIamPolicyRequestrrr,r_get_iam_policyr"rrrr*rs r4r1PublisherClient.get_iam_policyHs| gt $ $$88C7CGoo)) OO * * +* ?  # # 4 4z7CSCS6T5V W&      r7cN[U[5(a[R"S0UD6n[R R URRS[S9n[U5[RRSUR4454-nU"UUUUS9nU$)aTests the specified IAM permissions against the IAM access control policy for a function. If the function does not exist, this will return an empty set of permissions, not a NOT_FOUND error. Args: request (:class:`~.iam_policy_pb2.TestIamPermissionsRequest`): The request object. Request message for `TestIamPermissions` method. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (TimeoutType): The timeout for this request. metadata (Sequence[Tuple[str, str]]): Strings which should be sent along with the request as metadata. Returns: ~.iam_policy_pb2.TestIamPermissionsResponse: Response message for ``TestIamPermissions`` method. Nr(r*rr8)rrrTestIamPermissionsRequestrrr,r_test_iam_permissionsr"rrrr*rs r4r5$PublisherClient.test_iam_permissionss@ gt $ $$>>IIGoo)) OO 0 0 +* ?  # # 4 4z7CSCS6T5V W&      r7r^r9)r-rB)br:r;r<r=r> staticmethodrP_DEFAULT_SCOPESSERVICE_ADDRESSr__func__r classmethodrrUr?r[from_service_account_jsonpropertyr!rbrjrrqrvryr~rrrrrrrrrrrrrrrr"ga_credentialsrTr rr ClientInforrDEFAULTrr OptionalRetryrr r rrr FieldMaskrrr PubsubMessagePublishResponserrrrrr rr rr rrrrrrDetachSubscriptionResponserrr%rr+rPolicyr-r0r1r4TestIamPermissionsResponser5r@r8r7r4rBrBesV OO>O 2O-.6??$T$$ $$$"!: -      **S#X**       *c*d38n**      *s*tCH~**     **S#X**     *s*tCH~**     *S*T#s(^**     **S#X**       **c3h** JN@0%&8&F&FG@0@0J=A>BRV7J kn889kE#'9"9:; k !'9'G'G'M!NO k ))44 k k^8<j#'66'66.0j% d 234jsm j  j  j5c?+j j\EIu)-:>'66'66.0u% 9 94 ?@Au % u n667 u  uu5c?+u urAEl $DH'66'66.0l% 5 5t ;<=l} l ?6+?+?@A l  ll5c?+l   l`BFb $'66'66.0b% 6 6 <=>b} b  b  b5c?+b bLDHp"&'66'66.0p% 8 8$ >?@p# p  p  p5c?+p   phPTr $'66'66.0r% D Dd JKLr} r  r  r5c?+r  + +rlLPv $'66'66.0v% @ @$ FGHv} v  v  v5c?+v  ' 'vtEI]  $'66'66.0] % 9 94 ?@A] } ]  ]  ] 5c?+]  ] BLPV (66'66.0 V% @ @$ FGHV V  V 5c?+ V  * *VpAEw (66'66.0 w.<<=w w  w 5c?+ w   wvAEx (66'66.0 x.<<=x x  x 5c?+ x   xxGK: (66'66.0 :.BBC: :  : 5c?+ :  2 2::r7rB) metaclass)client_library_version)rB)J collectionsrrrrEtypingrrrrrr r r r r google.pubsub_v1rpackage_versiongoogle.api_corerrrcore_exceptionsrrretriesrtimeouts google.authrr>google.auth.transportrgoogle.auth.transport.grpcrgoogle.auth.exceptionsr google.oauth2rRetryr_MethodDefaultrAAttributeErrorobject google.iam.v1rrcloudsdk.google.protobufrr#google.pubsub_v1.services.publisherrgoogle.pubsub_v1.typesrrr)transports.baser!r"transports.grpcr#transports.grpc_asyncior$transports.restr%rr'rBrr? __version____all__r8r7r4res $    >@9$,/5&58)1'--)G)GGHM)$136). D3B3 <$