Page MenuHomePhorge
Files F114458

No OneTemporary
Actions

Size
3 KB
Referenced Files
None
Subscribers
None

View Options

diff --git a/lib/tesla/middleware/fuse.ex b/lib/tesla/middleware/fuse.ex
index 59b5ed3..aa074d6 100644
--- a/lib/tesla/middleware/fuse.ex
+++ b/lib/tesla/middleware/fuse.ex
@@ -1,92 +1,96 @@
if Code.ensure_loaded?(:fuse) do
defmodule Tesla.Middleware.Fuse do
@moduledoc """
Circuit Breaker middleware using [fuse](https://github.com/jlouis/fuse)
Remember to add `{:fuse, "~> 2.4"}` to dependencies (and `:fuse` to applications in `mix.exs`)
Also, you need to recompile tesla after adding `:fuse` dependency:
```
mix deps.clean tesla
mix deps.compile tesla
```
## Example usage
```
defmodule MyClient do
use Tesla
plug Tesla.Middleware.Fuse,
opts: {{:standard, 2, 10_000}, {:reset, 60_000}},
keep_original_error: true,
should_melt: fn
{:ok, %{status: status}} when status in [428, 500, 504] -> true
{:ok, _} -> false
{:error, _} -> true
end
end
```
## Options
- `:name` - fuse name (defaults to module name)
- `:opts` - fuse options (see fuse docs for reference)
- `:keep_original_error` - boolean to indicate if, in case of melting (based on `should_melt`), it should return the upstream's error or the fixed one `{:error, unavailable}`.
It's false by default, but it will be true in `2.0.0` version
- `:should_melt` - function to determine if response should melt the fuse
## SASL logger
fuse library uses [SASL (System Architecture Support Libraries)](http://erlang.org/doc/man/sasl_app.html).
You can disable its logger output using:
```
config :sasl, sasl_error_logger: :false
```
Read more at [jlouis/fuse#32](https://github.com/jlouis/fuse/issues/32) and [jlouis/fuse#19](https://github.com/jlouis/fuse/issues/19).
"""
@behaviour Tesla.Middleware
# options borrowed from http://blog.rokkincat.com/circuit-breakers-in-elixir/
# most probably not valid for your use case
@defaults {{:standard, 2, 10_000}, {:reset, 60_000}}
@impl Tesla.Middleware
def call(env, next, opts) do
opts = opts || []
context = %{
name: Keyword.get(opts, :name, env.__module__),
keep_original_error: Keyword.get(opts, :keep_original_error, false),
should_melt: Keyword.get(opts, :should_melt, &match?({:error, _}, &1))
}
case :fuse.ask(context.name, :sync) do
:ok ->
run(env, next, context)
:blown ->
{:error, :unavailable}
{:error, :not_found} ->
:fuse.install(context.name, Keyword.get(opts, :opts, @defaults))
run(env, next, context)
end
end
- defp run(env, next, %{should_melt: should_melt, name: name, keep_original_error: keep_original_error}) do
+ defp run(env, next, %{
+ should_melt: should_melt,
+ name: name,
+ keep_original_error: keep_original_error
+ }) do
res = Tesla.run(env, next)
if should_melt.(res) do
:fuse.melt(name)
if keep_original_error, do: res, else: {:error, :unavailable}
else
res
end
end
end
end

File Metadata

Mime Type
text/x-diff
Expires
Tue, Nov 26, 7:46 AM (1 d, 12 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
40242
Default Alt Text
(3 KB)

Event Timeline