Structs§
- Bulk
GetState Request - Bulk get projection states for multiple entities
- Bulk
Save State Item - Bulk
Save State Request - Bulk save projection states for multiple entities
- Consumer
Poll Query - GET /api/v1/consumers/{consumer_id}/events — Poll for events since last ack
- Entity
State Params - GetSchema
Params - List
Deliveries Params - Query parameters for listing webhook deliveries
- List
Event Types Params - Query parameters for listing event types
- List
Event Types Response - Response for listing event types
- List
Streams Params - Query parameters for listing streams
- List
Streams Response - Response for listing streams
- List
Webhooks Params - Query parameters for listing webhooks
- Save
Projection State Request - Request body for saving projection state
- SetCompatibility
Request - WebSocket
Params
Functions§
- ack_
consumer - POST /api/v1/consumers/{consumer_id}/ack — Acknowledge processed events
- 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_
projection - Delete (clear) a projection by name
- delete_
replay - delete_
webhook - Delete a webhook subscription
- detect_
duplicates - events_
websocket - exactly_
once_ stats - Exactly-once processing stats
- geo_
query - Geospatial: Query events by location
- geo_
stats - Geospatial index stats
- get_
consumer - GET /api/v1/consumers/{consumer_id} — Get consumer metadata and cursor position
- get_
entity_ snapshot - get_
entity_ state - get_
event_ by_ id - Get a single event by UUID
- 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_
projection_ state_ summary - Get aggregate projection state (all entities)
- get_
replay_ progress - get_
schema - get_
stats - get_
webhook - Get a specific webhook by ID
- graphql_
query - GraphQL: Execute GraphQL queries
- 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_
entities - list_
event_ types - list_
pipelines - list_
projections - List all registered projections
- list_
replays - list_
schema_ versions - list_
snapshots - list_
streams - list_
subjects - list_
webhook_ deliveries - List delivery history for a webhook
- list_
webhooks - List webhooks, optionally filtered by tenant_id
- pause_
projection - Pause a projection
- poll_
consumer_ events - prometheus_
metrics - query_
events - register_
consumer - POST /api/v1/consumers — Register a durable consumer
- register_
pipeline - register_
schema - register_
webhook - Register a new webhook subscription
- remove_
pipeline - reset_
pipeline - reset_
projection - Reset a projection to its initial state
- save_
projection_ state - Save/update projection state for an entity
- schema_
evolution_ history - Schema evolution history for an event type
- schema_
evolution_ schema - Current inferred schema for an event type
- schema_
evolution_ stats - Schema evolution stats
- serve
- set_
compatibility_ mode - start_
projection - Start (resume) a projection
- start_
replay - trigger_
compaction - update_
webhook - Update a webhook subscription
- validate_
event_ schema