Structs§
- Bulk
GetState Request - Bulk get projection states for multiple entities
- Entity
State Params - GetSchema
Params - Save
Projection State Request - Request body for saving projection state
- SetCompatibility
Request
Functions§
- all_
pipeline_ stats - analytics_
correlation - analytics_
frequency - analytics_
summary - bulk_
get_ projection_ states - 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 - list_
pipelines - list_
projections - List all registered projections
- list_
replays - list_
schema_ versions - list_
snapshots - 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