chore: add OTEL support to demos

Makefile

@@ -71,17 +71,24 @@ dc-stack-build:
 	docker compose --file docker-compose.cosmo.yml up --build --remove-orphans --detach
 
 full-demo-up:
+	cd demo && find . -type d -depth 1 -not -iname otel -exec cp -fr otel {} \;
 	docker compose -f docker-compose.full.yml --profile default up --build --remove-orphans --detach
 
 full-demo-down:
+	cd demo && find . -type d -depth 1 -not -iname otel -exec rm -fr {}/otel \;
 	docker compose -f docker-compose.full.yml --profile default --profile router --profile subgraphs down --remove-orphans -v
 
 dc-federation-demo:
 	docker compose -f docker-compose.full.yml --profile default --profile router --profile subgraphs up --remove-orphans --detach
 
 dc-subgraphs-demo:
+	cd demo && find . -type d -depth 1 -not -iname otel -exec cp -fr otel {} \;
 	docker compose -f docker-compose.full.yml --profile subgraphs up --remove-orphans --detach
 
+dc-subgraphs-demo-down:
+	cd demo && find . -type d -depth 1 -not -iname otel -exec rm -fr {}/otel \;
+	docker compose -f docker-compose.full.yml --profile subgraphs down --remove-orphans
+
 docker-build-local:
 	docker compose --file docker-compose.cosmo.yml build --no-cache
 
@@ -109,4 +116,4 @@ rollback-ch:
 	 dbmate -d "./controlplane/clickhouse/migrations" -s "./controlplane/db/schema.sql" -e CLICKHOUSE_DSN rollback
 
 migrate-ch-dump:
-	dbmate -d "./controlplane/clickhouse/migrations" -s "./controlplane/db/schema.sql" -e CLICKHOUSE_DSN dump
+	dbmate -d "./controlplane/clickhouse/migrations" -s "./controlplane/db/schema.sql" -e CLICKHOUSE_DSN dump

demo/employees/.gitignore

@@ -0,0 +1,2 @@
+/employees
+/otel

demo/employees/Dockerfile

@@ -4,6 +4,9 @@ WORKDIR /app
 
 COPY go.mod go.sum ./
 
+RUN mkdir ../otel
+COPY otel ../otel/
+
 RUN go mod download && go mod verify
 
 COPY . .
@@ -12,4 +15,4 @@ RUN go build -o server
 
 ENTRYPOINT [ "./server" ]
 
-EXPOSE 4001
+EXPOSE 4001

demo/employees/README.md

@@ -0,0 +1,10 @@
+# Cosmo demo service
+
+This directory contains a service used for cosmo demos.
+
+## OpenTelemetry
+
+To configure OpenTelemtry, the following environment variables are available:
+
+- `OTEL_HTTP_ENDPOINT`: Sets the endpoint for the OTEL collector. If empty, it defaults to `localhost:4318`.
+- `OTEL_AUTH_TOKEN`: Sets the token used to authenticate with the OTEL collector.

demo/employees/go.mod

@@ -1,27 +1,47 @@
-module github.com/wundergraph/comso/demo/employees
+module github.com/wundergraph/cosmo/demo/employees
 
 go 1.20
 
+replace github.com/wundergraph/cosmo/demo/otel => ../otel
+
 require (
 	github.com/99designs/gqlgen v0.17.36
 	github.com/vektah/gqlparser/v2 v2.5.8
 )
 
 require (
 	github.com/agnivade/levenshtein v1.1.1 // indirect
+	github.com/cenkalti/backoff/v4 v4.2.1 // indirect
 	github.com/cpuguy83/go-md2man/v2 v2.0.2 // indirect
+	github.com/go-logr/logr v1.2.4 // indirect
+	github.com/go-logr/stdr v1.2.2 // indirect
+	github.com/golang/protobuf v1.5.3 // indirect
 	github.com/gorilla/websocket v1.5.0 // indirect
+	github.com/grpc-ecosystem/grpc-gateway/v2 v2.7.0 // indirect
 	github.com/hashicorp/golang-lru/v2 v2.0.3 // indirect
 	github.com/logrusorgru/aurora/v3 v3.0.0 // indirect
 	github.com/mattn/go-colorable v0.1.13 // indirect
 	github.com/mattn/go-isatty v0.0.19 // indirect
 	github.com/mitchellh/mapstructure v1.5.0 // indirect
 	github.com/russross/blackfriday/v2 v2.1.0 // indirect
 	github.com/urfave/cli/v2 v2.25.5 // indirect
+	github.com/wundergraph/cosmo/demo/otel v0.0.0-00010101000000-000000000000 // indirect
 	github.com/xrash/smetrics v0.0.0-20201216005158-039620a65673 // indirect
+	go.opentelemetry.io/otel v1.16.0 // indirect
+	go.opentelemetry.io/otel/exporters/otlp/internal/retry v1.16.0 // indirect
+	go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.16.0 // indirect
+	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.16.0 // indirect
+	go.opentelemetry.io/otel/metric v1.16.0 // indirect
+	go.opentelemetry.io/otel/sdk v1.16.0 // indirect
+	go.opentelemetry.io/otel/trace v1.16.0 // indirect
+	go.opentelemetry.io/proto/otlp v0.19.0 // indirect
 	golang.org/x/mod v0.10.0 // indirect
+	golang.org/x/net v0.10.0 // indirect
 	golang.org/x/sys v0.8.0 // indirect
 	golang.org/x/text v0.9.0 // indirect
 	golang.org/x/tools v0.9.3 // indirect
+	google.golang.org/genproto v0.0.0-20230306155012-7f2fa6fef1f4 // indirect
+	google.golang.org/grpc v1.55.0 // indirect
+	google.golang.org/protobuf v1.30.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )

demo/employees/main.go

@@ -1,16 +1,23 @@
 package main
 
 import (
-	"github.com/99designs/gqlgen/graphql/playground"
-	"github.com/wundergraph/comso/demo/employees/subgraph"
+	"context"
 	"log"
 	"net/http"
 	"os"
+
+	"github.com/99designs/gqlgen/graphql/playground"
+	"github.com/wundergraph/cosmo/demo/employees/subgraph"
+	"github.com/wundergraph/cosmo/demo/otel"
 )
 
-const defaultPort = "4001"
+const (
+	defaultPort = "4001"
+	serviceName = "employees"
+)
 
 func main() {
+	otel.InitTracing(context.Background(), otel.Options{ServiceName: serviceName})
 	port := os.Getenv("PORT")
 	if port == "" {
 		port = defaultPort

demo/employees/subgraph/employees.go

@@ -1,6 +1,6 @@
 package subgraph
 
-import "github.com/wundergraph/comso/demo/employees/subgraph/model"
+import "github.com/wundergraph/cosmo/demo/employees/subgraph/model"
 
 var employees = []*model.Employee{
 	{