(conf *Config, attemptsRemaining int)
| 1185 | } |
| 1186 | |
| 1187 | func computeMetadataBackoff(conf *Config, attemptsRemaining int) time.Duration { |
| 1188 | if conf.Metadata.Retry.BackoffFunc != nil { |
| 1189 | maxRetries := conf.Metadata.Retry.Max |
| 1190 | retries := maxRetries - attemptsRemaining |
| 1191 | return conf.Metadata.Retry.BackoffFunc(retries, maxRetries) |
| 1192 | } |
| 1193 | return conf.Metadata.Retry.Backoff |
| 1194 | } |
| 1195 | |
| 1196 | func (client *client) findCoordinator(coordinatorKey string, coordinatorType CoordinatorType, attemptsRemaining int) (*FindCoordinatorResponse, error) { |
| 1197 | retry := func(err error) (*FindCoordinatorResponse, error) { |
no outgoing calls
no test coverage detected