Export OT components via performance.json (#168)

Author: kohrapha

terraform/ec2/outputs.tf

@@ -21,3 +21,7 @@ output "sample_app_instance_id" {
 output "testing_id" {
   value = module.common.testing_id
 }
+
+output "otconfig_content" {
+  value = module.basic_components.otconfig_content
+}

terraform/ec2_setup/outputs.tf

@@ -49,3 +49,6 @@ output "launch_date" {
   value = local.launch_date
 }
 
+output "otconfig_content" {
+  value = module.ec2_setup.otconfig_content
+}

terraform/performance/main.tf

@@ -48,6 +48,11 @@ module "ec2_setup" {
 locals{
   validation_config_file = "performance_validation.yml"
   ami_family = module.ec2_setup.ami_family
+  otconfig = yamldecode(module.ec2_setup.otconfig_content)
+  ot_components = lookup(local.otconfig["service"]["pipelines"], "${var.soaking_data_mode}s", {})
+  ot_receivers = lookup(local.ot_components, "receivers", [])
+  ot_processors = lookup(local.ot_components, "processors", [])
+  ot_exporters = lookup(local.ot_components, "exporters", [])
 }
 
 data "template_file" "validation_config" {
@@ -58,8 +63,11 @@ data "template_file" "validation_config" {
     memoryMetricName = local.ami_family["soaking_mem_metric_name"]
     collectionPeriod = var.collection_period
     dataType = var.data_type
-    dataRate = var.data_rate
     dataMode = var.soaking_data_mode
+    dataRate = var.data_rate
+    otReceivers = join(", ", local.ot_receivers)
+    otProcessors = join(", ", local.ot_processors)
+    otExporters = join(", ", local.ot_exporters)
     testcase = split("/", var.testcase)[2]
     commitId = module.ec2_setup.commit_id
     instanceId = module.ec2_setup.collector_instance_id

terraform/templates/defaults/performance_validation.tpl

@@ -7,6 +7,9 @@
   dataType: "${dataType}"
   dataMode: "${dataMode}"
   dataRate: ${dataRate}
+  otReceivers: [${otReceivers}]
+  otProcessors: [${otProcessors}]
+  otExporters: [${otExporters}]
   testcase: "${testcase}"
   commitId: "${commitId}"
   instanceId: "${instanceId}"

validator/src/main/java/com/amazon/aoc/models/PerformanceResult.java

@@ -24,7 +24,9 @@
 public class PerformanceResult implements Serializable {
   @NonNull private String testcase;
   @NonNull private String instanceType;
-  @NonNull private String testingAmi;
+  @NonNull private String[] receivers;
+  @NonNull private String[] processors;
+  @NonNull private String[] exporters;
 
   @NonNull private String dataType;
   @NonNull private String dataMode;
@@ -37,4 +39,5 @@ public class PerformanceResult implements Serializable {
   // Metadata
   @NonNull private String commitId;
   @NonNull private Integer collectionPeriod;
+  @NonNull private String testingAmi;
 }

validator/src/main/java/com/amazon/aoc/models/ValidationConfig.java

@@ -49,6 +49,9 @@ public class ValidationConfig {
   String dataType;
   String dataMode;
   Integer dataRate;
+  String[] otReceivers;
+  String[] otProcessors;
+  String[] otExporters;
 
   // Dimensions
   String testcase;

validator/src/main/java/com/amazon/aoc/validators/PerformanceValidator.java

@@ -110,14 +110,17 @@ public void validate() throws Exception {
           final PerformanceResult result = new PerformanceResult(
               validationConfig.getTestcase(),
               validationConfig.getInstanceType(),
-              validationConfig.getTestingAmi(),
+              validationConfig.getOtReceivers(),
+              validationConfig.getOtProcessors(),
+              validationConfig.getOtExporters(),
               validationConfig.getDataType(),
               validationConfig.getDataMode(),
               validationConfig.getDataRate(),
               avgCpu,
               avgMemory,
               validationConfig.getCommitId(),
-              validationConfig.getCollectionPeriod()
+              validationConfig.getCollectionPeriod(),
+              validationConfig.getTestingAmi()
           );
 
           try {