@@ -20,23 +20,23 @@ Create a new topic for the default project:
20
20
21
21
.. doctest ::
22
22
23
- >>> from gcloud.pubsub.topic import Topic
23
+ >>> from gcloud.pubsub import Topic
24
24
>>> topic = Topic(' topic_name' )
25
25
>>> topic.create() # API request
26
26
27
27
Create a new topic for an explicit project:
28
28
29
29
.. doctest ::
30
30
31
- >>> from gcloud.pubsub.topic import Topic
31
+ >>> from gcloud.pubsub import Topic
32
32
>>> topic = Topic(' topic_name' , project_id = ' my.project' )
33
33
>>> topic.create() # API request
34
34
35
35
Check for the existance of a topic:
36
36
37
37
.. doctest ::
38
38
39
- >>> from gcloud.pubsub.topic import Topic
39
+ >>> from gcloud.pubsub import Topic
40
40
>>> topic = Topic(' topic_name' )
41
41
>>> topic.exists() # API request
42
42
True
@@ -45,24 +45,24 @@ List topics for the default project:
45
45
46
46
.. doctest ::
47
47
48
- >>> from gcloud import pubsub
49
- >>> [topic.name for topic in pubsub. list_topics()] # API request
48
+ >>> from gcloud.pubsub import list_topics
49
+ >>> [topic.name for topic in list_topics()] # API request
50
50
['topic_name']
51
51
52
52
List topics for an explicit project:
53
53
54
54
.. doctest ::
55
55
56
- >>> from gcloud import pubsub
57
- >>> topics = pubsub. list_topics(project_id = ' my.project' ) # API request
56
+ >>> from gcloud.pubsub import list_topics
57
+ >>> topics = list_topics(project_id = ' my.project' ) # API request
58
58
>>> [topic.name for topic in topics]
59
59
['topic_name']
60
60
61
61
Delete a topic:
62
62
63
63
.. doctest ::
64
64
65
- >>> from gcloud.pubsub.topic import Topic
65
+ >>> from gcloud.pubsub import Topic
66
66
>>> topic = Topic(' topic_name' )
67
67
>>> topic.delete() # API request
68
68
@@ -74,7 +74,7 @@ Publish a single message to a topic, without attributes:
74
74
75
75
.. doctest ::
76
76
77
- >>> from gcloud.pubsub.topic import Topic
77
+ >>> from gcloud.pubsub import Topic
78
78
>>> topic = Topic(' topic_name' )
79
79
>>> topic.publish(' this is the message_payload' ) # API request
80
80
<message_id>
@@ -83,7 +83,7 @@ Publish a single message to a topic, with attributes:
83
83
84
84
.. doctest ::
85
85
86
- >>> from gcloud.pubsub.topic import Topic
86
+ >>> from gcloud.pubsub import Topic
87
87
>>> topic = Topic(' topic_name' )
88
88
>>> topic.publish(' this is another message_payload' ,
89
89
... attr1= ' value1' , attr2= ' value2' ) # API request
@@ -93,7 +93,7 @@ Publish a set of messages to a topic (as a single request):
93
93
94
94
.. doctest ::
95
95
96
- >>> from gcloud.pubsub.topic import Topic
96
+ >>> from gcloud.pubsub import Topic
97
97
>>> topic = Topic(' topic_name' )
98
98
>>> with topic.batch() as batch:
99
99
... batch.publish(' this is the first message_payload' )
@@ -115,8 +115,8 @@ Create a new pull subscription for a topic:
115
115
116
116
.. doctest ::
117
117
118
- >>> from gcloud.pubsub.topic import Topic
119
- >>> from gcloud.pubsub.subscription import Subscription
118
+ >>> from gcloud.pubsub import Topic
119
+ >>> from gcloud.pubsub import Subscription
120
120
>>> topic = Topic(' topic_name' )
121
121
>>> subscription = Subscription(' subscription_name' , topic)
122
122
>>> subscription.create() # API request
@@ -125,8 +125,8 @@ Create a new pull subscription for a topic with a non-default ACK deadline:
125
125
126
126
.. doctest ::
127
127
128
- >>> from gcloud.pubsub.topic import Topic
129
- >>> from gcloud.pubsub.subscription import Subscription
128
+ >>> from gcloud.pubsub import Topic
129
+ >>> from gcloud.pubsub import Subscription
130
130
>>> topic = Topic(' topic_name' )
131
131
>>> subscription = Subscription(' subscription_name' , ack_deadline = 90 )
132
132
>>> subscription.create() # API request
@@ -136,8 +136,8 @@ Create a new push subscription for a topic:
136
136
.. doctest ::
137
137
138
138
>>> ENDPOINT = ' https://example.com/hook'
139
- >>> from gcloud.pubsub.topic import Topic
140
- >>> from gcloud.pubsub.subscription import Subscription
139
+ >>> from gcloud.pubsub import Topic
140
+ >>> from gcloud.pubsub import Subscription
141
141
>>> topic = Topic(' topic_name' )
142
142
>>> subscription = Subscription(' subscription_name' , push_endpoint = ENDPOINT )
143
143
>>> subscription.create() # API request
@@ -146,8 +146,8 @@ Check for the existence of a subscription:
146
146
147
147
.. doctest ::
148
148
149
- >>> from gcloud.pubsub.topic import Topic
150
- >>> from gcloud.pubsub.subscription import Subscription
149
+ >>> from gcloud.pubsub import Topic
150
+ >>> from gcloud.pubsub import Subscription
151
151
>>> topic = Topic(' topic_name' )
152
152
>>> subscription = Subscription(' subscription_name' , topic)
153
153
>>> subscription.exists() # API request
@@ -158,8 +158,8 @@ Convert a pull subscription to push:
158
158
.. doctest ::
159
159
160
160
>>> ENDPOINT = ' https://example.com/hook'
161
- >>> from gcloud.pubsub.topic import Topic
162
- >>> from gcloud.pubsub.subscription import Subscription
161
+ >>> from gcloud.pubsub import Topic
162
+ >>> from gcloud.pubsub import Subscription
163
163
>>> topic = Topic(' topic_name' )
164
164
>>> subscription = Subscription(' subscription_name' , topic)
165
165
>>> subscription.modify_push_configuration(push_endpoint = ENDPOINT ) # API request
@@ -169,7 +169,7 @@ Convert a push subscription to pull:
169
169
.. doctest ::
170
170
171
171
>>> ENDPOINT = ' https://example.com/hook'
172
- >>> from gcloud.pubsub.topic import Topic
172
+ >>> from gcloud.pubsub import Topic
173
173
>>> topic = Topic(' topic_name' )
174
174
>>> subscription = Subscription(' subscription_name' , topic,
175
175
... push_endpoint= ENDPOINT )
@@ -179,18 +179,27 @@ List subscriptions for a topic:
179
179
180
180
.. doctest ::
181
181
182
- >>> from gcloud.pubsub.topic import Topic
182
+ >>> from gcloud.pubsub import Topic
183
183
>>> topic = Topic(' topic_name' )
184
184
>>> subscriptions = topic.list_subscriptions() # API request
185
185
>>> [subscription.name for subscription in subscriptions]
186
186
['subscription_name']
187
187
188
+ List all subscriptions for the default project:
189
+
190
+ .. doctest ::
191
+
192
+ >>> from gcloud.pubsub import list_subscriptions
193
+ >>> subscriptions = list_subscriptions() # API request
194
+ >>> [subscription.name for subscription in subscriptions]
195
+ ['subscription_name']
196
+
188
197
Delete a subscription:
189
198
190
199
.. doctest ::
191
200
192
- >>> from gcloud.pubsub.topic import Topic
193
- >>> from gcloud.pubsub.subscription import Subscription
201
+ >>> from gcloud.pubsub import Topic
202
+ >>> from gcloud.pubsub import Subscription
194
203
>>> topic = Topic(' topic_name' )
195
204
>>> subscription = Subscription(' subscription_name' , topic)
196
205
>>> subscription.delete() # API request
@@ -203,8 +212,8 @@ Fetch pending messages for a pull subscription:
203
212
204
213
.. doctest ::
205
214
206
- >>> from gcloud.pubsub.topic import Topic
207
- >>> from gcloud.pubsub.subscription import Subscription
215
+ >>> from gcloud.pubsub import Topic
216
+ >>> from gcloud.pubsub import Subscription
208
217
>>> topic = Topic(' topic_name' )
209
218
>>> subscription = Subscription(' subscription_name' , topic)
210
219
>>> with topic:
@@ -232,8 +241,8 @@ Fetch a limited number of pending messages for a pull subscription:
232
241
233
242
.. doctest ::
234
243
235
- >>> from gcloud.pubsub.topic import Topic
236
- >>> from gcloud.pubsub.subscription import Subscription
244
+ >>> from gcloud.pubsub import Topic
245
+ >>> from gcloud.pubsub import Subscription
237
246
>>> topic = Topic(' topic_name' )
238
247
>>> subscription = Subscription(' subscription_name' , topic)
239
248
>>> with topic:
@@ -248,8 +257,8 @@ Fetch messages for a pull subscription without blocking (none pending):
248
257
249
258
.. doctest ::
250
259
251
- >>> from gcloud.pubsub.topic import Topic
252
- >>> from gcloud.pubsub.subscription import Subscription
260
+ >>> from gcloud.pubsub import Topic
261
+ >>> from gcloud.pubsub import Subscription
253
262
>>> topic = Topic(' topic_name' )
254
263
>>> subscription = Subscription(' subscription_name' , topic)
255
264
>>> received = subscription.pull(max_messages = 1 ) # API request
0 commit comments