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
-
-
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 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()
-
-
-
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:
getCurrentNode
in 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:
getNodes
in 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:
getData
in interfacecom.atlassian.cluster.monitoring.spi.ClusterMonitoring
-
isAvailable
public boolean isAvailable()
- Specified by:
isAvailable
in interfacecom.atlassian.cluster.monitoring.spi.ClusterMonitoring
-
isDataCenterLicensed
public boolean isDataCenterLicensed()
- Specified by:
isDataCenterLicensed
in interfacecom.atlassian.cluster.monitoring.spi.ClusterMonitoring
-
enableClustering
public boolean enableClustering()
- Specified by:
enableClustering
in interfacecom.atlassian.cluster.monitoring.spi.ClusterMonitoring
-
isClusterSetupEnabled
public boolean isClusterSetupEnabled()
- Specified by:
isClusterSetupEnabled
in interfacecom.atlassian.cluster.monitoring.spi.ClusterMonitoring
-
init
public void init(com.atlassian.diagnostics.MonitoringService monitoringService)
- Specified by:
init
in classcom.atlassian.diagnostics.internal.InitializingMonitor
-
-