Api-roll 43: 2016-12-13

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 1925 matching lines @@
     }
     if (structuredNameAndMetadata != null) {
       _json["structuredNameAndMetadata"] = (structuredNameAndMetadata).toJson();
     }
     return _json;
   }
 }
 
 /** Request to create a Dataflow job. */
 class CreateJobFromTemplateRequest {
+  /** Runtime environment for the job. */
+  RuntimeEnvironment environment;
   /** A path to the serialized JSON representation of the job. */
   core.String gcsPath;
+  /** The job name to use for the created job.. */
+  core.String jobName;
   /** Dynamic parameterization of the job's runtime environment. */
   core.Map<core.String, core.String> parameters;
 
   CreateJobFromTemplateRequest();
 
   CreateJobFromTemplateRequest.fromJson(core.Map _json) {
+    if (_json.containsKey("environment")) {
+      environment = new RuntimeEnvironment.fromJson(_json["environment"]);
+    }
     if (_json.containsKey("gcsPath")) {
       gcsPath = _json["gcsPath"];
     }
+    if (_json.containsKey("jobName")) {
+      jobName = _json["jobName"];
+    }
     if (_json.containsKey("parameters")) {
       parameters = _json["parameters"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
+    if (environment != null) {
+      _json["environment"] = (environment).toJson();
+    }
     if (gcsPath != null) {
       _json["gcsPath"] = gcsPath;
     }
+    if (jobName != null) {
+      _json["jobName"] = jobName;
+    }
     if (parameters != null) {
       _json["parameters"] = parameters;
     }
     return _json;
   }
 }
 
 /** Identifies the location of a custom souce. */
 class CustomSourceLocation {
   /** Whether this source is stateful. */
@@ skipping 2037 matching lines @@
   /**
    * A pubsub topic, in the form of "pubsub.googleapis.com/topics/
    * /"
    */
   core.String topic;
   /**
    * If set, specifies the pubsub subscription that will be used for tracking
    * custom time timestamps for watermark estimation.
    */
   core.String trackingSubscription;
+  /** If true, then the client has requested to get pubsub attributes. */
+  core.bool withAttributes;
 
   PubsubLocation();
 
   PubsubLocation.fromJson(core.Map _json) {
     if (_json.containsKey("dropLateData")) {
       dropLateData = _json["dropLateData"];
     }
     if (_json.containsKey("idLabel")) {
       idLabel = _json["idLabel"];
     }
     if (_json.containsKey("subscription")) {
       subscription = _json["subscription"];
     }
     if (_json.containsKey("timestampLabel")) {
       timestampLabel = _json["timestampLabel"];
     }
     if (_json.containsKey("topic")) {
       topic = _json["topic"];
     }
     if (_json.containsKey("trackingSubscription")) {
       trackingSubscription = _json["trackingSubscription"];
     }
+    if (_json.containsKey("withAttributes")) {
+      withAttributes = _json["withAttributes"];
+    }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (dropLateData != null) {
       _json["dropLateData"] = dropLateData;
     }
     if (idLabel != null) {
       _json["idLabel"] = idLabel;
     }
     if (subscription != null) {
       _json["subscription"] = subscription;
     }
     if (timestampLabel != null) {
       _json["timestampLabel"] = timestampLabel;
     }
     if (topic != null) {
       _json["topic"] = topic;
     }
     if (trackingSubscription != null) {
       _json["trackingSubscription"] = trackingSubscription;
     }
+    if (withAttributes != null) {
+      _json["withAttributes"] = withAttributes;
+    }
     return _json;
   }
 }
 
 /** An instruction that reads records. Takes no inputs, produces one output. */
 class ReadInstruction {
   /** The source to read from. */
   Source source;
 
   ReadInstruction();
@@ skipping 125 matching lines @@
     if (isInfinite != null) {
       _json["isInfinite"] = isInfinite;
     }
     if (value != null) {
       _json["value"] = value;
     }
     return _json;
   }
 }
 
+/** Environment values to set at runtime. */
+class RuntimeEnvironment {
+  /** The maximum number of workers to start for the job. */
+  core.int maxWorkers;
+  /** The service account to run the job as. */
+  core.String serviceAccountEmail;
+  /** The zone to start the workers in. */
+  core.String zone;
+
+  RuntimeEnvironment();
+
+  RuntimeEnvironment.fromJson(core.Map _json) {
+    if (_json.containsKey("maxWorkers")) {
+      maxWorkers = _json["maxWorkers"];
+    }
+    if (_json.containsKey("serviceAccountEmail")) {
+      serviceAccountEmail = _json["serviceAccountEmail"];
+    }
+    if (_json.containsKey("zone")) {
+      zone = _json["zone"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (maxWorkers != null) {
+      _json["maxWorkers"] = maxWorkers;
+    }
+    if (serviceAccountEmail != null) {
+      _json["serviceAccountEmail"] = serviceAccountEmail;
+    }
+    if (zone != null) {
+      _json["zone"] = zone;
+    }
+    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();
@@ skipping 2563 matching lines @@
     var _json = new core.Map();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     return _json;
   }
 }