Core architecture
Built for massive scale. Six core services power telemetry ingestion, health scoring, alerts, and closed-loop operations.
High-Volume Ingestion
Go-based pipeline processes millions of telemetry points per second. Raw frames → decode → Kafka → ClickHouse.
Real-time Health Scoring
Rule-based and ML-ready health models. Daily per-pack scores with bands: Good, Watch, Degraded, Critical.
Closed-Loop Operations
Alerts drive work orders. Maintenance Service auto-creates from alert events. Mechanic-friendly views.
Device & Fleet Service
Single source of truth for tenants, devices, bikes, and battery packs. Resolves device identity for gateways.
Alert Engine
Evaluates rules against telemetry stream. Deduplication: one OPEN alert per bike/type. SSE for real-time Fleet Ops.
Bank-grade Security
Zero-trust, RBAC (ADMIN, OPS, MECHANIC, OEM_ANALYST), tenant isolation. OIDC/OAuth2 with Keycloak.