func()

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
}