com.hazelcast.internal.diagnostics

Class WANPlugin

java.lang.Object

com.hazelcast.internal.diagnostics.DiagnosticsPlugin

com.hazelcast.internal.diagnostics.WANPlugin

public class WANPlugin
extends com.hazelcast.internal.diagnostics.DiagnosticsPlugin

The WANPlugin exposes WAN state to the diagnostics system. Currently it allows inspecting the WanSyncState and LocalWanPublisherStats for each WanReplicationEndpoint. This allows to get an overview of the WAN system, mainly how events are being published. Detailed introspection of the WAN queues is not available.

Field Summary

Fields

Modifier and Type	Field and Description
static com.hazelcast.spi.properties.HazelcastProperty	PERIOD_SECONDS The period in seconds this plugin runs.

Fields inherited from class com.hazelcast.internal.diagnostics.DiagnosticsPlugin

logger

Constructor Summary

Constructors

Constructor and Description
WANPlugin(com.hazelcast.spi.impl.NodeEngineImpl nodeEngine)

Method Summary

Modifier and Type	Method and Description
long	getPeriodMillis()
void	onStart()
void	run(com.hazelcast.internal.diagnostics.DiagnosticsLogWriter writer)

Methods inherited from class java.lang.Object

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

Field Detail

PERIOD_SECONDS

public static final com.hazelcast.spi.properties.HazelcastProperty PERIOD_SECONDS

The period in seconds this plugin runs. If set to 0, the plugin is disabled.

Constructor Detail

WANPlugin

public WANPlugin(com.hazelcast.spi.impl.NodeEngineImpl nodeEngine)

Method Detail

getPeriodMillis

public long getPeriodMillis()

Specified by:

getPeriodMillis in class com.hazelcast.internal.diagnostics.DiagnosticsPlugin

onStart

public void onStart()

Specified by:

onStart in class com.hazelcast.internal.diagnostics.DiagnosticsPlugin

run

public void run(com.hazelcast.internal.diagnostics.DiagnosticsLogWriter writer)

Specified by:

run in class com.hazelcast.internal.diagnostics.DiagnosticsPlugin