Coverage for /pythoncovmergedfiles/medio/medio/usr/local/lib/python3.11/site-packages/google/pubsub_v1/__init__.py: 99%

1# -*- coding: utf-8 -*- 

2# Copyright 2025 Google LLC 

3# 

4# Licensed under the Apache License, Version 2.0 (the "License"); 

5# you may not use this file except in compliance with the License. 

6# You may obtain a copy of the License at 

7# 

8# http://www.apache.org/licenses/LICENSE-2.0 

9# 

10# Unless required by applicable law or agreed to in writing, software 

11# distributed under the License is distributed on an "AS IS" BASIS, 

12# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 

13# See the License for the specific language governing permissions and 

14# limitations under the License. 

15# 

16from google.pubsub_v1 import gapic_version as package_version 

17 

18__version__ = package_version.__version__ 

19 

20 

21from .services.publisher import PublisherClient 

22from .services.publisher import PublisherAsyncClient 

23from .services.schema_service import SchemaServiceClient 

24from .services.schema_service import SchemaServiceAsyncClient 

25from .services.subscriber import SubscriberClient 

26from .services.subscriber import SubscriberAsyncClient 

27 

28from .types.pubsub import AcknowledgeRequest 

29from .types.pubsub import BigQueryConfig 

30from .types.pubsub import CloudStorageConfig 

31from .types.pubsub import CreateSnapshotRequest 

32from .types.pubsub import DeadLetterPolicy 

33from .types.pubsub import DeleteSnapshotRequest 

34from .types.pubsub import DeleteSubscriptionRequest 

35from .types.pubsub import DeleteTopicRequest 

36from .types.pubsub import DetachSubscriptionRequest 

37from .types.pubsub import DetachSubscriptionResponse 

38from .types.pubsub import ExpirationPolicy 

39from .types.pubsub import GetSnapshotRequest 

40from .types.pubsub import GetSubscriptionRequest 

41from .types.pubsub import GetTopicRequest 

42from .types.pubsub import IngestionDataSourceSettings 

43from .types.pubsub import IngestionFailureEvent 

44from .types.pubsub import JavaScriptUDF 

45from .types.pubsub import ListSnapshotsRequest 

46from .types.pubsub import ListSnapshotsResponse 

47from .types.pubsub import ListSubscriptionsRequest 

48from .types.pubsub import ListSubscriptionsResponse 

49from .types.pubsub import ListTopicSnapshotsRequest 

50from .types.pubsub import ListTopicSnapshotsResponse 

51from .types.pubsub import ListTopicsRequest 

52from .types.pubsub import ListTopicsResponse 

53from .types.pubsub import ListTopicSubscriptionsRequest 

54from .types.pubsub import ListTopicSubscriptionsResponse 

55from .types.pubsub import MessageStoragePolicy 

56from .types.pubsub import MessageTransform 

57from .types.pubsub import ModifyAckDeadlineRequest 

58from .types.pubsub import ModifyPushConfigRequest 

59from .types.pubsub import PlatformLogsSettings 

60from .types.pubsub import PublishRequest 

61from .types.pubsub import PublishResponse 

62from .types.pubsub import PubsubMessage 

63from .types.pubsub import PullRequest 

64from .types.pubsub import PullResponse 

65from .types.pubsub import PushConfig 

66from .types.pubsub import ReceivedMessage 

67from .types.pubsub import RetryPolicy 

68from .types.pubsub import SchemaSettings 

69from .types.pubsub import SeekRequest 

70from .types.pubsub import SeekResponse 

71from .types.pubsub import Snapshot 

72from .types.pubsub import StreamingPullRequest 

73from .types.pubsub import StreamingPullResponse 

74from .types.pubsub import Subscription 

75from .types.pubsub import Topic 

76from .types.pubsub import UpdateSnapshotRequest 

77from .types.pubsub import UpdateSubscriptionRequest 

78from .types.pubsub import UpdateTopicRequest 

79from .types.schema import CommitSchemaRequest 

80from .types.schema import CreateSchemaRequest 

81from .types.schema import DeleteSchemaRequest 

82from .types.schema import DeleteSchemaRevisionRequest 

83from .types.schema import GetSchemaRequest 

84from .types.schema import ListSchemaRevisionsRequest 

85from .types.schema import ListSchemaRevisionsResponse 

86from .types.schema import ListSchemasRequest 

87from .types.schema import ListSchemasResponse 

88from .types.schema import RollbackSchemaRequest 

89from .types.schema import Schema 

90from .types.schema import ValidateMessageRequest 

91from .types.schema import ValidateMessageResponse 

92from .types.schema import ValidateSchemaRequest 

93from .types.schema import ValidateSchemaResponse 

94from .types.schema import Encoding 

95from .types.schema import SchemaView 

96 

97__all__ = ( 

98 "PublisherAsyncClient", 

99 "SchemaServiceAsyncClient", 

100 "SubscriberAsyncClient", 

101 "AcknowledgeRequest", 

102 "BigQueryConfig", 

103 "CloudStorageConfig", 

104 "CommitSchemaRequest", 

105 "CreateSchemaRequest", 

106 "CreateSnapshotRequest", 

107 "DeadLetterPolicy", 

108 "DeleteSchemaRequest", 

109 "DeleteSchemaRevisionRequest", 

110 "DeleteSnapshotRequest", 

111 "DeleteSubscriptionRequest", 

112 "DeleteTopicRequest", 

113 "DetachSubscriptionRequest", 

114 "DetachSubscriptionResponse", 

115 "Encoding", 

116 "ExpirationPolicy", 

117 "GetSchemaRequest", 

118 "GetSnapshotRequest", 

119 "GetSubscriptionRequest", 

120 "GetTopicRequest", 

121 "IngestionDataSourceSettings", 

122 "IngestionFailureEvent", 

123 "JavaScriptUDF", 

124 "ListSchemaRevisionsRequest", 

125 "ListSchemaRevisionsResponse", 

126 "ListSchemasRequest", 

127 "ListSchemasResponse", 

128 "ListSnapshotsRequest", 

129 "ListSnapshotsResponse", 

130 "ListSubscriptionsRequest", 

131 "ListSubscriptionsResponse", 

132 "ListTopicSnapshotsRequest", 

133 "ListTopicSnapshotsResponse", 

134 "ListTopicSubscriptionsRequest", 

135 "ListTopicSubscriptionsResponse", 

136 "ListTopicsRequest", 

137 "ListTopicsResponse", 

138 "MessageStoragePolicy", 

139 "MessageTransform", 

140 "ModifyAckDeadlineRequest", 

141 "ModifyPushConfigRequest", 

142 "PlatformLogsSettings", 

143 "PublishRequest", 

144 "PublishResponse", 

145 "PublisherClient", 

146 "PubsubMessage", 

147 "PullRequest", 

148 "PullResponse", 

149 "PushConfig", 

150 "ReceivedMessage", 

151 "RetryPolicy", 

152 "RollbackSchemaRequest", 

153 "Schema", 

154 "SchemaServiceClient", 

155 "SchemaSettings", 

156 "SchemaView", 

157 "SeekRequest", 

158 "SeekResponse", 

159 "Snapshot", 

160 "StreamingPullRequest", 

161 "StreamingPullResponse", 

162 "SubscriberClient", 

163 "Subscription", 

164 "Topic", 

165 "UpdateSnapshotRequest", 

166 "UpdateSubscriptionRequest", 

167 "UpdateTopicRequest", 

168 "ValidateMessageRequest", 

169 "ValidateMessageResponse", 

170 "ValidateSchemaRequest", 

171 "ValidateSchemaResponse", 

172)