SpecsModelExploreRequirements
SpecsModelExploreRequirements
Real-time event ingestion
Overview
Specification
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