feat: add ipv6 toggling logic

Author: gnmeyer

.env

@@ -5,6 +5,8 @@ IMAGE_VERSION=2.0.2
 IMAGE_NAME=ghcr.io/open-telemetry/demo
 DEMO_VERSION=latest
 
+IPV6_ENABLED=true
+
 # Build Args
 TRACETEST_IMAGE_VERSION=v1.7.1
 OTEL_JAVA_AGENT_VERSION=2.20.0
@@ -83,9 +85,10 @@ FRONTEND_DOCKERFILE=./src/frontend/Dockerfile
 
 # Frontend Proxy (Envoy)
 FRONTEND_HOST=frontend
-ENVOY_PORT=8080
 FRONTEND_PROXY_ADDR=frontend-proxy:${ENVOY_PORT}
 FRONTEND_PROXY_DOCKERFILE=./src/frontend-proxy/Dockerfile
+ENVOY_ADDR=0.0.0.0
+ENVOY_PORT=8080
 
 # Image Provider
 IMAGE_PROVIDER_HOST=image-provider

docker-compose.yml

@@ -192,6 +192,7 @@ services:
       - VERSION=${IMAGE_VERSION}
       - OTEL_EXPORTER_OTLP_ENDPOINT
       - OTEL_RESOURCE_ATTRIBUTES=${OTEL_RESOURCE_ATTRIBUTES},service.name=currency   # The C++ SDK does not support OTEL_SERVICE_NAME
+      - IPV6_ENABLED
     depends_on:
       otel-collector:
         condition: service_started
@@ -352,6 +353,7 @@ services:
       - OTEL_RESOURCE_ATTRIBUTES
       - OTEL_SERVICE_NAME=frontend-proxy
       - ENVOY_PORT
+      - ENVOY_ADDR
       - FLAGD_HOST
       - FLAGD_PORT
       - FLAGD_UI_HOST
@@ -458,6 +460,7 @@ services:
       - OTEL_EXPORTER_OTLP_METRICS_TEMPORALITY_PREFERENCE
       - OTEL_RESOURCE_ATTRIBUTES
       - OTEL_SERVICE_NAME=payment
+      - IPV6_ENABLED
     depends_on:
       otel-collector:
         condition: service_started
@@ -523,6 +526,7 @@ services:
       - OTEL_RESOURCE_ATTRIBUTES
       - OTEL_SERVICE_NAME=quote
       - OTEL_PHP_INTERNAL_METRICS_ENABLED=true
+      - IPV6_ENABLED
     depends_on:
       otel-collector:
         condition: service_started
@@ -587,6 +591,7 @@ services:
       - OTEL_RESOURCE_ATTRIBUTES
       - OTEL_SERVICE_NAME=shipping
       - OTEL_EXPORTER_OTLP_METRICS_TEMPORALITY_PREFERENCE
+      - IPV6_ENABLED
     healthcheck:
       test: ["CMD-SHELL", "timeout 1 bash -c '>/dev/tcp/localhost/${SHIPPING_PORT}'"]
       start_period: 10s

src/currency/src/server.cpp

@@ -238,7 +238,17 @@ class CurrencyService final : public oteldemo::CurrencyService::Service
 
 void RunServer(uint16_t port)
 {
-  std::string address("0.0.0.0:" + std::to_string(port));
+  std::string ip("0.0.0.0");
+
+  const char* ipv6_enabled = std::getenv("IPV6_ENABLED");
+  
+  if (ipv6_enabled == "true") {
+    ip = "[::]";
+    logger->Info("Overwriting Localhost IP: " + ip);
+  }
+
+  std::string address(ip + ":" +  std::to_string(port));
+
   CurrencyService currencyService;
   HealthServer healthService;
   ServerBuilder builder;

src/frontend-proxy/envoy.tmpl.yaml

@@ -6,7 +6,7 @@ static_resources:
   listeners:
     - address:
         socket_address:
-          address: 0.0.0.0
+          address: "${ENVOY_ADDR}"
           port_value: ${ENVOY_PORT}
       filter_chains:
         - filters:

src/payment/index.js

@@ -44,12 +44,24 @@ server.addService(health.service, new health.Implementation({
 
 server.addService(otelDemoPackage.oteldemo.PaymentService.service, { charge: chargeServiceHandler })
 
-server.bindAsync(`0.0.0.0:${process.env['PAYMENT_PORT']}`, grpc.ServerCredentials.createInsecure(), (err, port) => {
+
+let ip = "0.0.0.0";
+
+const ipv6_enabled = process.env.IPV6_ENABLED;
+
+if (ipv6_enabled == "true") {
+  ip = "[::]";
+  logger.info(`Overwriting Localhost IP: ${ip}`)
+}
+
+const address = ip + `:${process.env['PAYMENT_PORT']}`;
+
+server.bindAsync(address, grpc.ServerCredentials.createInsecure(), (err, port) => {
   if (err) {
     return logger.error({ err })
   }
 
-  logger.info(`payment gRPC server started on port ${port}`)
+  logger.info(`payment gRPC server started on ${address}`)
 })
 
 process.once('SIGINT', closeGracefully)

src/quote/public/index.php

@@ -87,7 +87,18 @@
 
     return $response;
 });
-$address = '0.0.0.0:' . getenv('QUOTE_PORT');
+
+$ip = "0.0.0.0";
+
+$ipv6_enabled = getenv('IPV6_ENABLED');
+
+if ($ipv6_enabled == "true") {
+    $ip = "[::]";
+    echo "Overwriting Localhost IP: {$ip}" . PHP_EOL;
+} 
+
+$address = $ip . ':' . getenv('QUOTE_PORT');
+
 $socket = new SocketServer($address);
 $server->listen($socket);
 

src/shipping/src/main.rs

@@ -26,7 +26,17 @@ async fn main() -> std::io::Result<()> {
         .expect("$SHIPPING_PORT is not set")
         .parse()
         .expect("$SHIPPING_PORT is not a valid port");
-    let addr = format!("0.0.0.0:{}", port);
+    
+    let mut ip = "0.0.0.0".to_string();
+    
+    if let Ok(ipv6_enabled) = env::var("IPV6_ENABLED") {
+        if ipv6_enabled == "true" {
+            ip = "[::]".to_string();
+            info!("Overwriting Localhost IP:  {ip}");
+        }
+    }
+    
+    let addr = format!("{}:{}", ip, port);
     info!(
         name = "ServerStartedSuccessfully",
         addr = addr.as_str(),