trait FailureDetectorRegistry[A] extends AnyRef
Interface for a registry of Akka failure detectors. New resources are implicitly registered when heartbeat is first called with the resource given as parameter.
type parameter A:
- The type of the key that identifies a resource to be monitored by a failure detector
- Alphabetic
- By Inheritance
- FailureDetectorRegistry
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Abstract Value Members
- 
      
      
      
        
      
    
      
        abstract 
        def
      
      
        heartbeat(resource: A): Unit
      
      
      Records a heartbeat for a resource. 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. 
- 
      
      
      
        
      
    
      
        abstract 
        def
      
      
        isAvailable(resource: A): Boolean
      
      
      Returns true if the resource is considered to be up and healthy and returns false otherwise. Returns true if the resource is considered to be up and healthy and returns false otherwise. For unregistered resources it returns true. 
- 
      
      
      
        
      
    
      
        abstract 
        def
      
      
        isMonitoring(resource: A): Boolean
      
      
      Returns true if the failure detector has received any heartbeats and started monitoring of the resource. 
- 
      
      
      
        
      
    
      
        abstract 
        def
      
      
        remove(resource: A): Unit
      
      
      Removes the heartbeat management for a resource. 
- 
      
      
      
        
      
    
      
        abstract 
        def
      
      
        reset(): Unit
      
      
      Removes all resources and any associated failure detector state. 
Concrete Value Members
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        !=(arg0: Any): Boolean
      
      
      - Definition Classes
- AnyRef → Any
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        ##(): Int
      
      
      - Definition Classes
- AnyRef → Any
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        +(other: String): String
      
      
      - Implicit
- This member is added by an implicit conversion from FailureDetectorRegistry[A] to any2stringadd[FailureDetectorRegistry[A]] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        ->[B](y: B): (FailureDetectorRegistry[A], B)
      
      
      - Implicit
- This member is added by an implicit conversion from FailureDetectorRegistry[A] to ArrowAssoc[FailureDetectorRegistry[A]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        ==(arg0: Any): Boolean
      
      
      - Definition Classes
- AnyRef → Any
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        asInstanceOf[T0]: T0
      
      
      - Definition Classes
- Any
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        clone(): AnyRef
      
      
      - Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        ensuring(cond: (FailureDetectorRegistry[A]) ⇒ Boolean, msg: ⇒ Any): FailureDetectorRegistry[A]
      
      
      - Implicit
- This member is added by an implicit conversion from FailureDetectorRegistry[A] to Ensuring[FailureDetectorRegistry[A]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        ensuring(cond: (FailureDetectorRegistry[A]) ⇒ Boolean): FailureDetectorRegistry[A]
      
      
      - Implicit
- This member is added by an implicit conversion from FailureDetectorRegistry[A] to Ensuring[FailureDetectorRegistry[A]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        ensuring(cond: Boolean, msg: ⇒ Any): FailureDetectorRegistry[A]
      
      
      - Implicit
- This member is added by an implicit conversion from FailureDetectorRegistry[A] to Ensuring[FailureDetectorRegistry[A]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        ensuring(cond: Boolean): FailureDetectorRegistry[A]
      
      
      - Implicit
- This member is added by an implicit conversion from FailureDetectorRegistry[A] to Ensuring[FailureDetectorRegistry[A]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        eq(arg0: AnyRef): Boolean
      
      
      - Definition Classes
- AnyRef
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        equals(arg0: Any): Boolean
      
      
      - Definition Classes
- AnyRef → Any
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        formatted(fmtstr: String): String
      
      
      - Implicit
- This member is added by an implicit conversion from FailureDetectorRegistry[A] to StringFormat[FailureDetectorRegistry[A]] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        getClass(): Class[_]
      
      
      - Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        hashCode(): Int
      
      
      - Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        isInstanceOf[T0]: Boolean
      
      
      - Definition Classes
- Any
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        ne(arg0: AnyRef): Boolean
      
      
      - Definition Classes
- AnyRef
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        notify(): Unit
      
      
      - Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        notifyAll(): Unit
      
      
      - Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        synchronized[T0](arg0: ⇒ T0): T0
      
      
      - Definition Classes
- AnyRef
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        toString(): String
      
      
      - Definition Classes
- AnyRef → Any
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        wait(arg0: Long, arg1: Int): Unit
      
      
      - Definition Classes
- AnyRef
- Annotations
- @throws( ... )
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        wait(arg0: Long): Unit
      
      
      - Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        wait(): Unit
      
      
      - Definition Classes
- AnyRef
- Annotations
- @throws( ... )
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        →[B](y: B): (FailureDetectorRegistry[A], B)
      
      
      - Implicit
- This member is added by an implicit conversion from FailureDetectorRegistry[A] to ArrowAssoc[FailureDetectorRegistry[A]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc