Arrea.Monitor (Arrea v2.2.0)

Copy Markdown View Source

Global monitor for the Arrea engine.

Responsible for:

  • Registering and updating worker state
  • Notifying worker completion
  • Providing aggregate statistics for workers, tasks, and errors

The Monitor is an internal component that accumulates statistics. External subscribers live on Arrea.Leader; the Monitor no longer maintains a subscriber set of its own.

Summary

Functions

child_spec(init_arg)

Child specification for the supervision tree.

get_state()

Returns the current state of the monitor.

get_stats()

Returns summarised Engine statistics.

register_worker(worker_id, state)

Registers a worker in the monitor.

start_link(opts \\ [])

Starts the Monitor as a GenServer with name Elixir.Arrea.Monitor.

update_worker(worker_id, updates)

Updates a worker's state.

worker_finished(worker_id, status, duration_ms)

Notifies the monitor that a worker has finished.

Functions

child_spec(init_arg)

@spec child_spec(keyword()) :: map()

Child specification for the supervision tree.

get_state()

@spec get_state() :: map()

Returns the current state of the monitor.

get_stats()

@spec get_stats() :: {:ok, map()}

Returns summarised Engine statistics.

register_worker(worker_id, state)

@spec register_worker(any(), map()) :: :ok

Registers a worker in the monitor.

start_link(opts \\ [])

@spec start_link(keyword()) :: GenServer.on_start()

Starts the Monitor as a GenServer with name Elixir.Arrea.Monitor.

update_worker(worker_id, updates)

@spec update_worker(any(), map()) :: :ok

Updates a worker's state.

worker_finished(worker_id, status, duration_ms)

@spec worker_finished(any(), atom(), integer()) :: :ok

Notifies the monitor that a worker has finished.