View Source ProcessHub.Strategy.Synchronization.Base protocol (ProcessHub v0.3.2-alpha)

This protocol defines the behavior of a synchronization strategy.

Summary

Types

t()

All the types that implement this protocol.

Functions

handle_synchronization(strategy, hub_id, remote_data, remote_node)

Handles the periodic synchronization of the process registry.

init(strategy, hub_id)

Triggered when coordinator is initialized.

init_sync(strategy, hub_id, cluster_nodes)

Initializes the periodic synchronization of the process registry.

propagate(strategy, hub_id, children, node, type, opts)

This function is called when a process has been started on the local node, and the information about the process is about to be propagated to other nodes.

Types

Link to this type

t()

View Source 
@type t() :: term()

All the types that implement this protocol.

Functions

Link to this function

handle_synchronization(strategy, hub_id, remote_data, remote_node)

View Source 
@spec handle_synchronization(t(), ProcessHub.hub_id(), term(), node()) :: :ok

Handles the periodic synchronization of the process registry.

Link to this function

init(strategy, hub_id)

View Source 
@spec init(
  struct(),
  ProcessHub.hub_id()
) :: any()

Triggered when coordinator is initialized.

Could be used to perform initialization.

Link to this function

init_sync(strategy, hub_id, cluster_nodes)

View Source 
@spec init_sync(t(), ProcessHub.hub_id(), [node()]) :: :ok

Initializes the periodic synchronization of the process registry.

Link to this function

propagate(strategy, hub_id, children, node, type, opts)

View Source 
@spec propagate(
  t(),
  ProcessHub.hub_id(),
  [
    ProcessHub.Handler.ChildrenAdd.PostStartData.t()
    | ProcessHub.Handler.ChildrenRem.StopHandle.t()
  ],
  node(),
  :add | :rem,
  keyword()
) :: :ok

This function is called when a process has been started on the local node, and the information about the process is about to be propagated to other nodes.