SpecsModelExploreRequirements
SpecsModelExploreRequirements
Real-time event ingestion
Overview
Specification
Steps
IDstreaming.realtime-event
DescriptionApplication event flows from the bus to a live dashboard.
Keyrealtime-event
TypeSequence Workflow Diagram
Tags
processing
analytics
Table of contents
  • Specification
  • Real-time event ingestion
  • Steps

Specification

Real-time event ingestion

Application event flows from the bus to a live dashboard.

End-to-end flow

This workflow is documented in specs under Workflows and embedded here as the canonical sequence diagram for the model.

Steps

Workflow steps
NumberSourceDestinationDescription
1Event busKafka consumerDomain event channels.domain.events.subscribe to dest
2Kafka consumerStream pipelineRoute jobs.windowed_metrics.operator
3Stream pipelineWindow aggregatorAggregate window on dest from source
4Window aggregatorQuery engineMaterialize paths./queries.post cache entities.CACHE_ENTRY
5Query engineDashboardPush live paths./dashboards/{dashboardId}.get
Open diagram editor (read-only in guest)