Add new cluster structures to cache records

lib/cachex/options.ex

@@ -308,7 +308,20 @@ defmodule Cachex.Options do
  error(:invalid_nodes)
 
  true ->
- cache(cache, nodes: nodes)
+ cache(cache,
+ nodes: nodes,
+ cluster:
+ cluster(
+ enabled: nodes != [node()],
+ router: fn key, nodes ->
+ key
+ |> :erlang.phash2()
+ |> Jumper.slot(length(nodes))
+ end,
+ nodes: nodes
+ )
+ )
+
  # coveralls-ignore-stop
  end
  end

lib/cachex/spec.ex

@@ -27,6 +27,7 @@ defmodule Cachex.Spec do
  @type cache ::
  record(:cache,
  name: atom,
+ cluster: cluster,
  commands: map,
  compressed: boolean,
  expiration: expiration,
@@ -39,6 +40,14 @@ defmodule Cachex.Spec do
  warmers: [warmer]
  )
 
+ # Record specification for a cluster instance
+ @type cluster ::
+ record(:cluster,
+ enabled: boolean,
+ router: (any, any -> atom),
+ nodes: any
+ )
+
  # Record specification for a command instance
  @type command ::
  record(:command,
@@ -119,6 +128,7 @@ defmodule Cachex.Spec do
  """
  defrecord :cache,
  name: nil,
+ cluster: nil,
  commands: %{},
  compressed: false,
  expiration: nil,
@@ -130,6 +140,11 @@ defmodule Cachex.Spec do
  transactions: false,
  warmers: []
 
+ defrecord :cluster,
+ enabled: false,
+ router: nil,
+ nodes: nil
+
  @doc """
  Creates a command record from the provided values.
 
@@ -273,6 +288,12 @@ defmodule Cachex.Spec do
  @spec cache(cache, Keyword.t()) :: cache
  defmacro cache(record, args)
 
+ @doc """
+ Updates a cluster record from the provided values.
+ """
+ @spec cluster(cluster, Keyword.t()) :: cluster
+ defmacro cluster(record, args)
+
  @doc """
  Updates a command record from the provided values.
  """