Clarity StreamClarity Stream
Create account
The platform

A data plane built for fleet operations.

Four planes, one product. Each layer is independently scalable, observable, and replayable. Built tenant-first, with cross-tenant insight as a governed primitive — not an afterthought.

Architecture planes

The four planes that make up the Clarity Stream data plane.

Customer plane
  • Connector Agent (outbound)
  • Initial snapshot + CDC
  • Local checkpointing
Edge plane
  • mTLS + device identity
  • Ingestion gateway (HTTP/2 + WS)
  • Per-tenant quotas
Data plane
  • Stream bus partitioned by tenant_id
  • Tenant materializer + typed extras
  • Global aggregator (delta rollups)
  • DLQ + replay + checkpoint store
Storage plane
  • bronze.cdc_events
  • analytics.* tenant read models
  • global_analytics.* (1m/1h)
  • Supabase Postgres + RLS

Data plane features

How ingestion, materialization, and rollups behave end-to-end.

Ingestion

Event-time + ingest-time. Schema-light JSON with typed-extras promotion. Dedup by (tenant, source, key, lsn).

Materialization

Incremental upserts per tenant read model. Watermarks for late events. Idempotent writes by event hash.

Global rollups

Allowlisted keys only. Minute + hour grain. Tenant-attribute breakdowns: plan, industry, region.