Package com.illumon.iris.db.tables.remotequery.keepalive

Class WorkerTtlCheckJob

java.lang.Object

io.deephaven.enterprise.comm.sched.Job

io.deephaven.enterprise.niowrapper.sched.TimedJob

com.illumon.iris.db.tables.remotequery.keepalive.WorkerTtlCheckJob

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable

public class WorkerTtlCheckJob
extends TimedJob

A timed job that examines a worker for liveness. If the worker has an expired TTL, then terminate it using the supplied callback.

Method Summary

Modifier and Type	Method	Description
static WorkerTtlCheckJob	installJob(Scheduler scheduler, long ttlExpiration, com.fishlib.io.logger.Logger log, Supplier<SafeCloseable> lockAcquire, Supplier<KeepAliveWorker> workerSupplier, Consumer<SafeCloseable> terminationCallback)
void	timedOut()	This method is invoked if the job times out.

Methods inherited from class io.deephaven.enterprise.niowrapper.sched.TimedJob

append, cancelled, invoke

Methods inherited from class io.deephaven.enterprise.comm.sched.Job

getStateFor, makeStateFor

Methods inherited from class java.lang.Object

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

Method Details

timedOut

public void timedOut()

Description copied from class: Job

This method is invoked if the job times out.

Specified by:

timedOut in class Job

installJob

public static WorkerTtlCheckJob installJob(Scheduler scheduler,
 long ttlExpiration,
 com.fishlib.io.logger.Logger log,
 Supplier<SafeCloseable> lockAcquire,
 Supplier<KeepAliveWorker> workerSupplier,
 Consumer<SafeCloseable> terminationCallback)