this repo has no description
increase batch delete size
+3
-2
+3
-2
cmd/nexus/outbox.go
+3
-2
cmd/nexus/outbox.go
···
279
279
}
280
280
281
281
func (o *Outbox) runBatchedDeletes(ctx context.Context) {
282
-
ticker := time.NewTicker(time.Second)
282
+
// drain every 10s as a fallback in the case of low-throughput ack queue
283
+
ticker := time.NewTicker(10 * time.Second)
283
284
defer ticker.Stop()
284
285
285
286
var batch []uint
···
290
291
return
291
292
case id := <-o.ackQueue:
292
293
batch = append(batch, id)
293
-
if len(batch) >= 100 {
294
+
if len(batch) >= 1000 {
294
295
o.flushDeleteBatch(batch)
295
296
batch = nil
296
297
}