This extends the SourceAndAck trait to have an extra method def processingLatency: F[FiniteDuration].
A SourceAndAck handles providing the source of events, and acking the events once processed. So it is the perfect place to implement a measurement of the processing latency of events currently being processed.
This is an instantaneous snapshot measurement. It is designed to be used as part of a Kubernetes health probe, so a pod can get killed if an event gets "stuck" and during processing.
This extends the
SourceAndAcktrait to have an extra methoddef processingLatency: F[FiniteDuration].A
SourceAndAckhandles providing the source of events, and acking the events once processed. So it is the perfect place to implement a measurement of the processing latency of events currently being processed.This is an instantaneous snapshot measurement. It is designed to be used as part of a Kubernetes health probe, so a pod can get killed if an event gets "stuck" and during processing.