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

Class WorkerTtlCheckJob

java.lang.Object

com.fishlib.io.sched.Job

com.fishlib.io.sched.TimedJob

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

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable

public class WorkerTtlCheckJob
extends com.fishlib.io.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(com.fishlib.io.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 com.fishlib.io.sched.TimedJob

append, cancelled, invoke

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 com.fishlib.io.sched.Job

installJob

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