mirror of
https://github.com/go-micro/go-micro.git
synced 2025-06-06 22:06:19 +02:00
fix retry test
This commit is contained in:
parent
c64cb1cb03
commit
66b3fd8893
@ -81,7 +81,6 @@ func TestCallRetry(t *testing.T) {
|
|||||||
if called == 1 {
|
if called == 1 {
|
||||||
return errors.InternalServerError("test.error", "retry request")
|
return errors.InternalServerError("test.error", "retry request")
|
||||||
}
|
}
|
||||||
|
|
||||||
// don't do the call
|
// don't do the call
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
@ -91,6 +90,8 @@ func TestCallRetry(t *testing.T) {
|
|||||||
c := NewClient(
|
c := NewClient(
|
||||||
Registry(r),
|
Registry(r),
|
||||||
WrapCall(wrap),
|
WrapCall(wrap),
|
||||||
|
Retry(RetryAlways),
|
||||||
|
Retries(1),
|
||||||
)
|
)
|
||||||
|
|
||||||
if err := c.Options().Selector.Init(selector.Registry(r)); err != nil {
|
if err := c.Options().Selector.Init(selector.Registry(r)); err != nil {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user