this repo has no description
resync parallelism cfg
+10
-5
+10
-5
nexus/nexus.go
+10
-5
nexus/nexus.go
···
41
41
DBPath string
42
42
RelayHost string
43
43
FirehoseParallelism int
44
+
ResyncParallelism int
44
45
FirehoseCursorSaveInterval time.Duration
45
46
FullNetworkMode bool
46
47
DisableAcks bool
···
94
95
pdsBackoff: make(map[string]time.Time),
95
96
}
96
97
97
-
parallelism := config.FirehoseParallelism
98
-
if parallelism == 0 {
99
-
parallelism = 10
98
+
firehoseParallelism := config.FirehoseParallelism
99
+
if firehoseParallelism == 0 {
100
+
firehoseParallelism = 10
100
101
}
101
102
102
103
cursorSaveInterval := config.FirehoseCursorSaveInterval
···
132
133
n.FirehoseConsumer = &FirehoseConsumer{
133
134
RelayHost: config.RelayHost,
134
135
Logger: n.logger.With("component", "firehose"),
135
-
Parallelism: parallelism,
136
+
Parallelism: firehoseParallelism,
136
137
Callbacks: rsc,
137
138
GetCursor: n.EventProcessor.ReadLastCursor,
138
139
}
···
150
151
}()
151
152
}
152
153
153
-
for i := 0; i < 20; i++ {
154
+
resyncParallelism := config.ResyncParallelism
155
+
if resyncParallelism == 0 {
156
+
resyncParallelism = 5
157
+
}
158
+
for i := 0; i < resyncParallelism; i++ {
154
159
go n.runResyncWorker(context.Background(), i)
155
160
}
156
161