Package org.nuxeo.ecm.core.management.probes

Class ProbeManagerImpl

java.lang.Object

org.nuxeo.ecm.core.management.probes.ProbeManagerImpl

All Implemented Interfaces:

ProbeManager, ProbeRunnerMBean

public class ProbeManagerImpl
extends Object
implements ProbeManager

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEFAULT_HEALTH_CHECK_INTERVAL_SECONDS
static String	DEFAULT_HEALTH_CHECK_INTERVAL_SECONDS_PROPERTY
protected Set<ProbeInfo>	failed
protected Map<String,ProbeInfo>	infosByShortcuts
protected Map<Class<? extends Probe>,ProbeInfo>	infosByTypes
protected static Log	log
protected Map<String,Probe>	probesByShortcuts
protected Map<String,ProbeInfo>	probesForHealthCheck
protected Set<ProbeInfo>	succeed

Constructor Summary

Constructors

Constructor	Description
ProbeManagerImpl()

Method Summary

Modifier and Type	Method	Description
protected Set<String>	doExtractProbesName(Collection<ProbeInfo> runners)
protected static Long	doGetDuration(Date fromDate, Date toDate)
protected void	doRun()
protected void	doRunProbe(ProbeInfo probe)
Collection<ProbeInfo>	getAllProbeInfos()
Collection<ProbeInfo>	getHealthCheckProbes()	List of probes evaluated for a health check
Collection<ProbeInfo>	getInFailureProbeInfos()
Collection<ProbeInfo>	getInSuccessProbeInfos()
HealthCheckResult	getOrRunHealthCheck(String name)	Return the status of the given probe.
HealthCheckResult	getOrRunHealthChecks()	Return the status of all the probes evaluated for a healthCheck.
ProbeInfo	getProbeInfo(Class<? extends Probe> probeClass)
ProbeInfo	getProbeInfo(String name)
Collection<String>	getProbeNames()
int	getProbesCount()
Collection<String>	getProbesInError()
int	getProbesInErrorCount()
Collection<String>	getProbesInSuccess()
int	getProbesInSuccessCount()
protected void	getStatusOrRunProbe(ProbeInfo probe, int refreshSeconds)
void	registerProbe(ProbeDescriptor descriptor)
void	registerProbeForHealthCheck(HealthCheckProbesDescriptor descriptor)	This probe is taken into account for the healthCheck
boolean	runAllProbes()
ProbeInfo	runProbe(String name)
ProbeInfo	runProbe(ProbeInfo probe)
void	unregisterProbe(ProbeDescriptor descriptor)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final Log log

infosByTypes

protected final Map<Class<? extends Probe>,ProbeInfo> infosByTypes

infosByShortcuts

protected final Map<String,ProbeInfo> infosByShortcuts

probesByShortcuts

protected final Map<String,Probe> probesByShortcuts

probesForHealthCheck

protected final Map<String,ProbeInfo> probesForHealthCheck

failed

protected final Set<ProbeInfo> failed

succeed

protected final Set<ProbeInfo> succeed

DEFAULT_HEALTH_CHECK_INTERVAL_SECONDS_PROPERTY

public static final String DEFAULT_HEALTH_CHECK_INTERVAL_SECONDS_PROPERTY

See Also:

Constant Field Values

DEFAULT_HEALTH_CHECK_INTERVAL_SECONDS

public static final String DEFAULT_HEALTH_CHECK_INTERVAL_SECONDS

See Also:

Constant Field Values

Constructor Detail

ProbeManagerImpl

public ProbeManagerImpl()

Method Detail

doExtractProbesName

protected Set<String> doExtractProbesName(Collection<ProbeInfo> runners)

getAllProbeInfos

public Collection<ProbeInfo> getAllProbeInfos()

Specified by:

getAllProbeInfos in interface ProbeManager

getInSuccessProbeInfos

public Collection<ProbeInfo> getInSuccessProbeInfos()

Specified by:

getInSuccessProbeInfos in interface ProbeManager

getInFailureProbeInfos

public Collection<ProbeInfo> getInFailureProbeInfos()

Specified by:

getInFailureProbeInfos in interface ProbeManager

getProbeNames

public Collection<String> getProbeNames()

Specified by:

getProbeNames in interface ProbeRunnerMBean

getProbesCount

public int getProbesCount()

Specified by:

getProbesCount in interface ProbeRunnerMBean

getProbesInError

public Collection<String> getProbesInError()

Specified by:

getProbesInError in interface ProbeRunnerMBean

getProbesInErrorCount

public int getProbesInErrorCount()

Specified by:

getProbesInErrorCount in interface ProbeRunnerMBean

getProbesInSuccess

public Collection<String> getProbesInSuccess()

Specified by:

getProbesInSuccess in interface ProbeRunnerMBean

getProbesInSuccessCount

public int getProbesInSuccessCount()

Specified by:

getProbesInSuccessCount in interface ProbeRunnerMBean

getProbeInfo

public ProbeInfo getProbeInfo(Class<? extends Probe> probeClass)

Specified by:

getProbeInfo in interface ProbeManager

runAllProbes

public boolean runAllProbes()

Specified by:

runAllProbes in interface ProbeRunnerMBean

runProbe

public ProbeInfo runProbe(ProbeInfo probe)

Specified by:

runProbe in interface ProbeManager

runProbe

public ProbeInfo runProbe(String name)

Specified by:

runProbe in interface ProbeManager

getProbeInfo

public ProbeInfo getProbeInfo(String name)

Specified by:

getProbeInfo in interface ProbeManager

registerProbe

public void registerProbe(ProbeDescriptor descriptor)

unregisterProbe

public void unregisterProbe(ProbeDescriptor descriptor)

doRun

protected void doRun()

doGetDuration

protected static Long doGetDuration(Date fromDate,
                                    Date toDate)

doRunProbe

protected void doRunProbe(ProbeInfo probe)

registerProbeForHealthCheck

public void registerProbeForHealthCheck(HealthCheckProbesDescriptor descriptor)

Description copied from interface: ProbeManager

This probe is taken into account for the healthCheck

Specified by:

registerProbeForHealthCheck in interface ProbeManager

getHealthCheckProbes

public Collection<ProbeInfo> getHealthCheckProbes()

Description copied from interface: ProbeManager

List of probes evaluated for a health check

Specified by:

getHealthCheckProbes in interface ProbeManager

getOrRunHealthChecks

public HealthCheckResult getOrRunHealthChecks()

Description copied from interface: ProbeManager

Return the status of all the probes evaluated for a healthCheck. The probes are run if the last run was more than a short while ago

Specified by:

getOrRunHealthChecks in interface ProbeManager

getOrRunHealthCheck

public HealthCheckResult getOrRunHealthCheck(String name)
                                      throws IllegalArgumentException

Description copied from interface: ProbeManager

Return the status of the given probe. The probe is run only if the last run was more than a short while ago

Specified by:

getOrRunHealthCheck in interface ProbeManager

Throws:

IllegalArgumentException

getStatusOrRunProbe

protected void getStatusOrRunProbe(ProbeInfo probe,
                                   int refreshSeconds)