io.pcp.parfait

Class QuiescentRegistryListener

java.lang.Object

io.pcp.parfait.QuiescentRegistryListener

All Implemented Interfaces:

MonitorableRegistryListener

public class QuiescentRegistryListener
extends java.lang.Object
implements MonitorableRegistryListener

Designed to run code after the MonitorableRegistry has become quiet, in terms of addition of new metrics

Field Summary

Fields

Modifier and Type	Field and Description
private com.google.common.base.Supplier<java.lang.Long>	clock
private long	lastTimeMonitorableAdded
private java.lang.Object	lock
private static org.slf4j.Logger	LOG
private Scheduler	quiescentScheduler

Constructor Summary

Constructors

Constructor and Description
QuiescentRegistryListener(java.lang.Runnable runnable, long quietPeriodInMillis)
QuiescentRegistryListener(java.lang.Runnable runnable, com.google.common.base.Supplier<java.lang.Long> clock, long quietPeriodInMillis, Scheduler scheduler)

Method Summary

Modifier and Type	Method and Description
void	monitorableAdded(Monitorable<?> monitorable)
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

quiescentScheduler

private final Scheduler quiescentScheduler

lastTimeMonitorableAdded

private volatile long lastTimeMonitorableAdded

lock

private final java.lang.Object lock

clock

private final com.google.common.base.Supplier<java.lang.Long> clock

Constructor Detail

QuiescentRegistryListener

public QuiescentRegistryListener(java.lang.Runnable runnable,
                                 long quietPeriodInMillis)

QuiescentRegistryListener

QuiescentRegistryListener(java.lang.Runnable runnable,
                          com.google.common.base.Supplier<java.lang.Long> clock,
                          long quietPeriodInMillis,
                          Scheduler scheduler)

Method Detail

monitorableAdded

public void monitorableAdded(Monitorable<?> monitorable)

Specified by:

monitorableAdded in interface MonitorableRegistryListener

stop

public void stop()