var serverIsOverloadedSet … var maxResponseCode … type BackoffManager … type URLBackoff … type NoBackoff … func (n *NoBackoff) UpdateBackoff(actualUrl *url.URL, err error, responseCode int) { … } func (n *NoBackoff) CalculateBackoff(actualUrl *url.URL) time.Duration { … } func (n *NoBackoff) Sleep(d time.Duration) { … } // Disable makes the backoff trivial, i.e., sets it to zero. This might be used // by tests which want to run 1000s of mock requests without slowing down. func (b *URLBackoff) Disable() { … } // baseUrlKey returns the key which urls will be mapped to. // For example, 127.0.0.1:8080/api/v2/abcde -> 127.0.0.1:8080. func (b *URLBackoff) baseUrlKey(rawurl *url.URL) string { … } // UpdateBackoff updates backoff metadata func (b *URLBackoff) UpdateBackoff(actualUrl *url.URL, err error, responseCode int) { … } // CalculateBackoff takes a url and back's off exponentially, // based on its knowledge of existing failures. func (b *URLBackoff) CalculateBackoff(actualUrl *url.URL) time.Duration { … } func (b *URLBackoff) Sleep(d time.Duration) { … }
Codebase Browser
kubernetes