Packages

o

org.apache.pekko.cluster

ClusterLogMarker

object ClusterLogMarker

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.

Annotations
@ApiMayChange()
Source
ClusterLogMarker.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ClusterLogMarker
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  10. val heartbeatStarvation: LogMarker

    Marker "pekkoHeartbeatStarvation" of log event when scheduled heartbeat was delayed.

  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. val joinFailed: LogMarker

    Marker "pekkoJoinFailed" of log event when node couldn't join seed nodes.

  13. val leaderIncapacitated: LogMarker

    Marker "pekkoClusterLeaderIncapacitated" of log event when leader can't perform its duties.

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

  14. val leaderRestored: LogMarker

    Marker "pekkoClusterLeaderRestored" of log event when leader can perform its duties again.

  15. def memberChanged(node: UniqueAddress, status: MemberStatus): LogMarker

    Marker "pekkoMemberChanged" of log event when a member's status is changed by the leader.

    Marker "pekkoMemberChanged" of log event when a member's status is changed by the leader.

    node

    The address of the node that is changed. Included as property "pekkoRemoteAddress" and "pekkoRemoteAddressUid".

    status

    New member status. Included as property "pekkoMemberStatus".

  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  18. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  19. def reachable(node: Address): LogMarker

    Marker "pekkoReachable" of log event when a node is marked as reachable again based no failure detector observation.

    Marker "pekkoReachable" of log event when a node is marked as reachable again based no failure detector observation.

    node

    The address of the node that is marked as reachable. Included as property "pekkoRemoteAddress".

  20. def sbrDowning(decision: Decision): LogMarker

    Marker "pekkoSbrDowning" of log event when Split Brain Resolver has made a downing 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.

    decision

    The downing decision. Included as property "pekkoSbrDecision".

  21. def sbrDowningNode(node: UniqueAddress, decision: Decision): LogMarker

    Marker "pekkoSbrDowningNode" of log event when a member is downed by Split Brain Resolver.

    Marker "pekkoSbrDowningNode" of log event when a member is downed by Split Brain Resolver.

    node

    The address of the node that is downed. Included as property "pekkoRemoteAddress" and "pekkoRemoteAddressUid".

    decision

    The downing decision. Included as property "pekkoSbrDecision".

  22. val sbrInstability: LogMarker

    Marker "pekkoSbrInstability" of log event when Split Brain Resolver has detected too much instability and will down all nodes.

  23. def sbrLeaseAcquired(decision: Decision): LogMarker

    Marker "pekkoSbrLeaseAcquired" of log event when Split Brain Resolver has acquired the lease.

    Marker "pekkoSbrLeaseAcquired" of log event when Split Brain Resolver has acquired the lease.

    decision

    The downing decision. Included as property "pekkoSbrDecision".

  24. def sbrLeaseDenied(reverseDecision: Decision): LogMarker

    Marker "pekkoSbrLeaseDenied" of log event when Split Brain Resolver has acquired the lease.

    Marker "pekkoSbrLeaseDenied" of log event when Split Brain Resolver has acquired the lease.

    reverseDecision

    The (reverse) downing decision. Included as property "pekkoSbrDecision".

  25. val sbrLeaseReleased: LogMarker

    Marker "pekkoSbrLeaseReleased" of log event when Split Brain Resolver has released the lease.

  26. val singletonStarted: LogMarker

    Marker "pekkoClusterSingletonStarted" of log event when Cluster Singleton instance has started.

  27. val singletonTerminated: LogMarker

    Marker "pekkoClusterSingletonTerminated" of log event when Cluster Singleton instance has terminated.

  28. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  29. def toString(): String
    Definition Classes
    AnyRef → Any
  30. def unreachable(node: Address): LogMarker

    Marker "pekkoUnreachable" of log event when a node is marked as unreachable based no failure detector observation.

    Marker "pekkoUnreachable" of log event when a node is marked as unreachable based no failure detector observation.

    node

    The address of the node that is marked as unreachable. Included as property "pekkoRemoteAddress".

  31. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  32. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  33. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped