| 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 |