in lib/persistedretry/config.go [39:64]
func (c Config) applyDefaults() Config {
if c.NumIncomingWorkers == 0 {
c.NumIncomingWorkers = 4
}
if c.NumRetryWorkers == 0 {
c.NumRetryWorkers = 2
}
if c.MaxTaskThroughput == 0 {
c.MaxTaskThroughput = 10 * time.Millisecond
}
if c.PollRetriesInterval == 0 {
c.PollRetriesInterval = 15 * time.Second
}
if c.RetryInterval == 0 {
c.RetryInterval = 30 * time.Second
}
if !c.Testing {
if c.IncomingBuffer == 0 {
c.IncomingBuffer = 1000
}
if c.RetryBuffer == 0 {
c.RetryBuffer = 1000
}
}
return c
}