Package org.apache.pekko.cluster

Class ClusterLogMarker

java.lang.Object
org.apache.pekko.cluster.ClusterLogMarker
public class ClusterLogMarker extends Object
This is public with the purpose to document the used markers and properties of log events. No guarantee that it will remain binary compatible, but the marker names and properties are considered public API and will not be changed without notice.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    ClusterLogMarker.Properties$
    INTERNAL API

  • Constructor Summary

    Constructors
    Constructor
    Description
    ClusterLogMarker()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static LogMarker
    heartbeatStarvation()
    Marker "pekkoHeartbeatStarvation" of log event when scheduled heartbeat was delayed.
    static LogMarker
    joinFailed()
    Marker "pekkoJoinFailed" of log event when node couldn't join seed nodes.
    static LogMarker
    leaderIncapacitated()
    Marker "pekkoClusterLeaderIncapacitated" of log event when leader can't perform its duties.
    static LogMarker
    leaderRestored()
    Marker "pekkoClusterLeaderRestored" of log event when leader can perform its duties again.
    static LogMarker
    memberChanged(UniqueAddress node, MemberStatus status)
    Marker "pekkoMemberChanged" of log event when a member's status is changed by the leader.
    static LogMarker
    reachable(Address node)
    Marker "pekkoReachable" of log event when a node is marked as reachable again based no failure detector observation.
    static LogMarker
    sbrDowning(org.apache.pekko.cluster.sbr.DowningStrategy.Decision decision)
    Marker "pekkoSbrDowning" of log event when Split Brain Resolver has made a downing decision.
    static LogMarker
    sbrDowningNode(UniqueAddress node, org.apache.pekko.cluster.sbr.DowningStrategy.Decision decision)
    Marker "pekkoSbrDowningNode" of log event when a member is downed by Split Brain Resolver.
    static LogMarker
    sbrInstability()
    Marker "pekkoSbrInstability" of log event when Split Brain Resolver has detected too much instability and will down all nodes.
    static LogMarker
    sbrLeaseAcquired(org.apache.pekko.cluster.sbr.DowningStrategy.Decision decision)
    Marker "pekkoSbrLeaseAcquired" of log event when Split Brain Resolver has acquired the lease.
    static LogMarker
    sbrLeaseDenied(org.apache.pekko.cluster.sbr.DowningStrategy.Decision reverseDecision)
    Marker "pekkoSbrLeaseDenied" of log event when Split Brain Resolver has acquired the lease.
    static LogMarker
    sbrLeaseReleased()
    Marker "pekkoSbrLeaseReleased" of log event when Split Brain Resolver has released the lease.
    static LogMarker
    singletonStarted()
    Marker "pekkoClusterSingletonStarted" of log event when Cluster Singleton instance has started.
    static LogMarker
    singletonTerminated()
    Marker "pekkoClusterSingletonTerminated" of log event when Cluster Singleton instance has terminated.
    static LogMarker
    unreachable(Address node)
    Marker "pekkoUnreachable" of log event when a node is marked as unreachable based no failure detector observation.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ClusterLogMarker

      public ClusterLogMarker()

  • Method Details

    • unreachable

      public static LogMarker unreachable(Address node)
      Marker "pekkoUnreachable" of log event when a node is marked as unreachable based no failure detector observation.
      Parameters:
      node - The address of the node that is marked as unreachable. Included as property "pekkoRemoteAddress".

    • reachable

      public static LogMarker reachable(Address node)
      Marker "pekkoReachable" of log event when a node is marked as reachable again based no failure detector observation.
      Parameters:
      node - The address of the node that is marked as reachable. Included as property "pekkoRemoteAddress".

    • heartbeatStarvation

      public static LogMarker heartbeatStarvation()
      Marker "pekkoHeartbeatStarvation" of log event when scheduled heartbeat was delayed.

    • leaderIncapacitated

      public static LogMarker leaderIncapacitated()
      Marker "pekkoClusterLeaderIncapacitated" of log event when leader can't perform its duties. Typically because there are unreachable nodes that have not been downed.

    • leaderRestored

      public static LogMarker leaderRestored()
      Marker "pekkoClusterLeaderRestored" of log event when leader can perform its duties again.

    • joinFailed

      public static LogMarker joinFailed()
      Marker "pekkoJoinFailed" of log event when node couldn't join seed nodes.

    • memberChanged

      public static LogMarker memberChanged(UniqueAddress node, MemberStatus status)
      Marker "pekkoMemberChanged" of log event when a member's status is changed by the leader.
      Parameters:
      node - The address of the node that is changed. Included as property "pekkoRemoteAddress" and "pekkoRemoteAddressUid".
      status - New member status. Included as property "pekkoMemberStatus".

    • singletonStarted

      public static LogMarker singletonStarted()
      Marker "pekkoClusterSingletonStarted" of log event when Cluster Singleton instance has started.

    • singletonTerminated

      public static LogMarker singletonTerminated()
      Marker "pekkoClusterSingletonTerminated" of log event when Cluster Singleton instance has terminated.

    • sbrDowning

      public static LogMarker sbrDowning(org.apache.pekko.cluster.sbr.DowningStrategy.Decision decision)
      Marker "pekkoSbrDowning" of log event when Split Brain Resolver has made a downing decision. Followed by ClusterLogMarker.sbrDowningNode for each node that is downed.
      Parameters:
      decision - The downing decision. Included as property "pekkoSbrDecision".

    • sbrDowningNode

      public static LogMarker sbrDowningNode(UniqueAddress node, org.apache.pekko.cluster.sbr.DowningStrategy.Decision decision)
      Marker "pekkoSbrDowningNode" of log event when a member is downed by Split Brain Resolver.
      Parameters:
      node - The address of the node that is downed. Included as property "pekkoRemoteAddress" and "pekkoRemoteAddressUid".
      decision - The downing decision. Included as property "pekkoSbrDecision".

    • sbrInstability

      public static LogMarker sbrInstability()
      Marker "pekkoSbrInstability" of log event when Split Brain Resolver has detected too much instability and will down all nodes.

    • sbrLeaseAcquired

      public static LogMarker sbrLeaseAcquired(org.apache.pekko.cluster.sbr.DowningStrategy.Decision decision)
      Marker "pekkoSbrLeaseAcquired" of log event when Split Brain Resolver has acquired the lease.
      Parameters:
      decision - The downing decision. Included as property "pekkoSbrDecision".

    • sbrLeaseDenied

      public static LogMarker sbrLeaseDenied(org.apache.pekko.cluster.sbr.DowningStrategy.Decision reverseDecision)
      Marker "pekkoSbrLeaseDenied" of log event when Split Brain Resolver has acquired the lease.
      Parameters:
      reverseDecision - The (reverse) downing decision. Included as property "pekkoSbrDecision".

    • sbrLeaseReleased

      public static LogMarker sbrLeaseReleased()
      Marker "pekkoSbrLeaseReleased" of log event when Split Brain Resolver has released the lease.