akka.lease.kubernetes

Class LeaseActor

java.lang.Object

akka.lease.kubernetes.LeaseActor

All Implemented Interfaces:

akka.actor.Actor, akka.actor.ActorLogging, akka.actor.FSM<LeaseActor.State,LeaseActor.Data>, akka.actor.LoggingFSM<LeaseActor.State,LeaseActor.Data>, akka.routing.Listeners

public class LeaseActor
extends java.lang.Object
implements akka.actor.LoggingFSM<LeaseActor.State,LeaseActor.Data>

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LeaseActor.Acquire
static class	LeaseActor.Acquire$
static interface	LeaseActor.Command
static interface	LeaseActor.Data
static class	LeaseActor.Granted$
static class	LeaseActor.GrantedVersion
static class	LeaseActor.GrantedVersion$
static class	LeaseActor.Granting$
static class	LeaseActor.Idle$
static class	LeaseActor.InvalidRequest
static class	LeaseActor.InvalidRequest$
static class	LeaseActor.LeaseAcquired$
static class	LeaseActor.LeaseCleared
static class	LeaseActor.LeaseCleared$
static class	LeaseActor.LeaseReleased$
static class	LeaseActor.LeaseTaken$
static class	LeaseActor.OperationInProgress
static class	LeaseActor.OperationInProgress$
static class	LeaseActor.PendingRead$
static class	LeaseActor.PendingReadData
static class	LeaseActor.PendingReadData$
static class	LeaseActor.ReadRequired$
static class	LeaseActor.Release
static class	LeaseActor.Release$
static class	LeaseActor.Releasing$
static interface	LeaseActor.ReplyRequired
static interface	LeaseActor.Response
static interface	LeaseActor.State

Nested classes/interfaces inherited from interface akka.actor.FSM

akka.actor.FSM.$minus$greater$, akka.actor.FSM.CurrentState<S>, akka.actor.FSM.CurrentState$, akka.actor.FSM.Event<D>, akka.actor.FSM.Event$, akka.actor.FSM.Failure, akka.actor.FSM.Failure$, akka.actor.FSM.LogEntry<S,D>, akka.actor.FSM.LogEntry$, akka.actor.FSM.Normal$, akka.actor.FSM.NullFunction$, akka.actor.FSM.Reason, akka.actor.FSM.Shutdown$, akka.actor.FSM.SilentState<S,D>, akka.actor.FSM.State$, akka.actor.FSM.StateTimeout$, akka.actor.FSM.StopEvent<S,D>, akka.actor.FSM.StopEvent$, akka.actor.FSM.SubscribeTransitionCallBack, akka.actor.FSM.SubscribeTransitionCallBack$, akka.actor.FSM.TimeoutMarker, akka.actor.FSM.TimeoutMarker$, akka.actor.FSM.Timer, akka.actor.FSM.Timer$, akka.actor.FSM.TransformHelper, akka.actor.FSM.Transition<S>, akka.actor.FSM.Transition$, akka.actor.FSM.UnsubscribeTransitionCallBack, akka.actor.FSM.UnsubscribeTransitionCallBack$

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
LeaseActor(KubernetesApi k8sApi, akka.coordination.lease.LeaseSettings settings, java.util.concurrent.atomic.AtomicBoolean granted)

Method Summary

Modifier and Type	Method and Description
akka.actor.FSM.$minus$greater$	$minus$greater()
protected void	akka$actor$Actor$_setter_$context_$eq(akka.actor.ActorContext x$1)
protected void	akka$actor$Actor$_setter_$self_$eq(akka.actor.ActorRef x$1)
protected void	akka$actor$FSM$_setter_$Event_$eq(akka.actor.FSM.Event$ x$1)
protected void	akka$actor$FSM$_setter_$StateTimeout_$eq(akka.actor.FSM.StateTimeout$ x$1)
protected void	akka$actor$FSM$_setter_$StopEvent_$eq(akka.actor.FSM.StopEvent$ x$1)
protected void	akka$actor$LoggingFSM$_setter_$debugEvent_$eq(boolean x$1)
protected void	akka$routing$Listeners$_setter_$listeners_$eq(java.util.Set<akka.actor.ActorRef> x$1)
akka.actor.ActorContext	context()
boolean	debugEvent()
akka.actor.FSM.Event$	Event()
protected java.util.Set<akka.actor.ActorRef>	listeners()
static akka.actor.Props	props(KubernetesApi k8sApi, akka.coordination.lease.LeaseSettings settings, java.util.concurrent.atomic.AtomicBoolean granted)
akka.actor.ActorRef	self()
akka.actor.FSM.StateTimeout$	StateTimeout()
akka.actor.FSM.StopEvent$	StopEvent()

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.actor.LoggingFSM

$init$, akka$actor$LoggingFSM$_setter_$akka$actor$LoggingFSM$$events_$eq, akka$actor$LoggingFSM$_setter_$akka$actor$LoggingFSM$$states_$eq, akka$actor$LoggingFSM$$events, akka$actor$LoggingFSM$$full_$eq, akka$actor$LoggingFSM$$full, akka$actor$LoggingFSM$$pos_$eq, akka$actor$LoggingFSM$$pos, akka$actor$LoggingFSM$$states, getLog, logDepth, processEvent

Methods inherited from interface akka.actor.FSM

