| Index: generated/googleapis_beta/lib/taskqueue/v1beta2.dart
|
| diff --git a/generated/googleapis_beta/lib/taskqueue/v1beta2.dart b/generated/googleapis_beta/lib/taskqueue/v1beta2.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..a36f39b8b858922e53278acf30405960453308a8
|
| --- /dev/null
|
| +++ b/generated/googleapis_beta/lib/taskqueue/v1beta2.dart
|
| @@ -0,0 +1,821 @@
|
| +library googleapis_beta.taskqueue.v1beta2;
|
| +
|
| +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: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;
|
| +
|
| +/** Lets you access a Google App Engine Pull Task Queue over REST. */
|
| +class TaskqueueApi {
|
| + /** Manage your Tasks and Taskqueues */
|
| + static const TaskqueueScope = "https://www.googleapis.com/auth/taskqueue";
|
| +
|
| + /** Consume Tasks from your Taskqueues */
|
| + static const TaskqueueConsumerScope = "https://www.googleapis.com/auth/taskqueue.consumer";
|
| +
|
| +
|
| + final common_internal.ApiRequester _requester;
|
| +
|
| + TaskqueuesResourceApi get taskqueues => new TaskqueuesResourceApi(_requester);
|
| + TasksResourceApi get tasks => new TasksResourceApi(_requester);
|
| +
|
| + TaskqueueApi(http.Client client) :
|
| + _requester = new common_internal.ApiRequester(client, "https://www.googleapis.com/", "/taskqueue/v1beta2/projects/");
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TaskqueuesResourceApi {
|
| + final common_internal.ApiRequester _requester;
|
| +
|
| + TaskqueuesResourceApi(common_internal.ApiRequester client) :
|
| + _requester = client;
|
| +
|
| + /**
|
| + * Get detailed information about a TaskQueue.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [project] - The project under which the queue lies.
|
| + *
|
| + * [taskqueue] - The id of the taskqueue to get the properties of.
|
| + *
|
| + * [getStats] - Whether to get stats. Optional.
|
| + *
|
| + * Completes with a [TaskQueue].
|
| + *
|
| + * Completes with a [common.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<TaskQueue> get(core.String project, core.String taskqueue, {core.bool getStats}) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (project == null) {
|
| + throw new core.ArgumentError("Parameter project is required.");
|
| + }
|
| + if (taskqueue == null) {
|
| + throw new core.ArgumentError("Parameter taskqueue is required.");
|
| + }
|
| + if (getStats != null) {
|
| + _queryParams["getStats"] = ["${getStats}"];
|
| + }
|
| +
|
| +
|
| + _url = common_internal.Escaper.ecapeVariable('$project') + '/taskqueues/' + common_internal.Escaper.ecapeVariable('$taskqueue');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new TaskQueue.fromJson(data));
|
| + }
|
| +
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TasksResourceApi {
|
| + final common_internal.ApiRequester _requester;
|
| +
|
| + TasksResourceApi(common_internal.ApiRequester client) :
|
| + _requester = client;
|
| +
|
| + /**
|
| + * Delete a task from a TaskQueue.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [project] - The project under which the queue lies.
|
| + *
|
| + * [taskqueue] - The taskqueue to delete a task from.
|
| + *
|
| + * [task] - The id of the task to delete.
|
| + *
|
| + * Completes with a [common.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 project, core.String taskqueue, core.String task) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (project == null) {
|
| + throw new core.ArgumentError("Parameter project is required.");
|
| + }
|
| + if (taskqueue == null) {
|
| + throw new core.ArgumentError("Parameter taskqueue is required.");
|
| + }
|
| + if (task == null) {
|
| + throw new core.ArgumentError("Parameter task is required.");
|
| + }
|
| +
|
| + _downloadOptions = null;
|
| +
|
| + _url = common_internal.Escaper.ecapeVariable('$project') + '/taskqueues/' + common_internal.Escaper.ecapeVariable('$taskqueue') + '/tasks/' + common_internal.Escaper.ecapeVariable('$task');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "DELETE",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => null);
|
| + }
|
| +
|
| + /**
|
| + * Get a particular task from a TaskQueue.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [project] - The project under which the queue lies.
|
| + *
|
| + * [taskqueue] - The taskqueue in which the task belongs.
|
| + *
|
| + * [task] - The task to get properties of.
|
| + *
|
| + * Completes with a [Task].
|
| + *
|
| + * Completes with a [common.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<Task> get(core.String project, core.String taskqueue, core.String task) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (project == null) {
|
| + throw new core.ArgumentError("Parameter project is required.");
|
| + }
|
| + if (taskqueue == null) {
|
| + throw new core.ArgumentError("Parameter taskqueue is required.");
|
| + }
|
| + if (task == null) {
|
| + throw new core.ArgumentError("Parameter task is required.");
|
| + }
|
| +
|
| +
|
| + _url = common_internal.Escaper.ecapeVariable('$project') + '/taskqueues/' + common_internal.Escaper.ecapeVariable('$taskqueue') + '/tasks/' + common_internal.Escaper.ecapeVariable('$task');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Task.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Insert a new task in a TaskQueue
|
| + *
|
| + * [request] - The metadata request object.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [project] - The project under which the queue lies
|
| + *
|
| + * [taskqueue] - The taskqueue to insert the task into
|
| + *
|
| + * Completes with a [Task].
|
| + *
|
| + * Completes with a [common.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<Task> insert(Task request, core.String project, core.String taskqueue) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (request != null) {
|
| + _body = convert.JSON.encode((request).toJson());
|
| + }
|
| + if (project == null) {
|
| + throw new core.ArgumentError("Parameter project is required.");
|
| + }
|
| + if (taskqueue == null) {
|
| + throw new core.ArgumentError("Parameter taskqueue is required.");
|
| + }
|
| +
|
| +
|
| + _url = common_internal.Escaper.ecapeVariable('$project') + '/taskqueues/' + common_internal.Escaper.ecapeVariable('$taskqueue') + '/tasks';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "POST",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Task.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Lease 1 or more tasks from a TaskQueue.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [project] - The project under which the queue lies.
|
| + *
|
| + * [taskqueue] - The taskqueue to lease a task from.
|
| + *
|
| + * [numTasks] - The number of tasks to lease.
|
| + *
|
| + * [leaseSecs] - The lease in seconds.
|
| + *
|
| + * [groupByTag] - When true, all returned tasks will have the same tag
|
| + *
|
| + * [tag] - The tag allowed for tasks in the response. Must only be specified
|
| + * if group_by_tag is true. If group_by_tag is true and tag is not specified
|
| + * the tag will be that of the oldest task by eta, i.e. the first available
|
| + * tag
|
| + *
|
| + * Completes with a [Tasks].
|
| + *
|
| + * Completes with a [common.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<Tasks> lease(core.String project, core.String taskqueue, core.int numTasks, core.int leaseSecs, {core.bool groupByTag, core.String tag}) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (project == null) {
|
| + throw new core.ArgumentError("Parameter project is required.");
|
| + }
|
| + if (taskqueue == null) {
|
| + throw new core.ArgumentError("Parameter taskqueue is required.");
|
| + }
|
| + if (numTasks == null) {
|
| + throw new core.ArgumentError("Parameter numTasks is required.");
|
| + }
|
| + _queryParams["numTasks"] = ["${numTasks}"];
|
| + if (leaseSecs == null) {
|
| + throw new core.ArgumentError("Parameter leaseSecs is required.");
|
| + }
|
| + _queryParams["leaseSecs"] = ["${leaseSecs}"];
|
| + if (groupByTag != null) {
|
| + _queryParams["groupByTag"] = ["${groupByTag}"];
|
| + }
|
| + if (tag != null) {
|
| + _queryParams["tag"] = [tag];
|
| + }
|
| +
|
| +
|
| + _url = common_internal.Escaper.ecapeVariable('$project') + '/taskqueues/' + common_internal.Escaper.ecapeVariable('$taskqueue') + '/tasks/lease';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "POST",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Tasks.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * List Tasks in a TaskQueue
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [project] - The project under which the queue lies.
|
| + *
|
| + * [taskqueue] - The id of the taskqueue to list tasks from.
|
| + *
|
| + * Completes with a [Tasks2].
|
| + *
|
| + * Completes with a [common.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<Tasks2> list(core.String project, core.String taskqueue) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (project == null) {
|
| + throw new core.ArgumentError("Parameter project is required.");
|
| + }
|
| + if (taskqueue == null) {
|
| + throw new core.ArgumentError("Parameter taskqueue is required.");
|
| + }
|
| +
|
| +
|
| + _url = common_internal.Escaper.ecapeVariable('$project') + '/taskqueues/' + common_internal.Escaper.ecapeVariable('$taskqueue') + '/tasks';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Tasks2.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Update tasks that are leased out of a TaskQueue. This method supports patch
|
| + * semantics.
|
| + *
|
| + * [request] - The metadata request object.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [project] - The project under which the queue lies.
|
| + *
|
| + * [taskqueue] - null
|
| + *
|
| + * [task] - null
|
| + *
|
| + * [newLeaseSeconds] - The new lease in seconds.
|
| + *
|
| + * Completes with a [Task].
|
| + *
|
| + * Completes with a [common.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<Task> patch(Task request, core.String project, core.String taskqueue, core.String task, core.int newLeaseSeconds) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (request != null) {
|
| + _body = convert.JSON.encode((request).toJson());
|
| + }
|
| + if (project == null) {
|
| + throw new core.ArgumentError("Parameter project is required.");
|
| + }
|
| + if (taskqueue == null) {
|
| + throw new core.ArgumentError("Parameter taskqueue is required.");
|
| + }
|
| + if (task == null) {
|
| + throw new core.ArgumentError("Parameter task is required.");
|
| + }
|
| + if (newLeaseSeconds == null) {
|
| + throw new core.ArgumentError("Parameter newLeaseSeconds is required.");
|
| + }
|
| + _queryParams["newLeaseSeconds"] = ["${newLeaseSeconds}"];
|
| +
|
| +
|
| + _url = common_internal.Escaper.ecapeVariable('$project') + '/taskqueues/' + common_internal.Escaper.ecapeVariable('$taskqueue') + '/tasks/' + common_internal.Escaper.ecapeVariable('$task');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "PATCH",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Task.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Update tasks that are leased out of a TaskQueue.
|
| + *
|
| + * [request] - The metadata request object.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [project] - The project under which the queue lies.
|
| + *
|
| + * [taskqueue] - null
|
| + *
|
| + * [task] - null
|
| + *
|
| + * [newLeaseSeconds] - The new lease in seconds.
|
| + *
|
| + * Completes with a [Task].
|
| + *
|
| + * Completes with a [common.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<Task> update(Task request, core.String project, core.String taskqueue, core.String task, core.int newLeaseSeconds) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (request != null) {
|
| + _body = convert.JSON.encode((request).toJson());
|
| + }
|
| + if (project == null) {
|
| + throw new core.ArgumentError("Parameter project is required.");
|
| + }
|
| + if (taskqueue == null) {
|
| + throw new core.ArgumentError("Parameter taskqueue is required.");
|
| + }
|
| + if (task == null) {
|
| + throw new core.ArgumentError("Parameter task is required.");
|
| + }
|
| + if (newLeaseSeconds == null) {
|
| + throw new core.ArgumentError("Parameter newLeaseSeconds is required.");
|
| + }
|
| + _queryParams["newLeaseSeconds"] = ["${newLeaseSeconds}"];
|
| +
|
| +
|
| + _url = common_internal.Escaper.ecapeVariable('$project') + '/taskqueues/' + common_internal.Escaper.ecapeVariable('$taskqueue') + '/tasks/' + common_internal.Escaper.ecapeVariable('$task');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "POST",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Task.fromJson(data));
|
| + }
|
| +
|
| +}
|
| +
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class Task {
|
| + /** Time (in seconds since the epoch) at which the task was enqueued. */
|
| + core.String enqueueTimestamp;
|
| +
|
| + /** Name of the task. */
|
| + core.String id;
|
| +
|
| + /** The kind of object returned, in this case set to task. */
|
| + core.String kind;
|
| +
|
| + /**
|
| + * Time (in seconds since the epoch) at which the task lease will expire. This
|
| + * value is 0 if the task isnt currently leased out to a worker.
|
| + */
|
| + core.String leaseTimestamp;
|
| +
|
| + /**
|
| + * A bag of bytes which is the task payload. The payload on the JSON side is
|
| + * always Base64 encoded.
|
| + */
|
| + core.String payloadBase64;
|
| +
|
| + /** Name of the queue that the task is in. */
|
| + core.String queueName;
|
| +
|
| + /** The number of leases applied to this task. */
|
| + core.int retryCount;
|
| +
|
| + /**
|
| + * Tag for the task, could be used later to lease tasks grouped by a specific
|
| + * tag.
|
| + */
|
| + core.String tag;
|
| +
|
| +
|
| + Task();
|
| +
|
| + Task.fromJson(core.Map _json) {
|
| + if (_json.containsKey("enqueueTimestamp")) {
|
| + enqueueTimestamp = _json["enqueueTimestamp"];
|
| + }
|
| + if (_json.containsKey("id")) {
|
| + id = _json["id"];
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("leaseTimestamp")) {
|
| + leaseTimestamp = _json["leaseTimestamp"];
|
| + }
|
| + if (_json.containsKey("payloadBase64")) {
|
| + payloadBase64 = _json["payloadBase64"];
|
| + }
|
| + if (_json.containsKey("queueName")) {
|
| + queueName = _json["queueName"];
|
| + }
|
| + if (_json.containsKey("retry_count")) {
|
| + retryCount = _json["retry_count"];
|
| + }
|
| + if (_json.containsKey("tag")) {
|
| + tag = _json["tag"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (enqueueTimestamp != null) {
|
| + _json["enqueueTimestamp"] = enqueueTimestamp;
|
| + }
|
| + if (id != null) {
|
| + _json["id"] = id;
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (leaseTimestamp != null) {
|
| + _json["leaseTimestamp"] = leaseTimestamp;
|
| + }
|
| + if (payloadBase64 != null) {
|
| + _json["payloadBase64"] = payloadBase64;
|
| + }
|
| + if (queueName != null) {
|
| + _json["queueName"] = queueName;
|
| + }
|
| + if (retryCount != null) {
|
| + _json["retry_count"] = retryCount;
|
| + }
|
| + if (tag != null) {
|
| + _json["tag"] = tag;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** ACLs that are applicable to this TaskQueue object. */
|
| +class TaskQueueAcl {
|
| + /**
|
| + * Email addresses of users who are "admins" of the TaskQueue. This means they
|
| + * can control the queue, eg set ACLs for the queue.
|
| + */
|
| + core.List<core.String> adminEmails;
|
| +
|
| + /**
|
| + * Email addresses of users who can "consume" tasks from the TaskQueue. This
|
| + * means they can Dequeue and Delete tasks from the queue.
|
| + */
|
| + core.List<core.String> consumerEmails;
|
| +
|
| + /**
|
| + * Email addresses of users who can "produce" tasks into the TaskQueue. This
|
| + * means they can Insert tasks into the queue.
|
| + */
|
| + core.List<core.String> producerEmails;
|
| +
|
| +
|
| + TaskQueueAcl();
|
| +
|
| + TaskQueueAcl.fromJson(core.Map _json) {
|
| + if (_json.containsKey("adminEmails")) {
|
| + adminEmails = _json["adminEmails"];
|
| + }
|
| + if (_json.containsKey("consumerEmails")) {
|
| + consumerEmails = _json["consumerEmails"];
|
| + }
|
| + if (_json.containsKey("producerEmails")) {
|
| + producerEmails = _json["producerEmails"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (adminEmails != null) {
|
| + _json["adminEmails"] = adminEmails;
|
| + }
|
| + if (consumerEmails != null) {
|
| + _json["consumerEmails"] = consumerEmails;
|
| + }
|
| + if (producerEmails != null) {
|
| + _json["producerEmails"] = producerEmails;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Statistics for the TaskQueue object in question. */
|
| +class TaskQueueStats {
|
| + /** Number of tasks leased in the last hour. */
|
| + core.String leasedLastHour;
|
| +
|
| + /** Number of tasks leased in the last minute. */
|
| + core.String leasedLastMinute;
|
| +
|
| + /**
|
| + * The timestamp (in seconds since the epoch) of the oldest unfinished task.
|
| + */
|
| + core.String oldestTask;
|
| +
|
| + /** Number of tasks in the queue. */
|
| + core.int totalTasks;
|
| +
|
| +
|
| + TaskQueueStats();
|
| +
|
| + TaskQueueStats.fromJson(core.Map _json) {
|
| + if (_json.containsKey("leasedLastHour")) {
|
| + leasedLastHour = _json["leasedLastHour"];
|
| + }
|
| + if (_json.containsKey("leasedLastMinute")) {
|
| + leasedLastMinute = _json["leasedLastMinute"];
|
| + }
|
| + if (_json.containsKey("oldestTask")) {
|
| + oldestTask = _json["oldestTask"];
|
| + }
|
| + if (_json.containsKey("totalTasks")) {
|
| + totalTasks = _json["totalTasks"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (leasedLastHour != null) {
|
| + _json["leasedLastHour"] = leasedLastHour;
|
| + }
|
| + if (leasedLastMinute != null) {
|
| + _json["leasedLastMinute"] = leasedLastMinute;
|
| + }
|
| + if (oldestTask != null) {
|
| + _json["oldestTask"] = oldestTask;
|
| + }
|
| + if (totalTasks != null) {
|
| + _json["totalTasks"] = totalTasks;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TaskQueue {
|
| + /** ACLs that are applicable to this TaskQueue object. */
|
| + TaskQueueAcl acl;
|
| +
|
| + /** Name of the taskqueue. */
|
| + core.String id;
|
| +
|
| + /** The kind of REST object returned, in this case taskqueue. */
|
| + core.String kind;
|
| +
|
| + /**
|
| + * The number of times we should lease out tasks before giving up on them. If
|
| + * unset we lease them out forever until a worker deletes the task.
|
| + */
|
| + core.int maxLeases;
|
| +
|
| + /** Statistics for the TaskQueue object in question. */
|
| + TaskQueueStats stats;
|
| +
|
| +
|
| + TaskQueue();
|
| +
|
| + TaskQueue.fromJson(core.Map _json) {
|
| + if (_json.containsKey("acl")) {
|
| + acl = new TaskQueueAcl.fromJson(_json["acl"]);
|
| + }
|
| + if (_json.containsKey("id")) {
|
| + id = _json["id"];
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("maxLeases")) {
|
| + maxLeases = _json["maxLeases"];
|
| + }
|
| + if (_json.containsKey("stats")) {
|
| + stats = new TaskQueueStats.fromJson(_json["stats"]);
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (acl != null) {
|
| + _json["acl"] = (acl).toJson();
|
| + }
|
| + if (id != null) {
|
| + _json["id"] = id;
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (maxLeases != null) {
|
| + _json["maxLeases"] = maxLeases;
|
| + }
|
| + if (stats != null) {
|
| + _json["stats"] = (stats).toJson();
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class Tasks {
|
| + /** The actual list of tasks returned as a result of the lease operation. */
|
| + core.List<Task> items;
|
| +
|
| + /** The kind of object returned, a list of tasks. */
|
| + core.String kind;
|
| +
|
| +
|
| + Tasks();
|
| +
|
| + Tasks.fromJson(core.Map _json) {
|
| + if (_json.containsKey("items")) {
|
| + items = _json["items"].map((value) => new Task.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (items != null) {
|
| + _json["items"] = items.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class Tasks2 {
|
| + /** The actual list of tasks currently active in the TaskQueue. */
|
| + core.List<Task> items;
|
| +
|
| + /** The kind of object returned, a list of tasks. */
|
| + core.String kind;
|
| +
|
| +
|
| + Tasks2();
|
| +
|
| + Tasks2.fromJson(core.Map _json) {
|
| + if (_json.containsKey("items")) {
|
| + items = _json["items"].map((value) => new Task.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (items != null) {
|
| + _json["items"] = items.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
|
|