SSKJr SSKrSSKrSSKJrJrJrJrJ r J r J r J r J r SSKJr SSKJr SSKJr SSKJr SSKJr SS KJr SS KJr SS KJr \ \R@\RBRD4r#SS K&J'r' SS K&J(r( SSK)J*r* SSK)J+r+ SSK,J-r- SSK.J/r/ SSK.J0r0 SSK1J2r2J3r3 SSK4J5r5 SSK6J7r7 "SS5r8\RrRu\RvS9r3SrS2SS\.RdRf\.RdRfSS.S\ \-\4R~\4S\ \S \ \@\4RS\6S\7S\8\9\\4S \4R4S!jjjrCS2S\.RdRf\.RdRfSS".S\ \-\4R\4S\ \S\6S\7S\8\9\\4S \4Rj4 S#jjjrES2S\.RdRf\.RdRfSS$.S\ \-\4R\4S%\ \S\6S\7S\8\9\\4S \GR4 S&jjjrIS2S\.RdRf\.RdRfSS".S\ \-\4R\4S\ \S\6S\7S\8\9\\4S \GR4 S'jjjrLS2S\.RdRf\.RdRfSS".S\ \-\4R\4S\ \S\6S\7S\8\9\\4S \GR4 S(jjjrOS2S\.RdRf\.RdRfSS".S\ \-\4R\4S\ \S\6S\7S\8\9\\4S S4 S)jjjrQS2\.RdRf\.RdRfSS*.S\ \-\4R\4S\6S\7S\8\9\\4S \4R4 S+jjjrTS2\.RdRf\.RdRfSS*.S\ \URS\6S\7S\8\9\\4S \WR4 S,jjjrYS2\.RdRf\.RdRfSS*.S\ \URS\6S\7S\8\9\\4S \WR4 S-jjjr[S2\.RdRf\.RdRfSS*.S\ \URS\6S\7S\8\9\\4S \UR4 S.jjjr^S3S/jr_S0r`S1rag)4PublisherAsyncClient:z\The service that an application uses to manipulate topics, and to send messages to a topic. _clientinfocT[RR"[U/UQ70UD6$)a>Creates 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: PublisherAsyncClient: The constructed client. )r from_service_account_info__func__r")clsr%argskwargss Clib/third_party/google/pubsub_v1/services/publisher/async_client.pyr'.PublisherAsyncClient.from_service_account_info]s+88AABVX\n_cngmnnfilenamecT[RR"[U/UQ70UD6$)aZCreates 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: PublisherAsyncClient: The constructed client. )r from_service_account_filer(r")r)r/r*r+s r,r1.PublisherAsyncClient.from_service_account_filels+88AABVX`rcgrkqrrr.Nclient_optionsc.[R"U5$)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. )r !get_mtls_endpoint_and_cert_source)r)r3s r,r56PublisherAsyncClient.get_mtls_endpoint_and_cert_source~sD@@PPr.returnc.URR$)zReturns the transport used by the client instance. Returns: PublisherTransport: The transport used by the client instance. )r$ transportselfs r,r9PublisherAsyncClient.transports||%%%r. grpc_asynciorr9r3 client_inforr9r?c&[UUUUS9Ulg)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 (ClientOptions): 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. Raises: google.auth.exceptions.MutualTlsChannelError: If mutual TLS transport creation failed for any reason. r>N)r r$)r;rr9r3r?s r,__init__PublisherAsyncClient.__init__sP'#)#   r.)namerrmetadatarequestrDrrrEc # [U/5nUbU(a [S5e[R"U5nUbX!l[ R RURRR[R"SSS[R"[R5SS9S[ S9n[#U5[ R$R'SUR4454-nU"UUUUS 9IShvN nU$N7f) a*Creates 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 async def sample_create_topic(): # Create a client client = pubsub_v1.PublisherAsyncClient() # Initialize request argument(s) request = pubsub_v1.Topic( name="name_value", ) # Make the request response = await client.create_topic(request=request) # Handle the response print(response) Args: request (Optional[Union[google.pubsub_v1.types.Topic, dict]]): The request object. A topic resource. name (:class:`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. N\If the `request` argument is set, then none of the individual field arguments should be set.皙?N@?initialmaximum multiplier predicatedeadline default_retrydefault_timeoutr?rDrrrE)any ValueErrorrTopicrDr method_async wrap_methodr$ _transport create_topicretriesRetryif_exception_typecore_exceptionsServiceUnavailablertuplerouting_headerto_grpc_metadata) r;rFrDrrrEhas_flattened_paramsrpcresponses r,r\!PublisherAsyncClient.create_topicsJ #D6{  #7@  ,,w'  L##// LL # # 0 0!--!33#66!+0  "?  # # 4 4vw||6L5N O&        sDD D D )topic update_maskrrrErirjc @# [X#/5nUbU(a [S5e[R"U5nUbX!lUbX1l[ RRURRR[R"SSS[R"[R 5SS9S["S9n[%U5[ R&R)SURR*4454-nU"UUUUS 9IShvN n U $N7f) aG 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 async def sample_update_topic(): # Create a client client = pubsub_v1.PublisherAsyncClient() # Initialize request argument(s) topic = pubsub_v1.Topic() topic.name = "name_value" request = pubsub_v1.UpdateTopicRequest( topic=topic, ) # Make the request response = await client.update_topic(request=request) # Handle the response print(response) Args: request (Optional[Union[google.pubsub_v1.types.UpdateTopicRequest, dict]]): The request object. Request for the UpdateTopic method. topic (:class:`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 (:class:`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. NrHrIrJrKrLrRz topic.namerU)rVrWrUpdateTopicRequestrirjrrYrZr$r[ update_topicr]r^r_r`rarrbrcrdrD) r;rFrirjrrrErerfrgs r,rm!PublisherAsyncClient.update_topicSs-X #E#78  #7@  ++G4  !M  ""- ##// LL # # 0 0!--!33#66!+0  "?  # # 4 4 2 235 &       sDDDD)rimessagesrrrEroc# [X#/5nUbU(a [S5e[R"U5nUbX!lU(aUR R U5 [RRURRR[R"SSS[R"[ R"[ R$[ R&[ R([ R*[ R,[ R.5SS9S[0S9n[3U5[R4R7SUR4454-nU"UUUUS 9IShvN n U $N7f) 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 async def sample_publish(): # Create a client client = pubsub_v1.PublisherAsyncClient() # Initialize request argument(s) request = pubsub_v1.PublishRequest( topic="topic_value", ) # Make the request response = await client.publish(request=request) # Handle the response print(response) Args: request (Optional[Union[google.pubsub_v1.types.PublishRequest, dict]]): The request object. Request for the Publish method. topic (:class:`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 (:class:`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. NrHrIrJg@rLrRrirU)rVrWrPublishRequestriroextendrrYrZr$r[publishr]r^r_r`Aborted CancelledDeadlineExceededInternalServerErrorResourceExhaustedraUnknownrrbrcrd) r;rFrirorrrErerfrgs r,rsPublisherAsyncClient.publishseJ #E#45  #7@  ''0  !M     # #H -##// LL # # + +!--!33#++#--#44#77#55#66#++!+%0 .?  # # 4 4w 6N5P Q&        sEF?F)rirrrEc V# [U/5nUbU(a [S5e[R"U5nUbX!l[ R RURRR[R"SSS[R"[R[R [R"5SS9S[$S9n['U5[ R(R+SUR4454-nU"UUUUS 9IShvN nU$N7f) aGets 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 async def sample_get_topic(): # Create a client client = pubsub_v1.PublisherAsyncClient() # Initialize request argument(s) request = pubsub_v1.GetTopicRequest( topic="topic_value", ) # Make the request response = await client.get_topic(request=request) # Handle the response print(response) Args: request (Optional[Union[google.pubsub_v1.types.GetTopicRequest, dict]]): The request object. Request for the GetTopic method. topic (:class:`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. NrHrIrJrKrLrRrirU)rVrWrGetTopicRequestrirrYrZr$r[ get_topicr]r^r_r`rtraryrrbrcrd r;rFrirrrErerfrgs r,r}PublisherAsyncClient.get_topicPs(z #E7|  #7@  ((1  !M##// LL # # - -!--!33#++#66#++  !+0 &?  # # 4 4w 6N5P Q&        sDD) D'!D))projectrrrErc # [U/5nUbU(a [S5e[R"U5nUbX!l[ R RURRR[R"SSS[R"[R[R [R"5SS9S[$S9n['U5[ R(R+SUR4454-nU"UUUUS 9IShvN n[,R."UUUUS 9nU$N7f) a`Lists 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 async def sample_list_topics(): # Create a client client = pubsub_v1.PublisherAsyncClient() # Initialize request argument(s) request = pubsub_v1.ListTopicsRequest( project="project_value", ) # Make the request page_result = client.list_topics(request=request) # Handle the response async for response in page_result: print(response) Args: request (Optional[Union[google.pubsub_v1.types.ListTopicsRequest, dict]]): The request object. Request for the ``ListTopics`` method. project (:class:`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.ListTopicsAsyncPager: Response for the ListTopics method. Iterating over this object will yield results and resolve additional pages automatically. NrHrIrJrKrLrRrrUmethodrFrgrE)rVrWrListTopicsRequestrrrYrZr$r[ list_topicsr]r^r_r`rtraryrrbrcrdrListTopicsAsyncPager) r;rFrrrrErerfrgs r,r PublisherAsyncClient.list_topicssFD #G9~  #7@  **73  %O##// LL # # / /!--!33#++#66#++  !+0 &?  # # 4 4y'//6R5T U&       ..  # DE D>!Ec # [U/5nUbU(a [S5e[R"U5nUbX!l[ R RURRR[R"SSS[R"[R[R [R"5SS9S[$S9n['U5[ R(R+SUR4454-nU"UUUUS 9IShvN n[,R."UUUUS 9nU$N7f) 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 async def sample_list_topic_subscriptions(): # Create a client client = pubsub_v1.PublisherAsyncClient() # 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 async for response in page_result: print(response) Args: request (Optional[Union[google.pubsub_v1.types.ListTopicSubscriptionsRequest, dict]]): The request object. Request for the ``ListTopicSubscriptions`` method. topic (:class:`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.ListTopicSubscriptionsAsyncPager: Response for the ListTopicSubscriptions method. Iterating over this object will yield results and resolve additional pages automatically. NrHrIrJrKrLrRrirUr)rVrWrListTopicSubscriptionsRequestrirrYrZr$r[list_topic_subscriptionsr]r^r_r`rtraryrrbrcrdr ListTopicSubscriptionsAsyncPagerr~s r,r-PublisherAsyncClient.list_topic_subscriptions<sFH #E7|  #7@  66w?  !M##// LL # # < <!--!33#++#66#++  !+0 &?  # # 4 4w 6N5P Q&       ::  # rc # [U/5nUbU(a [S5e[R"U5nUbX!l[ R RURRR[R"SSS[R"[R[R [R"5SS9S[$S9n['U5[ R(R+SUR4454-nU"UUUUS 9IShvN n[,R."UUUUS 9nU$N7f) 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 async def sample_list_topic_snapshots(): # Create a client client = pubsub_v1.PublisherAsyncClient() # 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 async for response in page_result: print(response) Args: request (Optional[Union[google.pubsub_v1.types.ListTopicSnapshotsRequest, dict]]): The request object. Request for the ``ListTopicSnapshots`` method. topic (:class:`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.ListTopicSnapshotsAsyncPager: Response for the ListTopicSnapshots method. Iterating over this object will yield results and resolve additional pages automatically. NrHrIrJrKrLrRrirUr)rVrWrListTopicSnapshotsRequestrirrYrZr$r[list_topic_snapshotsr]r^r_r`rtraryrrbrcrdrListTopicSnapshotsAsyncPagerr~s r,r)PublisherAsyncClient.list_topic_snapshotssFP #E7|  #7@  227;  !M##// LL # # 8 8!--!33#++#66#++  !+0 &?  # # 4 4w 6N5P Q&       66  # rc # [U/5nUbU(a [S5e[R"U5nUbX!l[ R RURRR[R"SSS[R"[R5SS9S[ S9n[#U5[ R$R'SUR4454-nU"UUUUS 9IShvN gN7f) aNDeletes 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 async def sample_delete_topic(): # Create a client client = pubsub_v1.PublisherAsyncClient() # Initialize request argument(s) request = pubsub_v1.DeleteTopicRequest( topic="topic_value", ) # Make the request await client.delete_topic(request=request) Args: request (Optional[Union[google.pubsub_v1.types.DeleteTopicRequest, dict]]): The request object. Request for the ``DeleteTopic`` method. topic (:class:`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. NrHrIrJrKrLrRrirU)rVrWrDeleteTopicRequestrirrYrZr$r[ delete_topicr]r^r_r`rarrbrcrd)r;rFrirrrErerfs r,r!PublisherAsyncClient.delete_topic>s v #E7|  #7@  ++G4  !M##// LL # # 0 0!--!33#66!+0  "?  # # 4 4w 6N5P Q&        sDD DD rUc # [R"U5n[RR UR R R[R"SSS[R"[R5SS9S[S9n[U5[RR!SUR"4454-nU"UUUUS9IShvN nU$N7f) 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 async def sample_detach_subscription(): # Create a client client = pubsub_v1.PublisherAsyncClient() # Initialize request argument(s) request = pubsub_v1.DetachSubscriptionRequest( subscription="subscription_value", ) # Make the request response = await client.detach_subscription(request=request) # Handle the response print(response) Args: request (Optional[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. rIrJrKrLrR subscriptionrUN)rDetachSubscriptionRequestrrYrZr$r[detach_subscriptionr]r^r_r`rarrbrcrdrr;rFrrrErfrgs r,r(PublisherAsyncClient.detach_subscriptionst227;##// LL # # 7 7!--!33#66!+0  "?  # # 4 4 '"6"679 &       sCC!CC!c~# [U[5(a[R"S0UD6n[R R URRRS[S9n[U5[RRSUR4454-nU"UUUUS9IShvN nU$N7f)a Sets the IAM access control policy on the specified function. Replaces any existing policy. Args: request (:class:`~.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 `__. NrTr?resourcerUrC) isinstancedictrSetIamPolicyRequestrrYrZr$r[set_iam_policyrrbrcrdrrs r,r#PublisherAsyncClient.set_iam_policysx gt $ $$88C7CG##// LL # # 2 2 +0 ?  # # 4 4z7CSCS6T5V W&        B2B=4B;5B=c~# [U[5(a[R"S0UD6n[R R URRRS[S9n[U5[RRSUR4454-nU"UUUUS9IShvN nU$N7f)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 `__. NrrrUrC)rrrGetIamPolicyRequestrrYrZr$r[get_iam_policyrrbrcrdrrs r,r#PublisherAsyncClient.get_iam_policy~s| gt $ $$88C7CG##// LL # # 2 2 +0 ?  # # 4 4z7CSCS6T5V W&        rc~# [U[5(a[R"S0UD6n[R R URRRS[S9n[U5[RRSUR4454-nU"UUUUS9IShvN nU$N7f)aTests the specified 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.PolicyTestIamPermissionsResponse: Response message for ``TestIamPermissions`` method. NrrrUrC)rrrTestIamPermissionsRequestrrYrZr$r[test_iam_permissionsrrbrcrdrrs r,r)PublisherAsyncClient.test_iam_permissionss@ gt $ $$>>IIG##// LL # # 8 8 +0 ?  # # 4 4z7CSCS6T5V W&        rc# U$7fNrCr:s r, __aenter__PublisherAsyncClient.__aenter__4s  scT# URR5IShvN gN7fr)r9close)r;exc_typeexctbs r, __aexit__PublisherAsyncClient.__aexit__7snn""$$$s (&()r$r)r7r")b__name__ __module__ __qualname____firstlineno____doc__r __annotations__DEFAULT_ENDPOINTDEFAULT_MTLS_ENDPOINT staticmethod schema_pathparse_schema_pathsubscription_pathparse_subscription_path topic_pathparse_topic_pathcommon_billing_account_path!parse_common_billing_account_pathcommon_folder_pathparse_common_folder_pathcommon_organization_pathparse_common_organization_pathcommon_project_pathparse_common_project_pathcommon_location_pathparse_common_location_path classmethodrr'strr1from_service_account_jsonrrr5propertyrr9 functoolspartialtypeget_transport_classrga_credentials Credentialsr rr? ClientInforArDEFAULTrrX OptionalRetryrr r r\rlr FieldMaskrmrqr PubsubMessagePublishResponsersr|r}rrrrrrrrrrrrrDetachSubscriptionResponserrrrPolicyrrrrTestIamPermissionsResponserrr__static_attributes__rCr.r,r"r":s &77+AA::;K$_%F%FG$_%F%FG*?+R+RSo889J#O$D$DE".33#)599)%&o&H&HI+O,T,TU+O,T,TU%166&"''J'JK ,_-V-V W'(L(LM!-22" oT o o s s s!:7;!Q%m4!Q!QF&-&&$++ _1143H=A4B267J - n889- 001 - !/ - ))44 -  - b8<s#'66'66.0s% d 234ssm s  s  s5c?+s snEI~)-:>'66'66.0~% 9 94 ?@A~ % ~ n667 ~  ~~5c?+~ ~DAE{ $DH'66'66.0{% 5 5t ;<={} { ?6+?+?@A {  {{5c?+{   {~BFm $'66'66.0m% 6 6 <=>m} m  m  m5c?+m mbDH{"&'66'66.0{% 8 8$ >?@{# {  {  {5c?+{  $ ${~PT} $'66'66.0}% D Dd JKL}} }  }  }5c?+}  0 0}BLPA $'66'66.0A% @ @$ FGHA} A  A  A5c?+A  , ,AJEIf  $'66'66.0f % 9 94 ?@Af } f  f  f 5c?+f  f TLP^ (66'66.0 ^% @ @$ FGH^ ^  ^ 5c?+ ^  * *^DAEv (66'66.0 v.<<=v v  v 5c?+ v   vtAEx (66'66.0 x.<<=x x  x 5c?+ x   xxGK: (66'66.0 :.BBC: :  : 5c?+ :  2 2:x%r.r")client_library_version)r")= collectionsrrretypingrrrrrr r r r google.pubsub_v1r package_versiongoogle.api_core.client_optionsrgoogle.api_corerr`rrr]rtimeouts google.authrr google.oauth2rr^r_MethodDefaultrAttributeErrorobject google.iam.v1rrcloudsdk.google.protobufrr#google.pubsub_v1.services.publisherrgoogle.pubsub_v1.typesrrtransports.baserrtransports.grpc_asynciorclientr r"r?r __version____all__rCr.r,rs $    >89$,/5)1'--)G)GGHM)$136).DB#~%~%B0**55*666 $k01'--/0M1s%C))DD