mirror of
https://github.com/v2fly/v2ray-core.git
synced 2024-12-22 18:17:52 -05:00
46 lines
672 B
Go
46 lines
672 B
Go
package retry
|
|
|
|
import (
|
|
"errors"
|
|
"time"
|
|
)
|
|
|
|
var (
|
|
RetryFailed = errors.New("All retry attempts failed.")
|
|
)
|
|
|
|
type RetryStrategy interface {
|
|
On(func() error) error
|
|
}
|
|
|
|
type retryer struct {
|
|
NextDelay func(int) int
|
|
}
|
|
|
|
func (r *retryer) On(method func() error) error {
|
|
attempt := 0
|
|
for {
|
|
err := method()
|
|
if err == nil {
|
|
return nil
|
|
}
|
|
delay := r.NextDelay(attempt)
|
|
if delay < 0 {
|
|
return RetryFailed
|
|
}
|
|
<-time.After(time.Duration(delay) * time.Millisecond)
|
|
attempt++
|
|
}
|
|
}
|
|
|
|
func Timed(attempts int, delay int) RetryStrategy {
|
|
return &retryer{
|
|
NextDelay: func(attempt int) int {
|
|
if attempt >= attempts {
|
|
return -1
|
|
}
|
|
return delay
|
|
},
|
|
}
|
|
}
|