OLD | NEW |
1 library googleapis_beta.pubsub.v1beta1; | 1 library googleapis_beta.pubsub.v1beta1; |
2 | 2 |
3 import "dart:core" as core; | 3 import "dart:core" as core; |
4 import "dart:collection" as collection; | 4 import "dart:collection" as collection; |
5 import "dart:async" as async; | 5 import "dart:async" as async; |
6 import "dart:convert" as convert; | 6 import "dart:convert" as convert; |
7 | 7 |
8 import "package:crypto/crypto.dart" as crypto; | 8 import "package:crypto/crypto.dart" as crypto; |
9 import 'package:http/http.dart' as http; | 9 import 'package:http/http.dart' as http; |
10 import '../src/common_internal.dart' as common_internal; | 10 import '../src/common_internal.dart' as common_internal; |
(...skipping 12 matching lines...) Expand all Loading... |
23 /** View and manage Pub/Sub topics and subscriptions */ | 23 /** View and manage Pub/Sub topics and subscriptions */ |
24 static const PubsubScope = "https://www.googleapis.com/auth/pubsub"; | 24 static const PubsubScope = "https://www.googleapis.com/auth/pubsub"; |
25 | 25 |
26 | 26 |
27 final common_internal.ApiRequester _requester; | 27 final common_internal.ApiRequester _requester; |
28 | 28 |
29 SubscriptionsResourceApi get subscriptions => new SubscriptionsResourceApi(_re
quester); | 29 SubscriptionsResourceApi get subscriptions => new SubscriptionsResourceApi(_re
quester); |
30 TopicsResourceApi get topics => new TopicsResourceApi(_requester); | 30 TopicsResourceApi get topics => new TopicsResourceApi(_requester); |
31 | 31 |
32 PubsubApi(http.Client client) : | 32 PubsubApi(http.Client client) : |
33 _requester = new common_internal.ApiRequester(client, "https://www.googlea
pis.com/", "/pubsub/v1beta1/"); | 33 _requester = new common_internal.ApiRequester(client, "https://www.googlea
pis.com/", "pubsub/v1beta1/"); |
34 } | 34 } |
35 | 35 |
36 | 36 |
37 /** Not documented yet. */ | 37 /** Not documented yet. */ |
38 class SubscriptionsResourceApi { | 38 class SubscriptionsResourceApi { |
39 final common_internal.ApiRequester _requester; | 39 final common_internal.ApiRequester _requester; |
40 | 40 |
41 SubscriptionsResourceApi(common_internal.ApiRequester client) : | 41 SubscriptionsResourceApi(common_internal.ApiRequester client) : |
42 _requester = client; | 42 _requester = client; |
43 | 43 |
(...skipping 730 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
774 if (topic != null) { | 774 if (topic != null) { |
775 _json["topic"] = topic.map((value) => (value).toJson()).toList(); | 775 _json["topic"] = topic.map((value) => (value).toJson()).toList(); |
776 } | 776 } |
777 return _json; | 777 return _json; |
778 } | 778 } |
779 } | 779 } |
780 | 780 |
781 | 781 |
782 /** Not documented yet. */ | 782 /** Not documented yet. */ |
783 class ModifyAckDeadlineRequest { | 783 class ModifyAckDeadlineRequest { |
784 /** The new Ack deadline. Must be >= 1. */ | 784 /** The new Ack deadline. Must be >= 0. */ |
785 core.int ackDeadlineSeconds; | 785 core.int ackDeadlineSeconds; |
786 | 786 |
787 /** The Ack ID. */ | 787 /** The Ack ID. */ |
788 core.String ackId; | 788 core.String ackId; |
789 | 789 |
790 /** The name of the subscription from which messages are being pulled. */ | 790 /** The name of the subscription from which messages are being pulled. */ |
791 core.String subscription; | 791 core.String subscription; |
792 | 792 |
793 | 793 |
794 ModifyAckDeadlineRequest(); | 794 ModifyAckDeadlineRequest(); |
(...skipping 387 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1182 core.Map toJson() { | 1182 core.Map toJson() { |
1183 var _json = new core.Map(); | 1183 var _json = new core.Map(); |
1184 if (name != null) { | 1184 if (name != null) { |
1185 _json["name"] = name; | 1185 _json["name"] = name; |
1186 } | 1186 } |
1187 return _json; | 1187 return _json; |
1188 } | 1188 } |
1189 } | 1189 } |
1190 | 1190 |
1191 | 1191 |
OLD | NEW |