mirror of
https://github.com/duke-git/lancet.git
synced 2026-02-04 21:02:27 +08:00
94 lines
1.3 KiB
Go
94 lines
1.3 KiB
Go
package retry
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
"time"
|
|
)
|
|
|
|
func ExampleContext() {
|
|
ctx, cancel := context.WithCancel(context.TODO())
|
|
|
|
number := 0
|
|
increaseNumber := func() error {
|
|
number++
|
|
if number > 3 {
|
|
cancel()
|
|
}
|
|
return errors.New("error occurs")
|
|
}
|
|
|
|
Retry(increaseNumber,
|
|
RetryDuration(time.Microsecond*50),
|
|
Context(ctx),
|
|
)
|
|
|
|
fmt.Println(number)
|
|
|
|
// Output:
|
|
// 4
|
|
}
|
|
|
|
func ExampleRetryDuration() {
|
|
number := 0
|
|
increaseNumber := func() error {
|
|
number++
|
|
if number == 3 {
|
|
return nil
|
|
}
|
|
return errors.New("error occurs")
|
|
}
|
|
|
|
err := Retry(increaseNumber, RetryDuration(time.Microsecond*50))
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
fmt.Println(number)
|
|
|
|
// Output:
|
|
// 3
|
|
}
|
|
|
|
func ExampleRetryTimes() {
|
|
number := 0
|
|
|
|
increaseNumber := func() error {
|
|
number++
|
|
if number == 3 {
|
|
return nil
|
|
}
|
|
return errors.New("error occurs")
|
|
}
|
|
|
|
err := Retry(increaseNumber, RetryTimes(2))
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
}
|
|
|
|
// Output:
|
|
// function retry.ExampleRetryTimes.func1 run failed after 2 times retry
|
|
}
|
|
|
|
func ExampleRetry() {
|
|
number := 0
|
|
increaseNumber := func() error {
|
|
number++
|
|
if number == 3 {
|
|
return nil
|
|
}
|
|
return errors.New("error occurs")
|
|
}
|
|
|
|
err := Retry(increaseNumber, RetryDuration(time.Microsecond*50))
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
fmt.Println(number)
|
|
|
|
// Output:
|
|
// 3
|
|
}
|