this repo has no description
relay: more checks and logging around initial seq
+5
-1
+5
-1
cmd/relay/main.go
+5
-1
cmd/relay/main.go
···
240
240
persitConfig := diskpersist.DefaultDiskPersistOptions()
241
241
persitConfig.Retention = cmd.Duration("replay-window")
242
242
persitConfig.InitialSeq = cmd.Int64("initial-seq-number")
243
-
logger.Info("setting up disk persister", "dir", persistDir, "replayWindow", persitConfig.Retention)
243
+
if persitConfig.InitialSeq <= 0 {
244
+
// belt-and-suspenders: the disk persister also checks this internally
245
+
return fmt.Errorf("negative or zero initial sequence config: %d", persitConfig.InitialSeq)
246
+
}
247
+
logger.Info("setting up disk persister", "dir", persistDir, "replayWindow", persitConfig.Retention, "initialSeq", persitConfig.InitialSeq)
244
248
persister, err := diskpersist.NewDiskPersistence(persistDir, "", db, persitConfig)
245
249
if err != nil {
246
250
return fmt.Errorf("setting up disk persister: %w", err)