Monitorex.Storage
(monitorex v0.6.0)
Copy Markdown
Read/query layer over the configured storage backend.
All functions delegate to the active backend (ETS by default, SQLite when configured). This module is the single entry-point for dashboard pages, API, and exports.
Configuration
config :monitorex, :storage_backend, Monitorex.Storage.ETSOr:
config :monitorex, :storage_backend, Monitorex.Storage.SQLite
config :monitorex, :sqlite_path, "/var/lib/monitorex/data.db"Summary
Functions
Returns count of recent inbound events matching optional filters.
Returns count of recent outbound events matching optional filters.
Fetches a specific event by timestamp from either outbound or inbound tables.
Returns consumer aggregates sorted by requests descending.
Returns consumer breakdown for a given route key.
Returns list of endpoint aggregates for a given host.
Returns list of host aggregates sorted by requests descending.
Returns most recent inbound Events with optional filtering.
Returns most recent outbound Events with optional filtering.
Returns route aggregates sorted by requests descending.
Returns slow inbound events, newest first.
Returns slow outbound events, newest first.
Functions
@spec count_recent_inbound(keyword()) :: non_neg_integer()
Returns count of recent inbound events matching optional filters.
@spec count_recent_outbound(keyword()) :: non_neg_integer()
Returns count of recent outbound events matching optional filters.
@spec get_event(integer()) :: Monitorex.Event.t() | nil
Fetches a specific event by timestamp from either outbound or inbound tables.
@spec list_consumers() :: [map()]
Returns consumer aggregates sorted by requests descending.
Returns consumer breakdown for a given route key.
Returns list of endpoint aggregates for a given host.
@spec list_hosts() :: [map()]
Returns list of host aggregates sorted by requests descending.
@spec list_recent_inbound(keyword()) :: [Monitorex.Event.t()]
Returns most recent inbound Events with optional filtering.
Options
:limit— maximum events (default: 50):offset— events to skip (default: 0):status_class— filter by status class atom:consumer— filter by exact consumer match:route— filter by route key ("Method:path")
@spec list_recent_outbound(keyword()) :: [Monitorex.Event.t()]
Returns most recent outbound Events with optional filtering.
Options
:limit— maximum events (default: 50):offset— events to skip (default: 0):status_class— filter by status class atom:host— filter by exact host match
@spec list_routes() :: [map()]
Returns route aggregates sorted by requests descending.
@spec list_slow_inbound(keyword()) :: [Monitorex.Event.t()]
Returns slow inbound events, newest first.
Options
:limit— max events (default: 50)
@spec list_slow_outbound(keyword()) :: [Monitorex.Event.t()]
Returns slow outbound events, newest first.
Options
:limit— max events (default: 50)