this repo has no description
more relay int64 flag fixes (#1179)
+7
-3
+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)
+2
-2
cmd/relay/pull.go
+2
-2
cmd/relay/pull.go
···
32
32
Value: "sqlite://data/relay/relay.sqlite",
33
33
Sources: cli.EnvVars("DATABASE_URL"),
34
34
},
35
-
&cli.IntFlag{
35
+
&cli.Int64Flag{
36
36
Name: "default-account-limit",
37
37
Value: 100,
38
38
Usage: "max number of active accounts for new upstream hosts",
39
39
Sources: cli.EnvVars("RELAY_DEFAULT_ACCOUNT_LIMIT", "RELAY_DEFAULT_REPO_LIMIT"),
40
40
},
41
-
&cli.IntFlag{
41
+
&cli.Int64Flag{
42
42
Name: "batch-size",
43
43
Value: 500,
44
44
Usage: "host many hosts to pull at a time",