in config/configelasticsearch/esclient.go [167:188]
func createElasticsearchBackoffFunc(config *RetrySettings) func(int) time.Duration {
if !config.Enabled {
return nil
}
expBackoff := backoff.NewExponentialBackOff()
if config.InitialInterval > 0 {
expBackoff.InitialInterval = config.InitialInterval
}
if config.MaxInterval > 0 {
expBackoff.MaxInterval = config.MaxInterval
}
expBackoff.Reset()
return func(attempts int) time.Duration {
if attempts == 1 {
expBackoff.Reset()
}
return expBackoff.NextBackOff()
}
}