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 |
index 9a113f2dd32a3678728f37ffabd45aadcc04aa1e..9bd2316d01a30651dab6744b22d281b3fb68b071 100644 |
--- a/generated/googleapis_beta/lib/taskqueue/v1beta2.dart |
+++ b/generated/googleapis_beta/lib/taskqueue/v1beta2.dart |
@@ -9,56 +9,56 @@ import 'dart:convert' as convert; |
import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons; |
import 'package:http/http.dart' as http; |
-export 'package:_discoveryapis_commons/_discoveryapis_commons.dart' show |
- ApiRequestError, DetailedApiRequestError; |
+export 'package:_discoveryapis_commons/_discoveryapis_commons.dart' |
+ show ApiRequestError, DetailedApiRequestError; |
const core.String USER_AGENT = 'dart-api-client taskqueue/v1beta2'; |
-/** Accesses a Google App Engine Pull Task Queue over REST. */ |
+/// Accesses a Google App Engine Pull Task Queue over REST. |
class TaskqueueApi { |
- /** Manage your Tasks and Taskqueues */ |
+ /// 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"; |
- |
+ /// Consume Tasks from your Taskqueues |
+ static const TaskqueueConsumerScope = |
+ "https://www.googleapis.com/auth/taskqueue.consumer"; |
final commons.ApiRequester _requester; |
TaskqueuesResourceApi get taskqueues => new TaskqueuesResourceApi(_requester); |
TasksResourceApi get tasks => new TasksResourceApi(_requester); |
- TaskqueueApi(http.Client client, {core.String rootUrl: "https://www.googleapis.com/", core.String servicePath: "taskqueue/v1beta2/projects/"}) : |
- _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_AGENT); |
+ TaskqueueApi(http.Client client, |
+ {core.String rootUrl: "https://www.googleapis.com/", |
+ core.String servicePath: "taskqueue/v1beta2/projects/"}) |
+ : _requester = |
+ new commons.ApiRequester(client, rootUrl, servicePath, USER_AGENT); |
} |
- |
class TaskqueuesResourceApi { |
final commons.ApiRequester _requester; |
- TaskqueuesResourceApi(commons.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 [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<TaskQueue> get(core.String project, core.String taskqueue, {core.bool getStats}) { |
+ TaskqueuesResourceApi(commons.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 [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<TaskQueue> get(core.String project, core.String taskqueue, |
+ {core.bool getStats}) { |
var _url = null; |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
@@ -76,45 +76,42 @@ class TaskqueuesResourceApi { |
_queryParams["getStats"] = ["${getStats}"]; |
} |
- _url = commons.Escaper.ecapeVariable('$project') + '/taskqueues/' + commons.Escaper.ecapeVariable('$taskqueue'); |
+ _url = commons.Escaper.ecapeVariable('$project') + |
+ '/taskqueues/' + |
+ commons.Escaper.ecapeVariable('$taskqueue'); |
- var _response = _requester.request(_url, |
- "GET", |
- body: _body, |
- queryParams: _queryParams, |
- uploadOptions: _uploadOptions, |
- uploadMedia: _uploadMedia, |
- downloadOptions: _downloadOptions); |
+ var _response = _requester.request(_url, "GET", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
return _response.then((data) => new TaskQueue.fromJson(data)); |
} |
- |
} |
- |
class TasksResourceApi { |
final commons.ApiRequester _requester; |
- TasksResourceApi(commons.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 [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 project, core.String taskqueue, core.String task) { |
+ TasksResourceApi(commons.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 [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 project, core.String taskqueue, core.String task) { |
var _url = null; |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
@@ -134,38 +131,40 @@ class TasksResourceApi { |
_downloadOptions = null; |
- _url = commons.Escaper.ecapeVariable('$project') + '/taskqueues/' + commons.Escaper.ecapeVariable('$taskqueue') + '/tasks/' + commons.Escaper.ecapeVariable('$task'); |
- |
- var _response = _requester.request(_url, |
- "DELETE", |
- body: _body, |
- queryParams: _queryParams, |
- uploadOptions: _uploadOptions, |
- uploadMedia: _uploadMedia, |
- downloadOptions: _downloadOptions); |
+ _url = commons.Escaper.ecapeVariable('$project') + |
+ '/taskqueues/' + |
+ commons.Escaper.ecapeVariable('$taskqueue') + |
+ '/tasks/' + |
+ commons.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 [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<Task> get(core.String project, core.String taskqueue, core.String task) { |
+ /// 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 [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<Task> get( |
+ core.String project, core.String taskqueue, core.String task) { |
var _url = null; |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
@@ -183,38 +182,40 @@ class TasksResourceApi { |
throw new core.ArgumentError("Parameter task is required."); |
} |
- _url = commons.Escaper.ecapeVariable('$project') + '/taskqueues/' + commons.Escaper.ecapeVariable('$taskqueue') + '/tasks/' + commons.Escaper.ecapeVariable('$task'); |
+ _url = commons.Escaper.ecapeVariable('$project') + |
+ '/taskqueues/' + |
+ commons.Escaper.ecapeVariable('$taskqueue') + |
+ '/tasks/' + |
+ commons.Escaper.ecapeVariable('$task'); |
- var _response = _requester.request(_url, |
- "GET", |
- body: _body, |
- queryParams: _queryParams, |
- uploadOptions: _uploadOptions, |
- uploadMedia: _uploadMedia, |
- downloadOptions: _downloadOptions); |
+ 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 [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<Task> insert(Task request, core.String project, core.String taskqueue) { |
+ /// 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 [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<Task> insert( |
+ Task request, core.String project, core.String taskqueue) { |
var _url = null; |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
@@ -232,47 +233,49 @@ class TasksResourceApi { |
throw new core.ArgumentError("Parameter taskqueue is required."); |
} |
- _url = commons.Escaper.ecapeVariable('$project') + '/taskqueues/' + commons.Escaper.ecapeVariable('$taskqueue') + '/tasks'; |
+ _url = commons.Escaper.ecapeVariable('$project') + |
+ '/taskqueues/' + |
+ commons.Escaper.ecapeVariable('$taskqueue') + |
+ '/tasks'; |
- var _response = _requester.request(_url, |
- "POST", |
- body: _body, |
- queryParams: _queryParams, |
- uploadOptions: _uploadOptions, |
- uploadMedia: _uploadMedia, |
- downloadOptions: _downloadOptions); |
+ 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 [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<Tasks> lease(core.String project, core.String taskqueue, core.int numTasks, core.int leaseSecs, {core.bool groupByTag, core.String tag}) { |
+ /// 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 [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<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; |
@@ -301,35 +304,35 @@ class TasksResourceApi { |
_queryParams["tag"] = [tag]; |
} |
- _url = commons.Escaper.ecapeVariable('$project') + '/taskqueues/' + commons.Escaper.ecapeVariable('$taskqueue') + '/tasks/lease'; |
+ _url = commons.Escaper.ecapeVariable('$project') + |
+ '/taskqueues/' + |
+ commons.Escaper.ecapeVariable('$taskqueue') + |
+ '/tasks/lease'; |
- var _response = _requester.request(_url, |
- "POST", |
- body: _body, |
- queryParams: _queryParams, |
- uploadOptions: _uploadOptions, |
- uploadMedia: _uploadMedia, |
- downloadOptions: _downloadOptions); |
+ 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 [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. |
- */ |
+ /// 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 [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<Tasks2> list(core.String project, core.String taskqueue) { |
var _url = null; |
var _queryParams = new core.Map(); |
@@ -345,43 +348,44 @@ class TasksResourceApi { |
throw new core.ArgumentError("Parameter taskqueue is required."); |
} |
- _url = commons.Escaper.ecapeVariable('$project') + '/taskqueues/' + commons.Escaper.ecapeVariable('$taskqueue') + '/tasks'; |
+ _url = commons.Escaper.ecapeVariable('$project') + |
+ '/taskqueues/' + |
+ commons.Escaper.ecapeVariable('$taskqueue') + |
+ '/tasks'; |
- var _response = _requester.request(_url, |
- "GET", |
- body: _body, |
- queryParams: _queryParams, |
- uploadOptions: _uploadOptions, |
- uploadMedia: _uploadMedia, |
- downloadOptions: _downloadOptions); |
+ 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 [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<Task> patch(Task request, core.String project, core.String taskqueue, core.String task, core.int newLeaseSeconds) { |
+ /// 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 [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<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; |
@@ -406,42 +410,44 @@ class TasksResourceApi { |
} |
_queryParams["newLeaseSeconds"] = ["${newLeaseSeconds}"]; |
- _url = commons.Escaper.ecapeVariable('$project') + '/taskqueues/' + commons.Escaper.ecapeVariable('$taskqueue') + '/tasks/' + commons.Escaper.ecapeVariable('$task'); |
- |
- var _response = _requester.request(_url, |
- "PATCH", |
- body: _body, |
- queryParams: _queryParams, |
- uploadOptions: _uploadOptions, |
- uploadMedia: _uploadMedia, |
- downloadOptions: _downloadOptions); |
+ _url = commons.Escaper.ecapeVariable('$project') + |
+ '/taskqueues/' + |
+ commons.Escaper.ecapeVariable('$taskqueue') + |
+ '/tasks/' + |
+ commons.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 [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<Task> update(Task request, core.String project, core.String taskqueue, core.String task, core.int newLeaseSeconds) { |
+ /// 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 [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<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; |
@@ -466,47 +472,48 @@ class TasksResourceApi { |
} |
_queryParams["newLeaseSeconds"] = ["${newLeaseSeconds}"]; |
- _url = commons.Escaper.ecapeVariable('$project') + '/taskqueues/' + commons.Escaper.ecapeVariable('$taskqueue') + '/tasks/' + commons.Escaper.ecapeVariable('$task'); |
- |
- var _response = _requester.request(_url, |
- "POST", |
- body: _body, |
- queryParams: _queryParams, |
- uploadOptions: _uploadOptions, |
- uploadMedia: _uploadMedia, |
- downloadOptions: _downloadOptions); |
+ _url = commons.Escaper.ecapeVariable('$project') + |
+ '/taskqueues/' + |
+ commons.Escaper.ecapeVariable('$taskqueue') + |
+ '/tasks/' + |
+ commons.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)); |
} |
- |
} |
- |
- |
class Task { |
- /** Time (in seconds since the epoch) at which the task was enqueued. */ |
+ /// Time (in seconds since the epoch) at which the task was enqueued. |
core.String enqueueTimestamp; |
- /** Name of the task. */ |
+ |
+ /// Name of the task. |
core.String id; |
- /** The kind of object returned, in this case set to task. */ |
+ |
+ /// 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. |
- */ |
+ |
+ /// 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. |
- */ |
+ |
+ /// 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. */ |
+ |
+ /// Name of the queue that the task is in. |
core.String queueName; |
- /** The number of leases applied to this task. */ |
+ |
+ /// 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. |
- */ |
+ |
+ /// Tag for the task, could be used later to lease tasks grouped by a |
+ /// specific tag. |
core.String tag; |
Task(); |
@@ -539,7 +546,8 @@ class Task { |
} |
core.Map<core.String, core.Object> toJson() { |
- final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>(); |
+ final core.Map<core.String, core.Object> _json = |
+ new core.Map<core.String, core.Object>(); |
if (enqueueTimestamp != null) { |
_json["enqueueTimestamp"] = enqueueTimestamp; |
} |
@@ -568,22 +576,18 @@ class Task { |
} |
} |
-/** ACLs that are applicable to this TaskQueue object. */ |
+/// 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. |
- */ |
+ /// 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. |
- */ |
+ |
+ /// 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. |
- */ |
+ |
+ /// 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(); |
@@ -601,7 +605,8 @@ class TaskQueueAcl { |
} |
core.Map<core.String, core.Object> toJson() { |
- final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>(); |
+ final core.Map<core.String, core.Object> _json = |
+ new core.Map<core.String, core.Object>(); |
if (adminEmails != null) { |
_json["adminEmails"] = adminEmails; |
} |
@@ -615,17 +620,18 @@ class TaskQueueAcl { |
} |
} |
-/** Statistics for the TaskQueue object in question. */ |
+/// Statistics for the TaskQueue object in question. |
class TaskQueueStats { |
- /** Number of tasks leased in the last hour. */ |
+ /// Number of tasks leased in the last hour. |
core.String leasedLastHour; |
- /** Number of tasks leased in the last minute. */ |
+ |
+ /// Number of tasks leased in the last minute. |
core.String leasedLastMinute; |
- /** |
- * The timestamp (in seconds since the epoch) of the oldest unfinished task. |
- */ |
+ |
+ /// The timestamp (in seconds since the epoch) of the oldest unfinished task. |
core.String oldestTask; |
- /** Number of tasks in the queue. */ |
+ |
+ /// Number of tasks in the queue. |
core.int totalTasks; |
TaskQueueStats(); |
@@ -646,7 +652,8 @@ class TaskQueueStats { |
} |
core.Map<core.String, core.Object> toJson() { |
- final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>(); |
+ final core.Map<core.String, core.Object> _json = |
+ new core.Map<core.String, core.Object>(); |
if (leasedLastHour != null) { |
_json["leasedLastHour"] = leasedLastHour; |
} |
@@ -664,18 +671,20 @@ class TaskQueueStats { |
} |
class TaskQueue { |
- /** ACLs that are applicable to this TaskQueue object. */ |
+ /// ACLs that are applicable to this TaskQueue object. |
TaskQueueAcl acl; |
- /** Name of the taskqueue. */ |
+ |
+ /// Name of the taskqueue. |
core.String id; |
- /** The kind of REST object returned, in this case taskqueue. */ |
+ |
+ /// 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. |
- */ |
+ |
+ /// 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. */ |
+ |
+ /// Statistics for the TaskQueue object in question. |
TaskQueueStats stats; |
TaskQueue(); |
@@ -699,7 +708,8 @@ class TaskQueue { |
} |
core.Map<core.String, core.Object> toJson() { |
- final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>(); |
+ final core.Map<core.String, core.Object> _json = |
+ new core.Map<core.String, core.Object>(); |
if (acl != null) { |
_json["acl"] = (acl).toJson(); |
} |
@@ -720,9 +730,10 @@ class TaskQueue { |
} |
class Tasks { |
- /** The actual list of tasks returned as a result of the lease operation. */ |
+ /// 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. */ |
+ |
+ /// The kind of object returned, a list of tasks. |
core.String kind; |
Tasks(); |
@@ -737,7 +748,8 @@ class Tasks { |
} |
core.Map<core.String, core.Object> toJson() { |
- final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>(); |
+ final core.Map<core.String, core.Object> _json = |
+ new core.Map<core.String, core.Object>(); |
if (items != null) { |
_json["items"] = items.map((value) => (value).toJson()).toList(); |
} |
@@ -749,9 +761,10 @@ class Tasks { |
} |
class Tasks2 { |
- /** The actual list of tasks currently active in the TaskQueue. */ |
+ /// The actual list of tasks currently active in the TaskQueue. |
core.List<Task> items; |
- /** The kind of object returned, a list of tasks. */ |
+ |
+ /// The kind of object returned, a list of tasks. |
core.String kind; |
Tasks2(); |
@@ -766,7 +779,8 @@ class Tasks2 { |
} |
core.Map<core.String, core.Object> toJson() { |
- final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>(); |
+ final core.Map<core.String, core.Object> _json = |
+ new core.Map<core.String, core.Object>(); |
if (items != null) { |
_json["items"] = items.map((value) => (value).toJson()).toList(); |
} |