Skip to content

Commit

Permalink
🦉 Updates from OwlBot
Browse files Browse the repository at this point in the history
  • Loading branch information
gcf-owl-bot[bot] committed May 24, 2021
1 parent 3759230 commit e90889d
Show file tree
Hide file tree
Showing 143 changed files with 3,163 additions and 27,427 deletions.
27 changes: 22 additions & 5 deletions google/cloud/pubsublite_v1/__init__.py
@@ -1,5 +1,4 @@
# -*- coding: utf-8 -*-

# Copyright 2020 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
Expand All @@ -16,11 +15,18 @@
#

from .services.admin_service import AdminServiceClient
from .services.admin_service import AdminServiceAsyncClient
from .services.cursor_service import CursorServiceClient
from .services.cursor_service import CursorServiceAsyncClient
from .services.partition_assignment_service import PartitionAssignmentServiceClient
from .services.partition_assignment_service import PartitionAssignmentServiceAsyncClient
from .services.publisher_service import PublisherServiceClient
from .services.publisher_service import PublisherServiceAsyncClient
from .services.subscriber_service import SubscriberServiceClient
from .services.subscriber_service import SubscriberServiceAsyncClient
from .services.topic_stats_service import TopicStatsServiceClient
from .services.topic_stats_service import TopicStatsServiceAsyncClient

from .types.admin import CreateSubscriptionRequest
from .types.admin import CreateTopicRequest
from .types.admin import DeleteSubscriptionRequest
Expand All @@ -30,10 +36,10 @@
from .types.admin import GetTopicRequest
from .types.admin import ListSubscriptionsRequest
from .types.admin import ListSubscriptionsResponse
from .types.admin import ListTopicSubscriptionsRequest
from .types.admin import ListTopicSubscriptionsResponse
from .types.admin import ListTopicsRequest
from .types.admin import ListTopicsResponse
from .types.admin import ListTopicSubscriptionsRequest
from .types.admin import ListTopicSubscriptionsResponse
from .types.admin import TopicPartitions
from .types.admin import UpdateSubscriptionRequest
from .types.admin import UpdateTopicRequest
Expand All @@ -42,6 +48,7 @@
from .types.common import PubSubMessage
from .types.common import SequencedMessage
from .types.common import Subscription
from .types.common import TimeTarget
from .types.common import Topic
from .types.cursor import CommitCursorRequest
from .types.cursor import CommitCursorResponse
Expand Down Expand Up @@ -76,9 +83,16 @@
from .types.topic_stats import ComputeHeadCursorResponse
from .types.topic_stats import ComputeMessageStatsRequest
from .types.topic_stats import ComputeMessageStatsResponse

from .types.topic_stats import ComputeTimeCursorRequest
from .types.topic_stats import ComputeTimeCursorResponse

__all__ = (
"AdminServiceAsyncClient",
"CursorServiceAsyncClient",
"PartitionAssignmentServiceAsyncClient",
"PublisherServiceAsyncClient",
"SubscriberServiceAsyncClient",
"TopicStatsServiceAsyncClient",
"AdminServiceClient",
"AttributeValues",
"CommitCursorRequest",
Expand All @@ -87,6 +101,8 @@
"ComputeHeadCursorResponse",
"ComputeMessageStatsRequest",
"ComputeMessageStatsResponse",
"ComputeTimeCursorRequest",
"ComputeTimeCursorResponse",
"CreateSubscriptionRequest",
"CreateTopicRequest",
"Cursor",
Expand Down Expand Up @@ -135,9 +151,10 @@
"SubscribeResponse",
"SubscriberServiceClient",
"Subscription",
"TimeTarget",
"Topic",
"TopicPartitions",
"TopicStatsServiceClient",
"UpdateSubscriptionRequest",
"UpdateTopicRequest",
"TopicStatsServiceClient",
)
1 change: 0 additions & 1 deletion google/cloud/pubsublite_v1/services/__init__.py
@@ -1,5 +1,4 @@
# -*- coding: utf-8 -*-

# Copyright 2020 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
Expand Down
2 changes: 0 additions & 2 deletions google/cloud/pubsublite_v1/services/admin_service/__init__.py
@@ -1,5 +1,4 @@
# -*- coding: utf-8 -*-

# Copyright 2020 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
Expand All @@ -14,7 +13,6 @@
# See the License for the specific language governing permissions and
# limitations under the License.
#

from .client import AdminServiceClient
from .async_client import AdminServiceAsyncClient

Expand Down

0 comments on commit e90889d

Please sign in to comment.