reckon_db_store_inspector (reckon_db v2.0.0)

View Source

Store-level introspection for debugging and monitoring.

Provides aggregate queries across streams, snapshots, and subscriptions within a single store. Designed for the Observer UI and operational tooling.

All functions read directly from the Khepri tree -- no data modification.

See the Store Inspector guide for detailed usage examples.

Summary

Functions

event_type_summary(StoreId)

Summary of event types in the store.

list_all_snapshots(StoreId)

List all snapshots across all streams in a store.

list_subscriptions(StoreId)

List all subscriptions for a store with their current state.

store_stats(StoreId)

Aggregate statistics for a store.

stream_info(StoreId, StreamId)

Detailed info for a single stream.

subscription_lag(StoreId, SubscriptionName)

Calculate lag for a specific subscription.

Functions

event_type_summary(StoreId)

-spec event_type_summary(atom()) -> {ok, [map()]} | {error, term()}.

Summary of event types in the store.

list_all_snapshots(StoreId)

-spec list_all_snapshots(atom()) -> {ok, [map()]} | {error, term()}.

List all snapshots across all streams in a store.

list_subscriptions(StoreId)

-spec list_subscriptions(atom()) -> {ok, [map()]} | {error, term()}.

List all subscriptions for a store with their current state.

store_stats(StoreId)

-spec store_stats(atom()) -> {ok, map()} | {error, term()}.

Aggregate statistics for a store.

stream_info(StoreId, StreamId)

-spec stream_info(atom(), binary()) -> {ok, map()} | {error, term()}.

Detailed info for a single stream.

subscription_lag(StoreId, SubscriptionName)

-spec subscription_lag(atom(), binary()) -> {ok, map()} | {error, term()}.

Calculate lag for a specific subscription.