Packages

ex_limiter

1.3.9
1.4.0 1.3.13 1.3.12 1.3.11 1.3.10 1.3.9 1.3.8 1.3.7 1.3.6 1.3.5 1.3.4 1.3.3 1.3.2 1.3.1 1.3.0 1.2.2 1.2.1 1.2.0 1.1.0 1.0.0 0.1.0

Token bucket rate limiter written in elixir with configurable backends

HexDocs

Current section

Files

Jump to
Readme
21 Versions
5 Dependencies
Dependants
Files
Activity
ex_limiter lib ex_limiter utils.ex
Raw

lib/ex_limiter/utils.ex 

defmodule ExLimiter.Utils do

  def now(), do: :os.system_time(:millisecond)



  def ets_stream(table) do

    Stream.resource(

      fn -> :ets.first(table) end,

      fn :"$end_of_table" -> {:halt, nil}

        previous_key -> {[previous_key], :ets.next(table, previous_key)} end,

      fn _ -> :ok end)

  end



  def parse_integer(val) when is_binary(val), do: Integer.parse(val) |> parse_integer()

  def parse_integer(val) when is_integer(val), do: val

  def parse_integer(:error), do: :error

  def parse_integer({val, _}), do: val

end