feature/actions: WIP

.github/workflows/tracing.yml

@@ -0,0 +1,56 @@
+name: Enable Tracing for PR
+
+on:
+  pull_request:
+    types: [opened, synchronize, labeled, unlabeled, closed]
+
+jobs:
+  tracing:
+    runs-on: ubuntu-latest
+    steps:
+    - name: Checkout code
+      uses: actions/checkout@v3
+
+    - name: Check for "enable tracing" label
+      id: check-label
+      run: |
+        label=$(jq -r '.pull_request.labels[].name' "$GITHUB_EVENT_PATH")
+        if [[ "$label" == "enable tracing" ]]; then
+          echo "Enable tracing label found."
+          echo "trace=true" >> $GITHUB_OUTPUT
+        else
+          echo "Enable tracing label not found."
+          echo "trace=true" >> $GITHUB_OUTPUT
+        fi
+        echo "$PWD"
+
+    - name: Setup Grafana and OpenTelemetry
+      id: docker-setup
+      if: steps.check-label.outputs.trace == 'true'
+      run: |
+        # Create network
+        docker network create tracing_network
+        
+        # Start Grafana
+        cd ./internal/examples/example-otlp-agent-tempo-grafana/
+        docker run -d --name=grafana -p 3000:3000 -v $PWD/grafana-datasources.yaml:/etc/grafana/provisioning/datasources/datasources.yaml -e GF_AUTH_ANONYMOUS_ENABLED=true -e GF_AUTH_ANONYMOUS_ORG_ROLE=Admin -e GF_AUTH_DISABLE_LOGIN_FORM=true -e GF_FEATURE_TOGGLES_ENABLE=traceqlEditor grafana/grafana:9.4.3
+
+        # Start Tempo
+        docker run -d --network=tracing_network --name=tempo -v ./tempo.yaml:/etc/tempo.yaml -v $PWD/tempo-data:/tmp/tempo grafana/tempo:latest -config.file=/etc/tempo.yaml
+
+        # Start OpenTelemetry Collector
+        docker run -d --network=tracing_network --name=otel-collector -v $PWD/otel-collector.yaml:/etc/otel-collector.yaml -p 4317:4317 otel/opentelemetry-collector:0.61.0 --config=/etc/otel-collector.yaml
+  
+    - name: Build Example GRPC Server Docker Image
+      if: steps.check-label.outputs.trace == 'true'
+      run: |
+        # Navigate to the directory containing the Dockerfile (note PWD resets for each step)
+        cd ./internal/examples/example-grpc-client-server/server
+          
+        # Build the Docker image
+        docker build -t example-grpc-server:latest -f Dockerfile.ci .
+            
+    - name: Start Example GRPC Server
+      if: steps.check-label.outputs.trace == 'true'
+      run: |
+        docker run -d --network=tracing_network --name=example-grpc-server -p 50051:50051 -e ENABLE_TELEMETRY=true -e TELEMETRY_TARGET=otel-collector:4317 example-grpc-server:latest

internal/examples/example-grpc-client-server/server/Dockerfile.ci

@@ -0,0 +1,18 @@
+FROM golang:latest
+
+WORKDIR /app
+
+COPY . .
+
+RUN ls -al
+
+RUN go mod download
+
+WORKDIR /app/internal/examples/example-grpc-client-server/server/
+
+RUN go clean
+RUN go build -o server server_main.go
+RUN chmod +x server
+
+# CMD ["/bin/sh"]
+CMD ["./server"]

internal/examples/example-grpc-client-server/server/server_main.go

@@ -38,7 +38,7 @@ func main() {
 	telemetryTarget := os.Getenv("TELEMETRY_TARGET")
 
 	opts := make([]server.ServerOption, 0, 1)
-	if enableTelemetry == "true" {
+	if enableTelemetry == "true" && telemetryTarget != "" {
 		opts = append(opts, server.WithOpenTelemetry(telemetryTarget))
 	}
 

internal/examples/example-otlp-agent-tempo-grafana/docker-compose.yaml

@@ -1,6 +1,7 @@
 version: "3"
 services:
 
+  # Instrumented application configured to export traces to ...
   example-grpc-server:
     build: 
       context: ../../../
@@ -13,7 +14,7 @@ services:
       - ENABLE_TELEMETRY=true
       - TELEMETRY_TARGET=otel-collector:4317
 
-  # Put traces in a Grafana Agent pipeline...
+  # ... the OpenTelemetry Collector configured to receive traces and export to Tempo ...
   otel-collector:
     image: otel/opentelemetry-collector:0.61.0
     command: [ "--config=/etc/otel-collector.yaml" ]
@@ -24,7 +25,7 @@ services:
     depends_on:
       - tempo
 
-  # To eventually offload to Tempo...
+  # .. Which accepts requests from grafana ...
   tempo:
     image: grafana/tempo:latest
     command: [ "-config.file=/etc/tempo.yaml" ]

server/server.go

@@ -121,8 +121,9 @@ func (s *Server) Serve() {
 	s.grpcServer = grpc.NewServer(
 		grpc.UnaryInterceptor(
 			grpc_middleware.ChainUnaryServer(
-				otelgrpc.UnaryServerInterceptor(),
 				loggingUnaryServerInterceptor,
+				otelgrpc.UnaryServerInterceptor(),
+
 			),
 		),
 	)