$init$, $u2192, akka$actor$FSM$_setter_$$minus$greater_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$handleEventDefault_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$stateFunctions_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$stateTimeouts_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$timerGen_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$timers_$eq, akka$actor$FSM$$currentState_$eq, akka$actor$FSM$$currentState, akka$actor$FSM$$generation_$eq, akka$actor$FSM$$generation, akka$actor$FSM$$handleEvent_$eq, akka$actor$FSM$$handleEvent, akka$actor$FSM$$handleEventDefault, akka$actor$FSM$$nextState_$eq, akka$actor$FSM$$nextState, akka$actor$FSM$$processMsg, akka$actor$FSM$$stateFunctions, akka$actor$FSM$$stateTimeouts, akka$actor$FSM$$terminateEvent_$eq, akka$actor$FSM$$terminateEvent, akka$actor$FSM$$timeoutFuture_$eq, akka$actor$FSM$$timeoutFuture, akka$actor$FSM$$timerGen, akka$actor$FSM$$timers, akka$actor$FSM$$transitionEvent_$eq, akka$actor$FSM$$transitionEvent, applyState, cancelTimer, goto, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextStateData, onTermination, onTransition, postStop, receive, setStateTimeout, setTimer, setTimer$default$4, startWith, startWith$default$3, stateData, stateName, stay, stop, stop, stop, total2pf, transform, when, when$default$2, whenUnhandled

Methods inherited from interface akka.actor.Actor

$init$, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, noSender, postRestart, preRestart, preStart, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.routing.Listeners

$init$, gossip, gossip$default$2, listenerManagement

Methods inherited from interface akka.actor.ActorLogging

$init$, akka$actor$ActorLogging$$_log_$eq, akka$actor$ActorLogging$$_log, log

Constructor Detail

LeaseActor

public LeaseActor(KubernetesApi k8sApi,
                  akka.coordination.lease.LeaseSettings settings,
                  java.util.concurrent.atomic.AtomicBoolean granted)

Method Detail

props

public static akka.actor.Props props(KubernetesApi k8sApi,
                                     akka.coordination.lease.LeaseSettings settings,
                                     java.util.concurrent.atomic.AtomicBoolean granted)

debugEvent

public boolean debugEvent()

Specified by:

debugEvent in interface akka.actor.FSM<LeaseActor.State,LeaseActor.Data>

Specified by:

debugEvent in interface akka.actor.LoggingFSM<LeaseActor.State,LeaseActor.Data>

akka$actor$LoggingFSM$_setter_$debugEvent_$eq

protected void akka$actor$LoggingFSM$_setter_$debugEvent_$eq(boolean x$1)

Specified by:

akka$actor$LoggingFSM$_setter_$debugEvent_$eq in interface akka.actor.LoggingFSM<LeaseActor.State,LeaseActor.Data>

Event

public akka.actor.FSM.Event$ Event()

Specified by:

Event in interface akka.actor.FSM<LeaseActor.State,LeaseActor.Data>

StopEvent

public akka.actor.FSM.StopEvent$ StopEvent()

Specified by:

StopEvent in interface akka.actor.FSM<LeaseActor.State,LeaseActor.Data>

$minus$greater

public akka.actor.FSM.$minus$greater$ $minus$greater()

Specified by:

$minus$greater in interface akka.actor.FSM<LeaseActor.State,LeaseActor.Data>

StateTimeout

public akka.actor.FSM.StateTimeout$ StateTimeout()

Specified by:

StateTimeout in interface akka.actor.FSM<LeaseActor.State,LeaseActor.Data>

akka$actor$FSM$_setter_$Event_$eq

protected void akka$actor$FSM$_setter_$Event_$eq(akka.actor.FSM.Event$ x$1)

Specified by:

akka$actor$FSM$_setter_$Event_$eq in interface akka.actor.FSM<LeaseActor.State,LeaseActor.Data>

akka$actor$FSM$_setter_$StopEvent_$eq

protected void akka$actor$FSM$_setter_$StopEvent_$eq(akka.actor.FSM.StopEvent$ x$1)

Specified by:

akka$actor$FSM$_setter_$StopEvent_$eq in interface akka.actor.FSM<LeaseActor.State,LeaseActor.Data>

akka$actor$FSM$_setter_$StateTimeout_$eq

protected void akka$actor$FSM$_setter_$StateTimeout_$eq(akka.actor.FSM.StateTimeout$ x$1)

Specified by:

akka$actor$FSM$_setter_$StateTimeout_$eq in interface akka.actor.FSM<LeaseActor.State,LeaseActor.Data>

listeners

protected java.util.Set<akka.actor.ActorRef> listeners()

Specified by:

listeners in interface akka.routing.Listeners

akka$routing$Listeners$_setter_$listeners_$eq

protected void akka$routing$Listeners$_setter_$listeners_$eq(java.util.Set<akka.actor.ActorRef> x$1)

Specified by:

akka$routing$Listeners$_setter_$listeners_$eq in interface akka.routing.Listeners

context

public akka.actor.ActorContext context()

Specified by:

context in interface akka.actor.Actor

self

public final akka.actor.ActorRef self()

Specified by:

self in interface akka.actor.Actor

akka$actor$Actor$_setter_$context_$eq

protected void akka$actor$Actor$_setter_$context_$eq(akka.actor.ActorContext x$1)

Specified by:

akka$actor$Actor$_setter_$context_$eq in interface akka.actor.Actor

akka$actor$Actor$_setter_$self_$eq

protected final void akka$actor$Actor$_setter_$self_$eq(akka.actor.ActorRef x$1)

Specified by:

akka$actor$Actor$_setter_$self_$eq in interface akka.actor.Actor