1
- package backoff
1
+ package backoff_test
2
2
3
3
import (
4
4
"context"
7
7
"log"
8
8
"net/http"
9
9
"strconv"
10
+
11
+ "github.com/cenkalti/backoff/v5"
10
12
)
11
13
12
14
func ExampleRetry () {
@@ -24,23 +26,23 @@ func ExampleRetry() {
24
26
// In case on non-retriable error, return Permanent error to stop retrying.
25
27
// For this HTTP example, client errors are non-retriable.
26
28
if resp .StatusCode == 400 {
27
- return "" , Permanent (errors .New ("bad request" ))
29
+ return "" , backoff . Permanent (errors .New ("bad request" ))
28
30
}
29
31
30
32
// If we are being rate limited, return a RetryAfter to specify how long to wait.
31
33
// This will also reset the backoff policy.
32
34
if resp .StatusCode == 429 {
33
35
seconds , err := strconv .ParseInt (resp .Header .Get ("Retry-After" ), 10 , 64 )
34
36
if err == nil {
35
- return "" , RetryAfter (int (seconds ))
37
+ return "" , backoff . RetryAfter (int (seconds ))
36
38
}
37
39
}
38
40
39
41
// Return successful response.
40
42
return "hello" , nil
41
43
}
42
44
43
- result , err := Retry (context .TODO (), operation , WithBackOff (NewExponentialBackOff ()))
45
+ result , err := backoff . Retry (context .TODO (), operation , backoff . WithBackOff (backoff . NewExponentialBackOff ()))
44
46
if err != nil {
45
47
fmt .Println ("Error:" , err )
46
48
return
@@ -58,7 +60,7 @@ func ExampleTicker() {
58
60
return "hello" , nil
59
61
}
60
62
61
- ticker := NewTicker (NewExponentialBackOff ())
63
+ ticker := backoff . NewTicker (backoff . NewExponentialBackOff ())
62
64
defer ticker .Stop ()
63
65
64
66
var result string
0 commit comments