Class HealthRunner

java.lang.Object

com.kingsrook.qqq.backend.core.health.HealthRunner

All Implemented Interfaces:

AutoCloseable

public class HealthRunner
extends Object
implements AutoCloseable

Slot-leased health execution. Probe threads are bounded even if interruption is ignored. Every worker installs and clears its own automated QContext.

Constructor Summary

Constructors

Constructor	Description
HealthRunner(QInstance qInstance, String podId, Clock clock)	Construction does not schedule work.

Method Summary

Modifier and Type	Method	Description
void	close()	Close transient runners after record actions.
static HealthRunner	getForInstance(QInstance qInstance)	Find the runner started for this instance in this JVM.
HealthCheckOutcome	getLastOutcome(String name)	Last sanitized outcome, including probes made during a storage outage.
Instant	getLastOutcomeAt(String name)	Completion time used by readiness to reject stale cached results.
HealthCheckOutcome	runNow(String checkName)	On-demand uses a unique request id and deliberately ignores enabled.
void	start()	Synchronize definitions before beginning fixed-delay ticks.
void	stop()	Stop scheduling and interrupt probes; daemon threads cannot hold shutdown.
void	tick()	Public deterministic tick.
HealthRunner	withRandom(Random random)	Configure deterministic jitter before starting this runner.

Methods inherited from class java.lang.Object

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

Constructor Details

HealthRunner

public HealthRunner(QInstance qInstance,
 String podId,
 Clock clock)

Construction does not schedule work. Clock and randomness are injectable.

Method Details

withRandom

public HealthRunner withRandom(Random random)

Configure deterministic jitter before starting this runner.

getForInstance

public static HealthRunner getForInstance(QInstance qInstance)

Find the runner started for this instance in this JVM.

getLastOutcome

public HealthCheckOutcome getLastOutcome(String name)

Last sanitized outcome, including probes made during a storage outage.

getLastOutcomeAt

public Instant getLastOutcomeAt(String name)

Completion time used by readiness to reject stale cached results.

start

public void start()
           throws QException

Synchronize definitions before beginning fixed-delay ticks.

Throws:

QException

stop

public void stop()

Stop scheduling and interrupt probes; daemon threads cannot hold shutdown.

close

public void close()

Close transient runners after record actions.

Specified by:

close in interface AutoCloseable

tick

public void tick()

Public deterministic tick. Launch all available probes before awaiting any.

runNow

public HealthCheckOutcome runNow(String checkName)
                          throws QException

On-demand uses a unique request id and deliberately ignores enabled.

Throws:

QException