Auto-Instrumentation

apiVersion: apps/v1
kind: Deployment
metadata:
  name: my-nodejs-app
spec:
  template:
    metadata:
      annotations:
        instrumentation.opentelemetry.io/inject-nodejs: "km-agent/km-agent-instrumentation-crd"
    spec:
      containers:
      - name: app
        image: my-nodejs-app:latest

package instrumentation

// KmCrdAnnotation generates deployment annotations for auto-instrumentation
func KmCrdAnnotation(osl string, enabled bool) (InstrumentAnnotiation, map[string]string) {
	ns := os.Getenv("KM_NAMESPACE")
	if ns == "" {
		ns = "km-agent"
	}
	crd := os.Getenv("KM_CRD_NAME")
	if crd == "" {
		crd = "km-agent-instrumentation-crd"
	}
	lang := ""
	switch osl {
	case "nodejs":
		lang = "nodejs"
	case "Java":
		lang = "java"
	case "Python":
		lang = "python"
	case "Go":
		lang = "go"
	case "dotnet":
		lang = "dotnet"
	}

	if ns == "" || lang == "" {
		return InstrumentAnnotiation{}, nil
	}

	return InstrumentAnnotiation{
		"spec": map[string]interface{}{
			"template": map[string]interface{}{
				"metadata": map[string]interface{}{
					"annotations": map[string]interface{}{
						// Triggers Kubernetes rollout
						"kubectl.kubernetes.io/restartedAt": time.Now().Format(time.RFC3339),
						// Instrumentation annotation
						fmt.Sprintf("instrumentation.opentelemetry.io/inject-%s", lang): 
							fmt.Sprintf("%s/%s", ns, crd),
					},
				},
			},
		},
	}, map[string]string{
		fmt.Sprintf("instrumentation.opentelemetry.io/inject-%s", lang): 
			fmt.Sprintf("%s/%s", ns, crd),
	}
}