BeamConsole.Lifecycle.Recorder (beam_console v0.2.0)

Monitors a bounded set of local supervised processes and records safe exits.

Recording is lazy by default: the first console subscriber activates watches and the last subscriber removes them. In :always mode the recorder remains active for the application lifetime. Snapshot observations are consumed from the collector's existing supervision traversal; this process never calls a supervisor or retains a runtime snapshot.

Summary

Types

query_error()

status()

Functions

activate(server \\ __MODULE__)

Activates lazy recording when the first console subscriber connects.

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

deactivate(server \\ __MODULE__)

Deactivates lazy recording and removes its process monitors.

events(options \\ [], server \\ __MODULE__)

Returns a newest-first bounded lifecycle-event window with omission metadata.

observe(frame, observations, options \\ [], server \\ __MODULE__)

Reconciles one bounded private observation batch from a completed collector frame.

pause(server \\ __MODULE__)

Pauses recording until an operator explicitly resumes it.

resume(server \\ __MODULE__)

Resumes recording when subscriber or always-on demand is present.

samples(options \\ [], server \\ __MODULE__)

Returns newest aggregate recorder frames under the configured history cap.

start_link(options \\ [])

Starts a lifecycle recorder with optional name, limits, clocks, and collector overrides.

status(server \\ __MODULE__)

Returns PID-free recorder activity, coverage, and bounded-history statistics.

Types

query_error()

@type query_error() :: {:error, {:invalid_query_options, term()}}

status()

@type status() :: BeamConsole.Recorder.Status.t()

Functions

activate(server \\ MODULE)

@spec activate(GenServer.server()) :: :ok

Activates lazy recording when the first console subscriber connects.

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

deactivate(server \\ MODULE)

@spec deactivate(GenServer.server()) :: :ok

Deactivates lazy recording and removes its process monitors.

events(options \\ [], server \\ MODULE)

@spec events(
  keyword(),
  GenServer.server()
) :: BeamConsole.Recorder.Query.t() | query_error()

Returns a newest-first bounded lifecycle-event window with omission metadata.

observe(frame, observations, options \\ [], server \\ MODULE)

@spec observe(
  BeamConsole.Recorder.Frame.t(),
  [BeamConsole.Lifecycle.Observation.t()],
  keyword(),
  GenServer.server()
) :: :ok

Reconciles one bounded private observation batch from a completed collector frame.

pause(server \\ MODULE)

@spec pause(GenServer.server()) :: BeamConsole.Recorder.Status.t()

Pauses recording until an operator explicitly resumes it.

resume(server \\ MODULE)

@spec resume(GenServer.server()) :: BeamConsole.Recorder.Status.t()

Resumes recording when subscriber or always-on demand is present.

samples(options \\ [], server \\ MODULE)

@spec samples(
  keyword(),
  GenServer.server()
) :: BeamConsole.Recorder.Query.t() | query_error()

Returns newest aggregate recorder frames under the configured history cap.

start_link(options \\ [])

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

Starts a lifecycle recorder with optional name, limits, clocks, and collector overrides.

status(server \\ MODULE)

@spec status(GenServer.server()) :: status()

Returns PID-free recorder activity, coverage, and bounded-history statistics.