Index: generated/googleapis_beta/lib/pubsub/v1beta2.dart |
diff --git a/generated/googleapis_beta/lib/pubsub/v1beta2.dart b/generated/googleapis_beta/lib/pubsub/v1beta2.dart |
index 0b59e75f0529bbec20c1a0114ae62e14381a483e..ef9072ac1f8fec272f9729ed5a8c93dbe616b489 100644 |
--- a/generated/googleapis_beta/lib/pubsub/v1beta2.dart |
+++ b/generated/googleapis_beta/lib/pubsub/v1beta2.dart |
@@ -1,17 +1,20 @@ |
+// This is a generated file (see the discoveryapis_generator project). |
+ |
library googleapis_beta.pubsub.v1beta2; |
-import "dart:core" as core; |
-import "dart:collection" as collection; |
-import "dart:async" as async; |
-import "dart:convert" as convert; |
+import 'dart:core' as core; |
+import 'dart:collection' as collection; |
+import 'dart:async' as async; |
+import 'dart:convert' as convert; |
-import "package:crypto/crypto.dart" as crypto; |
+import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons; |
+import 'package:crypto/crypto.dart' as crypto; |
import 'package:http/http.dart' as http; |
-import '../src/common_internal.dart' as common_internal; |
-import '../common/common.dart' as common; |
-export '../common/common.dart' show ApiRequestError; |
-export '../common/common.dart' show DetailedApiRequestError; |
+export 'package:_discoveryapis_commons/_discoveryapis_commons.dart' show |
+ ApiRequestError, DetailedApiRequestError; |
+ |
+const core.String USER_AGENT = 'dart-api-client pubsub/v1beta2'; |
/** |
* Provides reliable, many-to-many, asynchronous messaging between applications. |
@@ -24,32 +27,30 @@ class PubsubApi { |
static const PubsubScope = "https://www.googleapis.com/auth/pubsub"; |
- final common_internal.ApiRequester _requester; |
+ final commons.ApiRequester _requester; |
ProjectsResourceApi get projects => new ProjectsResourceApi(_requester); |
PubsubApi(http.Client client, {core.String rootUrl: "https://pubsub.googleapis.com/", core.String servicePath: "v1beta2/"}) : |
- _requester = new common_internal.ApiRequester(client, rootUrl, servicePath); |
+ _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_AGENT); |
} |
-/** Not documented yet. */ |
class ProjectsResourceApi { |
- final common_internal.ApiRequester _requester; |
+ final commons.ApiRequester _requester; |
ProjectsSubscriptionsResourceApi get subscriptions => new ProjectsSubscriptionsResourceApi(_requester); |
ProjectsTopicsResourceApi get topics => new ProjectsTopicsResourceApi(_requester); |
- ProjectsResourceApi(common_internal.ApiRequester client) : |
+ ProjectsResourceApi(commons.ApiRequester client) : |
_requester = client; |
} |
-/** Not documented yet. */ |
class ProjectsSubscriptionsResourceApi { |
- final common_internal.ApiRequester _requester; |
+ final commons.ApiRequester _requester; |
- ProjectsSubscriptionsResourceApi(common_internal.ApiRequester client) : |
+ ProjectsSubscriptionsResourceApi(commons.ApiRequester client) : |
_requester = client; |
/** |
@@ -67,7 +68,7 @@ class ProjectsSubscriptionsResourceApi { |
* |
* Completes with a [Empty]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -78,7 +79,7 @@ class ProjectsSubscriptionsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (request != null) { |
@@ -89,7 +90,7 @@ class ProjectsSubscriptionsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$subscription') + ':acknowledge'; |
+ _url = commons.Escaper.ecapeVariableReserved('$subscription') + ':acknowledge'; |
var _response = _requester.request(_url, |
"POST", |
@@ -116,7 +117,7 @@ class ProjectsSubscriptionsResourceApi { |
* |
* Completes with a [Subscription]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -127,7 +128,7 @@ class ProjectsSubscriptionsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (request != null) { |
@@ -138,7 +139,7 @@ class ProjectsSubscriptionsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$name'); |
+ _url = commons.Escaper.ecapeVariableReserved('$name'); |
var _response = _requester.request(_url, |
"PUT", |
@@ -163,7 +164,7 @@ class ProjectsSubscriptionsResourceApi { |
* |
* Completes with a [Empty]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -174,7 +175,7 @@ class ProjectsSubscriptionsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (subscription == null) { |
@@ -182,7 +183,7 @@ class ProjectsSubscriptionsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$subscription'); |
+ _url = commons.Escaper.ecapeVariableReserved('$subscription'); |
var _response = _requester.request(_url, |
"DELETE", |
@@ -203,7 +204,7 @@ class ProjectsSubscriptionsResourceApi { |
* |
* Completes with a [Subscription]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -214,7 +215,7 @@ class ProjectsSubscriptionsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (subscription == null) { |
@@ -222,7 +223,7 @@ class ProjectsSubscriptionsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$subscription'); |
+ _url = commons.Escaper.ecapeVariableReserved('$subscription'); |
var _response = _requester.request(_url, |
"GET", |
@@ -247,7 +248,7 @@ class ProjectsSubscriptionsResourceApi { |
* |
* Completes with a [ListSubscriptionsResponse]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -258,7 +259,7 @@ class ProjectsSubscriptionsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (project == null) { |
@@ -272,7 +273,7 @@ class ProjectsSubscriptionsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$project') + '/subscriptions'; |
+ _url = commons.Escaper.ecapeVariableReserved('$project') + '/subscriptions'; |
var _response = _requester.request(_url, |
"GET", |
@@ -298,7 +299,7 @@ class ProjectsSubscriptionsResourceApi { |
* |
* Completes with a [Empty]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -309,7 +310,7 @@ class ProjectsSubscriptionsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (request != null) { |
@@ -320,7 +321,7 @@ class ProjectsSubscriptionsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$subscription') + ':modifyAckDeadline'; |
+ _url = commons.Escaper.ecapeVariableReserved('$subscription') + ':modifyAckDeadline'; |
var _response = _requester.request(_url, |
"POST", |
@@ -347,7 +348,7 @@ class ProjectsSubscriptionsResourceApi { |
* |
* Completes with a [Empty]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -358,7 +359,7 @@ class ProjectsSubscriptionsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (request != null) { |
@@ -369,7 +370,7 @@ class ProjectsSubscriptionsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$subscription') + ':modifyPushConfig'; |
+ _url = commons.Escaper.ecapeVariableReserved('$subscription') + ':modifyPushConfig'; |
var _response = _requester.request(_url, |
"POST", |
@@ -395,7 +396,7 @@ class ProjectsSubscriptionsResourceApi { |
* |
* Completes with a [PullResponse]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -406,7 +407,7 @@ class ProjectsSubscriptionsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (request != null) { |
@@ -417,7 +418,7 @@ class ProjectsSubscriptionsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$subscription') + ':pull'; |
+ _url = commons.Escaper.ecapeVariableReserved('$subscription') + ':pull'; |
var _response = _requester.request(_url, |
"POST", |
@@ -432,13 +433,12 @@ class ProjectsSubscriptionsResourceApi { |
} |
-/** Not documented yet. */ |
class ProjectsTopicsResourceApi { |
- final common_internal.ApiRequester _requester; |
+ final commons.ApiRequester _requester; |
ProjectsTopicsSubscriptionsResourceApi get subscriptions => new ProjectsTopicsSubscriptionsResourceApi(_requester); |
- ProjectsTopicsResourceApi(common_internal.ApiRequester client) : |
+ ProjectsTopicsResourceApi(commons.ApiRequester client) : |
_requester = client; |
/** |
@@ -452,7 +452,7 @@ class ProjectsTopicsResourceApi { |
* |
* Completes with a [Topic]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -463,7 +463,7 @@ class ProjectsTopicsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (request != null) { |
@@ -474,7 +474,7 @@ class ProjectsTopicsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$name'); |
+ _url = commons.Escaper.ecapeVariableReserved('$name'); |
var _response = _requester.request(_url, |
"PUT", |
@@ -487,11 +487,10 @@ class ProjectsTopicsResourceApi { |
} |
/** |
- * Deletes the topic with the given name. All subscriptions to this topic are |
- * detached from the topic. Returns NOT_FOUND if the topic does not exist. |
- * After a topic is deleted, a new topic may be created with the same name; |
- * this is an entirely new topic with none of the old configuration or |
- * subscriptions. |
+ * Deletes the topic with the given name. Returns NOT_FOUND if the topic does |
+ * not exist. After a topic is deleted, a new topic may be created with the |
+ * same name; this is an entirely new topic with none of the old configuration |
+ * or subscriptions. Existing subscriptions to this topic are not deleted. |
* |
* Request parameters: |
* |
@@ -499,7 +498,7 @@ class ProjectsTopicsResourceApi { |
* |
* Completes with a [Empty]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -510,7 +509,7 @@ class ProjectsTopicsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (topic == null) { |
@@ -518,7 +517,7 @@ class ProjectsTopicsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$topic'); |
+ _url = commons.Escaper.ecapeVariableReserved('$topic'); |
var _response = _requester.request(_url, |
"DELETE", |
@@ -539,7 +538,7 @@ class ProjectsTopicsResourceApi { |
* |
* Completes with a [Topic]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -550,7 +549,7 @@ class ProjectsTopicsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (topic == null) { |
@@ -558,7 +557,7 @@ class ProjectsTopicsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$topic'); |
+ _url = commons.Escaper.ecapeVariableReserved('$topic'); |
var _response = _requester.request(_url, |
"GET", |
@@ -583,7 +582,7 @@ class ProjectsTopicsResourceApi { |
* |
* Completes with a [ListTopicsResponse]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -594,7 +593,7 @@ class ProjectsTopicsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (project == null) { |
@@ -608,7 +607,7 @@ class ProjectsTopicsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$project') + '/topics'; |
+ _url = commons.Escaper.ecapeVariableReserved('$project') + '/topics'; |
var _response = _requester.request(_url, |
"GET", |
@@ -632,7 +631,7 @@ class ProjectsTopicsResourceApi { |
* |
* Completes with a [PublishResponse]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -643,7 +642,7 @@ class ProjectsTopicsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (request != null) { |
@@ -654,7 +653,7 @@ class ProjectsTopicsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$topic') + ':publish'; |
+ _url = commons.Escaper.ecapeVariableReserved('$topic') + ':publish'; |
var _response = _requester.request(_url, |
"POST", |
@@ -669,11 +668,10 @@ class ProjectsTopicsResourceApi { |
} |
-/** Not documented yet. */ |
class ProjectsTopicsSubscriptionsResourceApi { |
- final common_internal.ApiRequester _requester; |
+ final commons.ApiRequester _requester; |
- ProjectsTopicsSubscriptionsResourceApi(common_internal.ApiRequester client) : |
+ ProjectsTopicsSubscriptionsResourceApi(commons.ApiRequester client) : |
_requester = client; |
/** |
@@ -689,7 +687,7 @@ class ProjectsTopicsSubscriptionsResourceApi { |
* |
* Completes with a [ListTopicSubscriptionsResponse]. |
* |
- * Completes with a [common.ApiRequestError] if the API endpoint returned an |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
* error. |
* |
* If the used [http.Client] completes with an error when making a REST call, |
@@ -700,7 +698,7 @@ class ProjectsTopicsSubscriptionsResourceApi { |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
var _uploadOptions = null; |
- var _downloadOptions = common.DownloadOptions.Metadata; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
var _body = null; |
if (topic == null) { |
@@ -714,7 +712,7 @@ class ProjectsTopicsSubscriptionsResourceApi { |
} |
- _url = common_internal.Escaper.ecapeVariableReserved('$topic') + '/subscriptions'; |
+ _url = commons.Escaper.ecapeVariableReserved('$topic') + '/subscriptions'; |
var _response = _requester.request(_url, |
"GET", |
@@ -730,9 +728,7 @@ class ProjectsTopicsSubscriptionsResourceApi { |
-/** Not documented yet. */ |
class AcknowledgeRequest { |
- /** Not documented yet. */ |
core.List<core.String> ackIds; |
@@ -754,7 +750,6 @@ class AcknowledgeRequest { |
} |
-/** Not documented yet. */ |
class Empty { |
Empty(); |
@@ -769,12 +764,9 @@ class Empty { |
} |
-/** Not documented yet. */ |
class ListSubscriptionsResponse { |
- /** Not documented yet. */ |
core.String nextPageToken; |
- /** Not documented yet. */ |
core.List<Subscription> subscriptions; |
@@ -802,12 +794,9 @@ class ListSubscriptionsResponse { |
} |
-/** Not documented yet. */ |
class ListTopicSubscriptionsResponse { |
- /** Not documented yet. */ |
core.String nextPageToken; |
- /** Not documented yet. */ |
core.List<core.String> subscriptions; |
@@ -835,12 +824,9 @@ class ListTopicSubscriptionsResponse { |
} |
-/** Not documented yet. */ |
class ListTopicsResponse { |
- /** Not documented yet. */ |
core.String nextPageToken; |
- /** Not documented yet. */ |
core.List<Topic> topics; |
@@ -868,12 +854,9 @@ class ListTopicsResponse { |
} |
-/** Not documented yet. */ |
class ModifyAckDeadlineRequest { |
- /** Not documented yet. */ |
core.int ackDeadlineSeconds; |
- /** Not documented yet. */ |
core.String ackId; |
@@ -901,9 +884,7 @@ class ModifyAckDeadlineRequest { |
} |
-/** Not documented yet. */ |
class ModifyPushConfigRequest { |
- /** Not documented yet. */ |
PushConfig pushConfig; |
@@ -925,9 +906,7 @@ class ModifyPushConfigRequest { |
} |
-/** Not documented yet. */ |
class PublishRequest { |
- /** Not documented yet. */ |
core.List<PubsubMessage> messages; |
@@ -949,9 +928,7 @@ class PublishRequest { |
} |
-/** Not documented yet. */ |
class PublishResponse { |
- /** Not documented yet. */ |
core.List<core.String> messageIds; |
@@ -973,12 +950,9 @@ class PublishResponse { |
} |
-/** Not documented yet. */ |
class PubsubMessage { |
- /** Not documented yet. */ |
core.Map<core.String, core.String> attributes; |
- /** Not documented yet. */ |
core.String data; |
core.List<core.int> get dataAsBytes { |
@@ -989,7 +963,6 @@ class PubsubMessage { |
data = crypto.CryptoUtils.bytesToBase64(_bytes, urlSafe: true); |
} |
- /** Not documented yet. */ |
core.String messageId; |
@@ -1023,12 +996,9 @@ class PubsubMessage { |
} |
-/** Not documented yet. */ |
class PullRequest { |
- /** Not documented yet. */ |
core.int maxMessages; |
- /** Not documented yet. */ |
core.bool returnImmediately; |
@@ -1056,9 +1026,7 @@ class PullRequest { |
} |
-/** Not documented yet. */ |
class PullResponse { |
- /** Not documented yet. */ |
core.List<ReceivedMessage> receivedMessages; |
@@ -1080,12 +1048,9 @@ class PullResponse { |
} |
-/** Not documented yet. */ |
class PushConfig { |
- /** Not documented yet. */ |
core.Map<core.String, core.String> attributes; |
- /** Not documented yet. */ |
core.String pushEndpoint; |
@@ -1113,12 +1078,9 @@ class PushConfig { |
} |
-/** Not documented yet. */ |
class ReceivedMessage { |
- /** Not documented yet. */ |
core.String ackId; |
- /** Not documented yet. */ |
PubsubMessage message; |
@@ -1146,18 +1108,13 @@ class ReceivedMessage { |
} |
-/** Not documented yet. */ |
class Subscription { |
- /** Not documented yet. */ |
core.int ackDeadlineSeconds; |
- /** Not documented yet. */ |
core.String name; |
- /** Not documented yet. */ |
PushConfig pushConfig; |
- /** Not documented yet. */ |
core.String topic; |
@@ -1197,9 +1154,7 @@ class Subscription { |
} |
-/** Not documented yet. */ |
class Topic { |
- /** Not documented yet. */ |
core.String name; |
@@ -1219,5 +1174,3 @@ class Topic { |
return _json; |
} |
} |
- |
- |