addMeasurement method
Add measurement to the measurements stream.
Implementation
@override
void addMeasurement(Measurement measurement) {
// timestamp this sampling
if (samplingConfiguration is PersistentSamplingConfiguration) {
(samplingConfiguration as PersistentSamplingConfiguration).lastTime =
DateTime.now().toUtc();
// Save the checkpoint once per burst, not once per measurement.
_saveCheckpoint ??= Timer(const Duration(seconds: 1), () {
_saveCheckpoint = null;
deployment?.hasBeenUpdated();
});
}
super.addMeasurement(measurement);
}