evoq_store_inspector (evoq v1.14.1)

Store-level introspection via adapter.

Provides aggregate queries for debugging and monitoring. Delegates to the configured event store adapter.

Summary

Functions

event_type_summary(StoreId)

Census of event types in the store.

list_all_snapshots(StoreId)

List all snapshots across all streams.

list_subscriptions(StoreId)

List all subscriptions with checkpoint positions.

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()}.

Census 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.

list_subscriptions(StoreId)

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

List all subscriptions with checkpoint positions.

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.