Packages

redlock

0.1.2
1.0.21 1.0.20 1.0.19 1.0.18 1.0.17 1.0.16 1.0.15 1.0.13 1.0.12 1.0.10 1.0.9 1.0.8 1.0.6 1.0.5 1.0.4 1.0.3 1.0.2 1.0.0 0.1.14 0.1.13 0.1.12 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1

Redlock (Redis Distributed Lock) implementation

HexDocs

Current section

Files

Jump to
Readme
31 Versions
4 Dependencies
Dependants
Files
Activity
redlock lib redlock node_chooser store hash_ring.ex
Raw

lib/redlock/node_chooser/store/hash_ring.ex 

defmodule Redlock.NodeChooser.Store.HashRing do



  @behaviour Redlock.NodeChooser.Store

  require Logger



  @impl true

  def new(pools_list) do



    len = length(pools_list)



    ring = idx_list(len) |> Enum.reduce(HashRing.new(), fn idx, ring ->

      {ok, ring2} = HashRing.add_node(ring, "#{idx}")

      ring2

    end)



    [ring, pools_list]



  end



  defp idx_list(0) do

    raise "must not come here"

  end

  defp idx_list(1) do

    # XXX Shouldn't be come here on production environment

    [0]

  end

  defp idx_list(len) do

    (0..(len - 1)) |> Enum.to_list()

  end



  @impl true

  def choose([ring, pools_list], key) do

    idx = HashRing.find_node(ring, key)

    Enum.at(pools_list, String.to_integer(idx))

  end



end