oppi.li
fork of indigo with slightly nicer lexgen
Update sonar a little bit
+3
-26
-14
cmd/sonar/docker-compose.yml
-14
cmd/sonar/docker-compose.yml
···
8
8
restart: always
9
9
ports:
10
10
- "8345:8345"
11
-
sonar-sandbox:
12
-
build:
13
-
context: ../../
14
-
dockerfile: cmd/sonar/Dockerfile
15
-
image: atproto-sonar
16
-
restart: always
17
-
ports:
18
-
- "8346:8345"
19
-
command:
20
-
[
21
-
"./sonar",
22
-
"--ws-url",
23
-
"wss://bgs.bsky-sandbox.dev/xrpc/com.atproto.sync.subscribeRepos",
24
-
]
+3
-12
cmd/sonar/main.go
+3
-12
cmd/sonar/main.go
···
14
14
"time"
15
15
16
16
"github.com/bluesky-social/indigo/events"
17
-
"github.com/bluesky-social/indigo/events/schedulers/autoscaling"
17
+
"github.com/bluesky-social/indigo/events/schedulers/sequential"
18
18
"github.com/bluesky-social/indigo/sonar"
19
19
"github.com/gorilla/websocket"
20
20
"github.com/prometheus/client_golang/prometheus/promhttp"
···
35
35
&cli.StringFlag{
36
36
Name: "ws-url",
37
37
Usage: "full websocket path to the ATProto SubscribeRepos XRPC endpoint",
38
-
Value: "wss://bsky.social/xrpc/com.atproto.sync.subscribeRepos",
38
+
Value: "wss://bsky.network/xrpc/com.atproto.sync.subscribeRepos",
39
39
},
40
40
&cli.StringFlag{
41
41
Name: "log-level",
···
46
46
Name: "port",
47
47
Usage: "listen port for metrics server",
48
48
Value: 8345,
49
-
},
50
-
&cli.IntFlag{
51
-
Name: "worker-count",
52
-
Usage: "number of workers to process events",
53
-
Value: 10,
54
49
},
55
50
&cli.IntFlag{
56
51
Name: "max-queue-size",
···
102
97
103
98
wg := sync.WaitGroup{}
104
99
105
-
scalingSettings := autoscaling.DefaultAutoscaleSettings()
106
-
scalingSettings.MaxConcurrency = cctx.Int("worker-count")
107
-
scalingSettings.AutoscaleFrequency = time.Second
108
-
109
-
pool := autoscaling.NewScheduler(scalingSettings, u.Host, s.HandleStreamEvent)
100
+
pool := sequential.NewScheduler(u.Host, s.HandleStreamEvent)
110
101
111
102
// Start a goroutine to manage the cursor file, saving the current cursor every 5 seconds.
112
103
go func() {