this repo has no description
remove queue depth config (which does nothing)
+3
-12
-7
cmd/relay/main.go
-7
cmd/relay/main.go
···
102
102
Value: 40,
103
103
},
104
104
&cli.IntFlag{
105
-
Name: "host-queue-depth",
106
-
Usage: "size of queue (channel) per-host for unprocessed events",
107
-
EnvVars: []string{"RELAY_HOST_QUEUE_SIZE"},
108
-
Value: 1000,
109
-
},
110
-
&cli.IntFlag{
111
105
Name: "default-account-limit",
112
106
Value: 100,
113
107
Usage: "max number of active accounts for new upstream hosts",
···
237
231
relayConfig := relay.DefaultRelayConfig()
238
232
relayConfig.UserAgent = fmt.Sprintf("indigo-relay/%s", versioninfo.Short())
239
233
relayConfig.ConcurrencyPerHost = cctx.Int("host-concurrency")
240
-
relayConfig.QueueDepthPerHost = cctx.Int("host-queue-depth")
241
234
relayConfig.DefaultRepoLimit = cctx.Int64("default-account-limit")
242
235
relayConfig.TrustedDomains = cctx.StringSlice("trusted-domains")
243
236
relayConfig.LenientSyncValidation = cctx.Bool("lenient-sync-validation")
-3
cmd/relay/relay/relay.go
-3
cmd/relay/relay/relay.go
···
41
41
DefaultRepoLimit int64
42
42
TrustedRepoLimit int64
43
43
ConcurrencyPerHost int
44
-
QueueDepthPerHost int
45
44
LenientSyncValidation bool
46
45
TrustedDomains []string
47
46
HostPerDayLimit int64
···
57
56
DefaultRepoLimit: 100,
58
57
TrustedRepoLimit: 10_000_000,
59
58
ConcurrencyPerHost: 40,
60
-
QueueDepthPerHost: 1000,
61
59
HostPerDayLimit: 50,
62
60
}
63
61
}
···
96
94
97
95
slurpConfig := DefaultSlurperConfig()
98
96
slurpConfig.ConcurrencyPerHost = config.ConcurrencyPerHost
99
-
slurpConfig.QueueDepthPerHost = config.QueueDepthPerHost
100
97
101
98
// register callbacks to persist cursors and host state in database
102
99
slurpConfig.PersistCursorCallback = r.PersistHostCursors
+3
-2
cmd/relay/relay/slurper.go
+3
-2
cmd/relay/relay/slurper.go
···
64
64
func DefaultSlurperConfig() *SlurperConfig {
65
65
// NOTE: many of these defaults are overruled by DefaultRelayConfig, or even process CLI arg defaults
66
66
return &SlurperConfig{
67
-
UserAgent: "indigo-relay",
68
-
ConcurrencyPerHost: 40,
67
+
UserAgent: "indigo-relay",
68
+
ConcurrencyPerHost: 40,
69
+
// NOTE: queue depth doesn't do anything with current parallel scheduler implementation
69
70
QueueDepthPerHost: 1000,
70
71
PersistCursorPeriod: time.Second * 4,
71
72