chore: Remove unused code and TODOs

client/es/elasticsearch.go

@@ -6,8 +6,6 @@ import (
 	"github.com/elastic/go-elasticsearch/v8"
 )
 
-// TODO: Metrics are not supported yet.
-
 // New creates a new elasticsearch client with tracing capabilities.
 func New(cfg elasticsearch.Config, version string) (*elasticsearch.Client, error) {
 	cfg.Instrumentation = elastictransport.NewOtelInstrumentation(nil, false, version)

client/es/elasticsearch_test.go

@@ -71,11 +71,4 @@ func TestNew(t *testing.T) {
 	// Traces
 	assert.NoError(t, tracePublisher.ForceFlush(context.Background()))
 	assert.Len(t, exp.GetSpans(), 1)
-
-	// TODO: Support metrics first.
-	// // Metrics
-	// collectedMetrics := &metricdata.ResourceMetrics{}
-	// assert.NoError(t, read.Collect(context.Background(), collectedMetrics))
-	// assert.Equal(t, 1, len(collectedMetrics.ScopeMetrics))
-	// assert.Equal(t, 1, len(collectedMetrics.ScopeMetrics[0].Metrics))
 }

client/http/http.go

@@ -48,7 +48,6 @@ func New(oo ...OptionFunc) (*TracedClient, error) {
 
 // Do execute an HTTP request with integrated tracing and tracing propagation downstream.
 func (tc *TracedClient) Do(req *http.Request) (*http.Response, error) {
-	// TODO: do we need this still?
 	req.Header.Set(correlation.HeaderID, correlation.IDFromContext(req.Context()))
 
 	rsp, err := tc.do(req)

client/http/http_test.go

@@ -65,9 +65,6 @@ func TestTracedClient_Do(t *testing.T) {
 				assert.NoError(t, err)
 				assert.NotNil(t, rsp)
 			}
-			// TODO: test tracing/metrics
-			// assert.Equal(t, tt.wantCounter, testutil.CollectAndCount(reqDurationMetrics, "client_http_request_duration_seconds"))
-			// reqDurationMetrics.Reset()
 		})
 	}
 }

component/http/router/router.go

@@ -44,7 +44,6 @@ func New(oo ...OptionFunc) (*http.ServeMux, error) {
 	var stdRoutes []*patronhttp.Route
 
 	mux := http.NewServeMux()
-	// TODO: Introduce metrics route???
 	stdRoutes = append(stdRoutes, patronhttp.ProfilingRoutes(cfg.enableProfilingExpVar)...)
 
 	route, err := patronhttp.LivenessCheckRoute(cfg.aliveCheckFunc)

correlation/correlation.go

@@ -7,8 +7,6 @@ import (
 	"github.com/google/uuid"
 )
 
-// TODO: Do we need this with opentelemetry? Merge with observability package?
-
 const (
 	// HeaderID constant.
 	HeaderID string = "X-Correlation-Id"

reliability/circuitbreaker/breaker.go

@@ -35,8 +35,6 @@ var (
 	statusCounter metric.Int64Counter
 )
 
-// TODO: Metrics move to OpenTelemetry.
-
 func init() {
 	var err error
 	statusCounter, err = otel.Meter("circuitbreaker").Int64Counter("circuitbreaker.status",