mirror of
https://github.com/luxfi/kms.git
synced 2026-10-30 16:23:36 +00:00
zeekay
cc986c328d
Squashes all pre-rewrite history into a single root commit. Previous tree: - 14506 commits including upstream Infisical fork history - Multiple merge chains carrying pre-purge content Force-rewrite per disk-space reclamation discipline. GHCR images (1.9.9, 1.9.11) remain immutable; their git lineage is no longer materialized.
36 lines
685 B
Go
36 lines
685 B
Go
package backoff
|
|
|
|
import "time"
|
|
|
|
/*
|
|
WithMaxRetries creates a wrapper around another BackOff, which will
|
|
return Stop if NextBackOff() has been called too many times since
|
|
the last time Reset() was called
|
|
|
|
Note: Implementation is not thread-safe.
|
|
*/
|
|
func WithMaxRetries(b BackOff, max uint64) BackOff {
|
|
return &backOffTries{delegate: b, maxTries: max}
|
|
}
|
|
|
|
type backOffTries struct {
|
|
delegate BackOff
|
|
maxTries uint64
|
|
numTries uint64
|
|
}
|
|
|
|
func (b *backOffTries) NextBackOff() time.Duration {
|
|
if b.maxTries > 0 {
|
|
if b.maxTries <= b.numTries {
|
|
return Stop
|
|
}
|
|
b.numTries++
|
|
}
|
|
return b.delegate.NextBackOff()
|
|
}
|
|
|
|
func (b *backOffTries) Reset() {
|
|
b.numTries = 0
|
|
b.delegate.Reset()
|
|
}
|