Add nolint comments for unused code

Temporarily suppress lint warnings for code that will be used in Phase 8+.
These nolint comments will be removed in PR #322 when the code is actually used.

Author: samikshya-db

telemetry/aggregator.go

@@ -23,6 +23,8 @@ type metricsAggregator struct {
 }
 
 // statementMetrics holds aggregated metrics for a statement.
+//
+//nolint:unused // Will be used in Phase 8+
 type statementMetrics struct {
 	statementID     string
 	sessionID       string
@@ -52,6 +54,8 @@ func newMetricsAggregator(exporter *telemetryExporter, cfg *Config) *metricsAggr
 }
 
 // recordMetric records a metric for aggregation.
+//
+//nolint:unused // Will be used in Phase 8+
 func (agg *metricsAggregator) recordMetric(ctx context.Context, metric *telemetryMetric) {
 	// Swallow all errors
 	defer func() {
@@ -123,6 +127,8 @@ func (agg *metricsAggregator) recordMetric(ctx context.Context, metric *telemetr
 }
 
 // completeStatement marks a statement as complete and emits aggregated metric.
+//
+//nolint:unused // Will be used in Phase 8+
 func (agg *metricsAggregator) completeStatement(ctx context.Context, statementID string, failed bool) {
 	defer func() {
 		if r := recover(); r != nil {
@@ -220,10 +226,13 @@ func (agg *metricsAggregator) close(ctx context.Context) error {
 }
 
 // simpleError is a simple error implementation for testing.
+//
+//nolint:unused // Will be used in Phase 8+
 type simpleError struct {
 	msg string
 }
 
+//nolint:unused // Will be used in Phase 8+
 func (e *simpleError) Error() string {
 	return e.msg
 }

telemetry/errors.go

@@ -8,6 +8,8 @@ import (
 // isTerminalError returns true if error is terminal (non-retryable).
 // Terminal errors indicate user errors or permanent failures that won't
 // be resolved by retrying the operation.
+//
+//nolint:unused // Will be used in Phase 8+
 func isTerminalError(err error) bool {
 	if err == nil {
 		return false
@@ -43,6 +45,8 @@ func isTerminalError(err error) bool {
 
 // classifyError classifies an error for telemetry purposes.
 // Returns a string representation of the error type.
+//
+//nolint:unused // Will be used in Phase 8+
 func classifyError(err error) string {
 	if err == nil {
 		return ""
@@ -75,21 +79,28 @@ func classifyError(err error) string {
 
 // isRetryableError returns true if the error is retryable.
 // This is the inverse of isTerminalError.
+//
+//nolint:unused // Will be used in Phase 8+
 func isRetryableError(err error) bool {
 	return !isTerminalError(err)
 }
 
 // httpError represents an HTTP error with status code.
+//
+//nolint:unused // Will be used in Phase 8+
 type httpError struct {
 	statusCode int
 	message    string
 }
 
+//nolint:unused // Will be used in Phase 8+
 func (e *httpError) Error() string {
 	return e.message
 }
 
 // newHTTPError creates a new HTTP error.
+//
+//nolint:unused // Will be used in Phase 8+
 func newHTTPError(statusCode int, message string) error {
 	return &httpError{
 		statusCode: statusCode,
@@ -98,12 +109,16 @@ func newHTTPError(statusCode int, message string) error {
 }
 
 // isTerminalHTTPStatus returns true for non-retryable HTTP status codes.
+//
+//nolint:unused // Will be used in Phase 8+
 func isTerminalHTTPStatus(status int) bool {
 	// 4xx errors (except 429) are terminal
 	return status >= 400 && status < 500 && status != 429
 }
 
 // extractHTTPError extracts HTTP error information if available.
+//
+//nolint:unused // Will be used in Phase 8+
 func extractHTTPError(err error) (*httpError, bool) {
 	var httpErr *httpError
 	if errors.As(err, &httpErr) {

telemetry/interceptor.go

@@ -15,14 +15,18 @@ type Interceptor struct {
 }
 
 // metricContext holds metric collection state in context.
+//
+//nolint:unused // Will be used in Phase 8+
 type metricContext struct {
 	statementID string
 	startTime   time.Time
 	tags        map[string]interface{}
 }
 
+//nolint:unused // Will be used in Phase 8+
 type contextKey int
 
+//nolint:unused // Will be used in Phase 8+
 const metricContextKey contextKey = 0
 
 // newInterceptor creates a new telemetry interceptor.
@@ -34,11 +38,15 @@ func newInterceptor(aggregator *metricsAggregator, enabled bool) *Interceptor {
 }
 
 // withMetricContext adds metric context to the context.
+//
+//nolint:unused // Will be used in Phase 8+
 func withMetricContext(ctx context.Context, mc *metricContext) context.Context {
 	return context.WithValue(ctx, metricContextKey, mc)
 }
 
 // getMetricContext retrieves metric context from the context.
+//
+//nolint:unused // Will be used in Phase 8+
 func getMetricContext(ctx context.Context) *metricContext {
 	if mc, ok := ctx.Value(metricContextKey).(*metricContext); ok {
 		return mc
@@ -48,6 +56,8 @@ func getMetricContext(ctx context.Context) *metricContext {
 
 // beforeExecute is called before statement execution.
 // Returns a new context with metric tracking attached.
+//
+//nolint:unused // Will be used in Phase 8+
 func (i *Interceptor) beforeExecute(ctx context.Context, statementID string) context.Context {
 	if !i.enabled {
 		return ctx
@@ -64,6 +74,8 @@ func (i *Interceptor) beforeExecute(ctx context.Context, statementID string) con
 
 // afterExecute is called after statement execution.
 // Records the metric with timing and error information.
+//
+//nolint:unused // Will be used in Phase 8+
 func (i *Interceptor) afterExecute(ctx context.Context, err error) {
 	if !i.enabled {
 		return
@@ -98,6 +110,8 @@ func (i *Interceptor) afterExecute(ctx context.Context, err error) {
 }
 
 // addTag adds a tag to the current metric context.
+//
+//nolint:unused // Will be used in Phase 8+
 func (i *Interceptor) addTag(ctx context.Context, key string, value interface{}) {
 	if !i.enabled {
 		return
@@ -110,6 +124,8 @@ func (i *Interceptor) addTag(ctx context.Context, key string, value interface{})
 }
 
 // recordConnection records a connection event.
+//
+//nolint:unused // Will be used in Phase 8+
 func (i *Interceptor) recordConnection(ctx context.Context, tags map[string]interface{}) {
 	if !i.enabled {
 		return
@@ -131,6 +147,8 @@ func (i *Interceptor) recordConnection(ctx context.Context, tags map[string]inte
 }
 
 // completeStatement marks a statement as complete and flushes aggregated metrics.
+//
+//nolint:unused // Will be used in Phase 8+
 func (i *Interceptor) completeStatement(ctx context.Context, statementID string, failed bool) {
 	if !i.enabled {
 		return