Workers
All workers share worker-base for RabbitMQ message handling and
the DB access layer, and are built/deployed independently (see each worker's
deploy/docker/Dockerfile).
See the pipelines documentation for the queue topology and message flow between workers (both the per-session ingestion pipeline and the periodic jobs).
| Worker | Description |
|---|---|
| analysis-worker | Runs anomaly detection, consistency and normal behaviour analyses in parallel |
| anomaly-detection-worker | Identifies outlier sessions within a semantic group |
| consistency-worker | Consistency analysis |
| embedding-worker | Processes telemetry sessions with vector embeddings |
| grouping-worker | Quick-grouping of sessions |
| hierarchical-grouping-worker | Hierarchical grouping of sessions |
| intelligence-worker | Executes insight templates from the intelligence catalog |
| mce-worker | Metrics Computation Engine processing |
| norm-worker | OTel span normalization |
| normal-behaviour-worker | Normal behaviour modeling |
| stateful-eval-worker | In-process temporal/stateful metric computation |