Roll of googleapis as of 4/7/2015.

generated/googleapis_beta/lib/pubsub/v1beta1.dart

+// This is a generated file (see the discoveryapis_generator project).
+
 library googleapis_beta.pubsub.v1beta1;
 
-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/v1beta1';
 
 /**
  * Provides reliable, many-to-many, asynchronous messaging between applications.
  */
 class PubsubApi {
   /** View and manage your data across Google Cloud Platform services */
   static const CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform";
 
   /** View and manage Pub/Sub topics and subscriptions */
   static const PubsubScope = "https://www.googleapis.com/auth/pubsub";
 
 
-  final common_internal.ApiRequester _requester;
+  final commons.ApiRequester _requester;
 
   SubscriptionsResourceApi get subscriptions => new SubscriptionsResourceApi(_requester);
   TopicsResourceApi get topics => new TopicsResourceApi(_requester);
 
   PubsubApi(http.Client client, {core.String rootUrl: "https://www.googleapis.com/", core.String servicePath: "pubsub/v1beta1/"}) :
-      _requester = new common_internal.ApiRequester(client, rootUrl, servicePath);
+      _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_AGENT);
 }
 
 
-/** Not documented yet. */
 class SubscriptionsResourceApi {
-  final common_internal.ApiRequester _requester;
+  final commons.ApiRequester _requester;
 
-  SubscriptionsResourceApi(common_internal.ApiRequester client) : 
+  SubscriptionsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
    * Acknowledges a particular received message: the Pub/Sub system can remove
    * the given message from the subscription. Acknowledging a message whose Ack
    * deadline has expired may succeed, but the message could have been already
    * redelivered. Acknowledging a message more than once will not result in an
    * error. This is only used for messages received via pull.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
-   * 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,
    * this method  will complete with the same error.
    */
   async.Future acknowledge(AcknowledgeRequest request) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
 
     _downloadOptions = null;
 
     _url = 'subscriptions/acknowledge';
 
@@ skipping 14 matching lines @@
    *
    * If the name is not provided in the request, the server will assign a random
    * name for this subscription on the same project as the topic.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<Subscription> create(Subscription request) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
 
 
     _url = 'subscriptions';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Subscription.fromJson(data));
   }
 
   /**
    * Deletes an existing subscription. All pending messages in the subscription
    * are immediately dropped. Calls to Pull after deletion will return
    * NOT_FOUND.
    *
    * Request parameters:
    *
    * [subscription] - The subscription to delete.
    *
-   * 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,
    * this method  will complete with the same error.
    */
   async.Future delete(core.String subscription) {
     var _url = null;
     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) {
       throw new core.ArgumentError("Parameter subscription is required.");
     }
 
     _downloadOptions = null;
 
-    _url = 'subscriptions/' + common_internal.Escaper.ecapeVariableReserved('$subscription');
+    _url = 'subscriptions/' + commons.Escaper.ecapeVariableReserved('$subscription');
 
     var _response = _requester.request(_url,
                                        "DELETE",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => null);
   }
 
   /**
    * Gets the configuration details of a subscription.
    *
    * Request parameters:
    *
    * [subscription] - The name of the subscription to get.
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<Subscription> get(core.String subscription) {
     var _url = null;
     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) {
       throw new core.ArgumentError("Parameter subscription is required.");
     }
 
 
-    _url = 'subscriptions/' + common_internal.Escaper.ecapeVariableReserved('$subscription');
+    _url = 'subscriptions/' + commons.Escaper.ecapeVariableReserved('$subscription');
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Subscription.fromJson(data));
   }
 
   /**
    * Lists matching subscriptions.
    *
    * Request parameters:
    *
    * [maxResults] - Maximum number of subscriptions to return.
    *
    * [pageToken] - The value obtained in the last ListSubscriptionsResponse for
    * continuation.
    *
    * [query] - A valid label query expression.
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<ListSubscriptionsResponse> list({core.int maxResults, core.String pageToken, core.String query}) {
     var _url = null;
     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 (maxResults != null) {
       _queryParams["maxResults"] = ["${maxResults}"];
     }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (query != null) {
       _queryParams["query"] = [query];
@@ skipping 12 matching lines @@
     return _response.then((data) => new ListSubscriptionsResponse.fromJson(data));
   }
 
   /**
    * Modifies the Ack deadline for a message received from a pull request.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
-   * 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,
    * this method  will complete with the same error.
    */
   async.Future modifyAckDeadline(ModifyAckDeadlineRequest request) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
 
     _downloadOptions = null;
 
     _url = 'subscriptions/modifyAckDeadline';
 
