Api-roll 40: 2016-08-08

generated/googleapis_beta/lib/dataflow/v1b3.dart

 // This is a generated file (see the discoveryapis_generator project).
 
 library googleapis_beta.dataflow.v1b3;
 
 import 'dart:core' as core;
 import 'dart:async' as async;
 import 'dart:convert' as convert;
 
 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons;
 import 'package:http/http.dart' as http;
@@ skipping 21 matching lines @@
 
   DataflowApi(http.Client client, {core.String rootUrl: "https://dataflow.googleapis.com/", core.String servicePath: ""}) :
       _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_AGENT);
 }
 
 
 class ProjectsResourceApi {
   final commons.ApiRequester _requester;
 
   ProjectsJobsResourceApi get jobs => new ProjectsJobsResourceApi(_requester);
+  ProjectsTemplatesResourceApi get templates => new ProjectsTemplatesResourceApi(_requester);
 
   ProjectsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
    * Send a worker_message to the service.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
@@ skipping 34 matching lines @@
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new SendWorkerMessagesResponse.fromJson(data));
   }
 
 }
 
 
 class ProjectsJobsResourceApi {
   final commons.ApiRequester _requester;
 
+  ProjectsJobsDebugResourceApi get debug => new ProjectsJobsDebugResourceApi(_requester);
   ProjectsJobsMessagesResourceApi get messages => new ProjectsJobsMessagesResourceApi(_requester);
   ProjectsJobsWorkItemsResourceApi get workItems => new ProjectsJobsWorkItemsResourceApi(_requester);
 
   ProjectsJobsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
    * Creates a dataflow job.
    *
    * [request] - The metadata request object.
@@ skipping 270 matching lines @@
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
 }
 
 
+class ProjectsJobsDebugResourceApi {
+  final commons.ApiRequester _requester;
+
+  ProjectsJobsDebugResourceApi(commons.ApiRequester client) : 
+      _requester = client;
+
+  /**
+   * Get encoded debug configuration for component. Not cacheable.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - The project id.
+   *
+   * [jobId] - The job id.
+   *
+   * Completes with a [GetDebugConfigResponse].
+   *
+   * 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<GetDebugConfigResponse> getConfig(GetDebugConfigRequest request, core.String projectId, core.String jobId) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (jobId == null) {
+      throw new core.ArgumentError("Parameter jobId is required.");
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/debug/getConfig';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new GetDebugConfigResponse.fromJson(data));
+  }
+
+  /**
+   * Send encoded debug capture data for component.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - The project id.
+   *
+   * [jobId] - The job id.
+   *
+   * Completes with a [SendDebugCaptureResponse].
+   *
+   * 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<SendDebugCaptureResponse> sendCapture(SendDebugCaptureRequest request, core.String projectId, core.String jobId) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (jobId == null) {
+      throw new core.ArgumentError("Parameter jobId is required.");
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/debug/sendCapture';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new SendDebugCaptureResponse.fromJson(data));
+  }
+
+}
+
+
 class ProjectsJobsMessagesResourceApi {
   final commons.ApiRequester _requester;
 
   ProjectsJobsMessagesResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
    * Request the job status.
    *
    * Request parameters:
@@ skipping 179 matching lines @@
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new ReportWorkItemStatusResponse.fromJson(data));
   }
 
 }
 
 
+class ProjectsTemplatesResourceApi {
+  final commons.ApiRequester _requester;
+
+  ProjectsTemplatesResourceApi(commons.ApiRequester client) : 
+      _requester = client;
+
+  /**
+   * Creates a dataflow job from a template.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - The project which owns the job.
+   *
+   * Completes with a [Job].
+   *
+   * 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<Job> create(CreateJobFromTemplateRequest request, core.String projectId) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/templates';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new Job.fromJson(data));
+  }
+
+}
+
+
 
 /**
  * Obsolete in favor of ApproximateReportedProgress and ApproximateSplitRequest.
  */
 class ApproximateProgress {
   /** Obsolete. */
   core.double percentComplete;
   /** Obsolete. */
   Position position;
   /** Obsolete. */
@@ skipping 604 matching lines @@
     if (stringList != null) {
       _json["stringList"] = (stringList).toJson();
     }
     if (structuredNameAndMetadata != null) {
       _json["structuredNameAndMetadata"] = (structuredNameAndMetadata).toJson();
     }
     return _json;
   }
 }
 
