+1 -1

splitter/ringbuf.go

reviewed

··· 4 4 "context" 5 5 "sync" 6 6 7 7 - events "github.com/bluesky-social/indigo/events" 7 7 + "github.com/bluesky-social/indigo/events" 8 8 "github.com/bluesky-social/indigo/models" 9 9 ) 10 10

+4 -3

splitter/splitter.go

reviewed

··· 6 6 "encoding/json" 7 7 "errors" 8 8 "fmt" 9 9 - "go.opentelemetry.io/otel" 10 9 "io" 11 10 "log/slog" 12 11 "math/rand" ··· 27 26 "github.com/bluesky-social/indigo/events/schedulers/sequential" 28 27 "github.com/bluesky-social/indigo/util" 29 28 "github.com/bluesky-social/indigo/xrpc" 29 29 + 30 30 "github.com/gorilla/websocket" 31 31 "github.com/labstack/echo/v4" 32 32 "github.com/labstack/echo/v4/middleware" 33 33 - promclient "github.com/prometheus/client_golang/prometheus" 33 33 + "github.com/prometheus/client_golang/prometheus" 34 34 "github.com/prometheus/client_golang/prometheus/promhttp" 35 35 dto "github.com/prometheus/client_model/go" 36 36 + "go.opentelemetry.io/otel" 36 37 ) 37 38 38 39 type Splitter struct { ··· 544 545 UserAgent string 545 546 RemoteAddr string 546 547 ConnectedAt time.Time 547 547 - EventsSent promclient.Counter 548 548 + EventsSent prometheus.Counter 548 549 } 549 550 550 551 func (s *Splitter) registerConsumer(c *SocketConsumer) uint64 {