-
public final class StreamHealthMonitorKt
-
-
Method Summary
Modifier and Type Method Description final static StreamHealthMonitorStreamHealthMonitor(StreamLogger logger, CoroutineScope scope, Long interval, Long livenessThreshold)Creates a new StreamHealthMonitor instance. -
-
Method Detail
-
StreamHealthMonitor
final static StreamHealthMonitor StreamHealthMonitor(StreamLogger logger, CoroutineScope scope, Long interval, Long livenessThreshold)
Creates a new StreamHealthMonitor instance.
- Parameters:
logger- The logger to use for logging.scope- The coroutine scope to use for running the health monitor.interval- The interval between heartbeats in milliseconds.livenessThreshold- The liveness threshold in milliseconds.
-
-
-
-