Package org.eclipse.ditto.internal.utils.health

Class SingletonStatusReporter

java.lang.Object
org.apache.pekko.actor.AbstractActor
org.apache.pekko.actor.AbstractActorWithTimers
org.eclipse.ditto.internal.utils.health.AbstractHealthCheckingActor
org.eclipse.ditto.internal.utils.health.SingletonStatusReporter
All Implemented Interfaces:
org.apache.pekko.actor.Actor, org.apache.pekko.actor.Timers
public final class SingletonStatusReporter extends AbstractHealthCheckingActor
Actor to report health status for a singleton on and only on the role leader of a cluster.

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.pekko.actor.AbstractActor

    org.apache.pekko.actor.AbstractActor.ActorContext, org.apache.pekko.actor.AbstractActor.Receive

    Nested classes/interfaces inherited from interface org.apache.pekko.actor.Actor

    org.apache.pekko.actor.Actor.emptyBehavior$, org.apache.pekko.actor.Actor.ignoringBehavior$

  • Field Summary

    Fields inherited from class org.eclipse.ditto.internal.utils.health.AbstractHealthCheckingActor

    ACTOR_NAME, log

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.apache.pekko.actor.AbstractActor.Receive
    matchCustomMessages()
    Defines a AbstractActor.Receive for the messages to be handled by the subclass actor.
    static org.apache.pekko.actor.Props
    props(String clusterRole, org.apache.pekko.actor.ActorRef cleanupCoordinatorProxy)
    Create Props actor for this actor.
    protected void
    triggerHealthRetrieval()
    Defines the action of the subclass actor which will be triggered when its health status is requested.

    Methods inherited from class org.eclipse.ditto.internal.utils.health.AbstractHealthCheckingActor

    createReceive, getHealth, updateHealth

    Methods inherited from class org.apache.pekko.actor.AbstractActorWithTimers

    aroundPostStop, aroundPreRestart, aroundReceive, getTimers, org$apache$pekko$actor$Timers$_setter_$org$apache$pekko$actor$Timers$$_timers_$eq, org$apache$pekko$actor$Timers$$_timers, timers

    Methods inherited from class org.apache.pekko.actor.AbstractActor

    aroundPostRestart, aroundPreStart, context, emptyBehavior, getContext, getSelf, getSender, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, postRestart, postStop, preRestart, preRestart, preStart, receive, receiveBuilder, self, sender, supervisorStrategy, unhandled

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.pekko.actor.Actor

    aroundPostRestart, aroundPreStart, context, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

  • Method Details

    • props

      public static org.apache.pekko.actor.Props props(String clusterRole, org.apache.pekko.actor.ActorRef cleanupCoordinatorProxy)
      Create Props actor for this actor.
      Parameters:
      clusterRole - cluster role where the singleton starts.
      cleanupCoordinatorProxy - proxy of the cluster singleton cleanup coordinator.
      Returns:
      Props to report status of the cleanup coordinator.

    • matchCustomMessages

      protected org.apache.pekko.actor.AbstractActor.Receive matchCustomMessages()
      Description copied from class: AbstractHealthCheckingActor
      Defines a AbstractActor.Receive for the messages to be handled by the subclass actor.
      Specified by:
      matchCustomMessages in class AbstractHealthCheckingActor
      Returns:
      the AbstractActor.Receive.

    • triggerHealthRetrieval

      protected void triggerHealthRetrieval()
      Description copied from class: AbstractHealthCheckingActor
      Defines the action of the subclass actor which will be triggered when its health status is requested.
      Specified by:
      triggerHealthRetrieval in class AbstractHealthCheckingActor