+3
-4
cmd/sonar/main.go
+3
-4
cmd/sonar/main.go
···
15
15
16
16
"github.com/bluesky-social/indigo/events"
17
17
"github.com/bluesky-social/indigo/events/schedulers/sequential"
18
-
"github.com/bluesky-social/indigo/sonar"
19
18
"github.com/gorilla/websocket"
20
19
"github.com/prometheus/client_golang/prometheus/promhttp"
21
20
_ "go.uber.org/automaxprocs"
···
63
62
},
64
63
}
65
64
66
-
app.Action = Sonar
65
+
app.Action = runSonar
67
66
68
67
err := app.Run(os.Args)
69
68
if err != nil {
···
71
70
}
72
71
}
73
72
74
-
func Sonar(cctx *cli.Context) error {
73
+
func runSonar(cctx *cli.Context) error {
75
74
ctx := cctx.Context
76
75
ctx, cancel := context.WithCancel(ctx)
77
76
defer cancel()
···
94
93
log.Fatalf("failed to parse ws-url: %+v", err)
95
94
}
96
95
97
-
s, err := sonar.NewSonar(logger, cctx.String("cursor-file"), u.String())
96
+
s, err := NewSonar(logger, cctx.String("cursor-file"), u.String())
98
97
if err != nil {
99
98
log.Fatalf("failed to create sonar: %+v", err)
100
99
}
+1
-1
sonar/metrics.go
cmd/sonar/metrics.go
+1
-1
sonar/metrics.go
cmd/sonar/metrics.go