Packages

exlasticsearch

1.3.0
2.3.0 2.2.3 2.2.2 2.2.1 2.2.0 2.1.0 2.0.0 1.11.0 1.10.1 1.10.0 1.9.0 1.8.0 1.7.0 1.6.5 1.6.4 1.6.3 1.6.2 1.6.1 1.6.0 1.5.4 1.5.3 1.5.2 1.5.1 1.5.0 1.4.0 1.3.3 1.3.2 1.3.1 1.3.0 1.2.3 1.2.2 1.2.1 1.2.0 1.1.0 1.0.0 0.2.2 0.2.1 0.2.0 0.1.0

Ecto-friendly Elasticsearch DSL

HexDocs

Current section

Files

Jump to
Readme
39 Versions
6 Dependencies
Dependants
Files
Activity
exlasticsearch lib exlasticsearch retry exponential_backoff.ex
Raw

lib/exlasticsearch/retry/exponential_backoff.ex 

defmodule ExlasticSearch.Retry.ExponentialBackoff do

  @moduledoc """

  Retry Strategy implementation utilizing exponential backoffs

  """

  @behaviour ExlasticSearch.RetryStrategy



  def retry(fun, opts) do

    initial = Keyword.get(opts, :initial, 1)

    max     = Keyword.get(opts, :max, 3)

    jitter  = Keyword.get(opts, :jitter, 4)



    do_retry(fun, max, initial, jitter, 0)

  end



  defp do_retry(fun, max, _, _, max), do: fun.()

  defp do_retry(fun, max, initial, jitter, retry) do

    case fun.() do

      {:ok, result} -> {:ok, result}

      {:error, _} ->

        sleep(initial, retry, jitter)

        |> :timer.sleep()



        do_retry(fun, max, initial, jitter, retry + 1)

    end

  end



  defp sleep(initial, retry, jitter) do

    jitter = :rand.uniform(jitter)

    exp = :math.pow(2, retry) |> round()

    jitter + (initial * exp)

  end

end