| Server IP : 88.223.91.250 / Your IP : 216.73.217.26 Web Server : LiteSpeed System : Linux id-dci-web1986.main-hosting.eu 5.14.0-611.26.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Jan 29 05:24:47 EST 2026 x86_64 User : u686484674 ( 686484674) PHP Version : 8.0.30 Disable Function : system, exec, shell_exec, passthru, mysql_list_dbs, ini_alter, dl, symlink, link, chgrp, leak, popen, apache_child_terminate, virtual, mb_send_mail MySQL : OFF | cURL : ON | WGET : ON | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python311/lib/python3.11/site-packages/google/pubsub/ |
Upload File : |
# -*- coding: utf-8 -*-
# Copyright 2025 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
from google.pubsub import gapic_version as package_version
__version__ = package_version.__version__
from google.pubsub_v1.services.publisher.client import PublisherClient
from google.pubsub_v1.services.publisher.async_client import PublisherAsyncClient
from google.pubsub_v1.services.schema_service.client import SchemaServiceClient
from google.pubsub_v1.services.schema_service.async_client import (
SchemaServiceAsyncClient,
)
from google.pubsub_v1.services.subscriber.client import SubscriberClient
from google.pubsub_v1.services.subscriber.async_client import SubscriberAsyncClient
from google.pubsub_v1.types.pubsub import AcknowledgeRequest
from google.pubsub_v1.types.pubsub import BigQueryConfig
from google.pubsub_v1.types.pubsub import CloudStorageConfig
from google.pubsub_v1.types.pubsub import CreateSnapshotRequest
from google.pubsub_v1.types.pubsub import DeadLetterPolicy
from google.pubsub_v1.types.pubsub import DeleteSnapshotRequest
from google.pubsub_v1.types.pubsub import DeleteSubscriptionRequest
from google.pubsub_v1.types.pubsub import DeleteTopicRequest
from google.pubsub_v1.types.pubsub import DetachSubscriptionRequest
from google.pubsub_v1.types.pubsub import DetachSubscriptionResponse
from google.pubsub_v1.types.pubsub import ExpirationPolicy
from google.pubsub_v1.types.pubsub import GetSnapshotRequest
from google.pubsub_v1.types.pubsub import GetSubscriptionRequest
from google.pubsub_v1.types.pubsub import GetTopicRequest
from google.pubsub_v1.types.pubsub import IngestionDataSourceSettings
from google.pubsub_v1.types.pubsub import IngestionFailureEvent
from google.pubsub_v1.types.pubsub import JavaScriptUDF
from google.pubsub_v1.types.pubsub import ListSnapshotsRequest
from google.pubsub_v1.types.pubsub import ListSnapshotsResponse
from google.pubsub_v1.types.pubsub import ListSubscriptionsRequest
from google.pubsub_v1.types.pubsub import ListSubscriptionsResponse
from google.pubsub_v1.types.pubsub import ListTopicSnapshotsRequest
from google.pubsub_v1.types.pubsub import ListTopicSnapshotsResponse
from google.pubsub_v1.types.pubsub import ListTopicsRequest
from google.pubsub_v1.types.pubsub import ListTopicsResponse
from google.pubsub_v1.types.pubsub import ListTopicSubscriptionsRequest
from google.pubsub_v1.types.pubsub import ListTopicSubscriptionsResponse
from google.pubsub_v1.types.pubsub import MessageStoragePolicy
from google.pubsub_v1.types.pubsub import MessageTransform
from google.pubsub_v1.types.pubsub import ModifyAckDeadlineRequest
from google.pubsub_v1.types.pubsub import ModifyPushConfigRequest
from google.pubsub_v1.types.pubsub import PlatformLogsSettings
from google.pubsub_v1.types.pubsub import PublishRequest
from google.pubsub_v1.types.pubsub import PublishResponse
from google.pubsub_v1.types.pubsub import PubsubMessage
from google.pubsub_v1.types.pubsub import PullRequest
from google.pubsub_v1.types.pubsub import PullResponse
from google.pubsub_v1.types.pubsub import PushConfig
from google.pubsub_v1.types.pubsub import ReceivedMessage
from google.pubsub_v1.types.pubsub import RetryPolicy
from google.pubsub_v1.types.pubsub import SchemaSettings
from google.pubsub_v1.types.pubsub import SeekRequest
from google.pubsub_v1.types.pubsub import SeekResponse
from google.pubsub_v1.types.pubsub import Snapshot
from google.pubsub_v1.types.pubsub import StreamingPullRequest
from google.pubsub_v1.types.pubsub import StreamingPullResponse
from google.pubsub_v1.types.pubsub import Subscription
from google.pubsub_v1.types.pubsub import Topic
from google.pubsub_v1.types.pubsub import UpdateSnapshotRequest
from google.pubsub_v1.types.pubsub import UpdateSubscriptionRequest
from google.pubsub_v1.types.pubsub import UpdateTopicRequest
from google.pubsub_v1.types.schema import CommitSchemaRequest
from google.pubsub_v1.types.schema import CreateSchemaRequest
from google.pubsub_v1.types.schema import DeleteSchemaRequest
from google.pubsub_v1.types.schema import DeleteSchemaRevisionRequest
from google.pubsub_v1.types.schema import GetSchemaRequest
from google.pubsub_v1.types.schema import ListSchemaRevisionsRequest
from google.pubsub_v1.types.schema import ListSchemaRevisionsResponse
from google.pubsub_v1.types.schema import ListSchemasRequest
from google.pubsub_v1.types.schema import ListSchemasResponse
from google.pubsub_v1.types.schema import RollbackSchemaRequest
from google.pubsub_v1.types.schema import Schema
from google.pubsub_v1.types.schema import ValidateMessageRequest
from google.pubsub_v1.types.schema import ValidateMessageResponse
from google.pubsub_v1.types.schema import ValidateSchemaRequest
from google.pubsub_v1.types.schema import ValidateSchemaResponse
from google.pubsub_v1.types.schema import Encoding
from google.pubsub_v1.types.schema import SchemaView
__all__ = (
"PublisherClient",
"PublisherAsyncClient",
"SchemaServiceClient",
"SchemaServiceAsyncClient",
"SubscriberClient",
"SubscriberAsyncClient",
"AcknowledgeRequest",
"BigQueryConfig",
"CloudStorageConfig",
"CreateSnapshotRequest",
"DeadLetterPolicy",
"DeleteSnapshotRequest",
"DeleteSubscriptionRequest",
"DeleteTopicRequest",
"DetachSubscriptionRequest",
"DetachSubscriptionResponse",
"ExpirationPolicy",
"GetSnapshotRequest",
"GetSubscriptionRequest",
"GetTopicRequest",
"IngestionDataSourceSettings",
"IngestionFailureEvent",
"JavaScriptUDF",
"ListSnapshotsRequest",
"ListSnapshotsResponse",
"ListSubscriptionsRequest",
"ListSubscriptionsResponse",
"ListTopicSnapshotsRequest",
"ListTopicSnapshotsResponse",
"ListTopicsRequest",
"ListTopicsResponse",
"ListTopicSubscriptionsRequest",
"ListTopicSubscriptionsResponse",
"MessageStoragePolicy",
"MessageTransform",
"ModifyAckDeadlineRequest",
"ModifyPushConfigRequest",
"PlatformLogsSettings",
"PublishRequest",
"PublishResponse",
"PubsubMessage",
"PullRequest",
"PullResponse",
"PushConfig",
"ReceivedMessage",
"RetryPolicy",
"SchemaSettings",
"SeekRequest",
"SeekResponse",
"Snapshot",
"StreamingPullRequest",
"StreamingPullResponse",
"Subscription",
"Topic",
"UpdateSnapshotRequest",
"UpdateSubscriptionRequest",
"UpdateTopicRequest",
"CommitSchemaRequest",
"CreateSchemaRequest",
"DeleteSchemaRequest",
"DeleteSchemaRevisionRequest",
"GetSchemaRequest",
"ListSchemaRevisionsRequest",
"ListSchemaRevisionsResponse",
"ListSchemasRequest",
"ListSchemasResponse",
"RollbackSchemaRequest",
"Schema",
"ValidateMessageRequest",
"ValidateMessageResponse",
"ValidateSchemaRequest",
"ValidateSchemaResponse",
"Encoding",
"SchemaView",
)