public class KubernetesLease
extends akka.coordination.lease.scaladsl.Lease
| 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) |
| 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() |
public KubernetesLease(akka.actor.ExtendedActorSystem system,
java.util.concurrent.atomic.AtomicBoolean leaseTaken,
akka.coordination.lease.LeaseSettings settings)
public KubernetesLease(akka.coordination.lease.LeaseSettings leaseSettings,
akka.actor.ExtendedActorSystem system)
public static java.lang.String configPath()
public boolean checkLease()
checkLease in class akka.coordination.lease.scaladsl.Leasepublic scala.concurrent.Future<java.lang.Object> release()
release in class akka.coordination.lease.scaladsl.Leasepublic scala.concurrent.Future<java.lang.Object> acquire()
acquire in class akka.coordination.lease.scaladsl.Leasepublic scala.concurrent.Future<java.lang.Object> acquire(scala.Function1<scala.Option<java.lang.Throwable>,scala.runtime.BoxedUnit> leaseLostCallback)
acquire in class akka.coordination.lease.scaladsl.Lease