Page Menu
Home
Phorge
Search
Configure Global Search
Log In
Files
F85712416
No One
Temporary
Actions
View File
Edit File
Delete File
View Transforms
Subscribe
Award Token
Flag For Later
Size
2 KB
Referenced Files
None
Subscribers
None
View Options
diff --git a/lib/tesla/middleware/retry.ex b/lib/tesla/middleware/retry.ex
index 3dc6778..62b83c2 100644
--- a/lib/tesla/middleware/retry.ex
+++ b/lib/tesla/middleware/retry.ex
@@ -1,50 +1,58 @@
defmodule Tesla.Middleware.Retry do
@behaviour Tesla.Middleware
@moduledoc """
- Retry few times in case of connection error (`nxdomain`, `connrefused` etc).
- This middleware will NOT retry in case of application error (HTTP status 5xx).
+ Retry the HTTP call in case of connection error by default (`nxdomain`, `connrefused` etc).
+ Application error checking for retry can be customized through should_retry options by
+ providing a function in returning a boolean.
### Example
```
defmodule MyClient do
use Tesla
- plug Tesla.Middleware.Retry, delay: 500, max_retries: 10
+ plug Tesla.Middleware.Retry,
+ delay: 500,
+ max_retries: 10,
+ should_retry: fn
+ {:ok, %{status: status}} when status in [400, 500] -> true
+ {:ok, _} -> false
+ {:error, _} -> true
+ end
end
```
### Options
- `:delay` - number of milliseconds to wait before retrying (defaults to 1000)
- `:max_retries` - maximum number of retries (defaults to 5)
- - `:should_retry` - function to determine it should be retried
+ - `:should_retry` - function to determine Tesla should be retried
"""
@defaults [
delay: 1000,
max_retries: 5
]
@doc false
def call(env, next, opts) do
opts = opts || []
delay = Keyword.get(opts, :delay, @defaults[:delay])
max_retries = Keyword.get(opts, :max_retries, @defaults[:max_retries])
should_retry = Keyword.get(opts, :should_retry, &match?({:error, _}, &1))
retry(env, next, delay, max_retries, should_retry)
end
defp retry(env, next, _delay, retries, _should_retry) when retries <= 1 do
Tesla.run(env, next)
end
defp retry(env, next, delay, retries, should_retry) do
if should_retry.(Tesla.run(env, next)) do
:timer.sleep(delay)
retry(env, next, delay, retries - 1, should_retry)
else
{:ok, env}
end
end
end
File Metadata
Details
Attached
Mime Type
text/x-diff
Expires
Sat, Sep 19, 10:41 AM (1 d, 23 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
1766672
Default Alt Text
(2 KB)
Attached To
Mode
R28 tesla
Attached
Detach File
Event Timeline
Log In to Comment