Module api

Structs§

all_pipeline_stats
analytics_correlation
analytics_frequency
analytics_summary
bulk_get_projection_states
bulk_save_projection_states: Bulk save projection states for multiple entities
cancel_replay
compaction_stats
create_snapshot
delete_replay
events_websocket
get_entity_snapshot
get_entity_state
get_latest_snapshot
get_pipeline
get_pipeline_stats
get_projection: Get projection metadata by name
get_projection_state: Get projection state for a specific entity
get_replay_progress
get_schema
get_stats
health
ingest_event
ingest_event_v1: Ingest a single event with semi-sync/sync replication ACK waiting.
ingest_events_batch: Batch ingest multiple events in a single request
ingest_events_batch_v1: Batch ingest with semi-sync/sync replication ACK waiting.
list_event_types
list_pipelines
list_projections: List all registered projections
list_replays
list_schema_versions
list_snapshots
list_streams
list_subjects
prometheus_metrics
query_events
register_pipeline
register_schema
remove_pipeline
reset_pipeline
save_projection_state: Save/update projection state for an entity
serve
set_compatibility_mode
start_replay
trigger_compaction
validate_event_schema