Expand description
Opt-in stream instrumentation for operational tooling.
Instrumentation is explicit: ordinary stream blueprints do not carry a registry,
branch, timestamp call, or atomic counter. Calling Source::instrumented inserts
a small counting boundary into that source only. Each materialization registers a
fresh run in a StreamInstrumentationRegistry, and future control-plane tools can
read snapshots from the registry without putting actors on the element path.
Structs§
- Stream
Instrumentation Id - Stable identifier for one instrumented stream materialization.
- Stream
Instrumentation Registry - Cloneable registry handle for instrumented stream materializations.
- Stream
Instrumentation Run - Handle for updating one instrumented materialization.
- Stream
Instrumentation Snapshot - Point-in-time values for one instrumented stream materialization.
Enums§
- Stream
Instrumentation State - The externally visible state of one instrumented stream materialization.