a !fmA@sddlmZddlZddlZddlZddlmZmZmZm Z m Z m Z m Z m Z mZmZddlZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZ dd l!m"Z"dd l#m$Z$dd l%m&Z&ddl'm(Z(zeej)ej*j+dfZ,Wn$e-yeej)e.dfZ,Yn0ddl/m0Z0ddl/m1Z1ddl2m3Z3ddl2m4Z4ddl5m6Z6ddl7m8Z8ddl7m9Z9ddl:Z:ddl;mm?Z?ddl@mAZAddlBmCZCGdddeDZEGdddeEdZFejGjHejId Z=d!ZJdS)") OrderedDictN) DictMappingMutableMappingMutableSequenceOptionalSequenceTupleTypeUnioncast) gapic_versionclient_options) exceptions)gapic_v1)retry)timeout) credentials)mtls)SslCredentials)MutualTLSChannelError)service_account)iam_policy_pb2) policy_pb2) duration_pb2)field_mask_pb2)pagers)pubsub) TimeoutType)PublisherTransportDEFAULT_CLIENT_INFO)PublisherGrpcTransport)PublisherGrpcAsyncIOTransport)PublisherRestTransportc@sHeZdZdZeZeed<eed<eed<d e e e e dddZ dS) PublisherClientMetazMetaclass for the Publisher client. This provides class-level methods for building and retrieving support objects (e.g. transport) without polluting the client instance objects. grpcZ grpc_asynciorestN)labelreturncCs |r|j|Stt|jS)aReturns an appropriate transport class. Args: label: The name of the desired transport. If none is provided, then the first transport in the registry is used. Returns: The transport class to use. )_transport_registrynextitervalues)clsr)r0k/var/www/html/python-backend/venv/lib/python3.9/site-packages/google/pubsub_v1/services/publisher/client.pyget_transport_classPs z'PublisherClientMeta.get_transport_class)N)__name__ __module__ __qualname____doc__rr+r#r$r%rstrr r!r2r0r0r0r1r&Csr&c @szeZdZdZeddZdZdZdZe eZ dZ dZ e ed d d Ze ed d dZeZeedddZeeeedddZeeeeefdddZeeeedddZeeeeefdddZeeeedddZeeeeefdd d!Zeeed"d#d$Zeeeeefdd%d&Zeeed'd(d)Zeeeeefdd*d+Z eeed,d-d.Z!eeeeefdd/d0Z"eeed1d2d3Z#eeeeefdd4d5Z$eeeed6d7d8Z%eeeeefdd9d:Z&e d~e'e(j)d<d=d>Z*ed?d@Z+edAdBZ,edCdDZ-ee'ee'eedEdFdGZ.eee/j0e1dHdIdJZ2dKdLZ3edMdNZ4eeddOdPZ5d;d;d;e6dQe'e/j0e'e7eefe'e7e(j)efe8j9j:d;dRdSdTZ;dd;e8jj?efe'ee@eAeBeCeefe>j?dWdXdYZDdd;d;e8jjEefe'e>j?e'eFjGe@eAeBeCeefe>j?d[d\d]ZHdd;d;e8jjIefe'ee'eJe>jKe@eAeBeCeefe>jLd_d`daZMdd;e8jjNefe'ee@eAeBeCeefe>j?dcdddeZOdd;e8jjPefe'ee@eAeBeCeefeQjRdgdhdiZSdd;e8jjTefe'ee@eAeBeCeefeQjUdcdjdkZVdd;e8jjWefe'ee@eAeBeCeefeQjXdcdldmZYdd;e8jjZefe'ee@eAeBeCeefd;dcdndoZ[de8jj\efe@eAeBeCeefe>j]dqdrdsZ^dddtduZ_dvdwZ`de8j[^.]+)(?P\.mtls)?(?P\.sandbox)?(?P\.googleapis\.com)?zsandbox.googleapis.comzmtls.sandbox.googleapis.comz.googleapis.comz.mtls.googleapis.com)recompilematchgroupsreplace) api_endpointZmtls_endpoint_remnamerZsandboxZ googledomainr0r0r1_get_default_mtls_endpointks  z*PublisherClient._get_default_mtls_endpoint)z.https://www.googleapis.com/auth/cloud-platformz&https://www.googleapis.com/auth/pubsubzpubsub.googleapis.com:443zpubsub.googleapis.comzpubsub.{UNIVERSE_DOMAIN}zgoogleapis.com)infocOs"tj|}||d<||i|S)ayCreates 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)r/rBargskwargsrr0r0r1rDs z)PublisherClient.from_service_account_info)filenamecOs"tj|}||d<||i|S)aCreates 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)rrCfrom_service_account_file)r/rGrErFrr0r0r1rHs z)PublisherClient.from_service_account_file)r*cCs|jS)zReturns the transport used by the client instance. Returns: PublisherTransport: The transport used by the client instance. ) _transportselfr0r0r1 transportszPublisherClient.transport)projectschemar*cCsdj||dS)z(Returns a fully-qualified schema string.z#projects/{project}/schemas/{schema}rMrNformatrOr0r0r1 schema_pathszPublisherClient.schema_path)pathr*cCstd|}|r|SiS)z1Parses a schema path into its component segments.z3^projects/(?P.+?)/schemas/(?P.+?)$r9r; groupdictrSr?r0r0r1parse_schema_paths z!PublisherClient.parse_schema_path)rM subscriptionr*cCsdj||dS)z.Returns a fully-qualified subscription string.z/projects/{project}/subscriptions/{subscription}rMrXrPrYr0r0r1subscription_pathsz!PublisherClient.subscription_pathcCstd|}|r|SiS)z7Parses a subscription path into its component segments.z?^projects/(?P.+?)/subscriptions/(?P.+?)$rTrVr0r0r1parse_subscription_pathsz'PublisherClient.parse_subscription_path)rMtopicr*cCsdj||dS)z'Returns a fully-qualified topic string.z!projects/{project}/topics/{topic}rMr\rPr]r0r0r1 topic_pathszPublisherClient.topic_pathcCstd|}|r|SiS)z0Parses a topic path into its component segments.z1^projects/(?P.+?)/topics/(?P.+?)$rTrVr0r0r1parse_topic_paths z PublisherClient.parse_topic_path)billing_accountr*cCs dj|dS)z1Returns a fully-qualified billing_account string.z!billingAccounts/{billing_account}r`rPrar0r0r1common_billing_account_pathsz+PublisherClient.common_billing_account_pathcCstd|}|r|SiS)z9Parse a billing_account path into its component segments.z*^billingAccounts/(?P.+?)$rTrVr0r0r1!parse_common_billing_account_path s z1PublisherClient.parse_common_billing_account_path)folderr*cCs dj|dS)z(Returns a fully-qualified folder string.zfolders/{folder}rdrPrer0r0r1common_folder_pathsz"PublisherClient.common_folder_pathcCstd|}|r|SiS)z0Parse a folder path into its component segments.z^folders/(?P.+?)$rTrVr0r0r1parse_common_folder_paths z(PublisherClient.parse_common_folder_path) organizationr*cCs dj|dS)z.Returns a fully-qualified organization string.zorganizations/{organization}rhrPrir0r0r1common_organization_pathsz(PublisherClient.common_organization_pathcCstd|}|r|SiS)z6Parse a organization path into its component segments.z%^organizations/(?P.+?)$rTrVr0r0r1parse_common_organization_path(s z.PublisherClient.parse_common_organization_path)rMr*cCs dj|dS)z)Returns a fully-qualified project string.zprojects/{project}rMrPrlr0r0r1common_project_path.sz#PublisherClient.common_project_pathcCstd|}|r|SiS)z1Parse a project path into its component segments.z^projects/(?P.+?)$rTrVr0r0r1parse_common_project_path7s z)PublisherClient.parse_common_project_path)rMlocationr*cCsdj||dS)z*Returns a fully-qualified location string.z'projects/{project}/locations/{location}rMrorPrpr0r0r1common_location_path=sz$PublisherClient.common_location_pathcCstd|}|r|SiS)z2Parse a location path into its component segments.z7^projects/(?P.+?)/locations/(?P.+?)$rTrVr0r0r1parse_common_location_pathHs z*PublisherClient.parse_common_location_pathNrcCstdt|durt}tdd}tdd}|dvrDtd|d vrTtd d}|d kr~|j rn|j }nt r~t }|j dur|j }n"|d ks|dkr|r|j}n|j}||fS) aDeprecated. 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. zWget_mtls_endpoint_and_cert_source is deprecated. Use the api_endpoint property instead.N!GOOGLE_API_USE_CLIENT_CERTIFICATEfalseGOOGLE_API_USE_MTLS_ENDPOINTautotruertYEnvironment variable `GOOGLE_API_USE_CLIENT_CERTIFICATE` must be either `true` or `false`rvneveralwaysWEnvironment variable `GOOGLE_API_USE_MTLS_ENDPOINT` must be `never`, `auto` or `always`rxr|)warningswarnDeprecationWarningclient_options_lib ClientOptionsosgetenv ValueErrorrclient_cert_sourcerhas_default_client_cert_sourcedefault_client_cert_sourcer>DEFAULT_MTLS_ENDPOINTDEFAULT_ENDPOINT)r/ruse_client_certuse_mtls_endpointrr>r0r0r1!get_mtls_endpoint_and_cert_sourceNs@#   z1PublisherClient.get_mtls_endpoint_and_cert_sourcecCsXtdd}tdd}td}|dvr:td|dvrJtd |d k||fS) aReturns the environment variables used by the client. Returns: Tuple[bool, str, str]: returns the GOOGLE_API_USE_CLIENT_CERTIFICATE, GOOGLE_API_USE_MTLS_ENDPOINT, and GOOGLE_CLOUD_UNIVERSE_DOMAIN environment variables. Raises: ValueError: If GOOGLE_API_USE_CLIENT_CERTIFICATE is not any of ["true", "false"]. google.auth.exceptions.MutualTLSChannelError: If GOOGLE_API_USE_MTLS_ENDPOINT is not any of ["auto", "never", "always"]. rsrtrurvZGOOGLE_CLOUD_UNIVERSE_DOMAINrwryrzr}rx)rrlowerrr)rruniverse_domain_envr0r0r1_read_environment_variabless z+PublisherClient._read_environment_variablescCs&d}|r"|r|}ntr"t}|S)aZReturn the client cert source to be used by the client. Args: provided_cert_source (bytes): The client certificate source provided. use_cert_flag (bool): A flag indicating whether to use the client certificate. Returns: bytes or None: The client cert source to be used by the client. N)rrr)Zprovided_cert_sourceZ use_cert_flagrr0r0r1_get_client_cert_sources z'PublisherClient._get_client_cert_sourcecCsZ|dur|}nH|dks"|dkrH|rHtj}||kr@td|dtj}ntjj|d}|S)aReturn the API endpoint used by the client. Args: api_override (str): The API endpoint override. If specified, this is always the return value of this function and the other arguments are not used. client_cert_source (bytes): The client certificate source used by the client. universe_domain (str): The universe domain used by the client. use_mtls_endpoint (str): How to use the mTLS endpoint, which depends also on the other parameters. Possible values are "always", "auto", or "never". Returns: str: The API endpoint to be used by the client. Nr|rvz1mTLS is not supported in any universe other than .)ZUNIVERSE_DOMAIN)r8_DEFAULT_UNIVERSErr_DEFAULT_ENDPOINT_TEMPLATErQ)Z api_overrideruniverse_domainrr>Z_default_universer0r0r1_get_api_endpoints" z!PublisherClient._get_api_endpoint)client_universe_domainrr*cCs<tj}|dur|}n |dur |}t|dkr8td|S)aReturn the universe domain used by the client. Args: client_universe_domain (Optional[str]): The universe domain configured via the client options. universe_domain_env (Optional[str]): The universe domain configured via the "GOOGLE_CLOUD_UNIVERSE_DOMAIN" environment variable. Returns: str: The universe domain to be used by the client. Raises: ValueError: If the universe domain is an empty string. Nrz*Universe Domain cannot be an empty string.)r8rlenstripr)rrrr0r0r1_get_universe_domainsz$PublisherClient._get_universe_domain)client_universerr*cCs:tj}t|d|}||kr6td|d|d|ddS)aReturns True iff the universe domains used by the client and credentials match. Args: client_universe (str): The universe domain configured via the client options. credentials (ga_credentials.Credentials): The credentials being used in the client. Returns: bool: True iff client_universe matches the universe in credentials. Raises: ValueError: when client_universe does not match the universe in credentials. rz The configured universe domain (z?) does not match the universe domain found in the credentials (z>). If you haven't configured the universe domain explicitly, `z` is the default.T)r8rgetattrr)rrZdefault_universeZcredentials_universer0r0r1_compare_universess z"PublisherClient._compare_universescCs |jpt|j|jj|_|jS)zValidates client's and credentials' universe domains are consistent. Returns: bool: True iff the configured universe domain is valid. Raises: ValueError: If the configured universe domain is not valid. )_is_universe_domain_validr8rrrLZ _credentialsrJr0r0r1_validate_universe_domains  z)PublisherClient._validate_universe_domaincCs|jS)zReturn the API endpoint used by the client instance. Returns: str: The API endpoint used by the client instance. ) _api_endpointrJr0r0r1r>0szPublisherClient.api_endpointcCs|jS)zReturn the universe domain used by the client instance. Returns: str: The universe domain used by the client instance. )_universe_domainrJr0r0r1r9szPublisherClient.universe_domain)rrLr client_info)rrLrrr*c Cs||_t|jtr t|j|_|jdur4t|_ttj|j|_t|jdd}t \|_ |_ |_ t |jj|j |_t||j |_d|_d|_t|jdd}|r|rtdt|t}|r|s|jjs|rtd|jjrtdtt||_|jj|_|jp"t|jj|j|j|j |_|sddl}|rXt|jjd rX|jj |}t!|"tt#|} t$j%&d } | rt'| t!|j(d rt)j*| d } nt)j+j*| d } t,j-| | d } | ||jj|j|jj|j|jj.|d|jj/d |_dS)an Instantiates 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. 1. The ``api_endpoint`` property can be used to override the default endpoint provided by the client when ``transport`` is not explicitly provided. Only if this property is not set and ``transport`` was not explicitly provided, the endpoint is determined by the GOOGLE_API_USE_MTLS_ENDPOINT environment variable, which have one of the following values: "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). 2. If the GOOGLE_API_USE_CLIENT_CERTIFICATE environment variable is "true", then the ``client_cert_source`` property can be used to provide a client certificate for mTLS 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. 3. The ``universe_domain`` property can be used to override the default "googleapis.com" universe. Note that the ``api_endpoint`` property still takes precedence; and ``universe_domain`` is currently not supported for mTLS. 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. NrFZapi_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_credentialsZPUBSUB_EMULATOR_HOSTr')target)channelT) rcredentials_filehostscopesZclient_cert_source_for_mtlsquota_project_idrZalways_use_jwt_access api_audience)0Z_client_options isinstancedictr from_dictrr rr8rZ_use_client_certZ_use_mtls_endpointZ_universe_domain_envrrZ_client_cert_sourcerrrrrr!rrrIrrr>Zgoogle.auth._defaulthasattrauth_defaultrtyper2r7renvironget issubclassr+r'Zinsecure_channelZaio functoolspartialrr) rKrrLrrZuniverse_domain_optZ api_key_valueZtransport_providedZgoogle TransportZ emulator_hostrr0r0r1__init__Bs7         zPublisherClient.__init__r0)r@rrmetadata)requestr@rrrr*c Cst|g}|dur|rtdt|tjsBt|}|durB||_|jj|jj}t |t j d|jfff}| |||||d}|S)a Creates the given topic with the given name. See the [resource name rules] (https://cloud.google.com/pubsub/docs/pubsub-basics#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. N\If the `request` argument is set, then none of the individual field arguments should be set.r@rrr)anyrrrTopicr@rI_wrapped_methods create_topictuplerrouting_headerto_grpc_metadatar) rKrr@rrrhas_flattened_paramsrpcresponser0r0r1rs*E    zPublisherClient.create_topic)r\ update_maskrrr)rr\rrrrr*c Cst||g}|dur |r tdt|tjsRt|}|durD||_|durR||_|jj|jj }t |t j d|jjfff}||||||d} | S)a Updates an existing topic by updating the fields specified in the update mask. 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. Nrz topic.namer)rrrrUpdateTopicRequestr\rrIr update_topicrrrrr@r) rKrr\rrrrrrrr0r0r1rCs2M     zPublisherClient.update_topic)r\messagesrrr)rr\rrrrr*c Cst||g}|dur |r tdt|tjsRt|}|durD||_|durR||_|jj|jj }t |t j d|jfff}||||||d} | S)aD 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 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. Nrr\r)rrrrPublishRequestr\rrIrpublishrrrrr) rKrr\rrrrrrrr0r0r1rs.E    zPublisherClient.publish)r\rrr)rr\rrrr*c Cst|g}|dur|rtdt|tjsBt|}|durB||_|jj|jj}t |t j d|jfff}| |||||d}|S)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 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. Nrr\r)rrrrGetTopicRequestr\rIr get_topicrrrrr rKrr\rrrrrrr0r0r1r/s*=    zPublisherClient.get_topic)rMrrr)rrMrrrr*c Cst|g}|dur|rtdt|tjsBt|}|durB||_|jj|jj}t |t j d|jfff}| |||||d}tj||||d}|S)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 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. NrrMrmethodrrr)rrrrListTopicsRequestrMrIr list_topicsrrrrrrListTopicsPager) rKrrMrrrrrrr0r0r1rs6B     zPublisherClient.list_topicsc Cst|g}|dur|rtdt|tjsBt|}|durB||_|jj|jj}t |t j d|jfff}| |||||d}tj||||d}|S)a( 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 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. Nrr\rr)rrrrListTopicSubscriptionsRequestr\rIrlist_topic_subscriptionsrrrrrrListTopicSubscriptionsPagerrr0r0r1r s6D     z(PublisherClient.list_topic_subscriptionsc Cst|g}|dur|rtdt|tjsBt|}|durB||_|jj|jj}t |t j d|jfff}| |||||d}tj||||d}|S)a3 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 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. Nrr\rr)rrrrListTopicSnapshotsRequestr\rIrlist_topic_snapshotsrrrrrrListTopicSnapshotsPagerrr0r0r1rs6H     z$PublisherClient.list_topic_snapshotscCst|g}|dur|rtdt|tjsBt|}|durB||_|jj|jj}t |t j d|jfff}| |||||ddS)abDeletes 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\rIr delete_topicrrrrr)rKrr\rrrrrr0r0r1rs(;    zPublisherClient.delete_topicr)rrrrr*cCs`t|tjst|}|jj|jj}t|tj d|j fff}| |||||d}|S)aDetaches a subscription from this topic. All messages retained in the subscription are dropped. Subsequent ``Pull`` and ``StreamingPull`` requests will return FAILED_PRECONDITION. If the subscription is a push subscription, pushes to the endpoint will stop. .. 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. rXr) rrDetachSubscriptionRequestrIrdetach_subscriptionrrrrrXrrKrrrrrrr0r0r1r_s >   z#PublisherClient.detach_subscriptioncCs|S)Nr0rJr0r0r1 __enter__szPublisherClient.__enter__cCs|jdS)aReleases 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)rLclose)rKrvalue tracebackr0r0r1__exit__szPublisherClient.__exit__cCsjt|trtjfi|}tjj|jjdt d}t |tj d|j fff}||||||d}|S)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 `__. NZdefault_timeoutrresourcer)rrrSetIamPolicyRequestrr wrap_methodrIset_iam_policyr"rrrrrrr0r0r1rs$] zPublisherClient.set_iam_policycCsjt|trtjfi|}tjj|jjdt d}t |tj d|j fff}||||||d}|S)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 `__. Nrrr)rrrGetIamPolicyRequestrrrrIget_iam_policyr"rrrrrrr0r0r1rCs$^ zPublisherClient.get_iam_policycCsjt|trtjfi|}tjj|jjdt d}t |tj d|j fff}||||||d}|S)a~Tests 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. Nrrr)rrrTestIamPermissionsRequestrrrrItest_iam_permissionsr"rrrrrrr0r0r1rs$ z$PublisherClient.test_iam_permissions)N)N)N)N)N)N)N)N)N)N)N)N)N)kr3r4r5r6 staticmethodrAZ_DEFAULT_SCOPESZSERVICE_ADDRESSr__func__rrr classmethodrrDr7rHZfrom_service_account_jsonpropertyr!rLrRrrWrZr[r^r_rbrcrfrgrjrkrmrnrqrrrrrrrrrrga_credentialsrCboolrrr>rr"r rr ClientInforrDEFAULTrr OptionalRetryrrr rrrZ FieldMaskrrrZ PubsubMessageZPublishResponserrrrrrrrrrrrrrrrZDetachSubscriptionResponserrrrrrPolicyrrrrZTestIamPermissionsResponserr0r0r0r1r8fs  !     G   !     q }  s i w y } d [  ~ r8) metaclass)Zclient_library_version)r8)K collectionsrrrr9typingrrrrrrr r r r r~Zgoogle.pubsub_v1r Zpackage_versionZgoogle.api_corerrrZcore_exceptionsrrretriesrZtimeoutsZ google.authrrZgoogle.auth.transportrZgoogle.auth.transport.grpcrZgoogle.auth.exceptionsrZ google.oauth2rRetryrZ_MethodDefaultrAttributeErrorobjectZ google.iam.v1rrZgoogle.protobufrrZ#google.pubsub_v1.services.publisherrZgoogle.pubsub_v1.typesrrr'Ztransports.baser!r"Ztransports.grpcr#Ztransports.grpc_asyncior$Ztransports.restr%rr&r8rr __version____all__r0r0r0r1sj 0                      #)