+/** Request to create a Dataflow job. */
+class CreateJobFromTemplateRequest {
+  /** A path to the serialized JSON representation of the job. */
+  core.String gcsPath;
+  /** Dynamic parameterization of the job's runtime environment. */
+  core.Map<core.String, core.String> parameters;
+
+  CreateJobFromTemplateRequest();
+
+  CreateJobFromTemplateRequest.fromJson(core.Map _json) {
+    if (_json.containsKey("gcsPath")) {
+      gcsPath = _json["gcsPath"];
+    }
+    if (_json.containsKey("parameters")) {
+      parameters = _json["parameters"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (gcsPath != null) {
+      _json["gcsPath"] = gcsPath;
+    }
+    if (parameters != null) {
+      _json["parameters"] = parameters;
+    }
+    return _json;
+  }
+}
+
 /** Identifies the location of a custom souce. */
 class CustomSourceLocation {
   /** Whether this source is stateful. */
   core.bool stateful;
 
   CustomSourceLocation();
 
   CustomSourceLocation.fromJson(core.Map _json) {
     if (_json.containsKey("stateful")) {
       stateful = _json["stateful"];
@@ skipping 385 matching lines @@
     if (count != null) {
       _json["count"] = (count).toJson();
     }
     if (sum != null) {
       _json["sum"] = sum;
     }
     return _json;
   }
 }
 
+/** Request to get updated debug configuration for component. */
+class GetDebugConfigRequest {
+  /** The internal component id for which debug configuration is requested. */
+  core.String componentId;
+  /** The worker id, i.e., VM hostname. */
+  core.String workerId;
+
+  GetDebugConfigRequest();
+
+  GetDebugConfigRequest.fromJson(core.Map _json) {
+    if (_json.containsKey("componentId")) {
+      componentId = _json["componentId"];
+    }
+    if (_json.containsKey("workerId")) {
+      workerId = _json["workerId"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (componentId != null) {
+      _json["componentId"] = componentId;
+    }
+    if (workerId != null) {
+      _json["workerId"] = workerId;
+    }
+    return _json;
+  }
+}
+
+/** Response to a get debug configuration request. */
+class GetDebugConfigResponse {
+  /** The encoded debug configuration for the requested component. */
+  core.String config;
+
+  GetDebugConfigResponse();
+
+  GetDebugConfigResponse.fromJson(core.Map _json) {
+    if (_json.containsKey("config")) {
+      config = _json["config"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (config != null) {
+      _json["config"] = config;
+    }
+    return _json;
+  }
+}
+
 /**
  * An input of an instruction, as a reference to an output of a producer
  * instruction.
  */
 class InstructionInput {
   /** The output index (origin zero) within the producer. */
   core.int outputNum;
   /**
    * The index (origin zero) of the parallel instruction that produces the
    * output to be consumed by this input. This index is relative to the list of
@@ skipping 1697 matching lines @@
     if (isInfinite != null) {
       _json["isInfinite"] = isInfinite;
     }
     if (value != null) {
       _json["value"] = value;
     }
     return _json;
   }
 }
 
+/** Request to send encoded debug information. */
+class SendDebugCaptureRequest {
+  /** The internal component id for which debug information is sent. */
+  core.String componentId;
+  /** The encoded debug information. */
+  core.String data;
+  /** The worker id, i.e., VM hostname. */
+  core.String workerId;
+
+  SendDebugCaptureRequest();
+
+  SendDebugCaptureRequest.fromJson(core.Map _json) {
+    if (_json.containsKey("componentId")) {
+      componentId = _json["componentId"];
+    }
+    if (_json.containsKey("data")) {
+      data = _json["data"];
+    }
+    if (_json.containsKey("workerId")) {
+      workerId = _json["workerId"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (componentId != null) {
+      _json["componentId"] = componentId;
+    }
+    if (data != null) {
+      _json["data"] = data;
+    }
+    if (workerId != null) {
+      _json["workerId"] = workerId;
+    }
+    return _json;
+  }
+}
+
+/** Response to a send capture request. nothing */
+class SendDebugCaptureResponse {
+
+  SendDebugCaptureResponse();
+
+  SendDebugCaptureResponse.fromJson(core.Map _json) {
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    return _json;
+  }
+}
+
 /** A request for sending worker messages to the service. */
 class SendWorkerMessagesRequest {
   /** The WorkerMessages to send. */
   core.List<WorkerMessage> workerMessages;
 
   SendWorkerMessagesRequest();
 
   SendWorkerMessagesRequest.fromJson(core.Map _json) {
     if (_json.containsKey("workerMessages")) {
       workerMessages = _json["workerMessages"].map((value) => new WorkerMessage.fromJson(value)).toList();
@@ skipping 2173 matching lines @@
    */
   core.int diskSizeGb;
   /** Fully qualified source image for disks. */
   core.String diskSourceImage;
   /**
    * Type of root disk for VMs. If empty or unspecified, the service will
    * attempt to choose a reasonable default.
    */
   core.String diskType;
   /**
+   * Configuration for VM IPs.
+   * Possible string values are:
+   * - "WORKER_IP_UNSPECIFIED" : A WORKER_IP_UNSPECIFIED.
+   * - "WORKER_IP_PUBLIC" : A WORKER_IP_PUBLIC.
+   * - "WORKER_IP_PRIVATE" : A WORKER_IP_PRIVATE.
+   */
+  core.String ipConfiguration;
+  /**
    * The kind of the worker pool; currently only 'harness' and 'shuffle' are
    * supported.
    */
   core.String kind;
   /**
    * Machine type (e.g. "n1-standard-1"). If empty or unspecified, the service
    * will attempt to choose a reasonable default.
    */
   core.String machineType;
   /** Metadata to set on the Google Compute Engine VMs. */
@@ skipping 83 matching lines @@
     }
     if (_json.containsKey("diskSizeGb")) {
       diskSizeGb = _json["diskSizeGb"];
     }
     if (_json.containsKey("diskSourceImage")) {
       diskSourceImage = _json["diskSourceImage"];
     }
     if (_json.containsKey("diskType")) {
       diskType = _json["diskType"];
     }
+    if (_json.containsKey("ipConfiguration")) {
+      ipConfiguration = _json["ipConfiguration"];
+    }
     if (_json.containsKey("kind")) {
       kind = _json["kind"];
     }
     if (_json.containsKey("machineType")) {
       machineType = _json["machineType"];
     }
     if (_json.containsKey("metadata")) {
       metadata = _json["metadata"];
     }
     if (_json.containsKey("network")) {
@@ skipping 44 matching lines @@
     }
     if (diskSizeGb != null) {
       _json["diskSizeGb"] = diskSizeGb;
     }
     if (diskSourceImage != null) {
       _json["diskSourceImage"] = diskSourceImage;
     }
     if (diskType != null) {
       _json["diskType"] = diskType;
     }
+    if (ipConfiguration != null) {
+      _json["ipConfiguration"] = ipConfiguration;
+    }
     if (kind != null) {
       _json["kind"] = kind;
     }
     if (machineType != null) {
       _json["machineType"] = machineType;
     }
     if (metadata != null) {
       _json["metadata"] = metadata;
     }
     if (network != null) {
@@ skipping 137 matching lines @@
     var _json = new core.Map();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     return _json;
   }
 }