Package akka.cluster

Class ClusterLogMarker

  • public class ClusterLogMarker
extends java.lang.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.

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static LogMarker heartbeatStarvation()
      Marker "akkaHeartbeatStarvation" of log event when scheduled heartbeat was delayed.
      static LogMarker joinFailed()
      Marker "akkaJoinFailed" of log event when node couldn't join seed nodes.
      static LogMarker leaderIncapacitated()
      Marker "akkaClusterLeaderIncapacitated" of log event when leader can't perform its duties.
      static LogMarker leaderRestored()
      Marker "akkaClusterLeaderRestored" of log event when leader can perform its duties again.
      static LogMarker memberChanged​(UniqueAddress node, MemberStatus status)
      Marker "akkaMemberChanged" of log event when a member's status is changed by the leader.
      static LogMarker reachable​(Address node)
      Marker "akkaReachable" of log event when a node is marked as reachable again based no failure detector observation.
      static LogMarker sbrDowning​(akka.cluster.sbr.DowningStrategy.Decision decision)
      Marker "akkaSbrDowning" of log event when Split Brain Resolver has made a downing decision.
      static LogMarker sbrDowningNode​(UniqueAddress node, akka.cluster.sbr.DowningStrategy.Decision decision)
      Marker "akkaSbrDowningNode" of log event when a member is downed by Split Brain Resolver.
      static LogMarker sbrInstability()
      Marker "akkaSbrInstability" of log event when Split Brain Resolver has detected too much instability and will down all nodes.
      static LogMarker sbrLeaseAcquired​(akka.cluster.sbr.DowningStrategy.Decision decision)
      Marker "akkaSbrLeaseAcquired" of log event when Split Brain Resolver has acquired the lease.
      static LogMarker sbrLeaseDenied​(akka.cluster.sbr.DowningStrategy.Decision reverseDecision)
      Marker "akkaSbrLeaseDenied" of log event when Split Brain Resolver has acquired the lease.
      static LogMarker sbrLeaseReleased()
      Marker "akkaSbrLeaseReleased" of log event when Split Brain Resolver has released the lease.
      static LogMarker singletonStarted()
      Marker "akkaClusterSingletonStarted" of log event when Cluster Singleton instance has started.
      static LogMarker singletonTerminated()
      Marker "akkaClusterSingletonTerminated" of log event when Cluster Singleton instance has terminated.
      static LogMarker unreachable​(Address node)
      Marker "akkaUnreachable" 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 Detail

      • ClusterLogMarker

        public ClusterLogMarker()

    • Method Detail

      • unreachable

        public static LogMarker unreachable​(Address node)
        Marker "akkaUnreachable" 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 "akkaRemoteAddress".

      • reachable

        public static LogMarker reachable​(Address node)
        Marker "akkaReachable" 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 "akkaRemoteAddress".

      • heartbeatStarvation

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

      • leaderIncapacitated

        public static LogMarker leaderIncapacitated()
        Marker "akkaClusterLeaderIncapacitated" 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 "akkaClusterLeaderRestored" of log event when leader can perform its duties again.

      • joinFailed

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

      • memberChanged

        public static LogMarker memberChanged​(UniqueAddress node,
                                      MemberStatus status)
        Marker "akkaMemberChanged" 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 "akkaRemoteAddress" and "akkaRemoteAddressUid".
        status - New member status. Included as property "akkaMemberStatus".

      • singletonStarted

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

      • singletonTerminated

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

      • sbrDowning

        public static LogMarker sbrDowning​(akka.cluster.sbr.DowningStrategy.Decision decision)
        Marker "akkaSbrDowning" 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 "akkaSbrDecision".

      • sbrDowningNode

        public static LogMarker sbrDowningNode​(UniqueAddress node,
                                       akka.cluster.sbr.DowningStrategy.Decision decision)
        Marker "akkaSbrDowningNode" 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 "akkaRemoteAddress" and "akkaRemoteAddressUid".
        decision - The downing decision. Included as property "akkaSbrDecision".

      • sbrInstability

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

      • sbrLeaseAcquired

        public static LogMarker sbrLeaseAcquired​(akka.cluster.sbr.DowningStrategy.Decision decision)
        Marker "akkaSbrLeaseAcquired" of log event when Split Brain Resolver has acquired the lease.
        Parameters:
        decision - The downing decision. Included as property "akkaSbrDecision".

      • sbrLeaseDenied

        public static LogMarker sbrLeaseDenied​(akka.cluster.sbr.DowningStrategy.Decision reverseDecision)
        Marker "akkaSbrLeaseDenied" of log event when Split Brain Resolver has acquired the lease.
        Parameters:
        reverseDecision - The (reverse) downing decision. Included as property "akkaSbrDecision".

      • sbrLeaseReleased

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