@@ skipping 11 matching lines @@
    * Modifies the PushConfig for a specified subscription. This method can be
    * used to suspend the flow of messages to an endpoint by clearing the
    * PushConfig field in the request. Messages will be accumulated for delivery
    * even if no push configuration is defined or while the configuration is
    * modified.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
-   * 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,
    * this method  will complete with the same error.
    */
   async.Future modifyPushConfig(ModifyPushConfigRequest request) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
 
     _downloadOptions = null;
 
     _url = 'subscriptions/modifyPushConfig';
 
@@ skipping 13 matching lines @@
    * FAILED_PRECONDITION. The system is free to return an UNAVAILABLE error if
    * no messages are available in a reasonable amount of time (to reduce system
    * load).
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<PullResponse> pull(PullRequest request) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
 
 
     _url = 'subscriptions/pull';
 
     var _response = _requester.request(_url,
@@ skipping 10 matching lines @@
    * Pulls messages from the server. Returns an empty list if there are no
    * messages available in the backlog. The system is free to return UNAVAILABLE
    * if there are too many pull requests outstanding for the given subscription.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * Completes with a [PullBatchResponse].
    *
-   * 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,
    * this method  will complete with the same error.
    */
   async.Future<PullBatchResponse> pullBatch(PullBatchRequest request) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
 
 
     _url = 'subscriptions/pullBatch';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new PullBatchResponse.fromJson(data));
   }
 
 }
 
 
-/** Not documented yet. */
 class TopicsResourceApi {
-  final common_internal.ApiRequester _requester;
+  final commons.ApiRequester _requester;
 
-  TopicsResourceApi(common_internal.ApiRequester client) : 
+  TopicsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
    * Creates the given topic with the given name.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<Topic> create(Topic request) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
 
 
     _url = 'topics';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Topic.fromJson(data));
   }
 
   /**
    * Deletes the topic with the given name. All subscriptions to this topic are
    * also deleted. Returns NOT_FOUND if the topic does not exist. After a topic
    * is deleted, a new topic may be created with the same name.
    *
    * Request parameters:
    *
    * [topic] - Name of the topic to delete.
    *
-   * 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,
    * this method  will complete with the same error.
    */
   async.Future delete(core.String topic) {
     var _url = null;
     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) {
       throw new core.ArgumentError("Parameter topic is required.");
     }
 
     _downloadOptions = null;
 
-    _url = 'topics/' + common_internal.Escaper.ecapeVariableReserved('$topic');
+    _url = 'topics/' + commons.Escaper.ecapeVariableReserved('$topic');
 
     var _response = _requester.request(_url,
                                        "DELETE",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => null);
   }
 
   /**
    * Gets the configuration of a topic. Since the topic only has the name
    * attribute, this method is only useful to check the existence of a topic. If
    * other attributes are added in the future, they will be returned here.
    *
    * Request parameters:
    *
    * [topic] - The name of the topic to get.
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<Topic> get(core.String topic) {
     var _url = null;
     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) {
       throw new core.ArgumentError("Parameter topic is required.");
     }
 
 
-    _url = 'topics/' + common_internal.Escaper.ecapeVariableReserved('$topic');
+    _url = 'topics/' + commons.Escaper.ecapeVariableReserved('$topic');
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Topic.fromJson(data));
   }
 
   /**
    * Lists matching topics.
    *
    * Request parameters:
    *
    * [maxResults] - Maximum number of topics to return.
    *
    * [pageToken] - The value obtained in the last ListTopicsResponse for
    * continuation.
    *
    * [query] - A valid label query expression.
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<ListTopicsResponse> list({core.int maxResults, core.String pageToken, core.String query}) {
     var _url = null;
     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 (maxResults != null) {
       _queryParams["maxResults"] = ["${maxResults}"];
     }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (query != null) {
       _queryParams["query"] = [query];
@@ skipping 12 matching lines @@
     return _response.then((data) => new ListTopicsResponse.fromJson(data));
   }
 
   /**
    * Adds a message to the topic. Returns NOT_FOUND if the topic does not exist.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
-   * 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,
    * this method  will complete with the same error.
    */
   async.Future publish(PublishRequest request) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
 
     _downloadOptions = null;
 
     _url = 'topics/publish';
 
@@ skipping 10 matching lines @@
   /**
    * Adds one or more messages to the topic. Returns NOT_FOUND if the topic does
    * not exist.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * Completes with a [PublishBatchResponse].
    *
-   * 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,
    * this method  will complete with the same error.
    */
   async.Future<PublishBatchResponse> publishBatch(PublishBatchRequest request) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
 
 
     _url = 'topics/publishBatch';
 
     var _response = _requester.request(_url,
@@ skipping 733 matching lines @@
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (name != null) {
       _json["name"] = name;
     }
     return _json;
   }
 }
-
-