Ensure that source's healthchecks telemetry are sampled (#2213)

This will save about 4.5M events per month.

GitOrigin-RevId: f791f98bbba9ccc3064ec9084e5823f97c74137e

Author: DavidS-ovm

aws-source/cmd/root.go

@@ -92,7 +92,7 @@ var rootCmd = &cobra.Command{
 		healthCheckPath := "/healthz"
 
 		http.HandleFunc(healthCheckPath, func(rw http.ResponseWriter, r *http.Request) {
-			ctx, span := tracing.Tracer().Start(r.Context(), "healthcheck")
+			ctx, span := tracing.HealthCheckTracer().Start(r.Context(), "healthcheck")
 			defer span.End()
 
 			err := e.HealthCheck(ctx)

k8s-source/cmd/root.go

@@ -171,6 +171,15 @@ func run(_ *cobra.Command, _ []string) int {
 	healthCheckPath := "/healthz"
 
 	http.HandleFunc(healthCheckPath, func(rw http.ResponseWriter, r *http.Request) {
+		ctx, span := tracing.HealthCheckTracer().Start(r.Context(), "healthcheck")
+		defer span.End()
+
+		err := e.HealthCheck(ctx)
+		if err != nil {
+			http.Error(rw, err.Error(), http.StatusInternalServerError)
+			return
+		}
+
 		if e.IsNATSConnected() {
 			fmt.Fprint(rw, "ok")
 		} else {

sources/gcp/cmd/root.go

@@ -56,7 +56,7 @@ var rootCmd = &cobra.Command{
 		healthCheckPath := "/healthz"
 
 		http.HandleFunc(healthCheckPath, func(rw http.ResponseWriter, r *http.Request) {
-			ctx, span := tracing.Tracer().Start(r.Context(), "healthcheck")
+			ctx, span := tracing.HealthCheckTracer().Start(r.Context(), "healthcheck")
 			defer span.End()
 
 			err := e.HealthCheck(ctx)

stdlib-source/cmd/root.go

@@ -93,7 +93,7 @@ var rootCmd = &cobra.Command{
 			e.EngineConfig.HeartbeatOptions.HealthCheck = healthCheck
 		}
 		http.HandleFunc(healthCheckPath, func(rw http.ResponseWriter, r *http.Request) {
-			ctx, span := tracing.Tracer().Start(r.Context(), "healthcheck")
+			ctx, span := tracing.HealthCheckTracer().Start(r.Context(), "healthcheck")
 			defer span.End()
 
 			err := healthCheck(ctx)