org.apache.sling.hc.core.impl.executor

Class HealthCheckExecutorImpl

java.lang.Object

org.apache.sling.hc.core.impl.executor.HealthCheckExecutorImpl

All Implemented Interfaces:

EventListener, org.apache.sling.hc.api.execution.HealthCheckExecutor, ExtendedHealthCheckExecutor, org.osgi.framework.ServiceListener

@Service(value={org.apache.sling.hc.api.execution.HealthCheckExecutor.class,ExtendedHealthCheckExecutor.class})
public class HealthCheckExecutorImpl
extends Object
implements ExtendedHealthCheckExecutor, org.osgi.framework.ServiceListener

Runs health checks for a given list of tags in parallel.

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROP_LONGRUNNING_FUTURE_THRESHOLD_CRITICAL_MS
static String	PROP_RESULT_CACHE_TTL_MS
static String	PROP_TIMEOUT_MS

Constructor Summary

Constructors

Constructor and Description
HealthCheckExecutorImpl()

Method Summary

Modifier and Type	Method and Description
protected void	activate(Map<String,Object> properties, org.osgi.framework.BundleContext bundleContext)
protected void	deactivate()
List<org.apache.sling.hc.api.execution.HealthCheckExecutionResult>	execute(org.apache.sling.hc.api.execution.HealthCheckExecutionOptions options, String... tags)
List<org.apache.sling.hc.api.execution.HealthCheckExecutionResult>	execute(org.apache.sling.hc.api.execution.HealthCheckSelector selector)
List<org.apache.sling.hc.api.execution.HealthCheckExecutionResult>	execute(org.apache.sling.hc.api.execution.HealthCheckSelector selector, org.apache.sling.hc.api.execution.HealthCheckExecutionOptions options)
org.apache.sling.hc.api.execution.HealthCheckExecutionResult	execute(org.osgi.framework.ServiceReference ref)
List<org.apache.sling.hc.api.execution.HealthCheckExecutionResult>	execute(String... tags)
protected void	modified(Map<String,Object> properties)
void	serviceChanged(org.osgi.framework.ServiceEvent event)
void	setLongRunningFutureThresholdForRedMs(long longRunningFutureThresholdForRedMs)
void	setTimeoutInMs(long timeoutInMs)

Methods inherited from class java.lang.Object

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

Field Detail

PROP_TIMEOUT_MS

public static final String PROP_TIMEOUT_MS

See Also:

Constant Field Values

PROP_LONGRUNNING_FUTURE_THRESHOLD_CRITICAL_MS

public static final String PROP_LONGRUNNING_FUTURE_THRESHOLD_CRITICAL_MS

See Also:

Constant Field Values

PROP_RESULT_CACHE_TTL_MS

public static final String PROP_RESULT_CACHE_TTL_MS

See Also:

Constant Field Values

Constructor Detail

HealthCheckExecutorImpl

public HealthCheckExecutorImpl()

Method Detail

activate

@Activate
protected final void activate(Map<String,Object> properties,
                                        org.osgi.framework.BundleContext bundleContext)

modified

@Modified
protected final void modified(Map<String,Object> properties)

deactivate

@Deactivate
protected final void deactivate()

serviceChanged

public void serviceChanged(org.osgi.framework.ServiceEvent event)

Specified by:

serviceChanged in interface org.osgi.framework.ServiceListener

execute

public List<org.apache.sling.hc.api.execution.HealthCheckExecutionResult> execute(org.apache.sling.hc.api.execution.HealthCheckSelector selector)

Specified by:

execute in interface org.apache.sling.hc.api.execution.HealthCheckExecutor

execute

public List<org.apache.sling.hc.api.execution.HealthCheckExecutionResult> execute(org.apache.sling.hc.api.execution.HealthCheckSelector selector,
                                                                                  org.apache.sling.hc.api.execution.HealthCheckExecutionOptions options)

Specified by:

execute in interface org.apache.sling.hc.api.execution.HealthCheckExecutor

execute

public List<org.apache.sling.hc.api.execution.HealthCheckExecutionResult> execute(String... tags)

Specified by:

execute in interface org.apache.sling.hc.api.execution.HealthCheckExecutor

See Also:

HealthCheckExecutor.execute(String[])

execute

public List<org.apache.sling.hc.api.execution.HealthCheckExecutionResult> execute(org.apache.sling.hc.api.execution.HealthCheckExecutionOptions options,
                                                                                  String... tags)

Specified by:

execute in interface org.apache.sling.hc.api.execution.HealthCheckExecutor

See Also:

HealthCheckExecutor.execute(HealthCheckExecutionOptions, String...)

execute

public org.apache.sling.hc.api.execution.HealthCheckExecutionResult execute(org.osgi.framework.ServiceReference ref)

Specified by:

execute in interface ExtendedHealthCheckExecutor

See Also:

ExtendedHealthCheckExecutor.execute(org.osgi.framework.ServiceReference)

setTimeoutInMs

public void setTimeoutInMs(long timeoutInMs)

setLongRunningFutureThresholdForRedMs

public void setLongRunningFutureThresholdForRedMs(long longRunningFutureThresholdForRedMs)