Page Menu
Home
Phorge
Search
Configure Global Search
Log In
Files
F140842
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/fuse.ex b/lib/tesla/middleware/fuse.ex
index e2ca954..7eae8f8 100644
--- a/lib/tesla/middleware/fuse.ex
+++ b/lib/tesla/middleware/fuse.ex
@@ -1,52 +1,54 @@
-defmodule Tesla.Middleware.Fuse do
- @moduledoc """
- Fuse (https://github.com/jlouis/fuse) middleware
+if Code.ensure_loaded?(:fuse) do
+ defmodule Tesla.Middleware.Fuse do
+ @moduledoc """
+ Fuse (https://github.com/jlouis/fuse) middleware
- Remember to add `{:fuse, "~> 2.4"}` to dependencies
- and `:fuse` to applications in `mix.exs`
+ Remember to add `{:fuse, "~> 2.4"}` to dependencies
+ and `:fuse` to applications in `mix.exs`
- Example
- defmodule Myclient do
- use Tesla
+ Example
+ defmodule Myclient do
+ use Tesla
- plug Tesla.Middleware.Fuse, opts: {{:standard, 2, 10_000}, {:reset, 60_000}}
- end
+ plug Tesla.Middleware.Fuse, opts: {{:standard, 2, 10_000}, {:reset, 60_000}}
+ end
- Options:
- - `:name` - fuse name (defaults to module name)
- - `:opts` - fuse options (see fuse docs for reference)
- """
+ Options:
+ - `:name` - fuse name (defaults to module name)
+ - `:opts` - fuse options (see fuse docs for reference)
+ """
- # 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}}
+ # 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}}
- def call(env, next, opts) do
- opts = opts || []
- name = Keyword.get(opts, :name, env.__module__)
+ def call(env, next, opts) do
+ opts = opts || []
+ name = Keyword.get(opts, :name, env.__module__)
- case :fuse.ask(name, :sync) do
- :ok ->
- run(env, next, name)
+ case :fuse.ask(name, :sync) do
+ :ok ->
+ run(env, next, name)
- :blown ->
- {:error, :unavailable}
+ :blown ->
+ {:error, :unavailable}
- {:error, :not_found} ->
- :fuse.install(name, Keyword.get(opts, :opts, @defaults))
- run(env, next, name)
+ {:error, :not_found} ->
+ :fuse.install(name, Keyword.get(opts, :opts, @defaults))
+ run(env, next, name)
+ end
end
- end
- defp run(env, next, name) do
- try do
- Tesla.run(env, next)
- rescue
- _error ->
- :fuse.melt(name)
- {:error, :unavailable}
+ defp run(env, next, name) do
+ try do
+ Tesla.run(env, next)
+ rescue
+ _error ->
+ :fuse.melt(name)
+ {:error, :unavailable}
+ end
end
end
end
File Metadata
Details
Attached
Mime Type
text/x-diff
Expires
Wed, Jan 22, 12:18 AM (1 d, 13 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
55746
Default Alt Text
(2 KB)
Attached To
Mode
R28 tesla
Attached
Detach File
Event Timeline
Log In to Comment