this repo has no description
Configurable Relay Event Retention (#786)
+12
-3
+10
-1
cmd/bigsky/main.go
+10
-1
cmd/bigsky/main.go
···
188
188
EnvVars: []string{"RELAY_DID_CACHE_SIZE"},
189
189
Value: 5_000_000,
190
190
},
191
+
&cli.DurationFlag{
192
+
Name: "event-playback-ttl",
193
+
Usage: "time to live for event playback buffering (only applies to disk persister)",
194
+
EnvVars: []string{"RELAY_EVENT_PLAYBACK_TTL"},
195
+
Value: 72 * time.Hour,
196
+
},
191
197
}
192
198
193
199
app.Action = runBigsky
···
327
333
328
334
if dpd := cctx.String("disk-persister-dir"); dpd != "" {
329
335
log.Infow("setting up disk persister")
330
-
dp, err := events.NewDiskPersistence(dpd, "", db, events.DefaultDiskPersistOptions())
336
+
337
+
pOpts := events.DefaultDiskPersistOptions()
338
+
pOpts.Retention = cctx.Duration("event-playback-ttl")
339
+
dp, err := events.NewDiskPersistence(dpd, "", db, pOpts)
331
340
if err != nil {
332
341
return fmt.Errorf("setting up disk persister: %w", err)
333
342
}
+2
-2
events/diskpersist.go
+2
-2
events/diskpersist.go
···
81
81
func DefaultDiskPersistOptions() *DiskPersistOptions {
82
82
return &DiskPersistOptions{
83
83
EventsPerFile: 10_000,
84
-
UIDCacheSize: 100_000,
85
-
DIDCacheSize: 100_000,
84
+
UIDCacheSize: 1_000_000,
85
+
DIDCacheSize: 1_000_000,
86
86
WriteBufferSize: 50,
87
87
Retention: time.Hour * 24 * 3, // 3 days
88
88
}