Package com.atlassian.confluence.cluster.hazelcast.monitoring

Class HazelcastClusterMonitoring

java.lang.Object
com.atlassian.diagnostics.internal.InitializingMonitor
com.atlassian.confluence.cluster.hazelcast.monitoring.HazelcastClusterMonitoring
All Implemented Interfaces:
com.atlassian.cluster.monitoring.spi.ClusterMonitoring
@Internal public class HazelcastClusterMonitoring extends com.atlassian.diagnostics.internal.InitializingMonitor implements com.atlassian.cluster.monitoring.spi.ClusterMonitoring
ClusterMonitoring implementation which relies on hazelcast to get information from other nodes
Since:
5.7

  • Field Summary

    Fields inherited from class com.atlassian.diagnostics.internal.InitializingMonitor

    monitor

  • Constructor Summary

    Constructors
    Constructor
    Description
    HazelcastClusterMonitoring(com.hazelcast.core.HazelcastInstance hazelcastInstance, com.atlassian.event.api.EventPublisher eventPublisher)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    enableClustering()
     
    io.atlassian.fugue.Either<com.atlassian.cluster.monitoring.spi.model.MonitoringError,com.atlassian.cluster.monitoring.spi.model.NodeIdentifier>
    getCurrentNode()
     
    @NonNull io.atlassian.fugue.Either<com.atlassian.cluster.monitoring.spi.model.MonitoringError,com.atlassian.cluster.monitoring.spi.model.Table>
    getData(com.atlassian.plugin.ModuleCompleteKey key, com.atlassian.cluster.monitoring.spi.model.NodeIdentifier nodeId)
     
    io.atlassian.fugue.Either<com.atlassian.cluster.monitoring.spi.model.MonitoringError,List<com.atlassian.cluster.monitoring.spi.model.NodeInformation>>
    getNodes()
     
    void
    init(com.atlassian.diagnostics.MonitoringService monitoringService)
     
    boolean
    isAvailable()
     
    boolean
    isClusterSetupEnabled()
     
    boolean
    isDataCenterLicensed()
     
    void
    preDestroy()
     

    Methods inherited from class com.atlassian.diagnostics.internal.InitializingMonitor

    alert, defineIssue, defineIssue

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • HazelcastClusterMonitoring

      public HazelcastClusterMonitoring(com.hazelcast.core.HazelcastInstance hazelcastInstance, com.atlassian.event.api.EventPublisher eventPublisher)

  • Method Details

    • preDestroy

      @PreDestroy public void preDestroy()

    • getCurrentNode

      public io.atlassian.fugue.Either<com.atlassian.cluster.monitoring.spi.model.MonitoringError,com.atlassian.cluster.monitoring.spi.model.NodeIdentifier> getCurrentNode()
      Specified by:
      getCurrentNode in interface com.atlassian.cluster.monitoring.spi.ClusterMonitoring

    • getNodes

      public io.atlassian.fugue.Either<com.atlassian.cluster.monitoring.spi.model.MonitoringError,List<com.atlassian.cluster.monitoring.spi.model.NodeInformation>> getNodes()
      Specified by:
      getNodes in interface com.atlassian.cluster.monitoring.spi.ClusterMonitoring

    • getData

      public @NonNull io.atlassian.fugue.Either<com.atlassian.cluster.monitoring.spi.model.MonitoringError,com.atlassian.cluster.monitoring.spi.model.Table> getData(com.atlassian.plugin.ModuleCompleteKey key, com.atlassian.cluster.monitoring.spi.model.NodeIdentifier nodeId)
      Specified by:
      getData in interface com.atlassian.cluster.monitoring.spi.ClusterMonitoring

    • isAvailable

      public boolean isAvailable()
      Specified by:
      isAvailable in interface com.atlassian.cluster.monitoring.spi.ClusterMonitoring

    • isDataCenterLicensed

      public boolean isDataCenterLicensed()
      Specified by:
      isDataCenterLicensed in interface com.atlassian.cluster.monitoring.spi.ClusterMonitoring

    • enableClustering

      public boolean enableClustering()
      Specified by:
      enableClustering in interface com.atlassian.cluster.monitoring.spi.ClusterMonitoring

    • isClusterSetupEnabled

      public boolean isClusterSetupEnabled()
      Specified by:
      isClusterSetupEnabled in interface com.atlassian.cluster.monitoring.spi.ClusterMonitoring

    • init

      public void init(com.atlassian.diagnostics.MonitoringService monitoringService)
      Specified by:
      init in class com.atlassian.diagnostics.internal.InitializingMonitor