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 and Description
HazelcastClusterMonitoring(Supplier<com.hazelcast.core.HazelcastInstance> instanceSupplier, com.atlassian.event.api.EventPublisher eventPublisher)

Method Summary

Modifier and Type	Method and 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 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 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