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.ClusterMonitoringClusterMonitoring implementation which relies on hazelcast to get information from other nodes- Since:
- 5.7
-
-
Constructor Summary
Constructors Constructor Description HazelcastClusterMonitoring(Supplier<com.hazelcast.core.HazelcastInstance> instanceSupplier, com.atlassian.event.api.EventPublisher eventPublisher)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanenableClustering()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()voidinit(com.atlassian.diagnostics.MonitoringService monitoringService)booleanisAvailable()booleanisClusterSetupEnabled()booleanisDataCenterLicensed()voidpreDestroy()
-
-
-
Constructor Detail
-
HazelcastClusterMonitoring
public HazelcastClusterMonitoring(Supplier<com.hazelcast.core.HazelcastInstance> instanceSupplier, com.atlassian.event.api.EventPublisher eventPublisher)
-
-
Method Detail
-
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:
getCurrentNodein interfacecom.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:
getNodesin interfacecom.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:
getDatain interfacecom.atlassian.cluster.monitoring.spi.ClusterMonitoring
-
isAvailable
public boolean isAvailable()
- Specified by:
isAvailablein interfacecom.atlassian.cluster.monitoring.spi.ClusterMonitoring
-
isDataCenterLicensed
public boolean isDataCenterLicensed()
- Specified by:
isDataCenterLicensedin interfacecom.atlassian.cluster.monitoring.spi.ClusterMonitoring
-
enableClustering
public boolean enableClustering()
- Specified by:
enableClusteringin interfacecom.atlassian.cluster.monitoring.spi.ClusterMonitoring
-
isClusterSetupEnabled
public boolean isClusterSetupEnabled()
- Specified by:
isClusterSetupEnabledin interfacecom.atlassian.cluster.monitoring.spi.ClusterMonitoring
-
init
public void init(com.atlassian.diagnostics.MonitoringService monitoringService)
- Specified by:
initin classcom.atlassian.diagnostics.internal.InitializingMonitor
-
-