Packages

esx

0.6.0
0.7.3 0.7.2 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.2.8 0.2.7 0.2.6 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.3 0.1.2 0.1.1 0.1.0

A client for the Elasticsearch with Ecto, written in Elixir

HexDocs

Current section

Files

Jump to
Readme
25 Versions
5 Dependencies
Dependants
Files
Activity
esx lib esx transport selector.ex
Raw

lib/esx/transport/selector.ex 

defmodule ESx.Transport.Selector do



  defmodule Base do

    @callback select(conns::List.t) :: ESx.Transport.Connection.t | {:error, term}

  end



  defmodule Random do

    @moduledoc "Random Selector"

    @behaviour Base



    def select(conns) do

      Enum.random conns

    end

  end



  defmodule RoundRobin do

    @moduledoc "RoundRobin Selector"

    @behaviour Base



    use ESx.Transport.Statex, [current: 0]



    def select(conns) do

      s    = state()

      next =

        if s.current >= (length(conns) - 1) do

          0

        else

          1 + s.current

        end



      conn = Enum.at conns, next

      set_state! :current, next



      conn

    end



  end



end