ddlmZddlZddlZddlmZmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZ e ej@ejBjDfZ#dd l&m'Z'dd l&m(Z(ddl)m*Z*ddl)m+Z+ddl,m-Z-ddl.m/Z/ddl.m0Z0ddl1m2Z2m3Z3ddl4m5Z5ddl6m7Z7GddZ8ejrjuejvZ3dZrrr?c Kt|g}| |r tdtj|}|||_t j j|jjjtjdddtjtjddt }t#|t j$j'd|jfffz}||||| d{}|S7w) 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:r>rrr?)any ValueErrorrTopicr>r method_async wrap_methodr# _transport create_topicretriesRetryif_exception_typecore_exceptionsServiceUnavailablertuplerouting_headerto_grpc_metadata) r7r@r>rrr?has_flattened_paramsrpcresponses r+rVz!PublisherAsyncClient.create_topicsJ #D6{  #7@  ,,w'  GL##// LL # # 0 0!--!33#66!+0  "?  # # 4 4vw||6L5N O&        sDD D D )topic update_maskrrr?rbrcc BKt||g}| |r tdtj|}|||_|||_t jj|jjjtjdddtjtj ddt"}t%|t j&j)d|jj*fffz}||||| d{} | S7w) 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 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. NrBrCrDrErFrLz topic.namerO)rPrQrUpdateTopicRequestrbrcrrSrTr#rU update_topicrWrXrYrZr[rr\r]r^r>) r7r@rbrcrrr?r_r`ras r+rfz!PublisherAsyncClient.update_topicSs4X #E;#78  #7@  ++G4  !GM  ""-G ##// LL # # 0 0!--!33#66!+0  "?  # # 4 4 2 235 &       sDDDD)rbmessagesrrr?rgc Kt||g}| |r tdtj|}|||_|r|j j |tjj|jjjtjdddtjt j"t j$t j&t j(t j*t j,t j.ddt0}t3|tj4j7d|jfffz}||||| d{} | S7w) aq Adds 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. NrBrCrDg@rFrLrbrO)rPrQrPublishRequestrbrgextendrrSrTr#rUpublishrWrXrYrZAborted CancelledDeadlineExceededInternalServerErrorResourceExhaustedr[Unknownrr\r]r^) r7r@rbrgrrr?r_r`ras r+rkzPublisherAsyncClient.publishsjJ #E8#45  #7@  ''0  !GM     # #H -##// LL # # + +!--!33#++#--#44#77#55#66#++!+%0 .?  # # 4 4w 6N5P Q&        sE8F:F;F)rbrrr?c VKt|g}| |r tdtj|}|||_t j j|jjjtjdddtjtjtj tj"ddt$}t'|t j(j+d|jfffz}||||| d{}|S7w) 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. NrBrCrDrErFrLrbrO)rPrQrGetTopicRequestrbrrSrTr#rU get_topicrWrXrYrZrlr[rqrr\r]r^ r7r@rbrrr?r_r`ras r+rtzPublisherAsyncClient.get_topicPs+z #E7|  #7@  ((1  !GM##// LL # # - -!--!33#++#66#++  !+0 &?  # # 4 4w 6N5P Q&        sDD) D'!D))projectrrr?rvc Kt|g}| |r tdtj|}|||_t j j|jjjtjdddtjtjtj tj"ddt$}t'|t j(j+d|jfffz}||||| d{}t-j.|||| }|S7w) aLists 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. NrBrCrDrErFrLrvrOmethodr@rar?)rPrQrListTopicsRequestrvrrSrTr#rU list_topicsrWrXrYrZrlr[rqrr\r]r^rListTopicsAsyncPager) r7r@rvrrr?r_r`ras r+r{z PublisherAsyncClient.list_topicssID #G9~  #7@  **73  %GO##// LL # # / /!--!33#++#66#++  !+0 &?  # # 4 4y'//6R5T U&       ..  # DE E! Ec Kt|g}| |r tdtj|}|||_t j j|jjjtjdddtjtjtj tj"ddt$}t'|t j(j+d|jfffz}||||| d{}t-j.|||| }|S7w) aQ Lists 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. NrBrCrDrErFrLrbrOrx)rPrQrListTopicSubscriptionsRequestrbrrSrTr#rUlist_topic_subscriptionsrWrXrYrZrlr[rqrr\r]r^r ListTopicSubscriptionsAsyncPagerrus r+rz-PublisherAsyncClient.list_topic_subscriptions<sIH #E7|  #7@  66w?  !GM##// LL # # < <!--!33#++#66#++  !+0 &?  # # 4 4w 6N5P Q&       ::  # r}c Kt|g}| |r tdtj|}|||_t j j|jjjtjdddtjtjtj tj"ddt$}t'|t j(j+d|jfffz}||||| d{}t-j.|||| }|S7w) a\ Lists 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. NrBrCrDrErFrLrbrOrx)rPrQrListTopicSnapshotsRequestrbrrSrTr#rUlist_topic_snapshotsrWrXrYrZrlr[rqrr\r]r^rListTopicSnapshotsAsyncPagerrus r+rz)PublisherAsyncClient.list_topic_snapshotssIP #E7|  #7@  227;  !GM##// LL # # 8 8!--!33#++#66#++  !+0 &?  # # 4 4w 6N5P Q&       66  # r}c Kt|g}| |r tdtj|}|||_t j j|jjjtjdddtjtjddt }t#|t j$j'd|jfffz}||||| d{y7w) aDeletes the topic with the given name. Returns ``NOT_FOUND`` if the topic does not exist. After a topic is deleted, a new topic may be created with the same name; this is an entirely new topic with none of the old configuration or subscriptions. Existing subscriptions to this topic are not deleted, but their ``topic`` field is set to ``_deleted-topic_``. .. 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. NrBrCrDrErFrLrbrO)rPrQrDeleteTopicRequestrbrrSrTr#rU delete_topicrWrXrYrZr[rr\r]r^)r7r@rbrrr?r_r`s r+rz!PublisherAsyncClient.delete_topic>sv #E7|  #7@  ++G4  !GM##// LL # # 0 0!--!33#66!+0  "?  # # 4 4w 6N5P Q&        sDD DD rOc Ktj|}tjj |j j jtjdddtjtjddt}t|tjj!d|j"fffz}|||||d{}|S7w) 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. rCrDrErFrL subscriptionrON)rDetachSubscriptionRequestrrSrTr#rUdetach_subscriptionrWrXrYrZr[rr\r]r^rr7r@rrr?r`ras r+rz(PublisherAsyncClient.detach_subscriptionst227;##// LL # # 7 7!--!33#66!+0  "?  # # 4 4 '"6"679 &       sCC'C%C'c~Kt|trtjdi|}tj j |jjjdt}t|tjjd|jfffz}|||||d{}|S7w)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 `__. NrNr:resourcerOr=) isinstancedictrSetIamPolicyRequestrrSrTr#rUset_iam_policyrr\r]r^rrs r+rz#PublisherAsyncClient.set_iam_policysx gt $$88C7CG##// LL # # 2 2 +0 ?  # # 4 4z7CSCS6T5V W&        B2B=4B;5B=c~Kt|trtjdi|}tj j |jjjdt}t|tjjd|jfffz}|||||d{}|S7w)aGets 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 `__. NrrrOr=)rrrGetIamPolicyRequestrrSrTr#rUget_iam_policyrr\r]r^rrs r+rz#PublisherAsyncClient.get_iam_policy~s| gt $$88C7CG##// LL # # 2 2 +0 ?  # # 4 4z7CSCS6T5V W&        rc~Kt|trtjdi|}tj j |jjjdt}t|tjjd|jfffz}|||||d{}|S7w)a~Tests 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. NrrrOr=)rrrTestIamPermissionsRequestrrSrTr#rUtest_iam_permissionsrr\r]r^rrs r+rz)PublisherAsyncClient.test_iam_permissionss@ gt $$>>IIG##// LL # # 8 8 +0 ?  # # 4 4z7CSCS6T5V W&        rcK|SwNr=r6s r+ __aenter__zPublisherAsyncClient.__aenter__4s  scTK|jjd{y7wr)r5close)r7exc_typeexctbs r+ __aexit__zPublisherAsyncClient.__aexit__7snn""$$$s (&(r)r3r")`__name__ __module__ __qualname____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&strr/from_service_account_jsonrrr2propertyrr5 functoolspartialtypeget_transport_classrga_credentials Credentialsr rr: ClientInfor<ryDEFAULTrrR OptionalRetryrr r rVrer FieldMaskrfrir PubsubMessagePublishResponserkrsrtrzrr|r{rrrrrrrrrDetachSubscriptionResponserrrrPolicyrrrrTestIamPermissionsResponserrrr=r,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_corerrZrrrWrtimeouts google.authrr google.oauth2rrXry_MethodDefaultrAttributeErrorobject google.iam.v1rrcloudsdk.google.protobufrr#google.pubsub_v1.services.publisherrgoogle.pubsub_v1.typesrrtransports.baserrtransports.grpc_asynciorclientr r"r:r __version____all__r=r,r+rs $    >89$,/5)1'--)G)GGHM)$136).DB#~%~%B0**55*666 $k01'--/0M1s%C,,DD