Package org.apache.pekko.remote

Class DefaultFailureDetectorRegistry<A>

java.lang.Object
org.apache.pekko.remote.DefaultFailureDetectorRegistry<A>
All Implemented Interfaces:
FailureDetectorRegistry<A>
public class DefaultFailureDetectorRegistry<A> extends Object implements FailureDetectorRegistry<A>
A lock-less thread-safe implementation of FailureDetectorRegistry.

param: detectorFactory By-name parameter that returns the failure detector instance to be used by a newly registered resource

  • Constructor Summary

    Constructors
    Constructor
    Description
    DefaultFailureDetectorRegistry(scala.Function0<FailureDetector> detectorFactory)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    final void
    heartbeat(A resource)
    Records a heartbeat for a resource.
    final boolean
    isAvailable(A resource)
    Returns true if the resource is considered to be up and healthy and returns false otherwise.
    final boolean
    isMonitoring(A resource)
    Returns true if the failure detector has received any heartbeats and started monitoring of the resource.
    final void
    remove(A resource)
    Removes the heartbeat management for a resource.
    final void
    reset()
    Removes all resources and any associated failure detector state.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • DefaultFailureDetectorRegistry

      public DefaultFailureDetectorRegistry(scala.Function0<FailureDetector> detectorFactory)

  • Method Details