Package akka.remote
Class DefaultFailureDetectorRegistry<A>
- java.lang.Object
-
- akka.remote.DefaultFailureDetectorRegistry<A>
-
- All Implemented Interfaces:
FailureDetectorRegistry<A>
public class DefaultFailureDetectorRegistry<A> extends java.lang.Object implements FailureDetectorRegistry<A>
INTERNAL API Get the underlying FailureDetector for a resource.
-
-
Constructor Summary
Constructors Constructor Description DefaultFailureDetectorRegistry(scala.Function0<FailureDetector> detectorFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.Option<FailureDetector>
failureDetector(A resource)
INTERNAL API Get the underlying FailureDetector for a resource.void
heartbeat(A resource)
Records a heartbeat for a resource.boolean
isAvailable(A resource)
Returns true if the resource is considered to be up and healthy and returns false otherwise.boolean
isMonitoring(A resource)
Returns true if the failure detector has received any heartbeats and started monitoring of the resource.void
remove(A resource)
Removes the heartbeat management for a resource.void
reset()
Removes all resources and any associated failure detector state.
-
-
-
Constructor Detail
-
DefaultFailureDetectorRegistry
public DefaultFailureDetectorRegistry(scala.Function0<FailureDetector> detectorFactory)
-
-
Method Detail
-
failureDetector
public scala.Option<FailureDetector> failureDetector(A resource)
INTERNAL API Get the underlying FailureDetector for a resource.- Parameters:
resource
- (undocumented)- Returns:
- (undocumented)
-
heartbeat
public final void heartbeat(A resource)
Description copied from interface:FailureDetectorRegistry
Records a heartbeat for a resource. If the resource is not yet registered (i.e. this is the first heartbeat) then it is automatically registered.- Specified by:
heartbeat
in interfaceFailureDetectorRegistry<A>
- Parameters:
resource
- (undocumented)
-
isAvailable
public final boolean isAvailable(A resource)
Description copied from interface:FailureDetectorRegistry
Returns true if the resource is considered to be up and healthy and returns false otherwise. For unregistered resources it returns true.- Specified by:
isAvailable
in interfaceFailureDetectorRegistry<A>
- Parameters:
resource
- (undocumented)- Returns:
- (undocumented)
-
isMonitoring
public final boolean isMonitoring(A resource)
Description copied from interface:FailureDetectorRegistry
Returns true if the failure detector has received any heartbeats and started monitoring of the resource.- Specified by:
isMonitoring
in interfaceFailureDetectorRegistry<A>
- Parameters:
resource
- (undocumented)- Returns:
- (undocumented)
-
remove
public final void remove(A resource)
Description copied from interface:FailureDetectorRegistry
Removes the heartbeat management for a resource.- Specified by:
remove
in interfaceFailureDetectorRegistry<A>
- Parameters:
resource
- (undocumented)
-
reset
public final void reset()
Description copied from interface:FailureDetectorRegistry
Removes all resources and any associated failure detector state.- Specified by:
reset
in interfaceFailureDetectorRegistry<A>
-
-