View Source ProcessHub.Hub (ProcessHub v0.5.0-beta)

Summary

Types

batch_state()

State for batched event handling.

t()

Functions

default_batch_state()

Returns the default event batch state.

Types

Link to this type

batch_state()

View Source 
@type batch_state() :: %{nodes: [node()], timer_ref: reference() | nil}

State for batched event handling.

  • nodes: List of nodes accumulated in the batch
  • timer_ref: Reference to the timer that will trigger batch processing
Link to this type

t()

View Source 
@type t() :: %ProcessHub.Hub{
  event_batches: %{nodedown: batch_state(), cluster_join: batch_state()},
  hub_id: atom(),
  pending_operations: %{
    required(reference()) => ProcessHub.Service.RequestManager.t()
  },
  pending_work_count: non_neg_integer(),
  procs: %{
    initializer: pid(),
    task_sup: {:via, Registry, {pid(), binary()}},
    dist_sup: {:via, Registry, {pid(), binary()}},
    worker_queue: {:via, Registry, {pid(), binary()}},
    janitor: {:via, Registry, {pid(), binary()}},
    event_queue: atom()
  },
  storage: %{misc: :ets.tid(), hook: :ets.tid()}
}

Functions

Link to this function

default_batch_state()

View Source

Returns the default event batch state.