fix: remove unused modelTypeTag and format Go files for CI

Author: ethenotethan

coordinator/api/consumer.go

@@ -690,12 +690,12 @@ func (s *Server) handleChatCompletions(w http.ResponseWriter, r *http.Request) {
 			}
 			pr.Timing.QueuedAt = time.Now()
 			if err := s.registry.Queue().Enqueue(queuedReq); err != nil {
-s.ddIncr("routing.decisions", []string{"model:" + model, "model_type:" + s.registry.ModelType(model), "outcome:over_capacity"})
+				s.ddIncr("routing.decisions", []string{"model:" + model, "model_type:" + s.registry.ModelType(model), "outcome:over_capacity"})
 				refundReservation()
 				writeJSON(w, http.StatusServiceUnavailable, errorResponse("model_not_available", fmt.Sprintf("no hardware-trusted provider available for model %q and queue is full", model)))
 				return
 			}
-s.ddIncr("routing.decisions", []string{"model:" + model, "model_type:" + s.registry.ModelType(model), "outcome:queued"})
+			s.ddIncr("routing.decisions", []string{"model:" + model, "model_type:" + s.registry.ModelType(model), "outcome:queued"})
 
 			s.logger.Info("request queued, waiting for provider",
 				"model", model,

coordinator/api/server.go

@@ -362,11 +362,6 @@ func (s *Server) ddGauge(name string, value float64, tags []string) {
 // modelTypeTag returns a DogStatsD tag "model_type:<type>" for the given
 // model ID, resolved from the registry. Returns "model_type:unknown" if
 // the model is not found.
-func (s *Server) modelTypeTag(model string) string {
-	return "model_type:" + s.registry.ModelType(model)
-}
-
-// emitPanic is the panic-specific emit helper. Captures stack separately.
 func (s *Server) emitPanic(ctx context.Context, message, stack string, fields map[string]any) {
 	if s.emitter == nil {
 		return

coordinator/registry/registry.go

@@ -376,8 +376,8 @@ type Registry struct {
 
 	logger *slog.Logger
 
-	onlineCount     atomic.Int64
-	modelProviders  map[string]*atomic.Int64
+	onlineCount      atomic.Int64
+	modelProviders   map[string]*atomic.Int64
 	modelProvidersMu sync.Mutex
 }
 

e2e/integration_test.go

@@ -19,8 +19,8 @@ import (
 	"github.com/eigeninference/d-inference/coordinator/payments"
 	"github.com/eigeninference/d-inference/e2e/testbed"
 	tbassert "github.com/eigeninference/d-inference/e2e/testbed/assert"
-	tbprofile "github.com/eigeninference/d-inference/e2e/testbed/profile"
 	"github.com/eigeninference/d-inference/e2e/testbed/profile"
+	tbprofile "github.com/eigeninference/d-inference/e2e/testbed/profile"
 )
 
 var httpTimeout = 300 * time.Second

e2e/testbed/config.go

@@ -8,8 +8,8 @@ type ModelSpec struct {
 }
 
 var KnownModelSizes = map[string]string{
-	"mlx-community/Qwen3.5-0.8B-MLX-4bit":  "0.5 GB",
-	"mlx-community/gemma-3-270m-4bit":       "0.2 GB",
+	"mlx-community/Qwen3.5-0.8B-MLX-4bit": "0.5 GB",
+	"mlx-community/gemma-3-270m-4bit":     "0.2 GB",
 }
 
 type TrustLevel string

e2e/testbed/load.go

@@ -313,36 +313,36 @@ func (r *LoadResult) SummaryTable() string {
 
 	if r.ProfileRun != nil && len(r.ProfileRun.SegmentTimings) > 0 {
 		s.WriteString("\n")
-	s.WriteString(fmt.Sprintf("%-30s %8s %8s %8s %8s %8s\n", "SEGMENT", "COUNT", "MEAN", "P50", "P95", "MAX"))
-	s.WriteString("─────────────────────────────────────────────────────────────────────\n")
-
-	for _, seg := range []Segment{
-		SegmentTotalE2E,
-		SegmentParse,
-		SegmentReserve,
-		SegmentRoute,
-		SegmentQueueWait,
-		SegmentEncrypt,
-		SegmentDispatch,
-		SegmentCoordinatorToProvider,
-		SegmentTTFT,
-	} {
-		durations, ok := r.ProfileRun.SegmentTimings[seg]
-		if !ok || len(durations) == 0 {
-			continue
-		}
-		stats := computeStats(durations)
-		precision := time.Millisecond
-		if stats.Max < time.Millisecond {
-			precision = time.Microsecond
-		}
-		s.WriteString(fmt.Sprintf("%-30s %8d %8s %8s %8s %8s\n",
-			seg, stats.Count,
-			stats.Mean.Round(precision),
-			stats.Median.Round(precision),
-			stats.P95.Round(precision),
-			stats.Max.Round(precision),
-		))
+		s.WriteString(fmt.Sprintf("%-30s %8s %8s %8s %8s %8s\n", "SEGMENT", "COUNT", "MEAN", "P50", "P95", "MAX"))
+		s.WriteString("─────────────────────────────────────────────────────────────────────\n")
+
+		for _, seg := range []Segment{
+			SegmentTotalE2E,
+			SegmentParse,
+			SegmentReserve,
+			SegmentRoute,
+			SegmentQueueWait,
+			SegmentEncrypt,
+			SegmentDispatch,
+			SegmentCoordinatorToProvider,
+			SegmentTTFT,
+		} {
+			durations, ok := r.ProfileRun.SegmentTimings[seg]
+			if !ok || len(durations) == 0 {
+				continue
+			}
+			stats := computeStats(durations)
+			precision := time.Millisecond
+			if stats.Max < time.Millisecond {
+				precision = time.Microsecond
+			}
+			s.WriteString(fmt.Sprintf("%-30s %8d %8s %8s %8s %8s\n",
+				seg, stats.Count,
+				stats.Mean.Round(precision),
+				stats.Median.Round(precision),
+				stats.P95.Round(precision),
+				stats.Max.Round(precision),
+			))
 		}
 	}
 

e2e/testbed/suite.go

@@ -44,9 +44,9 @@ func execCommandContext(ctx context.Context, name string, args ...string) *exec.
 }
 
 type Suite struct {
-	Ctx     context.Context
-	Logger  *slog.Logger
-	Config  SuiteConfig
+	Ctx    context.Context
+	Logger *slog.Logger
+	Config SuiteConfig
 
 	Pg          *deps.PostgresLifecycle
 	PgStore     store.Store