Api-roll 33: 2016-03-14

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 3745 matching lines @@
     }
     if (taskType != null) {
       _json["taskType"] = taskType;
     }
     return _json;
   }
 }
 
 /** A task which initializes part of a streaming Dataflow job. */
 class StreamingSetupTask {
+  /** The user has requested drain. */
+  core.bool drain;
   /**
    * The TCP port on which the worker should listen for messages from other
    * streaming computation workers.
    */
   core.int receiveWorkPort;
   /** The global topology of the streaming Dataflow job. */
   TopologyConfig streamingComputationTopology;
   /**
    * The TCP port used by the worker to communicate with the Dataflow worker
    * harness.
    */
   core.int workerHarnessPort;
 
   StreamingSetupTask();
 
   StreamingSetupTask.fromJson(core.Map _json) {
+    if (_json.containsKey("drain")) {
+      drain = _json["drain"];
+    }
     if (_json.containsKey("receiveWorkPort")) {
       receiveWorkPort = _json["receiveWorkPort"];
     }
     if (_json.containsKey("streamingComputationTopology")) {
       streamingComputationTopology = new TopologyConfig.fromJson(_json["streamingComputationTopology"]);
     }
     if (_json.containsKey("workerHarnessPort")) {
       workerHarnessPort = _json["workerHarnessPort"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
+    if (drain != null) {
+      _json["drain"] = drain;
+    }
     if (receiveWorkPort != null) {
       _json["receiveWorkPort"] = receiveWorkPort;
     }
     if (streamingComputationTopology != null) {
       _json["streamingComputationTopology"] = (streamingComputationTopology).toJson();
     }
     if (workerHarnessPort != null) {
       _json["workerHarnessPort"] = workerHarnessPort;
     }
     return _json;
@@ skipping 960 matching lines @@
   /** Packages to be installed on workers. */
   core.List<Package> packages;
   /**
    * Extra arguments for this worker pool.
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> poolArgs;
   /**
+   * Subnetwork to which VMs will be assigned, if desired. Expected to be of the
+   * form "zones/ZONE/subnetworks/SUBNETWORK".
+   */
+  core.String subnetwork;
+  /**
    * Settings passed through to Google Compute Engine workers when using the
    * standard Dataflow task runner. Users should ignore this field.
    */
   TaskRunnerSettings taskrunnerSettings;
   /**
    * Sets the policy for determining when to turndown worker pool. Allowed
    * values are: TEARDOWN_ALWAYS, TEARDOWN_ON_SUCCESS, and TEARDOWN_NEVER.
    * TEARDOWN_ALWAYS means workers are always torn down regardless of whether
    * the job succeeds. TEARDOWN_ON_SUCCESS means workers are torn down if the
    * job succeeds. TEARDOWN_NEVER means the workers are never torn down. If the
    * workers are not torn down by the service, they will continue to run and use
    * Google Compute Engine VM resources in the user's project until they are
    * explicitly terminated by the user. Because of this, Google recommends using
    * the TEARDOWN_ALWAYS policy except for small, manually supervised test jobs.
    * If unknown or unspecified, the service will attempt to choose a reasonable
    * default.
    * Possible string values are:
    * - "TEARDOWN_POLICY_UNKNOWN" : A TEARDOWN_POLICY_UNKNOWN.
    * - "TEARDOWN_ALWAYS" : A TEARDOWN_ALWAYS.
    * - "TEARDOWN_ON_SUCCESS" : A TEARDOWN_ON_SUCCESS.
    * - "TEARDOWN_NEVER" : A TEARDOWN_NEVER.
    */
   core.String teardownPolicy;
   /**
+   * Docker container image that executes Dataflow worker harness, residing in
+   * Google Container Registry. Required.
+   */
+  core.String workerHarnessContainerImage;
+  /**
    * Zone to run the worker pools in. If empty or unspecified, the service will
    * attempt to choose a reasonable default.
    */
   core.String zone;
 
   WorkerPool();
 
   WorkerPool.fromJson(core.Map _json) {
     if (_json.containsKey("autoscalingSettings")) {
       autoscalingSettings = new AutoscalingSettings.fromJson(_json["autoscalingSettings"]);
@@ skipping 30 matching lines @@
     }
     if (_json.containsKey("onHostMaintenance")) {
       onHostMaintenance = _json["onHostMaintenance"];
     }
     if (_json.containsKey("packages")) {
       packages = _json["packages"].map((value) => new Package.fromJson(value)).toList();
     }
     if (_json.containsKey("poolArgs")) {
       poolArgs = _json["poolArgs"];
     }
+    if (_json.containsKey("subnetwork")) {
+      subnetwork = _json["subnetwork"];
+    }
     if (_json.containsKey("taskrunnerSettings")) {
       taskrunnerSettings = new TaskRunnerSettings.fromJson(_json["taskrunnerSettings"]);
     }
     if (_json.containsKey("teardownPolicy")) {
       teardownPolicy = _json["teardownPolicy"];
     }
+    if (_json.containsKey("workerHarnessContainerImage")) {
+      workerHarnessContainerImage = _json["workerHarnessContainerImage"];
+    }
     if (_json.containsKey("zone")) {
       zone = _json["zone"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (autoscalingSettings != null) {
       _json["autoscalingSettings"] = (autoscalingSettings).toJson();
     }
@@ skipping 29 matching lines @@
     }
     if (onHostMaintenance != null) {
       _json["onHostMaintenance"] = onHostMaintenance;
     }
     if (packages != null) {
       _json["packages"] = packages.map((value) => (value).toJson()).toList();
     }
     if (poolArgs != null) {
       _json["poolArgs"] = poolArgs;
     }
+    if (subnetwork != null) {
+      _json["subnetwork"] = subnetwork;
+    }
     if (taskrunnerSettings != null) {
       _json["taskrunnerSettings"] = (taskrunnerSettings).toJson();
     }
     if (teardownPolicy != null) {
       _json["teardownPolicy"] = teardownPolicy;
     }
+    if (workerHarnessContainerImage != null) {
+      _json["workerHarnessContainerImage"] = workerHarnessContainerImage;
+    }
     if (zone != null) {
       _json["zone"] = zone;
     }
     return _json;
   }
 }
 
 /** Provides data to pass through to the worker harness. */
 class WorkerSettings {
   /**
@@ skipping 98 matching lines @@
     var _json = new core.Map();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     return _json;
   }
 }