akka.lease.kubernetes

Class KubernetesLease

java.lang.Object

akka.coordination.lease.scaladsl.Lease

akka.lease.kubernetes.KubernetesLease

public class KubernetesLease
extends akka.coordination.lease.scaladsl.Lease

Constructor Summary

Constructors

Constructor and Description
KubernetesLease(akka.actor.ExtendedActorSystem system, java.util.concurrent.atomic.AtomicBoolean leaseTaken, akka.coordination.lease.LeaseSettings settings)
KubernetesLease(akka.coordination.lease.LeaseSettings leaseSettings, akka.actor.ExtendedActorSystem system)

Method Summary

Modifier and Type	Method and Description
scala.concurrent.Future<java.lang.Object>	acquire()
scala.concurrent.Future<java.lang.Object>	acquire(scala.Function1<scala.Option<java.lang.Throwable>,scala.runtime.BoxedUnit> leaseLostCallback)
boolean	checkLease()
static java.lang.String	configPath()
scala.concurrent.Future<java.lang.Object>	release()

Methods inherited from class akka.coordination.lease.scaladsl.Lease

settings

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesLease

public KubernetesLease(akka.actor.ExtendedActorSystem system,
                       java.util.concurrent.atomic.AtomicBoolean leaseTaken,
                       akka.coordination.lease.LeaseSettings settings)

KubernetesLease

public KubernetesLease(akka.coordination.lease.LeaseSettings leaseSettings,
                       akka.actor.ExtendedActorSystem system)

Method Detail

configPath

public static java.lang.String configPath()

checkLease

public boolean checkLease()

Specified by:

checkLease in class akka.coordination.lease.scaladsl.Lease

release

public scala.concurrent.Future<java.lang.Object> release()

Specified by:

release in class akka.coordination.lease.scaladsl.Lease

acquire

public scala.concurrent.Future<java.lang.Object> acquire()

Specified by:

acquire in class akka.coordination.lease.scaladsl.Lease

acquire

public scala.concurrent.Future<java.lang.Object> acquire(scala.Function1<scala.Option<java.lang.Throwable>,scala.runtime.BoxedUnit> leaseLostCallback)

Specified by:

acquire in class akka.coordination.lease.scaladsl.Lease