Package io.deephaven.enterprise.etcdclient.presence

Class PresenceKvLeaseHandlerEtcd

java.lang.Object

io.deephaven.enterprise.etcdclient.lease.LeaseHandlerEtcd

io.deephaven.enterprise.etcdclient.presence.PresenceKvLeaseHandlerEtcd

All Implemented Interfaces:

LeaseHandler, PresenceKvLeaseHandler

public class PresenceKvLeaseHandlerEtcd
extends LeaseHandlerEtcd
implements PresenceKvLeaseHandler

An etcd server backed implementation of PresenceLeaseHandler.

Nested Class Summary

Nested classes/interfaces inherited from class io.deephaven.enterprise.etcdclient.lease.LeaseHandlerEtcd

LeaseHandlerEtcd.WithLeaseLostCallback

Nested classes/interfaces inherited from interface io.deephaven.enterprise.etcdclient.presence.PresenceKvLeaseHandler

PresenceKvLeaseHandler.Factory, PresenceKvLeaseHandler.LeaseRecreationListener

Field Summary

Fields

Modifier and Type	Field	Description
static PresenceKvLeaseHandler.Factory	FACTORY

Fields inherited from class io.deephaven.enterprise.etcdclient.lease.LeaseHandlerEtcd

log, logName

Fields inherited from interface io.deephaven.enterprise.etcdclient.lease.LeaseHandler

NULL

Fields inherited from interface io.deephaven.enterprise.etcdclient.presence.PresenceKvLeaseHandler

NULL, NULL_FACTORY

Constructor Summary

Constructors

Constructor	Description
PresenceKvLeaseHandlerEtcd(String who, com.fishlib.io.logger.Logger log, io.deephaven.shadow.jetcd.io.etcd.jetcd.Client client, PresenceKvLeaseHandler.LeaseRecreationListener leaseRecreationListener, int clientTtlSeconds, int leaseTtlSeconds, int leaseRenewSeconds, int leaseRenewRetryDelaySeconds, long leaseKeepaliveTimeoutMillis)

Method Summary

Modifier and Type	Method	Description
void	onPutFailure(Exception e)	A hook for derived classes to react to put failures.
protected void	onRenewalException(Exception e)
protected void	onRenewalFailure()	Hook invoked when we have definitively failed to renew the lease before its TTL elapsed: the lease is lost and this handler is giving up (the renewal timer is not rescheduled afterwards, so this fires at most once per handler).
PresenceKvLeaseHandler.LeaseRecreationListener	setLeaseRecreationListener(PresenceKvLeaseHandler.LeaseRecreationListener leaseRecreationListener)

Methods inherited from class io.deephaven.enterprise.etcdclient.lease.LeaseHandlerEtcd

abort, abort, cancelTimedJob, close, closeWithoutRevokingLease, createLease, deleteKv, ensureNotClosedOrThrow, expectedLeaseExpirationTimeMillis, getLeaseId, isClosed, putKv, putKvConditional, renewLeaseNow

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.enterprise.etcdclient.lease.LeaseHandler

close, closeWithoutRevokingLease, deleteKv, isClosed

Methods inherited from interface io.deephaven.enterprise.etcdclient.presence.PresenceKvLeaseHandler

putKv, putKvConditional

Field Details

FACTORY

public static PresenceKvLeaseHandler.Factory FACTORY

Constructor Details

PresenceKvLeaseHandlerEtcd

public PresenceKvLeaseHandlerEtcd(String who,
 com.fishlib.io.logger.Logger log,
 io.deephaven.shadow.jetcd.io.etcd.jetcd.Client client,
 PresenceKvLeaseHandler.LeaseRecreationListener leaseRecreationListener,
 int clientTtlSeconds,
 int leaseTtlSeconds,
 int leaseRenewSeconds,
 int leaseRenewRetryDelaySeconds,
 long leaseKeepaliveTimeoutMillis)
                           throws ExecutionException,
InterruptedException,
TimeoutException

Throws:

ExecutionException

InterruptedException

TimeoutException

Method Details

onRenewalException

protected void onRenewalException(Exception e)

Overrides:

onRenewalException in class LeaseHandlerEtcd

onRenewalFailure

protected void onRenewalFailure()

Description copied from class: LeaseHandlerEtcd

Hook invoked when we have definitively failed to renew the lease before its TTL elapsed: the lease is lost and this handler is giving up (the renewal timer is not rescheduled afterwards, so this fires at most once per handler).

Specified by:

onRenewalFailure in class LeaseHandlerEtcd

onPutFailure

public void onPutFailure(Exception e)

Description copied from class: LeaseHandlerEtcd

A hook for derived classes to react to put failures. Do nothing (other than logging) by default.

Overrides:

onPutFailure in class LeaseHandlerEtcd

Parameters:

e - The exception that we got on the put attempt.

setLeaseRecreationListener

public PresenceKvLeaseHandler.LeaseRecreationListener setLeaseRecreationListener(PresenceKvLeaseHandler.LeaseRecreationListener leaseRecreationListener)

Specified by:

setLeaseRecreationListener in interface PresenceKvLeaseHandler