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 io.deephaven.enterprise.niowrapper.sched.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(io.deephaven.enterprise.niowrapper.sched.Scheduler scheduler, long ttlExpiration, com.fishlib.io.logger.Logger log, Supplier<SafeCloseable> lockAcquire, Supplier<KeepAliveWorker> workerSupplier, Consumer<SafeCloseable> terminationCallback)
void	timedOut()

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()

Specified by:

timedOut in class io.deephaven.enterprise.comm.sched.Job

installJob

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