Packages

rafted_value

0.10.3
0.12.0 0.11.2 0.11.1 0.11.0 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.3 0.9.2 0.9.1 retired 0.9.0 0.8.0 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.0 0.4.0 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 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 0.1.0

Replicated and synchronized values wrapped by processes

HexDocs

Current section

Files

Jump to
Readme
37 Versions
1 Dependency
Dependants
Files
Activity
rafted_value lib rafted_value communication.ex
Raw

lib/rafted_value/communication.ex 

use Croma



defmodule RaftedValue.Communication do

  @callback cast(server :: GenServer.server, msg :: any) :: :ok



  @callback reply(from :: GenServer.from, reply :: any) :: :ok

end



defmodule RaftedValue.RemoteMessageGateway do

  @moduledoc """

  Default implementation of `:communication_module`.



  Essentially `cast/2` behaves as `:gen_statem.cast/2` and `reply/2` behaves as `:gen_statem.reply/2`.



  This is introduced in order to work-around slow message passing to unreachable nodes;

  if the target node is not connected to `Node.self()`, functions in this node give up delivering message.

  In order to recover from temporary network issues, reconnecting to disconnected nodes should be tried elsewhere.

  Note that `:raft_fleet` (since 0.5.0) periodically tries to re-establish inter-node connections out of the box.

  """



  @behaviour RaftedValue.Communication



  def cast(fsm_ref, event) do

    do_send(fsm_ref, {:"$gen_cast", event})

  end



  def reply({pid, tag}, reply) do

    do_send(pid, {tag, reply})

  end



  defp do_send(dest, msg) do

    :erlang.send(dest, msg, [:noconnect])

    :ok

  end

end