| Index: generated/googleapis_beta/test/dataflow/v1b3_test.dart
|
| diff --git a/generated/googleapis_beta/test/dataflow/v1b3_test.dart b/generated/googleapis_beta/test/dataflow/v1b3_test.dart
|
| index 30782dc838755fa978a2410fdb62a46f973f2de9..1db71b4da2729b46688fdaeee751429e57431032 100644
|
| --- a/generated/googleapis_beta/test/dataflow/v1b3_test.dart
|
| +++ b/generated/googleapis_beta/test/dataflow/v1b3_test.dart
|
| @@ -51,7 +51,3701 @@ http.StreamedResponse stringResponse(
|
| return new http.StreamedResponse(stream, status, headers: headers);
|
| }
|
|
|
| +core.int buildCounterApproximateProgress = 0;
|
| +buildApproximateProgress() {
|
| + var o = new api.ApproximateProgress();
|
| + buildCounterApproximateProgress++;
|
| + if (buildCounterApproximateProgress < 3) {
|
| + o.percentComplete = 42.0;
|
| + o.position = buildPosition();
|
| + o.remainingTime = "foo";
|
| + }
|
| + buildCounterApproximateProgress--;
|
| + return o;
|
| +}
|
| +
|
| +checkApproximateProgress(api.ApproximateProgress o) {
|
| + buildCounterApproximateProgress++;
|
| + if (buildCounterApproximateProgress < 3) {
|
| + unittest.expect(o.percentComplete, unittest.equals(42.0));
|
| + checkPosition(o.position);
|
| + unittest.expect(o.remainingTime, unittest.equals('foo'));
|
| + }
|
| + buildCounterApproximateProgress--;
|
| +}
|
| +
|
| +core.int buildCounterAutoscalingSettings = 0;
|
| +buildAutoscalingSettings() {
|
| + var o = new api.AutoscalingSettings();
|
| + buildCounterAutoscalingSettings++;
|
| + if (buildCounterAutoscalingSettings < 3) {
|
| + o.algorithm = "foo";
|
| + o.maxNumWorkers = 42;
|
| + }
|
| + buildCounterAutoscalingSettings--;
|
| + return o;
|
| +}
|
| +
|
| +checkAutoscalingSettings(api.AutoscalingSettings o) {
|
| + buildCounterAutoscalingSettings++;
|
| + if (buildCounterAutoscalingSettings < 3) {
|
| + unittest.expect(o.algorithm, unittest.equals('foo'));
|
| + unittest.expect(o.maxNumWorkers, unittest.equals(42));
|
| + }
|
| + buildCounterAutoscalingSettings--;
|
| +}
|
| +
|
| +buildUnnamed2387() {
|
| + var o = new core.List<api.StreamLocation>();
|
| + o.add(buildStreamLocation());
|
| + o.add(buildStreamLocation());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2387(core.List<api.StreamLocation> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkStreamLocation(o[0]);
|
| + checkStreamLocation(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2388() {
|
| + var o = new core.List<api.KeyRangeLocation>();
|
| + o.add(buildKeyRangeLocation());
|
| + o.add(buildKeyRangeLocation());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2388(core.List<api.KeyRangeLocation> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkKeyRangeLocation(o[0]);
|
| + checkKeyRangeLocation(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2389() {
|
| + var o = new core.List<api.StreamLocation>();
|
| + o.add(buildStreamLocation());
|
| + o.add(buildStreamLocation());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2389(core.List<api.StreamLocation> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkStreamLocation(o[0]);
|
| + checkStreamLocation(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2390() {
|
| + var o = new core.List<api.StateFamilyConfig>();
|
| + o.add(buildStateFamilyConfig());
|
| + o.add(buildStateFamilyConfig());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2390(core.List<api.StateFamilyConfig> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkStateFamilyConfig(o[0]);
|
| + checkStateFamilyConfig(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterComputationTopology = 0;
|
| +buildComputationTopology() {
|
| + var o = new api.ComputationTopology();
|
| + buildCounterComputationTopology++;
|
| + if (buildCounterComputationTopology < 3) {
|
| + o.computationId = "foo";
|
| + o.inputs = buildUnnamed2387();
|
| + o.keyRanges = buildUnnamed2388();
|
| + o.outputs = buildUnnamed2389();
|
| + o.stateFamilies = buildUnnamed2390();
|
| + o.systemStageName = "foo";
|
| + o.userStageName = "foo";
|
| + }
|
| + buildCounterComputationTopology--;
|
| + return o;
|
| +}
|
| +
|
| +checkComputationTopology(api.ComputationTopology o) {
|
| + buildCounterComputationTopology++;
|
| + if (buildCounterComputationTopology < 3) {
|
| + unittest.expect(o.computationId, unittest.equals('foo'));
|
| + checkUnnamed2387(o.inputs);
|
| + checkUnnamed2388(o.keyRanges);
|
| + checkUnnamed2389(o.outputs);
|
| + checkUnnamed2390(o.stateFamilies);
|
| + unittest.expect(o.systemStageName, unittest.equals('foo'));
|
| + unittest.expect(o.userStageName, unittest.equals('foo'));
|
| + }
|
| + buildCounterComputationTopology--;
|
| +}
|
| +
|
| +core.int buildCounterCustomSourceLocation = 0;
|
| +buildCustomSourceLocation() {
|
| + var o = new api.CustomSourceLocation();
|
| + buildCounterCustomSourceLocation++;
|
| + if (buildCounterCustomSourceLocation < 3) {
|
| + o.stateful = true;
|
| + }
|
| + buildCounterCustomSourceLocation--;
|
| + return o;
|
| +}
|
| +
|
| +checkCustomSourceLocation(api.CustomSourceLocation o) {
|
| + buildCounterCustomSourceLocation++;
|
| + if (buildCounterCustomSourceLocation < 3) {
|
| + unittest.expect(o.stateful, unittest.isTrue);
|
| + }
|
| + buildCounterCustomSourceLocation--;
|
| +}
|
| +
|
| +buildUnnamed2391() {
|
| + var o = new core.List<core.String>();
|
| + o.add("foo");
|
| + o.add("foo");
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2391(core.List<core.String> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + unittest.expect(o[0], unittest.equals('foo'));
|
| + unittest.expect(o[1], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterDataDiskAssignment = 0;
|
| +buildDataDiskAssignment() {
|
| + var o = new api.DataDiskAssignment();
|
| + buildCounterDataDiskAssignment++;
|
| + if (buildCounterDataDiskAssignment < 3) {
|
| + o.dataDisks = buildUnnamed2391();
|
| + o.vmInstance = "foo";
|
| + }
|
| + buildCounterDataDiskAssignment--;
|
| + return o;
|
| +}
|
| +
|
| +checkDataDiskAssignment(api.DataDiskAssignment o) {
|
| + buildCounterDataDiskAssignment++;
|
| + if (buildCounterDataDiskAssignment < 3) {
|
| + checkUnnamed2391(o.dataDisks);
|
| + unittest.expect(o.vmInstance, unittest.equals('foo'));
|
| + }
|
| + buildCounterDataDiskAssignment--;
|
| +}
|
| +
|
| +core.int buildCounterDerivedSource = 0;
|
| +buildDerivedSource() {
|
| + var o = new api.DerivedSource();
|
| + buildCounterDerivedSource++;
|
| + if (buildCounterDerivedSource < 3) {
|
| + o.derivationMode = "foo";
|
| + o.source = buildSource();
|
| + }
|
| + buildCounterDerivedSource--;
|
| + return o;
|
| +}
|
| +
|
| +checkDerivedSource(api.DerivedSource o) {
|
| + buildCounterDerivedSource++;
|
| + if (buildCounterDerivedSource < 3) {
|
| + unittest.expect(o.derivationMode, unittest.equals('foo'));
|
| + checkSource(o.source);
|
| + }
|
| + buildCounterDerivedSource--;
|
| +}
|
| +
|
| +core.int buildCounterDisk = 0;
|
| +buildDisk() {
|
| + var o = new api.Disk();
|
| + buildCounterDisk++;
|
| + if (buildCounterDisk < 3) {
|
| + o.diskType = "foo";
|
| + o.mountPoint = "foo";
|
| + o.sizeGb = 42;
|
| + }
|
| + buildCounterDisk--;
|
| + return o;
|
| +}
|
| +
|
| +checkDisk(api.Disk o) {
|
| + buildCounterDisk++;
|
| + if (buildCounterDisk < 3) {
|
| + unittest.expect(o.diskType, unittest.equals('foo'));
|
| + unittest.expect(o.mountPoint, unittest.equals('foo'));
|
| + unittest.expect(o.sizeGb, unittest.equals(42));
|
| + }
|
| + buildCounterDisk--;
|
| +}
|
| +
|
| +core.int buildCounterDynamicSourceSplit = 0;
|
| +buildDynamicSourceSplit() {
|
| + var o = new api.DynamicSourceSplit();
|
| + buildCounterDynamicSourceSplit++;
|
| + if (buildCounterDynamicSourceSplit < 3) {
|
| + o.primary = buildDerivedSource();
|
| + o.residual = buildDerivedSource();
|
| + }
|
| + buildCounterDynamicSourceSplit--;
|
| + return o;
|
| +}
|
| +
|
| +checkDynamicSourceSplit(api.DynamicSourceSplit o) {
|
| + buildCounterDynamicSourceSplit++;
|
| + if (buildCounterDynamicSourceSplit < 3) {
|
| + checkDerivedSource(o.primary);
|
| + checkDerivedSource(o.residual);
|
| + }
|
| + buildCounterDynamicSourceSplit--;
|
| +}
|
| +
|
| +buildUnnamed2392() {
|
| + var o = new core.List<core.String>();
|
| + o.add("foo");
|
| + o.add("foo");
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2392(core.List<core.String> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + unittest.expect(o[0], unittest.equals('foo'));
|
| + unittest.expect(o[1], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2393() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2393(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted1 = (o["x"]) as core.Map; unittest.expect(casted1, unittest.hasLength(3)); unittest.expect(casted1["list"], unittest.equals([1, 2, 3])); unittest.expect(casted1["bool"], unittest.equals(true)); unittest.expect(casted1["string"], unittest.equals('foo'));
|
| + var casted2 = (o["y"]) as core.Map; unittest.expect(casted2, unittest.hasLength(3)); unittest.expect(casted2["list"], unittest.equals([1, 2, 3])); unittest.expect(casted2["bool"], unittest.equals(true)); unittest.expect(casted2["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2394() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2394(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted3 = (o["x"]) as core.Map; unittest.expect(casted3, unittest.hasLength(3)); unittest.expect(casted3["list"], unittest.equals([1, 2, 3])); unittest.expect(casted3["bool"], unittest.equals(true)); unittest.expect(casted3["string"], unittest.equals('foo'));
|
| + var casted4 = (o["y"]) as core.Map; unittest.expect(casted4, unittest.hasLength(3)); unittest.expect(casted4["list"], unittest.equals([1, 2, 3])); unittest.expect(casted4["bool"], unittest.equals(true)); unittest.expect(casted4["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2395() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2395(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted5 = (o["x"]) as core.Map; unittest.expect(casted5, unittest.hasLength(3)); unittest.expect(casted5["list"], unittest.equals([1, 2, 3])); unittest.expect(casted5["bool"], unittest.equals(true)); unittest.expect(casted5["string"], unittest.equals('foo'));
|
| + var casted6 = (o["y"]) as core.Map; unittest.expect(casted6, unittest.hasLength(3)); unittest.expect(casted6["list"], unittest.equals([1, 2, 3])); unittest.expect(casted6["bool"], unittest.equals(true)); unittest.expect(casted6["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2396() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2396(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted7 = (o["x"]) as core.Map; unittest.expect(casted7, unittest.hasLength(3)); unittest.expect(casted7["list"], unittest.equals([1, 2, 3])); unittest.expect(casted7["bool"], unittest.equals(true)); unittest.expect(casted7["string"], unittest.equals('foo'));
|
| + var casted8 = (o["y"]) as core.Map; unittest.expect(casted8, unittest.hasLength(3)); unittest.expect(casted8["list"], unittest.equals([1, 2, 3])); unittest.expect(casted8["bool"], unittest.equals(true)); unittest.expect(casted8["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2397() {
|
| + var o = new core.List<api.WorkerPool>();
|
| + o.add(buildWorkerPool());
|
| + o.add(buildWorkerPool());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2397(core.List<api.WorkerPool> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkWorkerPool(o[0]);
|
| + checkWorkerPool(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterEnvironment = 0;
|
| +buildEnvironment() {
|
| + var o = new api.Environment();
|
| + buildCounterEnvironment++;
|
| + if (buildCounterEnvironment < 3) {
|
| + o.clusterManagerApiService = "foo";
|
| + o.dataset = "foo";
|
| + o.experiments = buildUnnamed2392();
|
| + o.internalExperiments = buildUnnamed2393();
|
| + o.sdkPipelineOptions = buildUnnamed2394();
|
| + o.tempStoragePrefix = "foo";
|
| + o.userAgent = buildUnnamed2395();
|
| + o.version = buildUnnamed2396();
|
| + o.workerPools = buildUnnamed2397();
|
| + }
|
| + buildCounterEnvironment--;
|
| + return o;
|
| +}
|
| +
|
| +checkEnvironment(api.Environment o) {
|
| + buildCounterEnvironment++;
|
| + if (buildCounterEnvironment < 3) {
|
| + unittest.expect(o.clusterManagerApiService, unittest.equals('foo'));
|
| + unittest.expect(o.dataset, unittest.equals('foo'));
|
| + checkUnnamed2392(o.experiments);
|
| + checkUnnamed2393(o.internalExperiments);
|
| + checkUnnamed2394(o.sdkPipelineOptions);
|
| + unittest.expect(o.tempStoragePrefix, unittest.equals('foo'));
|
| + checkUnnamed2395(o.userAgent);
|
| + checkUnnamed2396(o.version);
|
| + checkUnnamed2397(o.workerPools);
|
| + }
|
| + buildCounterEnvironment--;
|
| +}
|
| +
|
| +buildUnnamed2398() {
|
| + var o = new core.List<api.InstructionInput>();
|
| + o.add(buildInstructionInput());
|
| + o.add(buildInstructionInput());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2398(core.List<api.InstructionInput> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkInstructionInput(o[0]);
|
| + checkInstructionInput(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterFlattenInstruction = 0;
|
| +buildFlattenInstruction() {
|
| + var o = new api.FlattenInstruction();
|
| + buildCounterFlattenInstruction++;
|
| + if (buildCounterFlattenInstruction < 3) {
|
| + o.inputs = buildUnnamed2398();
|
| + }
|
| + buildCounterFlattenInstruction--;
|
| + return o;
|
| +}
|
| +
|
| +checkFlattenInstruction(api.FlattenInstruction o) {
|
| + buildCounterFlattenInstruction++;
|
| + if (buildCounterFlattenInstruction < 3) {
|
| + checkUnnamed2398(o.inputs);
|
| + }
|
| + buildCounterFlattenInstruction--;
|
| +}
|
| +
|
| +core.int buildCounterInstructionInput = 0;
|
| +buildInstructionInput() {
|
| + var o = new api.InstructionInput();
|
| + buildCounterInstructionInput++;
|
| + if (buildCounterInstructionInput < 3) {
|
| + o.outputNum = 42;
|
| + o.producerInstructionIndex = 42;
|
| + }
|
| + buildCounterInstructionInput--;
|
| + return o;
|
| +}
|
| +
|
| +checkInstructionInput(api.InstructionInput o) {
|
| + buildCounterInstructionInput++;
|
| + if (buildCounterInstructionInput < 3) {
|
| + unittest.expect(o.outputNum, unittest.equals(42));
|
| + unittest.expect(o.producerInstructionIndex, unittest.equals(42));
|
| + }
|
| + buildCounterInstructionInput--;
|
| +}
|
| +
|
| +buildUnnamed2399() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2399(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted9 = (o["x"]) as core.Map; unittest.expect(casted9, unittest.hasLength(3)); unittest.expect(casted9["list"], unittest.equals([1, 2, 3])); unittest.expect(casted9["bool"], unittest.equals(true)); unittest.expect(casted9["string"], unittest.equals('foo'));
|
| + var casted10 = (o["y"]) as core.Map; unittest.expect(casted10, unittest.hasLength(3)); unittest.expect(casted10["list"], unittest.equals([1, 2, 3])); unittest.expect(casted10["bool"], unittest.equals(true)); unittest.expect(casted10["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterInstructionOutput = 0;
|
| +buildInstructionOutput() {
|
| + var o = new api.InstructionOutput();
|
| + buildCounterInstructionOutput++;
|
| + if (buildCounterInstructionOutput < 3) {
|
| + o.codec = buildUnnamed2399();
|
| + o.name = "foo";
|
| + }
|
| + buildCounterInstructionOutput--;
|
| + return o;
|
| +}
|
| +
|
| +checkInstructionOutput(api.InstructionOutput o) {
|
| + buildCounterInstructionOutput++;
|
| + if (buildCounterInstructionOutput < 3) {
|
| + checkUnnamed2399(o.codec);
|
| + unittest.expect(o.name, unittest.equals('foo'));
|
| + }
|
| + buildCounterInstructionOutput--;
|
| +}
|
| +
|
| +buildUnnamed2400() {
|
| + var o = new core.List<api.Step>();
|
| + o.add(buildStep());
|
| + o.add(buildStep());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2400(core.List<api.Step> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkStep(o[0]);
|
| + checkStep(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2401() {
|
| + var o = new core.Map<core.String, core.String>();
|
| + o["x"] = "foo";
|
| + o["y"] = "foo";
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2401(core.Map<core.String, core.String> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + unittest.expect(o["x"], unittest.equals('foo'));
|
| + unittest.expect(o["y"], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterJob = 0;
|
| +buildJob() {
|
| + var o = new api.Job();
|
| + buildCounterJob++;
|
| + if (buildCounterJob < 3) {
|
| + o.clientRequestId = "foo";
|
| + o.createTime = "foo";
|
| + o.currentState = "foo";
|
| + o.currentStateTime = "foo";
|
| + o.environment = buildEnvironment();
|
| + o.executionInfo = buildJobExecutionInfo();
|
| + o.id = "foo";
|
| + o.name = "foo";
|
| + o.projectId = "foo";
|
| + o.replaceJobId = "foo";
|
| + o.replacedByJobId = "foo";
|
| + o.requestedState = "foo";
|
| + o.steps = buildUnnamed2400();
|
| + o.transformNameMapping = buildUnnamed2401();
|
| + o.type = "foo";
|
| + }
|
| + buildCounterJob--;
|
| + return o;
|
| +}
|
| +
|
| +checkJob(api.Job o) {
|
| + buildCounterJob++;
|
| + if (buildCounterJob < 3) {
|
| + unittest.expect(o.clientRequestId, unittest.equals('foo'));
|
| + unittest.expect(o.createTime, unittest.equals('foo'));
|
| + unittest.expect(o.currentState, unittest.equals('foo'));
|
| + unittest.expect(o.currentStateTime, unittest.equals('foo'));
|
| + checkEnvironment(o.environment);
|
| + checkJobExecutionInfo(o.executionInfo);
|
| + unittest.expect(o.id, unittest.equals('foo'));
|
| + unittest.expect(o.name, unittest.equals('foo'));
|
| + unittest.expect(o.projectId, unittest.equals('foo'));
|
| + unittest.expect(o.replaceJobId, unittest.equals('foo'));
|
| + unittest.expect(o.replacedByJobId, unittest.equals('foo'));
|
| + unittest.expect(o.requestedState, unittest.equals('foo'));
|
| + checkUnnamed2400(o.steps);
|
| + checkUnnamed2401(o.transformNameMapping);
|
| + unittest.expect(o.type, unittest.equals('foo'));
|
| + }
|
| + buildCounterJob--;
|
| +}
|
| +
|
| +buildUnnamed2402() {
|
| + var o = new core.Map<core.String, api.JobExecutionStageInfo>();
|
| + o["x"] = buildJobExecutionStageInfo();
|
| + o["y"] = buildJobExecutionStageInfo();
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2402(core.Map<core.String, api.JobExecutionStageInfo> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkJobExecutionStageInfo(o["x"]);
|
| + checkJobExecutionStageInfo(o["y"]);
|
| +}
|
| +
|
| +core.int buildCounterJobExecutionInfo = 0;
|
| +buildJobExecutionInfo() {
|
| + var o = new api.JobExecutionInfo();
|
| + buildCounterJobExecutionInfo++;
|
| + if (buildCounterJobExecutionInfo < 3) {
|
| + o.stages = buildUnnamed2402();
|
| + }
|
| + buildCounterJobExecutionInfo--;
|
| + return o;
|
| +}
|
| +
|
| +checkJobExecutionInfo(api.JobExecutionInfo o) {
|
| + buildCounterJobExecutionInfo++;
|
| + if (buildCounterJobExecutionInfo < 3) {
|
| + checkUnnamed2402(o.stages);
|
| + }
|
| + buildCounterJobExecutionInfo--;
|
| +}
|
| +
|
| +buildUnnamed2403() {
|
| + var o = new core.List<core.String>();
|
| + o.add("foo");
|
| + o.add("foo");
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2403(core.List<core.String> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + unittest.expect(o[0], unittest.equals('foo'));
|
| + unittest.expect(o[1], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterJobExecutionStageInfo = 0;
|
| +buildJobExecutionStageInfo() {
|
| + var o = new api.JobExecutionStageInfo();
|
| + buildCounterJobExecutionStageInfo++;
|
| + if (buildCounterJobExecutionStageInfo < 3) {
|
| + o.stepName = buildUnnamed2403();
|
| + }
|
| + buildCounterJobExecutionStageInfo--;
|
| + return o;
|
| +}
|
| +
|
| +checkJobExecutionStageInfo(api.JobExecutionStageInfo o) {
|
| + buildCounterJobExecutionStageInfo++;
|
| + if (buildCounterJobExecutionStageInfo < 3) {
|
| + checkUnnamed2403(o.stepName);
|
| + }
|
| + buildCounterJobExecutionStageInfo--;
|
| +}
|
| +
|
| +core.int buildCounterJobMessage = 0;
|
| +buildJobMessage() {
|
| + var o = new api.JobMessage();
|
| + buildCounterJobMessage++;
|
| + if (buildCounterJobMessage < 3) {
|
| + o.id = "foo";
|
| + o.messageImportance = "foo";
|
| + o.messageText = "foo";
|
| + o.time = "foo";
|
| + }
|
| + buildCounterJobMessage--;
|
| + return o;
|
| +}
|
| +
|
| +checkJobMessage(api.JobMessage o) {
|
| + buildCounterJobMessage++;
|
| + if (buildCounterJobMessage < 3) {
|
| + unittest.expect(o.id, unittest.equals('foo'));
|
| + unittest.expect(o.messageImportance, unittest.equals('foo'));
|
| + unittest.expect(o.messageText, unittest.equals('foo'));
|
| + unittest.expect(o.time, unittest.equals('foo'));
|
| + }
|
| + buildCounterJobMessage--;
|
| +}
|
| +
|
| +buildUnnamed2404() {
|
| + var o = new core.List<api.MetricUpdate>();
|
| + o.add(buildMetricUpdate());
|
| + o.add(buildMetricUpdate());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2404(core.List<api.MetricUpdate> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkMetricUpdate(o[0]);
|
| + checkMetricUpdate(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterJobMetrics = 0;
|
| +buildJobMetrics() {
|
| + var o = new api.JobMetrics();
|
| + buildCounterJobMetrics++;
|
| + if (buildCounterJobMetrics < 3) {
|
| + o.metricTime = "foo";
|
| + o.metrics = buildUnnamed2404();
|
| + }
|
| + buildCounterJobMetrics--;
|
| + return o;
|
| +}
|
| +
|
| +checkJobMetrics(api.JobMetrics o) {
|
| + buildCounterJobMetrics++;
|
| + if (buildCounterJobMetrics < 3) {
|
| + unittest.expect(o.metricTime, unittest.equals('foo'));
|
| + checkUnnamed2404(o.metrics);
|
| + }
|
| + buildCounterJobMetrics--;
|
| +}
|
| +
|
| +core.int buildCounterKeyRangeDataDiskAssignment = 0;
|
| +buildKeyRangeDataDiskAssignment() {
|
| + var o = new api.KeyRangeDataDiskAssignment();
|
| + buildCounterKeyRangeDataDiskAssignment++;
|
| + if (buildCounterKeyRangeDataDiskAssignment < 3) {
|
| + o.dataDisk = "foo";
|
| + o.end = "foo";
|
| + o.start = "foo";
|
| + }
|
| + buildCounterKeyRangeDataDiskAssignment--;
|
| + return o;
|
| +}
|
| +
|
| +checkKeyRangeDataDiskAssignment(api.KeyRangeDataDiskAssignment o) {
|
| + buildCounterKeyRangeDataDiskAssignment++;
|
| + if (buildCounterKeyRangeDataDiskAssignment < 3) {
|
| + unittest.expect(o.dataDisk, unittest.equals('foo'));
|
| + unittest.expect(o.end, unittest.equals('foo'));
|
| + unittest.expect(o.start, unittest.equals('foo'));
|
| + }
|
| + buildCounterKeyRangeDataDiskAssignment--;
|
| +}
|
| +
|
| +core.int buildCounterKeyRangeLocation = 0;
|
| +buildKeyRangeLocation() {
|
| + var o = new api.KeyRangeLocation();
|
| + buildCounterKeyRangeLocation++;
|
| + if (buildCounterKeyRangeLocation < 3) {
|
| + o.dataDisk = "foo";
|
| + o.deliveryEndpoint = "foo";
|
| + o.end = "foo";
|
| + o.persistentDirectory = "foo";
|
| + o.start = "foo";
|
| + }
|
| + buildCounterKeyRangeLocation--;
|
| + return o;
|
| +}
|
| +
|
| +checkKeyRangeLocation(api.KeyRangeLocation o) {
|
| + buildCounterKeyRangeLocation++;
|
| + if (buildCounterKeyRangeLocation < 3) {
|
| + unittest.expect(o.dataDisk, unittest.equals('foo'));
|
| + unittest.expect(o.deliveryEndpoint, unittest.equals('foo'));
|
| + unittest.expect(o.end, unittest.equals('foo'));
|
| + unittest.expect(o.persistentDirectory, unittest.equals('foo'));
|
| + unittest.expect(o.start, unittest.equals('foo'));
|
| + }
|
| + buildCounterKeyRangeLocation--;
|
| +}
|
| +
|
| +buildUnnamed2405() {
|
| + var o = new core.List<core.String>();
|
| + o.add("foo");
|
| + o.add("foo");
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2405(core.List<core.String> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + unittest.expect(o[0], unittest.equals('foo'));
|
| + unittest.expect(o[1], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2406() {
|
| + var o = new core.List<core.String>();
|
| + o.add("foo");
|
| + o.add("foo");
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2406(core.List<core.String> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + unittest.expect(o[0], unittest.equals('foo'));
|
| + unittest.expect(o[1], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterLeaseWorkItemRequest = 0;
|
| +buildLeaseWorkItemRequest() {
|
| + var o = new api.LeaseWorkItemRequest();
|
| + buildCounterLeaseWorkItemRequest++;
|
| + if (buildCounterLeaseWorkItemRequest < 3) {
|
| + o.currentWorkerTime = "foo";
|
| + o.requestedLeaseDuration = "foo";
|
| + o.workItemTypes = buildUnnamed2405();
|
| + o.workerCapabilities = buildUnnamed2406();
|
| + o.workerId = "foo";
|
| + }
|
| + buildCounterLeaseWorkItemRequest--;
|
| + return o;
|
| +}
|
| +
|
| +checkLeaseWorkItemRequest(api.LeaseWorkItemRequest o) {
|
| + buildCounterLeaseWorkItemRequest++;
|
| + if (buildCounterLeaseWorkItemRequest < 3) {
|
| + unittest.expect(o.currentWorkerTime, unittest.equals('foo'));
|
| + unittest.expect(o.requestedLeaseDuration, unittest.equals('foo'));
|
| + checkUnnamed2405(o.workItemTypes);
|
| + checkUnnamed2406(o.workerCapabilities);
|
| + unittest.expect(o.workerId, unittest.equals('foo'));
|
| + }
|
| + buildCounterLeaseWorkItemRequest--;
|
| +}
|
| +
|
| +buildUnnamed2407() {
|
| + var o = new core.List<api.WorkItem>();
|
| + o.add(buildWorkItem());
|
| + o.add(buildWorkItem());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2407(core.List<api.WorkItem> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkWorkItem(o[0]);
|
| + checkWorkItem(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterLeaseWorkItemResponse = 0;
|
| +buildLeaseWorkItemResponse() {
|
| + var o = new api.LeaseWorkItemResponse();
|
| + buildCounterLeaseWorkItemResponse++;
|
| + if (buildCounterLeaseWorkItemResponse < 3) {
|
| + o.workItems = buildUnnamed2407();
|
| + }
|
| + buildCounterLeaseWorkItemResponse--;
|
| + return o;
|
| +}
|
| +
|
| +checkLeaseWorkItemResponse(api.LeaseWorkItemResponse o) {
|
| + buildCounterLeaseWorkItemResponse++;
|
| + if (buildCounterLeaseWorkItemResponse < 3) {
|
| + checkUnnamed2407(o.workItems);
|
| + }
|
| + buildCounterLeaseWorkItemResponse--;
|
| +}
|
| +
|
| +buildUnnamed2408() {
|
| + var o = new core.List<api.JobMessage>();
|
| + o.add(buildJobMessage());
|
| + o.add(buildJobMessage());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2408(core.List<api.JobMessage> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkJobMessage(o[0]);
|
| + checkJobMessage(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterListJobMessagesResponse = 0;
|
| +buildListJobMessagesResponse() {
|
| + var o = new api.ListJobMessagesResponse();
|
| + buildCounterListJobMessagesResponse++;
|
| + if (buildCounterListJobMessagesResponse < 3) {
|
| + o.jobMessages = buildUnnamed2408();
|
| + o.nextPageToken = "foo";
|
| + }
|
| + buildCounterListJobMessagesResponse--;
|
| + return o;
|
| +}
|
| +
|
| +checkListJobMessagesResponse(api.ListJobMessagesResponse o) {
|
| + buildCounterListJobMessagesResponse++;
|
| + if (buildCounterListJobMessagesResponse < 3) {
|
| + checkUnnamed2408(o.jobMessages);
|
| + unittest.expect(o.nextPageToken, unittest.equals('foo'));
|
| + }
|
| + buildCounterListJobMessagesResponse--;
|
| +}
|
| +
|
| +buildUnnamed2409() {
|
| + var o = new core.List<api.Job>();
|
| + o.add(buildJob());
|
| + o.add(buildJob());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2409(core.List<api.Job> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkJob(o[0]);
|
| + checkJob(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterListJobsResponse = 0;
|
| +buildListJobsResponse() {
|
| + var o = new api.ListJobsResponse();
|
| + buildCounterListJobsResponse++;
|
| + if (buildCounterListJobsResponse < 3) {
|
| + o.jobs = buildUnnamed2409();
|
| + o.nextPageToken = "foo";
|
| + }
|
| + buildCounterListJobsResponse--;
|
| + return o;
|
| +}
|
| +
|
| +checkListJobsResponse(api.ListJobsResponse o) {
|
| + buildCounterListJobsResponse++;
|
| + if (buildCounterListJobsResponse < 3) {
|
| + checkUnnamed2409(o.jobs);
|
| + unittest.expect(o.nextPageToken, unittest.equals('foo'));
|
| + }
|
| + buildCounterListJobsResponse--;
|
| +}
|
| +
|
| +buildUnnamed2410() {
|
| + var o = new core.List<api.ParallelInstruction>();
|
| + o.add(buildParallelInstruction());
|
| + o.add(buildParallelInstruction());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2410(core.List<api.ParallelInstruction> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkParallelInstruction(o[0]);
|
| + checkParallelInstruction(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterMapTask = 0;
|
| +buildMapTask() {
|
| + var o = new api.MapTask();
|
| + buildCounterMapTask++;
|
| + if (buildCounterMapTask < 3) {
|
| + o.instructions = buildUnnamed2410();
|
| + o.stageName = "foo";
|
| + o.systemName = "foo";
|
| + }
|
| + buildCounterMapTask--;
|
| + return o;
|
| +}
|
| +
|
| +checkMapTask(api.MapTask o) {
|
| + buildCounterMapTask++;
|
| + if (buildCounterMapTask < 3) {
|
| + checkUnnamed2410(o.instructions);
|
| + unittest.expect(o.stageName, unittest.equals('foo'));
|
| + unittest.expect(o.systemName, unittest.equals('foo'));
|
| + }
|
| + buildCounterMapTask--;
|
| +}
|
| +
|
| +buildUnnamed2411() {
|
| + var o = new core.Map<core.String, core.String>();
|
| + o["x"] = "foo";
|
| + o["y"] = "foo";
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2411(core.Map<core.String, core.String> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + unittest.expect(o["x"], unittest.equals('foo'));
|
| + unittest.expect(o["y"], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterMetricStructuredName = 0;
|
| +buildMetricStructuredName() {
|
| + var o = new api.MetricStructuredName();
|
| + buildCounterMetricStructuredName++;
|
| + if (buildCounterMetricStructuredName < 3) {
|
| + o.context = buildUnnamed2411();
|
| + o.name = "foo";
|
| + o.origin = "foo";
|
| + }
|
| + buildCounterMetricStructuredName--;
|
| + return o;
|
| +}
|
| +
|
| +checkMetricStructuredName(api.MetricStructuredName o) {
|
| + buildCounterMetricStructuredName++;
|
| + if (buildCounterMetricStructuredName < 3) {
|
| + checkUnnamed2411(o.context);
|
| + unittest.expect(o.name, unittest.equals('foo'));
|
| + unittest.expect(o.origin, unittest.equals('foo'));
|
| + }
|
| + buildCounterMetricStructuredName--;
|
| +}
|
| +
|
| +core.int buildCounterMetricUpdate = 0;
|
| +buildMetricUpdate() {
|
| + var o = new api.MetricUpdate();
|
| + buildCounterMetricUpdate++;
|
| + if (buildCounterMetricUpdate < 3) {
|
| + o.cumulative = true;
|
| + o.internal = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o.kind = "foo";
|
| + o.meanCount = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o.meanSum = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o.name = buildMetricStructuredName();
|
| + o.scalar = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o.set = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o.updateTime = "foo";
|
| + }
|
| + buildCounterMetricUpdate--;
|
| + return o;
|
| +}
|
| +
|
| +checkMetricUpdate(api.MetricUpdate o) {
|
| + buildCounterMetricUpdate++;
|
| + if (buildCounterMetricUpdate < 3) {
|
| + unittest.expect(o.cumulative, unittest.isTrue);
|
| + var casted11 = (o.internal) as core.Map; unittest.expect(casted11, unittest.hasLength(3)); unittest.expect(casted11["list"], unittest.equals([1, 2, 3])); unittest.expect(casted11["bool"], unittest.equals(true)); unittest.expect(casted11["string"], unittest.equals('foo'));
|
| + unittest.expect(o.kind, unittest.equals('foo'));
|
| + var casted12 = (o.meanCount) as core.Map; unittest.expect(casted12, unittest.hasLength(3)); unittest.expect(casted12["list"], unittest.equals([1, 2, 3])); unittest.expect(casted12["bool"], unittest.equals(true)); unittest.expect(casted12["string"], unittest.equals('foo'));
|
| + var casted13 = (o.meanSum) as core.Map; unittest.expect(casted13, unittest.hasLength(3)); unittest.expect(casted13["list"], unittest.equals([1, 2, 3])); unittest.expect(casted13["bool"], unittest.equals(true)); unittest.expect(casted13["string"], unittest.equals('foo'));
|
| + checkMetricStructuredName(o.name);
|
| + var casted14 = (o.scalar) as core.Map; unittest.expect(casted14, unittest.hasLength(3)); unittest.expect(casted14["list"], unittest.equals([1, 2, 3])); unittest.expect(casted14["bool"], unittest.equals(true)); unittest.expect(casted14["string"], unittest.equals('foo'));
|
| + var casted15 = (o.set) as core.Map; unittest.expect(casted15, unittest.hasLength(3)); unittest.expect(casted15["list"], unittest.equals([1, 2, 3])); unittest.expect(casted15["bool"], unittest.equals(true)); unittest.expect(casted15["string"], unittest.equals('foo'));
|
| + unittest.expect(o.updateTime, unittest.equals('foo'));
|
| + }
|
| + buildCounterMetricUpdate--;
|
| +}
|
| +
|
| +core.int buildCounterMountedDataDisk = 0;
|
| +buildMountedDataDisk() {
|
| + var o = new api.MountedDataDisk();
|
| + buildCounterMountedDataDisk++;
|
| + if (buildCounterMountedDataDisk < 3) {
|
| + o.dataDisk = "foo";
|
| + }
|
| + buildCounterMountedDataDisk--;
|
| + return o;
|
| +}
|
| +
|
| +checkMountedDataDisk(api.MountedDataDisk o) {
|
| + buildCounterMountedDataDisk++;
|
| + if (buildCounterMountedDataDisk < 3) {
|
| + unittest.expect(o.dataDisk, unittest.equals('foo'));
|
| + }
|
| + buildCounterMountedDataDisk--;
|
| +}
|
| +
|
| +core.int buildCounterMultiOutputInfo = 0;
|
| +buildMultiOutputInfo() {
|
| + var o = new api.MultiOutputInfo();
|
| + buildCounterMultiOutputInfo++;
|
| + if (buildCounterMultiOutputInfo < 3) {
|
| + o.tag = "foo";
|
| + }
|
| + buildCounterMultiOutputInfo--;
|
| + return o;
|
| +}
|
| +
|
| +checkMultiOutputInfo(api.MultiOutputInfo o) {
|
| + buildCounterMultiOutputInfo++;
|
| + if (buildCounterMultiOutputInfo < 3) {
|
| + unittest.expect(o.tag, unittest.equals('foo'));
|
| + }
|
| + buildCounterMultiOutputInfo--;
|
| +}
|
| +
|
| +core.int buildCounterPackage = 0;
|
| +buildPackage() {
|
| + var o = new api.Package();
|
| + buildCounterPackage++;
|
| + if (buildCounterPackage < 3) {
|
| + o.location = "foo";
|
| + o.name = "foo";
|
| + }
|
| + buildCounterPackage--;
|
| + return o;
|
| +}
|
| +
|
| +checkPackage(api.Package o) {
|
| + buildCounterPackage++;
|
| + if (buildCounterPackage < 3) {
|
| + unittest.expect(o.location, unittest.equals('foo'));
|
| + unittest.expect(o.name, unittest.equals('foo'));
|
| + }
|
| + buildCounterPackage--;
|
| +}
|
| +
|
| +buildUnnamed2412() {
|
| + var o = new core.List<api.MultiOutputInfo>();
|
| + o.add(buildMultiOutputInfo());
|
| + o.add(buildMultiOutputInfo());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2412(core.List<api.MultiOutputInfo> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkMultiOutputInfo(o[0]);
|
| + checkMultiOutputInfo(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2413() {
|
| + var o = new core.List<api.SideInputInfo>();
|
| + o.add(buildSideInputInfo());
|
| + o.add(buildSideInputInfo());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2413(core.List<api.SideInputInfo> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkSideInputInfo(o[0]);
|
| + checkSideInputInfo(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2414() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2414(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted16 = (o["x"]) as core.Map; unittest.expect(casted16, unittest.hasLength(3)); unittest.expect(casted16["list"], unittest.equals([1, 2, 3])); unittest.expect(casted16["bool"], unittest.equals(true)); unittest.expect(casted16["string"], unittest.equals('foo'));
|
| + var casted17 = (o["y"]) as core.Map; unittest.expect(casted17, unittest.hasLength(3)); unittest.expect(casted17["list"], unittest.equals([1, 2, 3])); unittest.expect(casted17["bool"], unittest.equals(true)); unittest.expect(casted17["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterParDoInstruction = 0;
|
| +buildParDoInstruction() {
|
| + var o = new api.ParDoInstruction();
|
| + buildCounterParDoInstruction++;
|
| + if (buildCounterParDoInstruction < 3) {
|
| + o.input = buildInstructionInput();
|
| + o.multiOutputInfos = buildUnnamed2412();
|
| + o.numOutputs = 42;
|
| + o.sideInputs = buildUnnamed2413();
|
| + o.userFn = buildUnnamed2414();
|
| + }
|
| + buildCounterParDoInstruction--;
|
| + return o;
|
| +}
|
| +
|
| +checkParDoInstruction(api.ParDoInstruction o) {
|
| + buildCounterParDoInstruction++;
|
| + if (buildCounterParDoInstruction < 3) {
|
| + checkInstructionInput(o.input);
|
| + checkUnnamed2412(o.multiOutputInfos);
|
| + unittest.expect(o.numOutputs, unittest.equals(42));
|
| + checkUnnamed2413(o.sideInputs);
|
| + checkUnnamed2414(o.userFn);
|
| + }
|
| + buildCounterParDoInstruction--;
|
| +}
|
| +
|
| +buildUnnamed2415() {
|
| + var o = new core.List<api.InstructionOutput>();
|
| + o.add(buildInstructionOutput());
|
| + o.add(buildInstructionOutput());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2415(core.List<api.InstructionOutput> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkInstructionOutput(o[0]);
|
| + checkInstructionOutput(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterParallelInstruction = 0;
|
| +buildParallelInstruction() {
|
| + var o = new api.ParallelInstruction();
|
| + buildCounterParallelInstruction++;
|
| + if (buildCounterParallelInstruction < 3) {
|
| + o.flatten = buildFlattenInstruction();
|
| + o.name = "foo";
|
| + o.outputs = buildUnnamed2415();
|
| + o.parDo = buildParDoInstruction();
|
| + o.partialGroupByKey = buildPartialGroupByKeyInstruction();
|
| + o.read = buildReadInstruction();
|
| + o.systemName = "foo";
|
| + o.write = buildWriteInstruction();
|
| + }
|
| + buildCounterParallelInstruction--;
|
| + return o;
|
| +}
|
| +
|
| +checkParallelInstruction(api.ParallelInstruction o) {
|
| + buildCounterParallelInstruction++;
|
| + if (buildCounterParallelInstruction < 3) {
|
| + checkFlattenInstruction(o.flatten);
|
| + unittest.expect(o.name, unittest.equals('foo'));
|
| + checkUnnamed2415(o.outputs);
|
| + checkParDoInstruction(o.parDo);
|
| + checkPartialGroupByKeyInstruction(o.partialGroupByKey);
|
| + checkReadInstruction(o.read);
|
| + unittest.expect(o.systemName, unittest.equals('foo'));
|
| + checkWriteInstruction(o.write);
|
| + }
|
| + buildCounterParallelInstruction--;
|
| +}
|
| +
|
| +buildUnnamed2416() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2416(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted18 = (o["x"]) as core.Map; unittest.expect(casted18, unittest.hasLength(3)); unittest.expect(casted18["list"], unittest.equals([1, 2, 3])); unittest.expect(casted18["bool"], unittest.equals(true)); unittest.expect(casted18["string"], unittest.equals('foo'));
|
| + var casted19 = (o["y"]) as core.Map; unittest.expect(casted19, unittest.hasLength(3)); unittest.expect(casted19["list"], unittest.equals([1, 2, 3])); unittest.expect(casted19["bool"], unittest.equals(true)); unittest.expect(casted19["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2417() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2417(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted20 = (o["x"]) as core.Map; unittest.expect(casted20, unittest.hasLength(3)); unittest.expect(casted20["list"], unittest.equals([1, 2, 3])); unittest.expect(casted20["bool"], unittest.equals(true)); unittest.expect(casted20["string"], unittest.equals('foo'));
|
| + var casted21 = (o["y"]) as core.Map; unittest.expect(casted21, unittest.hasLength(3)); unittest.expect(casted21["list"], unittest.equals([1, 2, 3])); unittest.expect(casted21["bool"], unittest.equals(true)); unittest.expect(casted21["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterPartialGroupByKeyInstruction = 0;
|
| +buildPartialGroupByKeyInstruction() {
|
| + var o = new api.PartialGroupByKeyInstruction();
|
| + buildCounterPartialGroupByKeyInstruction++;
|
| + if (buildCounterPartialGroupByKeyInstruction < 3) {
|
| + o.input = buildInstructionInput();
|
| + o.inputElementCodec = buildUnnamed2416();
|
| + o.valueCombiningFn = buildUnnamed2417();
|
| + }
|
| + buildCounterPartialGroupByKeyInstruction--;
|
| + return o;
|
| +}
|
| +
|
| +checkPartialGroupByKeyInstruction(api.PartialGroupByKeyInstruction o) {
|
| + buildCounterPartialGroupByKeyInstruction++;
|
| + if (buildCounterPartialGroupByKeyInstruction < 3) {
|
| + checkInstructionInput(o.input);
|
| + checkUnnamed2416(o.inputElementCodec);
|
| + checkUnnamed2417(o.valueCombiningFn);
|
| + }
|
| + buildCounterPartialGroupByKeyInstruction--;
|
| +}
|
| +
|
| +core.int buildCounterPosition = 0;
|
| +buildPosition() {
|
| + var o = new api.Position();
|
| + buildCounterPosition++;
|
| + if (buildCounterPosition < 3) {
|
| + o.byteOffset = "foo";
|
| + o.end = true;
|
| + o.key = "foo";
|
| + o.recordIndex = "foo";
|
| + o.shufflePosition = "foo";
|
| + }
|
| + buildCounterPosition--;
|
| + return o;
|
| +}
|
| +
|
| +checkPosition(api.Position o) {
|
| + buildCounterPosition++;
|
| + if (buildCounterPosition < 3) {
|
| + unittest.expect(o.byteOffset, unittest.equals('foo'));
|
| + unittest.expect(o.end, unittest.isTrue);
|
| + unittest.expect(o.key, unittest.equals('foo'));
|
| + unittest.expect(o.recordIndex, unittest.equals('foo'));
|
| + unittest.expect(o.shufflePosition, unittest.equals('foo'));
|
| + }
|
| + buildCounterPosition--;
|
| +}
|
| +
|
| +core.int buildCounterPubsubLocation = 0;
|
| +buildPubsubLocation() {
|
| + var o = new api.PubsubLocation();
|
| + buildCounterPubsubLocation++;
|
| + if (buildCounterPubsubLocation < 3) {
|
| + o.dropLateData = true;
|
| + o.idLabel = "foo";
|
| + o.subscription = "foo";
|
| + o.timestampLabel = "foo";
|
| + o.topic = "foo";
|
| + o.trackingSubscription = "foo";
|
| + }
|
| + buildCounterPubsubLocation--;
|
| + return o;
|
| +}
|
| +
|
| +checkPubsubLocation(api.PubsubLocation o) {
|
| + buildCounterPubsubLocation++;
|
| + if (buildCounterPubsubLocation < 3) {
|
| + unittest.expect(o.dropLateData, unittest.isTrue);
|
| + unittest.expect(o.idLabel, unittest.equals('foo'));
|
| + unittest.expect(o.subscription, unittest.equals('foo'));
|
| + unittest.expect(o.timestampLabel, unittest.equals('foo'));
|
| + unittest.expect(o.topic, unittest.equals('foo'));
|
| + unittest.expect(o.trackingSubscription, unittest.equals('foo'));
|
| + }
|
| + buildCounterPubsubLocation--;
|
| +}
|
| +
|
| +core.int buildCounterReadInstruction = 0;
|
| +buildReadInstruction() {
|
| + var o = new api.ReadInstruction();
|
| + buildCounterReadInstruction++;
|
| + if (buildCounterReadInstruction < 3) {
|
| + o.source = buildSource();
|
| + }
|
| + buildCounterReadInstruction--;
|
| + return o;
|
| +}
|
| +
|
| +checkReadInstruction(api.ReadInstruction o) {
|
| + buildCounterReadInstruction++;
|
| + if (buildCounterReadInstruction < 3) {
|
| + checkSource(o.source);
|
| + }
|
| + buildCounterReadInstruction--;
|
| +}
|
| +
|
| +buildUnnamed2418() {
|
| + var o = new core.List<api.WorkItemStatus>();
|
| + o.add(buildWorkItemStatus());
|
| + o.add(buildWorkItemStatus());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2418(core.List<api.WorkItemStatus> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkWorkItemStatus(o[0]);
|
| + checkWorkItemStatus(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterReportWorkItemStatusRequest = 0;
|
| +buildReportWorkItemStatusRequest() {
|
| + var o = new api.ReportWorkItemStatusRequest();
|
| + buildCounterReportWorkItemStatusRequest++;
|
| + if (buildCounterReportWorkItemStatusRequest < 3) {
|
| + o.currentWorkerTime = "foo";
|
| + o.workItemStatuses = buildUnnamed2418();
|
| + o.workerId = "foo";
|
| + }
|
| + buildCounterReportWorkItemStatusRequest--;
|
| + return o;
|
| +}
|
| +
|
| +checkReportWorkItemStatusRequest(api.ReportWorkItemStatusRequest o) {
|
| + buildCounterReportWorkItemStatusRequest++;
|
| + if (buildCounterReportWorkItemStatusRequest < 3) {
|
| + unittest.expect(o.currentWorkerTime, unittest.equals('foo'));
|
| + checkUnnamed2418(o.workItemStatuses);
|
| + unittest.expect(o.workerId, unittest.equals('foo'));
|
| + }
|
| + buildCounterReportWorkItemStatusRequest--;
|
| +}
|
| +
|
| +buildUnnamed2419() {
|
| + var o = new core.List<api.WorkItemServiceState>();
|
| + o.add(buildWorkItemServiceState());
|
| + o.add(buildWorkItemServiceState());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2419(core.List<api.WorkItemServiceState> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkWorkItemServiceState(o[0]);
|
| + checkWorkItemServiceState(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterReportWorkItemStatusResponse = 0;
|
| +buildReportWorkItemStatusResponse() {
|
| + var o = new api.ReportWorkItemStatusResponse();
|
| + buildCounterReportWorkItemStatusResponse++;
|
| + if (buildCounterReportWorkItemStatusResponse < 3) {
|
| + o.workItemServiceStates = buildUnnamed2419();
|
| + }
|
| + buildCounterReportWorkItemStatusResponse--;
|
| + return o;
|
| +}
|
| +
|
| +checkReportWorkItemStatusResponse(api.ReportWorkItemStatusResponse o) {
|
| + buildCounterReportWorkItemStatusResponse++;
|
| + if (buildCounterReportWorkItemStatusResponse < 3) {
|
| + checkUnnamed2419(o.workItemServiceStates);
|
| + }
|
| + buildCounterReportWorkItemStatusResponse--;
|
| +}
|
| +
|
| +buildUnnamed2420() {
|
| + var o = new core.List<api.SideInputInfo>();
|
| + o.add(buildSideInputInfo());
|
| + o.add(buildSideInputInfo());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2420(core.List<api.SideInputInfo> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkSideInputInfo(o[0]);
|
| + checkSideInputInfo(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2421() {
|
| + var o = new core.List<api.SeqMapTaskOutputInfo>();
|
| + o.add(buildSeqMapTaskOutputInfo());
|
| + o.add(buildSeqMapTaskOutputInfo());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2421(core.List<api.SeqMapTaskOutputInfo> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkSeqMapTaskOutputInfo(o[0]);
|
| + checkSeqMapTaskOutputInfo(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2422() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2422(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted22 = (o["x"]) as core.Map; unittest.expect(casted22, unittest.hasLength(3)); unittest.expect(casted22["list"], unittest.equals([1, 2, 3])); unittest.expect(casted22["bool"], unittest.equals(true)); unittest.expect(casted22["string"], unittest.equals('foo'));
|
| + var casted23 = (o["y"]) as core.Map; unittest.expect(casted23, unittest.hasLength(3)); unittest.expect(casted23["list"], unittest.equals([1, 2, 3])); unittest.expect(casted23["bool"], unittest.equals(true)); unittest.expect(casted23["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterSeqMapTask = 0;
|
| +buildSeqMapTask() {
|
| + var o = new api.SeqMapTask();
|
| + buildCounterSeqMapTask++;
|
| + if (buildCounterSeqMapTask < 3) {
|
| + o.inputs = buildUnnamed2420();
|
| + o.name = "foo";
|
| + o.outputInfos = buildUnnamed2421();
|
| + o.stageName = "foo";
|
| + o.systemName = "foo";
|
| + o.userFn = buildUnnamed2422();
|
| + }
|
| + buildCounterSeqMapTask--;
|
| + return o;
|
| +}
|
| +
|
| +checkSeqMapTask(api.SeqMapTask o) {
|
| + buildCounterSeqMapTask++;
|
| + if (buildCounterSeqMapTask < 3) {
|
| + checkUnnamed2420(o.inputs);
|
| + unittest.expect(o.name, unittest.equals('foo'));
|
| + checkUnnamed2421(o.outputInfos);
|
| + unittest.expect(o.stageName, unittest.equals('foo'));
|
| + unittest.expect(o.systemName, unittest.equals('foo'));
|
| + checkUnnamed2422(o.userFn);
|
| + }
|
| + buildCounterSeqMapTask--;
|
| +}
|
| +
|
| +core.int buildCounterSeqMapTaskOutputInfo = 0;
|
| +buildSeqMapTaskOutputInfo() {
|
| + var o = new api.SeqMapTaskOutputInfo();
|
| + buildCounterSeqMapTaskOutputInfo++;
|
| + if (buildCounterSeqMapTaskOutputInfo < 3) {
|
| + o.sink = buildSink();
|
| + o.tag = "foo";
|
| + }
|
| + buildCounterSeqMapTaskOutputInfo--;
|
| + return o;
|
| +}
|
| +
|
| +checkSeqMapTaskOutputInfo(api.SeqMapTaskOutputInfo o) {
|
| + buildCounterSeqMapTaskOutputInfo++;
|
| + if (buildCounterSeqMapTaskOutputInfo < 3) {
|
| + checkSink(o.sink);
|
| + unittest.expect(o.tag, unittest.equals('foo'));
|
| + }
|
| + buildCounterSeqMapTaskOutputInfo--;
|
| +}
|
| +
|
| +core.int buildCounterShellTask = 0;
|
| +buildShellTask() {
|
| + var o = new api.ShellTask();
|
| + buildCounterShellTask++;
|
| + if (buildCounterShellTask < 3) {
|
| + o.command = "foo";
|
| + o.exitCode = 42;
|
| + }
|
| + buildCounterShellTask--;
|
| + return o;
|
| +}
|
| +
|
| +checkShellTask(api.ShellTask o) {
|
| + buildCounterShellTask++;
|
| + if (buildCounterShellTask < 3) {
|
| + unittest.expect(o.command, unittest.equals('foo'));
|
| + unittest.expect(o.exitCode, unittest.equals(42));
|
| + }
|
| + buildCounterShellTask--;
|
| +}
|
| +
|
| +buildUnnamed2423() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2423(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted24 = (o["x"]) as core.Map; unittest.expect(casted24, unittest.hasLength(3)); unittest.expect(casted24["list"], unittest.equals([1, 2, 3])); unittest.expect(casted24["bool"], unittest.equals(true)); unittest.expect(casted24["string"], unittest.equals('foo'));
|
| + var casted25 = (o["y"]) as core.Map; unittest.expect(casted25, unittest.hasLength(3)); unittest.expect(casted25["list"], unittest.equals([1, 2, 3])); unittest.expect(casted25["bool"], unittest.equals(true)); unittest.expect(casted25["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2424() {
|
| + var o = new core.List<api.Source>();
|
| + o.add(buildSource());
|
| + o.add(buildSource());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2424(core.List<api.Source> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkSource(o[0]);
|
| + checkSource(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterSideInputInfo = 0;
|
| +buildSideInputInfo() {
|
| + var o = new api.SideInputInfo();
|
| + buildCounterSideInputInfo++;
|
| + if (buildCounterSideInputInfo < 3) {
|
| + o.kind = buildUnnamed2423();
|
| + o.sources = buildUnnamed2424();
|
| + o.tag = "foo";
|
| + }
|
| + buildCounterSideInputInfo--;
|
| + return o;
|
| +}
|
| +
|
| +checkSideInputInfo(api.SideInputInfo o) {
|
| + buildCounterSideInputInfo++;
|
| + if (buildCounterSideInputInfo < 3) {
|
| + checkUnnamed2423(o.kind);
|
| + checkUnnamed2424(o.sources);
|
| + unittest.expect(o.tag, unittest.equals('foo'));
|
| + }
|
| + buildCounterSideInputInfo--;
|
| +}
|
| +
|
| +buildUnnamed2425() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2425(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted26 = (o["x"]) as core.Map; unittest.expect(casted26, unittest.hasLength(3)); unittest.expect(casted26["list"], unittest.equals([1, 2, 3])); unittest.expect(casted26["bool"], unittest.equals(true)); unittest.expect(casted26["string"], unittest.equals('foo'));
|
| + var casted27 = (o["y"]) as core.Map; unittest.expect(casted27, unittest.hasLength(3)); unittest.expect(casted27["list"], unittest.equals([1, 2, 3])); unittest.expect(casted27["bool"], unittest.equals(true)); unittest.expect(casted27["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2426() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2426(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted28 = (o["x"]) as core.Map; unittest.expect(casted28, unittest.hasLength(3)); unittest.expect(casted28["list"], unittest.equals([1, 2, 3])); unittest.expect(casted28["bool"], unittest.equals(true)); unittest.expect(casted28["string"], unittest.equals('foo'));
|
| + var casted29 = (o["y"]) as core.Map; unittest.expect(casted29, unittest.hasLength(3)); unittest.expect(casted29["list"], unittest.equals([1, 2, 3])); unittest.expect(casted29["bool"], unittest.equals(true)); unittest.expect(casted29["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterSink = 0;
|
| +buildSink() {
|
| + var o = new api.Sink();
|
| + buildCounterSink++;
|
| + if (buildCounterSink < 3) {
|
| + o.codec = buildUnnamed2425();
|
| + o.spec = buildUnnamed2426();
|
| + }
|
| + buildCounterSink--;
|
| + return o;
|
| +}
|
| +
|
| +checkSink(api.Sink o) {
|
| + buildCounterSink++;
|
| + if (buildCounterSink < 3) {
|
| + checkUnnamed2425(o.codec);
|
| + checkUnnamed2426(o.spec);
|
| + }
|
| + buildCounterSink--;
|
| +}
|
| +
|
| +buildUnnamed2427() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2427(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted30 = (o["x"]) as core.Map; unittest.expect(casted30, unittest.hasLength(3)); unittest.expect(casted30["list"], unittest.equals([1, 2, 3])); unittest.expect(casted30["bool"], unittest.equals(true)); unittest.expect(casted30["string"], unittest.equals('foo'));
|
| + var casted31 = (o["y"]) as core.Map; unittest.expect(casted31, unittest.hasLength(3)); unittest.expect(casted31["list"], unittest.equals([1, 2, 3])); unittest.expect(casted31["bool"], unittest.equals(true)); unittest.expect(casted31["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2428() {
|
| + var o = new core.List<core.Map<core.String, core.Object>>();
|
| + o.add(buildUnnamed2427());
|
| + o.add(buildUnnamed2427());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2428(core.List<core.Map<core.String, core.Object>> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkUnnamed2427(o[0]);
|
| + checkUnnamed2427(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2429() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2429(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted32 = (o["x"]) as core.Map; unittest.expect(casted32, unittest.hasLength(3)); unittest.expect(casted32["list"], unittest.equals([1, 2, 3])); unittest.expect(casted32["bool"], unittest.equals(true)); unittest.expect(casted32["string"], unittest.equals('foo'));
|
| + var casted33 = (o["y"]) as core.Map; unittest.expect(casted33, unittest.hasLength(3)); unittest.expect(casted33["list"], unittest.equals([1, 2, 3])); unittest.expect(casted33["bool"], unittest.equals(true)); unittest.expect(casted33["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2430() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2430(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted34 = (o["x"]) as core.Map; unittest.expect(casted34, unittest.hasLength(3)); unittest.expect(casted34["list"], unittest.equals([1, 2, 3])); unittest.expect(casted34["bool"], unittest.equals(true)); unittest.expect(casted34["string"], unittest.equals('foo'));
|
| + var casted35 = (o["y"]) as core.Map; unittest.expect(casted35, unittest.hasLength(3)); unittest.expect(casted35["list"], unittest.equals([1, 2, 3])); unittest.expect(casted35["bool"], unittest.equals(true)); unittest.expect(casted35["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterSource = 0;
|
| +buildSource() {
|
| + var o = new api.Source();
|
| + buildCounterSource++;
|
| + if (buildCounterSource < 3) {
|
| + o.baseSpecs = buildUnnamed2428();
|
| + o.codec = buildUnnamed2429();
|
| + o.doesNotNeedSplitting = true;
|
| + o.metadata = buildSourceMetadata();
|
| + o.spec = buildUnnamed2430();
|
| + }
|
| + buildCounterSource--;
|
| + return o;
|
| +}
|
| +
|
| +checkSource(api.Source o) {
|
| + buildCounterSource++;
|
| + if (buildCounterSource < 3) {
|
| + checkUnnamed2428(o.baseSpecs);
|
| + checkUnnamed2429(o.codec);
|
| + unittest.expect(o.doesNotNeedSplitting, unittest.isTrue);
|
| + checkSourceMetadata(o.metadata);
|
| + checkUnnamed2430(o.spec);
|
| + }
|
| + buildCounterSource--;
|
| +}
|
| +
|
| +core.int buildCounterSourceFork = 0;
|
| +buildSourceFork() {
|
| + var o = new api.SourceFork();
|
| + buildCounterSourceFork++;
|
| + if (buildCounterSourceFork < 3) {
|
| + o.primary = buildSourceSplitShard();
|
| + o.primarySource = buildDerivedSource();
|
| + o.residual = buildSourceSplitShard();
|
| + o.residualSource = buildDerivedSource();
|
| + }
|
| + buildCounterSourceFork--;
|
| + return o;
|
| +}
|
| +
|
| +checkSourceFork(api.SourceFork o) {
|
| + buildCounterSourceFork++;
|
| + if (buildCounterSourceFork < 3) {
|
| + checkSourceSplitShard(o.primary);
|
| + checkDerivedSource(o.primarySource);
|
| + checkSourceSplitShard(o.residual);
|
| + checkDerivedSource(o.residualSource);
|
| + }
|
| + buildCounterSourceFork--;
|
| +}
|
| +
|
| +core.int buildCounterSourceGetMetadataRequest = 0;
|
| +buildSourceGetMetadataRequest() {
|
| + var o = new api.SourceGetMetadataRequest();
|
| + buildCounterSourceGetMetadataRequest++;
|
| + if (buildCounterSourceGetMetadataRequest < 3) {
|
| + o.source = buildSource();
|
| + }
|
| + buildCounterSourceGetMetadataRequest--;
|
| + return o;
|
| +}
|
| +
|
| +checkSourceGetMetadataRequest(api.SourceGetMetadataRequest o) {
|
| + buildCounterSourceGetMetadataRequest++;
|
| + if (buildCounterSourceGetMetadataRequest < 3) {
|
| + checkSource(o.source);
|
| + }
|
| + buildCounterSourceGetMetadataRequest--;
|
| +}
|
| +
|
| +core.int buildCounterSourceGetMetadataResponse = 0;
|
| +buildSourceGetMetadataResponse() {
|
| + var o = new api.SourceGetMetadataResponse();
|
| + buildCounterSourceGetMetadataResponse++;
|
| + if (buildCounterSourceGetMetadataResponse < 3) {
|
| + o.metadata = buildSourceMetadata();
|
| + }
|
| + buildCounterSourceGetMetadataResponse--;
|
| + return o;
|
| +}
|
| +
|
| +checkSourceGetMetadataResponse(api.SourceGetMetadataResponse o) {
|
| + buildCounterSourceGetMetadataResponse++;
|
| + if (buildCounterSourceGetMetadataResponse < 3) {
|
| + checkSourceMetadata(o.metadata);
|
| + }
|
| + buildCounterSourceGetMetadataResponse--;
|
| +}
|
| +
|
| +core.int buildCounterSourceMetadata = 0;
|
| +buildSourceMetadata() {
|
| + var o = new api.SourceMetadata();
|
| + buildCounterSourceMetadata++;
|
| + if (buildCounterSourceMetadata < 3) {
|
| + o.estimatedSizeBytes = "foo";
|
| + o.infinite = true;
|
| + o.producesSortedKeys = true;
|
| + }
|
| + buildCounterSourceMetadata--;
|
| + return o;
|
| +}
|
| +
|
| +checkSourceMetadata(api.SourceMetadata o) {
|
| + buildCounterSourceMetadata++;
|
| + if (buildCounterSourceMetadata < 3) {
|
| + unittest.expect(o.estimatedSizeBytes, unittest.equals('foo'));
|
| + unittest.expect(o.infinite, unittest.isTrue);
|
| + unittest.expect(o.producesSortedKeys, unittest.isTrue);
|
| + }
|
| + buildCounterSourceMetadata--;
|
| +}
|
| +
|
| +core.int buildCounterSourceOperationRequest = 0;
|
| +buildSourceOperationRequest() {
|
| + var o = new api.SourceOperationRequest();
|
| + buildCounterSourceOperationRequest++;
|
| + if (buildCounterSourceOperationRequest < 3) {
|
| + o.getMetadata = buildSourceGetMetadataRequest();
|
| + o.split = buildSourceSplitRequest();
|
| + }
|
| + buildCounterSourceOperationRequest--;
|
| + return o;
|
| +}
|
| +
|
| +checkSourceOperationRequest(api.SourceOperationRequest o) {
|
| + buildCounterSourceOperationRequest++;
|
| + if (buildCounterSourceOperationRequest < 3) {
|
| + checkSourceGetMetadataRequest(o.getMetadata);
|
| + checkSourceSplitRequest(o.split);
|
| + }
|
| + buildCounterSourceOperationRequest--;
|
| +}
|
| +
|
| +core.int buildCounterSourceOperationResponse = 0;
|
| +buildSourceOperationResponse() {
|
| + var o = new api.SourceOperationResponse();
|
| + buildCounterSourceOperationResponse++;
|
| + if (buildCounterSourceOperationResponse < 3) {
|
| + o.getMetadata = buildSourceGetMetadataResponse();
|
| + o.split = buildSourceSplitResponse();
|
| + }
|
| + buildCounterSourceOperationResponse--;
|
| + return o;
|
| +}
|
| +
|
| +checkSourceOperationResponse(api.SourceOperationResponse o) {
|
| + buildCounterSourceOperationResponse++;
|
| + if (buildCounterSourceOperationResponse < 3) {
|
| + checkSourceGetMetadataResponse(o.getMetadata);
|
| + checkSourceSplitResponse(o.split);
|
| + }
|
| + buildCounterSourceOperationResponse--;
|
| +}
|
| +
|
| +core.int buildCounterSourceSplitOptions = 0;
|
| +buildSourceSplitOptions() {
|
| + var o = new api.SourceSplitOptions();
|
| + buildCounterSourceSplitOptions++;
|
| + if (buildCounterSourceSplitOptions < 3) {
|
| + o.desiredBundleSizeBytes = "foo";
|
| + o.desiredShardSizeBytes = "foo";
|
| + }
|
| + buildCounterSourceSplitOptions--;
|
| + return o;
|
| +}
|
| +
|
| +checkSourceSplitOptions(api.SourceSplitOptions o) {
|
| + buildCounterSourceSplitOptions++;
|
| + if (buildCounterSourceSplitOptions < 3) {
|
| + unittest.expect(o.desiredBundleSizeBytes, unittest.equals('foo'));
|
| + unittest.expect(o.desiredShardSizeBytes, unittest.equals('foo'));
|
| + }
|
| + buildCounterSourceSplitOptions--;
|
| +}
|
| +
|
| +core.int buildCounterSourceSplitRequest = 0;
|
| +buildSourceSplitRequest() {
|
| + var o = new api.SourceSplitRequest();
|
| + buildCounterSourceSplitRequest++;
|
| + if (buildCounterSourceSplitRequest < 3) {
|
| + o.options = buildSourceSplitOptions();
|
| + o.source = buildSource();
|
| + }
|
| + buildCounterSourceSplitRequest--;
|
| + return o;
|
| +}
|
| +
|
| +checkSourceSplitRequest(api.SourceSplitRequest o) {
|
| + buildCounterSourceSplitRequest++;
|
| + if (buildCounterSourceSplitRequest < 3) {
|
| + checkSourceSplitOptions(o.options);
|
| + checkSource(o.source);
|
| + }
|
| + buildCounterSourceSplitRequest--;
|
| +}
|
| +
|
| +buildUnnamed2431() {
|
| + var o = new core.List<api.DerivedSource>();
|
| + o.add(buildDerivedSource());
|
| + o.add(buildDerivedSource());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2431(core.List<api.DerivedSource> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkDerivedSource(o[0]);
|
| + checkDerivedSource(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2432() {
|
| + var o = new core.List<api.SourceSplitShard>();
|
| + o.add(buildSourceSplitShard());
|
| + o.add(buildSourceSplitShard());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2432(core.List<api.SourceSplitShard> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkSourceSplitShard(o[0]);
|
| + checkSourceSplitShard(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterSourceSplitResponse = 0;
|
| +buildSourceSplitResponse() {
|
| + var o = new api.SourceSplitResponse();
|
| + buildCounterSourceSplitResponse++;
|
| + if (buildCounterSourceSplitResponse < 3) {
|
| + o.bundles = buildUnnamed2431();
|
| + o.outcome = "foo";
|
| + o.shards = buildUnnamed2432();
|
| + }
|
| + buildCounterSourceSplitResponse--;
|
| + return o;
|
| +}
|
| +
|
| +checkSourceSplitResponse(api.SourceSplitResponse o) {
|
| + buildCounterSourceSplitResponse++;
|
| + if (buildCounterSourceSplitResponse < 3) {
|
| + checkUnnamed2431(o.bundles);
|
| + unittest.expect(o.outcome, unittest.equals('foo'));
|
| + checkUnnamed2432(o.shards);
|
| + }
|
| + buildCounterSourceSplitResponse--;
|
| +}
|
| +
|
| +core.int buildCounterSourceSplitShard = 0;
|
| +buildSourceSplitShard() {
|
| + var o = new api.SourceSplitShard();
|
| + buildCounterSourceSplitShard++;
|
| + if (buildCounterSourceSplitShard < 3) {
|
| + o.derivationMode = "foo";
|
| + o.source = buildSource();
|
| + }
|
| + buildCounterSourceSplitShard--;
|
| + return o;
|
| +}
|
| +
|
| +checkSourceSplitShard(api.SourceSplitShard o) {
|
| + buildCounterSourceSplitShard++;
|
| + if (buildCounterSourceSplitShard < 3) {
|
| + unittest.expect(o.derivationMode, unittest.equals('foo'));
|
| + checkSource(o.source);
|
| + }
|
| + buildCounterSourceSplitShard--;
|
| +}
|
| +
|
| +core.int buildCounterStateFamilyConfig = 0;
|
| +buildStateFamilyConfig() {
|
| + var o = new api.StateFamilyConfig();
|
| + buildCounterStateFamilyConfig++;
|
| + if (buildCounterStateFamilyConfig < 3) {
|
| + o.isRead = true;
|
| + o.stateFamily = "foo";
|
| + }
|
| + buildCounterStateFamilyConfig--;
|
| + return o;
|
| +}
|
| +
|
| +checkStateFamilyConfig(api.StateFamilyConfig o) {
|
| + buildCounterStateFamilyConfig++;
|
| + if (buildCounterStateFamilyConfig < 3) {
|
| + unittest.expect(o.isRead, unittest.isTrue);
|
| + unittest.expect(o.stateFamily, unittest.equals('foo'));
|
| + }
|
| + buildCounterStateFamilyConfig--;
|
| +}
|
| +
|
| +buildUnnamed2433() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2433(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted36 = (o["x"]) as core.Map; unittest.expect(casted36, unittest.hasLength(3)); unittest.expect(casted36["list"], unittest.equals([1, 2, 3])); unittest.expect(casted36["bool"], unittest.equals(true)); unittest.expect(casted36["string"], unittest.equals('foo'));
|
| + var casted37 = (o["y"]) as core.Map; unittest.expect(casted37, unittest.hasLength(3)); unittest.expect(casted37["list"], unittest.equals([1, 2, 3])); unittest.expect(casted37["bool"], unittest.equals(true)); unittest.expect(casted37["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2434() {
|
| + var o = new core.List<core.Map<core.String, core.Object>>();
|
| + o.add(buildUnnamed2433());
|
| + o.add(buildUnnamed2433());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2434(core.List<core.Map<core.String, core.Object>> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkUnnamed2433(o[0]);
|
| + checkUnnamed2433(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterStatus = 0;
|
| +buildStatus() {
|
| + var o = new api.Status();
|
| + buildCounterStatus++;
|
| + if (buildCounterStatus < 3) {
|
| + o.code = 42;
|
| + o.details = buildUnnamed2434();
|
| + o.message = "foo";
|
| + }
|
| + buildCounterStatus--;
|
| + return o;
|
| +}
|
| +
|
| +checkStatus(api.Status o) {
|
| + buildCounterStatus++;
|
| + if (buildCounterStatus < 3) {
|
| + unittest.expect(o.code, unittest.equals(42));
|
| + checkUnnamed2434(o.details);
|
| + unittest.expect(o.message, unittest.equals('foo'));
|
| + }
|
| + buildCounterStatus--;
|
| +}
|
| +
|
| +buildUnnamed2435() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2435(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted38 = (o["x"]) as core.Map; unittest.expect(casted38, unittest.hasLength(3)); unittest.expect(casted38["list"], unittest.equals([1, 2, 3])); unittest.expect(casted38["bool"], unittest.equals(true)); unittest.expect(casted38["string"], unittest.equals('foo'));
|
| + var casted39 = (o["y"]) as core.Map; unittest.expect(casted39, unittest.hasLength(3)); unittest.expect(casted39["list"], unittest.equals([1, 2, 3])); unittest.expect(casted39["bool"], unittest.equals(true)); unittest.expect(casted39["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterStep = 0;
|
| +buildStep() {
|
| + var o = new api.Step();
|
| + buildCounterStep++;
|
| + if (buildCounterStep < 3) {
|
| + o.kind = "foo";
|
| + o.name = "foo";
|
| + o.properties = buildUnnamed2435();
|
| + }
|
| + buildCounterStep--;
|
| + return o;
|
| +}
|
| +
|
| +checkStep(api.Step o) {
|
| + buildCounterStep++;
|
| + if (buildCounterStep < 3) {
|
| + unittest.expect(o.kind, unittest.equals('foo'));
|
| + unittest.expect(o.name, unittest.equals('foo'));
|
| + checkUnnamed2435(o.properties);
|
| + }
|
| + buildCounterStep--;
|
| +}
|
| +
|
| +core.int buildCounterStreamLocation = 0;
|
| +buildStreamLocation() {
|
| + var o = new api.StreamLocation();
|
| + buildCounterStreamLocation++;
|
| + if (buildCounterStreamLocation < 3) {
|
| + o.customSourceLocation = buildCustomSourceLocation();
|
| + o.pubsubLocation = buildPubsubLocation();
|
| + o.sideInputLocation = buildStreamingSideInputLocation();
|
| + o.streamingStageLocation = buildStreamingStageLocation();
|
| + }
|
| + buildCounterStreamLocation--;
|
| + return o;
|
| +}
|
| +
|
| +checkStreamLocation(api.StreamLocation o) {
|
| + buildCounterStreamLocation++;
|
| + if (buildCounterStreamLocation < 3) {
|
| + checkCustomSourceLocation(o.customSourceLocation);
|
| + checkPubsubLocation(o.pubsubLocation);
|
| + checkStreamingSideInputLocation(o.sideInputLocation);
|
| + checkStreamingStageLocation(o.streamingStageLocation);
|
| + }
|
| + buildCounterStreamLocation--;
|
| +}
|
| +
|
| +buildUnnamed2436() {
|
| + var o = new core.List<api.KeyRangeDataDiskAssignment>();
|
| + o.add(buildKeyRangeDataDiskAssignment());
|
| + o.add(buildKeyRangeDataDiskAssignment());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2436(core.List<api.KeyRangeDataDiskAssignment> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkKeyRangeDataDiskAssignment(o[0]);
|
| + checkKeyRangeDataDiskAssignment(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterStreamingComputationRanges = 0;
|
| +buildStreamingComputationRanges() {
|
| + var o = new api.StreamingComputationRanges();
|
| + buildCounterStreamingComputationRanges++;
|
| + if (buildCounterStreamingComputationRanges < 3) {
|
| + o.computationId = "foo";
|
| + o.rangeAssignments = buildUnnamed2436();
|
| + }
|
| + buildCounterStreamingComputationRanges--;
|
| + return o;
|
| +}
|
| +
|
| +checkStreamingComputationRanges(api.StreamingComputationRanges o) {
|
| + buildCounterStreamingComputationRanges++;
|
| + if (buildCounterStreamingComputationRanges < 3) {
|
| + unittest.expect(o.computationId, unittest.equals('foo'));
|
| + checkUnnamed2436(o.rangeAssignments);
|
| + }
|
| + buildCounterStreamingComputationRanges--;
|
| +}
|
| +
|
| +buildUnnamed2437() {
|
| + var o = new core.List<api.StreamingComputationRanges>();
|
| + o.add(buildStreamingComputationRanges());
|
| + o.add(buildStreamingComputationRanges());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2437(core.List<api.StreamingComputationRanges> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkStreamingComputationRanges(o[0]);
|
| + checkStreamingComputationRanges(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2438() {
|
| + var o = new core.List<api.MountedDataDisk>();
|
| + o.add(buildMountedDataDisk());
|
| + o.add(buildMountedDataDisk());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2438(core.List<api.MountedDataDisk> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkMountedDataDisk(o[0]);
|
| + checkMountedDataDisk(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterStreamingComputationTask = 0;
|
| +buildStreamingComputationTask() {
|
| + var o = new api.StreamingComputationTask();
|
| + buildCounterStreamingComputationTask++;
|
| + if (buildCounterStreamingComputationTask < 3) {
|
| + o.computationRanges = buildUnnamed2437();
|
| + o.dataDisks = buildUnnamed2438();
|
| + o.taskType = "foo";
|
| + }
|
| + buildCounterStreamingComputationTask--;
|
| + return o;
|
| +}
|
| +
|
| +checkStreamingComputationTask(api.StreamingComputationTask o) {
|
| + buildCounterStreamingComputationTask++;
|
| + if (buildCounterStreamingComputationTask < 3) {
|
| + checkUnnamed2437(o.computationRanges);
|
| + checkUnnamed2438(o.dataDisks);
|
| + unittest.expect(o.taskType, unittest.equals('foo'));
|
| + }
|
| + buildCounterStreamingComputationTask--;
|
| +}
|
| +
|
| +core.int buildCounterStreamingSetupTask = 0;
|
| +buildStreamingSetupTask() {
|
| + var o = new api.StreamingSetupTask();
|
| + buildCounterStreamingSetupTask++;
|
| + if (buildCounterStreamingSetupTask < 3) {
|
| + o.receiveWorkPort = 42;
|
| + o.streamingComputationTopology = buildTopologyConfig();
|
| + o.workerHarnessPort = 42;
|
| + }
|
| + buildCounterStreamingSetupTask--;
|
| + return o;
|
| +}
|
| +
|
| +checkStreamingSetupTask(api.StreamingSetupTask o) {
|
| + buildCounterStreamingSetupTask++;
|
| + if (buildCounterStreamingSetupTask < 3) {
|
| + unittest.expect(o.receiveWorkPort, unittest.equals(42));
|
| + checkTopologyConfig(o.streamingComputationTopology);
|
| + unittest.expect(o.workerHarnessPort, unittest.equals(42));
|
| + }
|
| + buildCounterStreamingSetupTask--;
|
| +}
|
| +
|
| +core.int buildCounterStreamingSideInputLocation = 0;
|
| +buildStreamingSideInputLocation() {
|
| + var o = new api.StreamingSideInputLocation();
|
| + buildCounterStreamingSideInputLocation++;
|
| + if (buildCounterStreamingSideInputLocation < 3) {
|
| + o.stateFamily = "foo";
|
| + o.tag = "foo";
|
| + }
|
| + buildCounterStreamingSideInputLocation--;
|
| + return o;
|
| +}
|
| +
|
| +checkStreamingSideInputLocation(api.StreamingSideInputLocation o) {
|
| + buildCounterStreamingSideInputLocation++;
|
| + if (buildCounterStreamingSideInputLocation < 3) {
|
| + unittest.expect(o.stateFamily, unittest.equals('foo'));
|
| + unittest.expect(o.tag, unittest.equals('foo'));
|
| + }
|
| + buildCounterStreamingSideInputLocation--;
|
| +}
|
| +
|
| +core.int buildCounterStreamingStageLocation = 0;
|
| +buildStreamingStageLocation() {
|
| + var o = new api.StreamingStageLocation();
|
| + buildCounterStreamingStageLocation++;
|
| + if (buildCounterStreamingStageLocation < 3) {
|
| + o.streamId = "foo";
|
| + }
|
| + buildCounterStreamingStageLocation--;
|
| + return o;
|
| +}
|
| +
|
| +checkStreamingStageLocation(api.StreamingStageLocation o) {
|
| + buildCounterStreamingStageLocation++;
|
| + if (buildCounterStreamingStageLocation < 3) {
|
| + unittest.expect(o.streamId, unittest.equals('foo'));
|
| + }
|
| + buildCounterStreamingStageLocation--;
|
| +}
|
| +
|
| +buildUnnamed2439() {
|
| + var o = new core.List<core.String>();
|
| + o.add("foo");
|
| + o.add("foo");
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2439(core.List<core.String> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + unittest.expect(o[0], unittest.equals('foo'));
|
| + unittest.expect(o[1], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterTaskRunnerSettings = 0;
|
| +buildTaskRunnerSettings() {
|
| + var o = new api.TaskRunnerSettings();
|
| + buildCounterTaskRunnerSettings++;
|
| + if (buildCounterTaskRunnerSettings < 3) {
|
| + o.alsologtostderr = true;
|
| + o.baseTaskDir = "foo";
|
| + o.baseUrl = "foo";
|
| + o.commandlinesFileName = "foo";
|
| + o.continueOnException = true;
|
| + o.dataflowApiVersion = "foo";
|
| + o.harnessCommand = "foo";
|
| + o.languageHint = "foo";
|
| + o.logDir = "foo";
|
| + o.logToSerialconsole = true;
|
| + o.logUploadLocation = "foo";
|
| + o.oauthScopes = buildUnnamed2439();
|
| + o.parallelWorkerSettings = buildWorkerSettings();
|
| + o.streamingWorkerMainClass = "foo";
|
| + o.taskGroup = "foo";
|
| + o.taskUser = "foo";
|
| + o.tempStoragePrefix = "foo";
|
| + o.vmId = "foo";
|
| + o.workflowFileName = "foo";
|
| + }
|
| + buildCounterTaskRunnerSettings--;
|
| + return o;
|
| +}
|
| +
|
| +checkTaskRunnerSettings(api.TaskRunnerSettings o) {
|
| + buildCounterTaskRunnerSettings++;
|
| + if (buildCounterTaskRunnerSettings < 3) {
|
| + unittest.expect(o.alsologtostderr, unittest.isTrue);
|
| + unittest.expect(o.baseTaskDir, unittest.equals('foo'));
|
| + unittest.expect(o.baseUrl, unittest.equals('foo'));
|
| + unittest.expect(o.commandlinesFileName, unittest.equals('foo'));
|
| + unittest.expect(o.continueOnException, unittest.isTrue);
|
| + unittest.expect(o.dataflowApiVersion, unittest.equals('foo'));
|
| + unittest.expect(o.harnessCommand, unittest.equals('foo'));
|
| + unittest.expect(o.languageHint, unittest.equals('foo'));
|
| + unittest.expect(o.logDir, unittest.equals('foo'));
|
| + unittest.expect(o.logToSerialconsole, unittest.isTrue);
|
| + unittest.expect(o.logUploadLocation, unittest.equals('foo'));
|
| + checkUnnamed2439(o.oauthScopes);
|
| + checkWorkerSettings(o.parallelWorkerSettings);
|
| + unittest.expect(o.streamingWorkerMainClass, unittest.equals('foo'));
|
| + unittest.expect(o.taskGroup, unittest.equals('foo'));
|
| + unittest.expect(o.taskUser, unittest.equals('foo'));
|
| + unittest.expect(o.tempStoragePrefix, unittest.equals('foo'));
|
| + unittest.expect(o.vmId, unittest.equals('foo'));
|
| + unittest.expect(o.workflowFileName, unittest.equals('foo'));
|
| + }
|
| + buildCounterTaskRunnerSettings--;
|
| +}
|
| +
|
| +buildUnnamed2440() {
|
| + var o = new core.List<api.ComputationTopology>();
|
| + o.add(buildComputationTopology());
|
| + o.add(buildComputationTopology());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2440(core.List<api.ComputationTopology> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkComputationTopology(o[0]);
|
| + checkComputationTopology(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2441() {
|
| + var o = new core.List<api.DataDiskAssignment>();
|
| + o.add(buildDataDiskAssignment());
|
| + o.add(buildDataDiskAssignment());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2441(core.List<api.DataDiskAssignment> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkDataDiskAssignment(o[0]);
|
| + checkDataDiskAssignment(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2442() {
|
| + var o = new core.Map<core.String, core.String>();
|
| + o["x"] = "foo";
|
| + o["y"] = "foo";
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2442(core.Map<core.String, core.String> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + unittest.expect(o["x"], unittest.equals('foo'));
|
| + unittest.expect(o["y"], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterTopologyConfig = 0;
|
| +buildTopologyConfig() {
|
| + var o = new api.TopologyConfig();
|
| + buildCounterTopologyConfig++;
|
| + if (buildCounterTopologyConfig < 3) {
|
| + o.computations = buildUnnamed2440();
|
| + o.dataDiskAssignments = buildUnnamed2441();
|
| + o.userStageToComputationNameMap = buildUnnamed2442();
|
| + }
|
| + buildCounterTopologyConfig--;
|
| + return o;
|
| +}
|
| +
|
| +checkTopologyConfig(api.TopologyConfig o) {
|
| + buildCounterTopologyConfig++;
|
| + if (buildCounterTopologyConfig < 3) {
|
| + checkUnnamed2440(o.computations);
|
| + checkUnnamed2441(o.dataDiskAssignments);
|
| + checkUnnamed2442(o.userStageToComputationNameMap);
|
| + }
|
| + buildCounterTopologyConfig--;
|
| +}
|
| +
|
| +buildUnnamed2443() {
|
| + var o = new core.List<api.Package>();
|
| + o.add(buildPackage());
|
| + o.add(buildPackage());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2443(core.List<api.Package> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkPackage(o[0]);
|
| + checkPackage(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterWorkItem = 0;
|
| +buildWorkItem() {
|
| + var o = new api.WorkItem();
|
| + buildCounterWorkItem++;
|
| + if (buildCounterWorkItem < 3) {
|
| + o.configuration = "foo";
|
| + o.id = "foo";
|
| + o.initialReportIndex = "foo";
|
| + o.jobId = "foo";
|
| + o.leaseExpireTime = "foo";
|
| + o.mapTask = buildMapTask();
|
| + o.packages = buildUnnamed2443();
|
| + o.projectId = "foo";
|
| + o.reportStatusInterval = "foo";
|
| + o.seqMapTask = buildSeqMapTask();
|
| + o.shellTask = buildShellTask();
|
| + o.sourceOperationTask = buildSourceOperationRequest();
|
| + o.streamingComputationTask = buildStreamingComputationTask();
|
| + o.streamingSetupTask = buildStreamingSetupTask();
|
| + }
|
| + buildCounterWorkItem--;
|
| + return o;
|
| +}
|
| +
|
| +checkWorkItem(api.WorkItem o) {
|
| + buildCounterWorkItem++;
|
| + if (buildCounterWorkItem < 3) {
|
| + unittest.expect(o.configuration, unittest.equals('foo'));
|
| + unittest.expect(o.id, unittest.equals('foo'));
|
| + unittest.expect(o.initialReportIndex, unittest.equals('foo'));
|
| + unittest.expect(o.jobId, unittest.equals('foo'));
|
| + unittest.expect(o.leaseExpireTime, unittest.equals('foo'));
|
| + checkMapTask(o.mapTask);
|
| + checkUnnamed2443(o.packages);
|
| + unittest.expect(o.projectId, unittest.equals('foo'));
|
| + unittest.expect(o.reportStatusInterval, unittest.equals('foo'));
|
| + checkSeqMapTask(o.seqMapTask);
|
| + checkShellTask(o.shellTask);
|
| + checkSourceOperationRequest(o.sourceOperationTask);
|
| + checkStreamingComputationTask(o.streamingComputationTask);
|
| + checkStreamingSetupTask(o.streamingSetupTask);
|
| + }
|
| + buildCounterWorkItem--;
|
| +}
|
| +
|
| +buildUnnamed2444() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2444(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted40 = (o["x"]) as core.Map; unittest.expect(casted40, unittest.hasLength(3)); unittest.expect(casted40["list"], unittest.equals([1, 2, 3])); unittest.expect(casted40["bool"], unittest.equals(true)); unittest.expect(casted40["string"], unittest.equals('foo'));
|
| + var casted41 = (o["y"]) as core.Map; unittest.expect(casted41, unittest.hasLength(3)); unittest.expect(casted41["list"], unittest.equals([1, 2, 3])); unittest.expect(casted41["bool"], unittest.equals(true)); unittest.expect(casted41["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterWorkItemServiceState = 0;
|
| +buildWorkItemServiceState() {
|
| + var o = new api.WorkItemServiceState();
|
| + buildCounterWorkItemServiceState++;
|
| + if (buildCounterWorkItemServiceState < 3) {
|
| + o.harnessData = buildUnnamed2444();
|
| + o.leaseExpireTime = "foo";
|
| + o.nextReportIndex = "foo";
|
| + o.reportStatusInterval = "foo";
|
| + o.suggestedStopPoint = buildApproximateProgress();
|
| + o.suggestedStopPosition = buildPosition();
|
| + }
|
| + buildCounterWorkItemServiceState--;
|
| + return o;
|
| +}
|
| +
|
| +checkWorkItemServiceState(api.WorkItemServiceState o) {
|
| + buildCounterWorkItemServiceState++;
|
| + if (buildCounterWorkItemServiceState < 3) {
|
| + checkUnnamed2444(o.harnessData);
|
| + unittest.expect(o.leaseExpireTime, unittest.equals('foo'));
|
| + unittest.expect(o.nextReportIndex, unittest.equals('foo'));
|
| + unittest.expect(o.reportStatusInterval, unittest.equals('foo'));
|
| + checkApproximateProgress(o.suggestedStopPoint);
|
| + checkPosition(o.suggestedStopPosition);
|
| + }
|
| + buildCounterWorkItemServiceState--;
|
| +}
|
| +
|
| +buildUnnamed2445() {
|
| + var o = new core.List<api.Status>();
|
| + o.add(buildStatus());
|
| + o.add(buildStatus());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2445(core.List<api.Status> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkStatus(o[0]);
|
| + checkStatus(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2446() {
|
| + var o = new core.List<api.MetricUpdate>();
|
| + o.add(buildMetricUpdate());
|
| + o.add(buildMetricUpdate());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2446(core.List<api.MetricUpdate> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkMetricUpdate(o[0]);
|
| + checkMetricUpdate(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterWorkItemStatus = 0;
|
| +buildWorkItemStatus() {
|
| + var o = new api.WorkItemStatus();
|
| + buildCounterWorkItemStatus++;
|
| + if (buildCounterWorkItemStatus < 3) {
|
| + o.completed = true;
|
| + o.dynamicSourceSplit = buildDynamicSourceSplit();
|
| + o.errors = buildUnnamed2445();
|
| + o.metricUpdates = buildUnnamed2446();
|
| + o.progress = buildApproximateProgress();
|
| + o.reportIndex = "foo";
|
| + o.requestedLeaseDuration = "foo";
|
| + o.sourceFork = buildSourceFork();
|
| + o.sourceOperationResponse = buildSourceOperationResponse();
|
| + o.stopPosition = buildPosition();
|
| + o.workItemId = "foo";
|
| + }
|
| + buildCounterWorkItemStatus--;
|
| + return o;
|
| +}
|
| +
|
| +checkWorkItemStatus(api.WorkItemStatus o) {
|
| + buildCounterWorkItemStatus++;
|
| + if (buildCounterWorkItemStatus < 3) {
|
| + unittest.expect(o.completed, unittest.isTrue);
|
| + checkDynamicSourceSplit(o.dynamicSourceSplit);
|
| + checkUnnamed2445(o.errors);
|
| + checkUnnamed2446(o.metricUpdates);
|
| + checkApproximateProgress(o.progress);
|
| + unittest.expect(o.reportIndex, unittest.equals('foo'));
|
| + unittest.expect(o.requestedLeaseDuration, unittest.equals('foo'));
|
| + checkSourceFork(o.sourceFork);
|
| + checkSourceOperationResponse(o.sourceOperationResponse);
|
| + checkPosition(o.stopPosition);
|
| + unittest.expect(o.workItemId, unittest.equals('foo'));
|
| + }
|
| + buildCounterWorkItemStatus--;
|
| +}
|
| +
|
| +buildUnnamed2447() {
|
| + var o = new core.List<api.Disk>();
|
| + o.add(buildDisk());
|
| + o.add(buildDisk());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2447(core.List<api.Disk> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkDisk(o[0]);
|
| + checkDisk(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2448() {
|
| + var o = new core.Map<core.String, core.String>();
|
| + o["x"] = "foo";
|
| + o["y"] = "foo";
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2448(core.Map<core.String, core.String> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + unittest.expect(o["x"], unittest.equals('foo'));
|
| + unittest.expect(o["y"], unittest.equals('foo'));
|
| +}
|
| +
|
| +buildUnnamed2449() {
|
| + var o = new core.List<api.Package>();
|
| + o.add(buildPackage());
|
| + o.add(buildPackage());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2449(core.List<api.Package> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkPackage(o[0]);
|
| + checkPackage(o[1]);
|
| +}
|
| +
|
| +buildUnnamed2450() {
|
| + var o = new core.Map<core.String, core.Object>();
|
| + o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed2450(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted42 = (o["x"]) as core.Map; unittest.expect(casted42, unittest.hasLength(3)); unittest.expect(casted42["list"], unittest.equals([1, 2, 3])); unittest.expect(casted42["bool"], unittest.equals(true)); unittest.expect(casted42["string"], unittest.equals('foo'));
|
| + var casted43 = (o["y"]) as core.Map; unittest.expect(casted43, unittest.hasLength(3)); unittest.expect(casted43["list"], unittest.equals([1, 2, 3])); unittest.expect(casted43["bool"], unittest.equals(true)); unittest.expect(casted43["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| +core.int buildCounterWorkerPool = 0;
|
| +buildWorkerPool() {
|
| + var o = new api.WorkerPool();
|
| + buildCounterWorkerPool++;
|
| + if (buildCounterWorkerPool < 3) {
|
| + o.autoscalingSettings = buildAutoscalingSettings();
|
| + o.dataDisks = buildUnnamed2447();
|
| + o.defaultPackageSet = "foo";
|
| + o.diskSizeGb = 42;
|
| + o.diskSourceImage = "foo";
|
| + o.diskType = "foo";
|
| + o.kind = "foo";
|
| + o.machineType = "foo";
|
| + o.metadata = buildUnnamed2448();
|
| + o.network = "foo";
|
| + o.numWorkers = 42;
|
| + o.onHostMaintenance = "foo";
|
| + o.packages = buildUnnamed2449();
|
| + o.poolArgs = buildUnnamed2450();
|
| + o.taskrunnerSettings = buildTaskRunnerSettings();
|
| + o.teardownPolicy = "foo";
|
| + o.zone = "foo";
|
| + }
|
| + buildCounterWorkerPool--;
|
| + return o;
|
| +}
|
| +
|
| +checkWorkerPool(api.WorkerPool o) {
|
| + buildCounterWorkerPool++;
|
| + if (buildCounterWorkerPool < 3) {
|
| + checkAutoscalingSettings(o.autoscalingSettings);
|
| + checkUnnamed2447(o.dataDisks);
|
| + unittest.expect(o.defaultPackageSet, unittest.equals('foo'));
|
| + unittest.expect(o.diskSizeGb, unittest.equals(42));
|
| + unittest.expect(o.diskSourceImage, unittest.equals('foo'));
|
| + unittest.expect(o.diskType, unittest.equals('foo'));
|
| + unittest.expect(o.kind, unittest.equals('foo'));
|
| + unittest.expect(o.machineType, unittest.equals('foo'));
|
| + checkUnnamed2448(o.metadata);
|
| + unittest.expect(o.network, unittest.equals('foo'));
|
| + unittest.expect(o.numWorkers, unittest.equals(42));
|
| + unittest.expect(o.onHostMaintenance, unittest.equals('foo'));
|
| + checkUnnamed2449(o.packages);
|
| + checkUnnamed2450(o.poolArgs);
|
| + checkTaskRunnerSettings(o.taskrunnerSettings);
|
| + unittest.expect(o.teardownPolicy, unittest.equals('foo'));
|
| + unittest.expect(o.zone, unittest.equals('foo'));
|
| + }
|
| + buildCounterWorkerPool--;
|
| +}
|
| +
|
| +core.int buildCounterWorkerSettings = 0;
|
| +buildWorkerSettings() {
|
| + var o = new api.WorkerSettings();
|
| + buildCounterWorkerSettings++;
|
| + if (buildCounterWorkerSettings < 3) {
|
| + o.baseUrl = "foo";
|
| + o.reportingEnabled = true;
|
| + o.servicePath = "foo";
|
| + o.shuffleServicePath = "foo";
|
| + o.tempStoragePrefix = "foo";
|
| + o.workerId = "foo";
|
| + }
|
| + buildCounterWorkerSettings--;
|
| + return o;
|
| +}
|
| +
|
| +checkWorkerSettings(api.WorkerSettings o) {
|
| + buildCounterWorkerSettings++;
|
| + if (buildCounterWorkerSettings < 3) {
|
| + unittest.expect(o.baseUrl, unittest.equals('foo'));
|
| + unittest.expect(o.reportingEnabled, unittest.isTrue);
|
| + unittest.expect(o.servicePath, unittest.equals('foo'));
|
| + unittest.expect(o.shuffleServicePath, unittest.equals('foo'));
|
| + unittest.expect(o.tempStoragePrefix, unittest.equals('foo'));
|
| + unittest.expect(o.workerId, unittest.equals('foo'));
|
| + }
|
| + buildCounterWorkerSettings--;
|
| +}
|
| +
|
| +core.int buildCounterWriteInstruction = 0;
|
| +buildWriteInstruction() {
|
| + var o = new api.WriteInstruction();
|
| + buildCounterWriteInstruction++;
|
| + if (buildCounterWriteInstruction < 3) {
|
| + o.input = buildInstructionInput();
|
| + o.sink = buildSink();
|
| + }
|
| + buildCounterWriteInstruction--;
|
| + return o;
|
| +}
|
| +
|
| +checkWriteInstruction(api.WriteInstruction o) {
|
| + buildCounterWriteInstruction++;
|
| + if (buildCounterWriteInstruction < 3) {
|
| + checkInstructionInput(o.input);
|
| + checkSink(o.sink);
|
| + }
|
| + buildCounterWriteInstruction--;
|
| +}
|
| +
|
|
|
| main() {
|
| + unittest.group("obj-schema-ApproximateProgress", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildApproximateProgress();
|
| + var od = new api.ApproximateProgress.fromJson(o.toJson());
|
| + checkApproximateProgress(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-AutoscalingSettings", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildAutoscalingSettings();
|
| + var od = new api.AutoscalingSettings.fromJson(o.toJson());
|
| + checkAutoscalingSettings(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-ComputationTopology", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildComputationTopology();
|
| + var od = new api.ComputationTopology.fromJson(o.toJson());
|
| + checkComputationTopology(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-CustomSourceLocation", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildCustomSourceLocation();
|
| + var od = new api.CustomSourceLocation.fromJson(o.toJson());
|
| + checkCustomSourceLocation(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-DataDiskAssignment", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildDataDiskAssignment();
|
| + var od = new api.DataDiskAssignment.fromJson(o.toJson());
|
| + checkDataDiskAssignment(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-DerivedSource", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildDerivedSource();
|
| + var od = new api.DerivedSource.fromJson(o.toJson());
|
| + checkDerivedSource(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-Disk", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildDisk();
|
| + var od = new api.Disk.fromJson(o.toJson());
|
| + checkDisk(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-DynamicSourceSplit", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildDynamicSourceSplit();
|
| + var od = new api.DynamicSourceSplit.fromJson(o.toJson());
|
| + checkDynamicSourceSplit(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-Environment", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildEnvironment();
|
| + var od = new api.Environment.fromJson(o.toJson());
|
| + checkEnvironment(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-FlattenInstruction", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildFlattenInstruction();
|
| + var od = new api.FlattenInstruction.fromJson(o.toJson());
|
| + checkFlattenInstruction(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-InstructionInput", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildInstructionInput();
|
| + var od = new api.InstructionInput.fromJson(o.toJson());
|
| + checkInstructionInput(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-InstructionOutput", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildInstructionOutput();
|
| + var od = new api.InstructionOutput.fromJson(o.toJson());
|
| + checkInstructionOutput(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-Job", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildJob();
|
| + var od = new api.Job.fromJson(o.toJson());
|
| + checkJob(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-JobExecutionInfo", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildJobExecutionInfo();
|
| + var od = new api.JobExecutionInfo.fromJson(o.toJson());
|
| + checkJobExecutionInfo(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-JobExecutionStageInfo", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildJobExecutionStageInfo();
|
| + var od = new api.JobExecutionStageInfo.fromJson(o.toJson());
|
| + checkJobExecutionStageInfo(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-JobMessage", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildJobMessage();
|
| + var od = new api.JobMessage.fromJson(o.toJson());
|
| + checkJobMessage(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-JobMetrics", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildJobMetrics();
|
| + var od = new api.JobMetrics.fromJson(o.toJson());
|
| + checkJobMetrics(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-KeyRangeDataDiskAssignment", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildKeyRangeDataDiskAssignment();
|
| + var od = new api.KeyRangeDataDiskAssignment.fromJson(o.toJson());
|
| + checkKeyRangeDataDiskAssignment(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-KeyRangeLocation", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildKeyRangeLocation();
|
| + var od = new api.KeyRangeLocation.fromJson(o.toJson());
|
| + checkKeyRangeLocation(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-LeaseWorkItemRequest", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildLeaseWorkItemRequest();
|
| + var od = new api.LeaseWorkItemRequest.fromJson(o.toJson());
|
| + checkLeaseWorkItemRequest(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-LeaseWorkItemResponse", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildLeaseWorkItemResponse();
|
| + var od = new api.LeaseWorkItemResponse.fromJson(o.toJson());
|
| + checkLeaseWorkItemResponse(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-ListJobMessagesResponse", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildListJobMessagesResponse();
|
| + var od = new api.ListJobMessagesResponse.fromJson(o.toJson());
|
| + checkListJobMessagesResponse(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-ListJobsResponse", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildListJobsResponse();
|
| + var od = new api.ListJobsResponse.fromJson(o.toJson());
|
| + checkListJobsResponse(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-MapTask", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildMapTask();
|
| + var od = new api.MapTask.fromJson(o.toJson());
|
| + checkMapTask(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-MetricStructuredName", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildMetricStructuredName();
|
| + var od = new api.MetricStructuredName.fromJson(o.toJson());
|
| + checkMetricStructuredName(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-MetricUpdate", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildMetricUpdate();
|
| + var od = new api.MetricUpdate.fromJson(o.toJson());
|
| + checkMetricUpdate(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-MountedDataDisk", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildMountedDataDisk();
|
| + var od = new api.MountedDataDisk.fromJson(o.toJson());
|
| + checkMountedDataDisk(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-MultiOutputInfo", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildMultiOutputInfo();
|
| + var od = new api.MultiOutputInfo.fromJson(o.toJson());
|
| + checkMultiOutputInfo(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-Package", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildPackage();
|
| + var od = new api.Package.fromJson(o.toJson());
|
| + checkPackage(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-ParDoInstruction", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildParDoInstruction();
|
| + var od = new api.ParDoInstruction.fromJson(o.toJson());
|
| + checkParDoInstruction(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-ParallelInstruction", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildParallelInstruction();
|
| + var od = new api.ParallelInstruction.fromJson(o.toJson());
|
| + checkParallelInstruction(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-PartialGroupByKeyInstruction", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildPartialGroupByKeyInstruction();
|
| + var od = new api.PartialGroupByKeyInstruction.fromJson(o.toJson());
|
| + checkPartialGroupByKeyInstruction(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-Position", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildPosition();
|
| + var od = new api.Position.fromJson(o.toJson());
|
| + checkPosition(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-PubsubLocation", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildPubsubLocation();
|
| + var od = new api.PubsubLocation.fromJson(o.toJson());
|
| + checkPubsubLocation(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-ReadInstruction", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildReadInstruction();
|
| + var od = new api.ReadInstruction.fromJson(o.toJson());
|
| + checkReadInstruction(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-ReportWorkItemStatusRequest", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildReportWorkItemStatusRequest();
|
| + var od = new api.ReportWorkItemStatusRequest.fromJson(o.toJson());
|
| + checkReportWorkItemStatusRequest(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-ReportWorkItemStatusResponse", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildReportWorkItemStatusResponse();
|
| + var od = new api.ReportWorkItemStatusResponse.fromJson(o.toJson());
|
| + checkReportWorkItemStatusResponse(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SeqMapTask", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSeqMapTask();
|
| + var od = new api.SeqMapTask.fromJson(o.toJson());
|
| + checkSeqMapTask(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SeqMapTaskOutputInfo", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSeqMapTaskOutputInfo();
|
| + var od = new api.SeqMapTaskOutputInfo.fromJson(o.toJson());
|
| + checkSeqMapTaskOutputInfo(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-ShellTask", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildShellTask();
|
| + var od = new api.ShellTask.fromJson(o.toJson());
|
| + checkShellTask(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SideInputInfo", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSideInputInfo();
|
| + var od = new api.SideInputInfo.fromJson(o.toJson());
|
| + checkSideInputInfo(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-Sink", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSink();
|
| + var od = new api.Sink.fromJson(o.toJson());
|
| + checkSink(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-Source", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSource();
|
| + var od = new api.Source.fromJson(o.toJson());
|
| + checkSource(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SourceFork", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSourceFork();
|
| + var od = new api.SourceFork.fromJson(o.toJson());
|
| + checkSourceFork(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SourceGetMetadataRequest", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSourceGetMetadataRequest();
|
| + var od = new api.SourceGetMetadataRequest.fromJson(o.toJson());
|
| + checkSourceGetMetadataRequest(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SourceGetMetadataResponse", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSourceGetMetadataResponse();
|
| + var od = new api.SourceGetMetadataResponse.fromJson(o.toJson());
|
| + checkSourceGetMetadataResponse(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SourceMetadata", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSourceMetadata();
|
| + var od = new api.SourceMetadata.fromJson(o.toJson());
|
| + checkSourceMetadata(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SourceOperationRequest", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSourceOperationRequest();
|
| + var od = new api.SourceOperationRequest.fromJson(o.toJson());
|
| + checkSourceOperationRequest(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SourceOperationResponse", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSourceOperationResponse();
|
| + var od = new api.SourceOperationResponse.fromJson(o.toJson());
|
| + checkSourceOperationResponse(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SourceSplitOptions", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSourceSplitOptions();
|
| + var od = new api.SourceSplitOptions.fromJson(o.toJson());
|
| + checkSourceSplitOptions(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SourceSplitRequest", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSourceSplitRequest();
|
| + var od = new api.SourceSplitRequest.fromJson(o.toJson());
|
| + checkSourceSplitRequest(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SourceSplitResponse", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSourceSplitResponse();
|
| + var od = new api.SourceSplitResponse.fromJson(o.toJson());
|
| + checkSourceSplitResponse(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-SourceSplitShard", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildSourceSplitShard();
|
| + var od = new api.SourceSplitShard.fromJson(o.toJson());
|
| + checkSourceSplitShard(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-StateFamilyConfig", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildStateFamilyConfig();
|
| + var od = new api.StateFamilyConfig.fromJson(o.toJson());
|
| + checkStateFamilyConfig(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-Status", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildStatus();
|
| + var od = new api.Status.fromJson(o.toJson());
|
| + checkStatus(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-Step", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildStep();
|
| + var od = new api.Step.fromJson(o.toJson());
|
| + checkStep(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-StreamLocation", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildStreamLocation();
|
| + var od = new api.StreamLocation.fromJson(o.toJson());
|
| + checkStreamLocation(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-StreamingComputationRanges", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildStreamingComputationRanges();
|
| + var od = new api.StreamingComputationRanges.fromJson(o.toJson());
|
| + checkStreamingComputationRanges(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-StreamingComputationTask", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildStreamingComputationTask();
|
| + var od = new api.StreamingComputationTask.fromJson(o.toJson());
|
| + checkStreamingComputationTask(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-StreamingSetupTask", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildStreamingSetupTask();
|
| + var od = new api.StreamingSetupTask.fromJson(o.toJson());
|
| + checkStreamingSetupTask(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-StreamingSideInputLocation", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildStreamingSideInputLocation();
|
| + var od = new api.StreamingSideInputLocation.fromJson(o.toJson());
|
| + checkStreamingSideInputLocation(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-StreamingStageLocation", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildStreamingStageLocation();
|
| + var od = new api.StreamingStageLocation.fromJson(o.toJson());
|
| + checkStreamingStageLocation(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-TaskRunnerSettings", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildTaskRunnerSettings();
|
| + var od = new api.TaskRunnerSettings.fromJson(o.toJson());
|
| + checkTaskRunnerSettings(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-TopologyConfig", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildTopologyConfig();
|
| + var od = new api.TopologyConfig.fromJson(o.toJson());
|
| + checkTopologyConfig(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-WorkItem", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildWorkItem();
|
| + var od = new api.WorkItem.fromJson(o.toJson());
|
| + checkWorkItem(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-WorkItemServiceState", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildWorkItemServiceState();
|
| + var od = new api.WorkItemServiceState.fromJson(o.toJson());
|
| + checkWorkItemServiceState(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-WorkItemStatus", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildWorkItemStatus();
|
| + var od = new api.WorkItemStatus.fromJson(o.toJson());
|
| + checkWorkItemStatus(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-WorkerPool", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildWorkerPool();
|
| + var od = new api.WorkerPool.fromJson(o.toJson());
|
| + checkWorkerPool(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-WorkerSettings", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildWorkerSettings();
|
| + var od = new api.WorkerSettings.fromJson(o.toJson());
|
| + checkWorkerSettings(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-WriteInstruction", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildWriteInstruction();
|
| + var od = new api.WriteInstruction.fromJson(o.toJson());
|
| + checkWriteInstruction(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("resource-ProjectsJobsResourceApi", () {
|
| + unittest.test("method--create", () {
|
| +
|
| + var mock = new HttpServerMock();
|
| + api.ProjectsJobsResourceApi res = new api.DataflowApi(mock).projects.jobs;
|
| + var arg_request = buildJob();
|
| + var arg_projectId = "foo";
|
| + var arg_view = "foo";
|
| + var arg_replaceJobId = "foo";
|
| + mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + var obj = new api.Job.fromJson(json);
|
| + checkJob(obj);
|
| +
|
| + var path = (req.url).path;
|
| + var pathOffset = 0;
|
| + var index;
|
| + var subPart;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
|
| + pathOffset += 1;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
|
| + pathOffset += 14;
|
| + index = path.indexOf("/jobs", pathOffset);
|
| + unittest.expect(index >= 0, unittest.isTrue);
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
|
| + pathOffset = index;
|
| + unittest.expect(subPart, unittest.equals("$arg_projectId"));
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 5), unittest.equals("/jobs"));
|
| + pathOffset += 5;
|
| +
|
| + var query = (req.url).query;
|
| + var queryOffset = 0;
|
| + var queryMap = {};
|
| + addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
|
| + parseBool(n) {
|
| + if (n == "true") return true;
|
| + if (n == "false") return false;
|
| + if (n == null) return null;
|
| + throw new core.ArgumentError("Invalid boolean: $n");
|
| + }
|
| + if (query.length > 0) {
|
| + for (var part in query.split("&")) {
|
| + var keyvalue = part.split("=");
|
| + addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
|
| + }
|
| + }
|
| + unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
|
| + unittest.expect(queryMap["replaceJobId"].first, unittest.equals(arg_replaceJobId));
|
| +
|
| +
|
| + var h = {
|
| + "content-type" : "application/json; charset=utf-8",
|
| + };
|
| + var resp = convert.JSON.encode(buildJob());
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| + }), true);
|
| + res.create(arg_request, arg_projectId, view: arg_view, replaceJobId: arg_replaceJobId).then(unittest.expectAsync(((api.Job response) {
|
| + checkJob(response);
|
| + })));
|
| + });
|
| +
|
| + unittest.test("method--get", () {
|
| +
|
| + var mock = new HttpServerMock();
|
| + api.ProjectsJobsResourceApi res = new api.DataflowApi(mock).projects.jobs;
|
| + var arg_projectId = "foo";
|
| + var arg_jobId = "foo";
|
| + var arg_view = "foo";
|
| + mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + var path = (req.url).path;
|
| + var pathOffset = 0;
|
| + var index;
|
| + var subPart;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
|
| + pathOffset += 1;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
|
| + pathOffset += 14;
|
| + index = path.indexOf("/jobs/", pathOffset);
|
| + unittest.expect(index >= 0, unittest.isTrue);
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
|
| + pathOffset = index;
|
| + unittest.expect(subPart, unittest.equals("$arg_projectId"));
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 6), unittest.equals("/jobs/"));
|
| + pathOffset += 6;
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset));
|
| + pathOffset = path.length;
|
| + unittest.expect(subPart, unittest.equals("$arg_jobId"));
|
| +
|
| + var query = (req.url).query;
|
| + var queryOffset = 0;
|
| + var queryMap = {};
|
| + addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
|
| + parseBool(n) {
|
| + if (n == "true") return true;
|
| + if (n == "false") return false;
|
| + if (n == null) return null;
|
| + throw new core.ArgumentError("Invalid boolean: $n");
|
| + }
|
| + if (query.length > 0) {
|
| + for (var part in query.split("&")) {
|
| + var keyvalue = part.split("=");
|
| + addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
|
| + }
|
| + }
|
| + unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
|
| +
|
| +
|
| + var h = {
|
| + "content-type" : "application/json; charset=utf-8",
|
| + };
|
| + var resp = convert.JSON.encode(buildJob());
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| + }), true);
|
| + res.get(arg_projectId, arg_jobId, view: arg_view).then(unittest.expectAsync(((api.Job response) {
|
| + checkJob(response);
|
| + })));
|
| + });
|
| +
|
| + unittest.test("method--getMetrics", () {
|
| +
|
| + var mock = new HttpServerMock();
|
| + api.ProjectsJobsResourceApi res = new api.DataflowApi(mock).projects.jobs;
|
| + var arg_projectId = "foo";
|
| + var arg_jobId = "foo";
|
| + var arg_startTime = "foo";
|
| + mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + var path = (req.url).path;
|
| + var pathOffset = 0;
|
| + var index;
|
| + var subPart;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
|
| + pathOffset += 1;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
|
| + pathOffset += 14;
|
| + index = path.indexOf("/jobs/", pathOffset);
|
| + unittest.expect(index >= 0, unittest.isTrue);
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
|
| + pathOffset = index;
|
| + unittest.expect(subPart, unittest.equals("$arg_projectId"));
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 6), unittest.equals("/jobs/"));
|
| + pathOffset += 6;
|
| + index = path.indexOf("/metrics", pathOffset);
|
| + unittest.expect(index >= 0, unittest.isTrue);
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
|
| + pathOffset = index;
|
| + unittest.expect(subPart, unittest.equals("$arg_jobId"));
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equals("/metrics"));
|
| + pathOffset += 8;
|
| +
|
| + var query = (req.url).query;
|
| + var queryOffset = 0;
|
| + var queryMap = {};
|
| + addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
|
| + parseBool(n) {
|
| + if (n == "true") return true;
|
| + if (n == "false") return false;
|
| + if (n == null) return null;
|
| + throw new core.ArgumentError("Invalid boolean: $n");
|
| + }
|
| + if (query.length > 0) {
|
| + for (var part in query.split("&")) {
|
| + var keyvalue = part.split("=");
|
| + addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
|
| + }
|
| + }
|
| + unittest.expect(queryMap["startTime"].first, unittest.equals(arg_startTime));
|
| +
|
| +
|
| + var h = {
|
| + "content-type" : "application/json; charset=utf-8",
|
| + };
|
| + var resp = convert.JSON.encode(buildJobMetrics());
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| + }), true);
|
| + res.getMetrics(arg_projectId, arg_jobId, startTime: arg_startTime).then(unittest.expectAsync(((api.JobMetrics response) {
|
| + checkJobMetrics(response);
|
| + })));
|
| + });
|
| +
|
| + unittest.test("method--list", () {
|
| +
|
| + var mock = new HttpServerMock();
|
| + api.ProjectsJobsResourceApi res = new api.DataflowApi(mock).projects.jobs;
|
| + var arg_projectId = "foo";
|
| + var arg_view = "foo";
|
| + var arg_pageSize = 42;
|
| + var arg_pageToken = "foo";
|
| + mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + var path = (req.url).path;
|
| + var pathOffset = 0;
|
| + var index;
|
| + var subPart;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
|
| + pathOffset += 1;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
|
| + pathOffset += 14;
|
| + index = path.indexOf("/jobs", pathOffset);
|
| + unittest.expect(index >= 0, unittest.isTrue);
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
|
| + pathOffset = index;
|
| + unittest.expect(subPart, unittest.equals("$arg_projectId"));
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 5), unittest.equals("/jobs"));
|
| + pathOffset += 5;
|
| +
|
| + var query = (req.url).query;
|
| + var queryOffset = 0;
|
| + var queryMap = {};
|
| + addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
|
| + parseBool(n) {
|
| + if (n == "true") return true;
|
| + if (n == "false") return false;
|
| + if (n == null) return null;
|
| + throw new core.ArgumentError("Invalid boolean: $n");
|
| + }
|
| + if (query.length > 0) {
|
| + for (var part in query.split("&")) {
|
| + var keyvalue = part.split("=");
|
| + addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
|
| + }
|
| + }
|
| + unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
|
| + unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
|
| + unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
|
| +
|
| +
|
| + var h = {
|
| + "content-type" : "application/json; charset=utf-8",
|
| + };
|
| + var resp = convert.JSON.encode(buildListJobsResponse());
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| + }), true);
|
| + res.list(arg_projectId, view: arg_view, pageSize: arg_pageSize, pageToken: arg_pageToken).then(unittest.expectAsync(((api.ListJobsResponse response) {
|
| + checkListJobsResponse(response);
|
| + })));
|
| + });
|
| +
|
| + unittest.test("method--update", () {
|
| +
|
| + var mock = new HttpServerMock();
|
| + api.ProjectsJobsResourceApi res = new api.DataflowApi(mock).projects.jobs;
|
| + var arg_request = buildJob();
|
| + var arg_projectId = "foo";
|
| + var arg_jobId = "foo";
|
| + mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + var obj = new api.Job.fromJson(json);
|
| + checkJob(obj);
|
| +
|
| + var path = (req.url).path;
|
| + var pathOffset = 0;
|
| + var index;
|
| + var subPart;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
|
| + pathOffset += 1;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
|
| + pathOffset += 14;
|
| + index = path.indexOf("/jobs/", pathOffset);
|
| + unittest.expect(index >= 0, unittest.isTrue);
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
|
| + pathOffset = index;
|
| + unittest.expect(subPart, unittest.equals("$arg_projectId"));
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 6), unittest.equals("/jobs/"));
|
| + pathOffset += 6;
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset));
|
| + pathOffset = path.length;
|
| + unittest.expect(subPart, unittest.equals("$arg_jobId"));
|
| +
|
| + var query = (req.url).query;
|
| + var queryOffset = 0;
|
| + var queryMap = {};
|
| + addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
|
| + parseBool(n) {
|
| + if (n == "true") return true;
|
| + if (n == "false") return false;
|
| + if (n == null) return null;
|
| + throw new core.ArgumentError("Invalid boolean: $n");
|
| + }
|
| + if (query.length > 0) {
|
| + for (var part in query.split("&")) {
|
| + var keyvalue = part.split("=");
|
| + addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
|
| + }
|
| + }
|
| +
|
| +
|
| + var h = {
|
| + "content-type" : "application/json; charset=utf-8",
|
| + };
|
| + var resp = convert.JSON.encode(buildJob());
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| + }), true);
|
| + res.update(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync(((api.Job response) {
|
| + checkJob(response);
|
| + })));
|
| + });
|
| +
|
| + });
|
| +
|
| +
|
| + unittest.group("resource-ProjectsJobsMessagesResourceApi", () {
|
| + unittest.test("method--list", () {
|
| +
|
| + var mock = new HttpServerMock();
|
| + api.ProjectsJobsMessagesResourceApi res = new api.DataflowApi(mock).projects.jobs.messages;
|
| + var arg_projectId = "foo";
|
| + var arg_jobId = "foo";
|
| + var arg_minimumImportance = "foo";
|
| + var arg_pageSize = 42;
|
| + var arg_pageToken = "foo";
|
| + var arg_startTime = "foo";
|
| + var arg_endTime = "foo";
|
| + mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + var path = (req.url).path;
|
| + var pathOffset = 0;
|
| + var index;
|
| + var subPart;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
|
| + pathOffset += 1;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
|
| + pathOffset += 14;
|
| + index = path.indexOf("/jobs/", pathOffset);
|
| + unittest.expect(index >= 0, unittest.isTrue);
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
|
| + pathOffset = index;
|
| + unittest.expect(subPart, unittest.equals("$arg_projectId"));
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 6), unittest.equals("/jobs/"));
|
| + pathOffset += 6;
|
| + index = path.indexOf("/messages", pathOffset);
|
| + unittest.expect(index >= 0, unittest.isTrue);
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
|
| + pathOffset = index;
|
| + unittest.expect(subPart, unittest.equals("$arg_jobId"));
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 9), unittest.equals("/messages"));
|
| + pathOffset += 9;
|
| +
|
| + var query = (req.url).query;
|
| + var queryOffset = 0;
|
| + var queryMap = {};
|
| + addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
|
| + parseBool(n) {
|
| + if (n == "true") return true;
|
| + if (n == "false") return false;
|
| + if (n == null) return null;
|
| + throw new core.ArgumentError("Invalid boolean: $n");
|
| + }
|
| + if (query.length > 0) {
|
| + for (var part in query.split("&")) {
|
| + var keyvalue = part.split("=");
|
| + addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
|
| + }
|
| + }
|
| + unittest.expect(queryMap["minimumImportance"].first, unittest.equals(arg_minimumImportance));
|
| + unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
|
| + unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
|
| + unittest.expect(queryMap["startTime"].first, unittest.equals(arg_startTime));
|
| + unittest.expect(queryMap["endTime"].first, unittest.equals(arg_endTime));
|
| +
|
| +
|
| + var h = {
|
| + "content-type" : "application/json; charset=utf-8",
|
| + };
|
| + var resp = convert.JSON.encode(buildListJobMessagesResponse());
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| + }), true);
|
| + res.list(arg_projectId, arg_jobId, minimumImportance: arg_minimumImportance, pageSize: arg_pageSize, pageToken: arg_pageToken, startTime: arg_startTime, endTime: arg_endTime).then(unittest.expectAsync(((api.ListJobMessagesResponse response) {
|
| + checkListJobMessagesResponse(response);
|
| + })));
|
| + });
|
| +
|
| + });
|
| +
|
| +
|
| + unittest.group("resource-ProjectsJobsWorkItemsResourceApi", () {
|
| + unittest.test("method--lease", () {
|
| +
|
| + var mock = new HttpServerMock();
|
| + api.ProjectsJobsWorkItemsResourceApi res = new api.DataflowApi(mock).projects.jobs.workItems;
|
| + var arg_request = buildLeaseWorkItemRequest();
|
| + var arg_projectId = "foo";
|
| + var arg_jobId = "foo";
|
| + mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + var obj = new api.LeaseWorkItemRequest.fromJson(json);
|
| + checkLeaseWorkItemRequest(obj);
|
| +
|
| + var path = (req.url).path;
|
| + var pathOffset = 0;
|
| + var index;
|
| + var subPart;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
|
| + pathOffset += 1;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
|
| + pathOffset += 14;
|
| + index = path.indexOf("/jobs/", pathOffset);
|
| + unittest.expect(index >= 0, unittest.isTrue);
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
|
| + pathOffset = index;
|
| + unittest.expect(subPart, unittest.equals("$arg_projectId"));
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 6), unittest.equals("/jobs/"));
|
| + pathOffset += 6;
|
| + index = path.indexOf("/workItems:lease", pathOffset);
|
| + unittest.expect(index >= 0, unittest.isTrue);
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
|
| + pathOffset = index;
|
| + unittest.expect(subPart, unittest.equals("$arg_jobId"));
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.equals("/workItems:lease"));
|
| + pathOffset += 16;
|
| +
|
| + var query = (req.url).query;
|
| + var queryOffset = 0;
|
| + var queryMap = {};
|
| + addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
|
| + parseBool(n) {
|
| + if (n == "true") return true;
|
| + if (n == "false") return false;
|
| + if (n == null) return null;
|
| + throw new core.ArgumentError("Invalid boolean: $n");
|
| + }
|
| + if (query.length > 0) {
|
| + for (var part in query.split("&")) {
|
| + var keyvalue = part.split("=");
|
| + addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
|
| + }
|
| + }
|
| +
|
| +
|
| + var h = {
|
| + "content-type" : "application/json; charset=utf-8",
|
| + };
|
| + var resp = convert.JSON.encode(buildLeaseWorkItemResponse());
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| + }), true);
|
| + res.lease(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync(((api.LeaseWorkItemResponse response) {
|
| + checkLeaseWorkItemResponse(response);
|
| + })));
|
| + });
|
| +
|
| + unittest.test("method--reportStatus", () {
|
| +
|
| + var mock = new HttpServerMock();
|
| + api.ProjectsJobsWorkItemsResourceApi res = new api.DataflowApi(mock).projects.jobs.workItems;
|
| + var arg_request = buildReportWorkItemStatusRequest();
|
| + var arg_projectId = "foo";
|
| + var arg_jobId = "foo";
|
| + mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + var obj = new api.ReportWorkItemStatusRequest.fromJson(json);
|
| + checkReportWorkItemStatusRequest(obj);
|
| +
|
| + var path = (req.url).path;
|
| + var pathOffset = 0;
|
| + var index;
|
| + var subPart;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
|
| + pathOffset += 1;
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
|
| + pathOffset += 14;
|
| + index = path.indexOf("/jobs/", pathOffset);
|
| + unittest.expect(index >= 0, unittest.isTrue);
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
|
| + pathOffset = index;
|
| + unittest.expect(subPart, unittest.equals("$arg_projectId"));
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 6), unittest.equals("/jobs/"));
|
| + pathOffset += 6;
|
| + index = path.indexOf("/workItems:reportStatus", pathOffset);
|
| + unittest.expect(index >= 0, unittest.isTrue);
|
| + subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
|
| + pathOffset = index;
|
| + unittest.expect(subPart, unittest.equals("$arg_jobId"));
|
| + unittest.expect(path.substring(pathOffset, pathOffset + 23), unittest.equals("/workItems:reportStatus"));
|
| + pathOffset += 23;
|
| +
|
| + var query = (req.url).query;
|
| + var queryOffset = 0;
|
| + var queryMap = {};
|
| + addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
|
| + parseBool(n) {
|
| + if (n == "true") return true;
|
| + if (n == "false") return false;
|
| + if (n == null) return null;
|
| + throw new core.ArgumentError("Invalid boolean: $n");
|
| + }
|
| + if (query.length > 0) {
|
| + for (var part in query.split("&")) {
|
| + var keyvalue = part.split("=");
|
| + addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
|
| + }
|
| + }
|
| +
|
| +
|
| + var h = {
|
| + "content-type" : "application/json; charset=utf-8",
|
| + };
|
| + var resp = convert.JSON.encode(buildReportWorkItemStatusResponse());
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| + }), true);
|
| + res.reportStatus(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync(((api.ReportWorkItemStatusResponse response) {
|
| + checkReportWorkItemStatusResponse(response);
|
| + })));
|
| + });
|
| +
|
| + });
|
| +
|
| +
|
| }
|
|
|
|
|
Chromium Code Reviews
Issue 1296863002:
Api-roll 22: 2015-08-17 (Closed)
Base URL: git@github.com:dart-lang/googleapis.git@master