com.hazelcast.monitor.impl

Class LocalWanPublisherStatsImpl

java.lang.Object

com.hazelcast.monitor.impl.LocalWanPublisherStatsImpl

All Implemented Interfaces:

JsonSerializable, LocalWanPublisherStats

public class LocalWanPublisherStatsImpl
extends Object
implements LocalWanPublisherStats

Constructor Summary

Constructors

Constructor and Description
LocalWanPublisherStatsImpl()

Method Summary

Modifier and Type	Method and Description
void	fromJson(JsonObject json) Extracts the state from the given json object and mutates the state of this object.
Map<String,ConsistencyCheckResult>	getLastConsistencyCheckResults() Returns the last results of the consistency checks, mapped by map name.
Map<String,WanSyncStats>	getLastSyncStats() Returns the last synchronization statistics, mapped by map name.
int	getOutboundQueueSize() Returns the outbound queue size on this member
WanPublisherState	getPublisherState() Returns the current WanPublisherState of this publisher.
Map<String,DistributedServiceWanEventCounters.DistributedObjectWanEventCounters>	getSentCacheEventCounter() Returns the counter for the successfully transfered cache WAN events.
Map<String,DistributedServiceWanEventCounters.DistributedObjectWanEventCounters>	getSentMapEventCounter() Returns the counter for the successfully transfered map WAN events.
long	getTotalPublishedEventCount() Returns the total number of published events from this member
long	getTotalPublishLatency() Returns the total latency of published wan events from this member by millisecond.
void	incrementPublishedEventCount(long latency)
boolean	isConnected() Returns if this member is connected to the Wan publisher
void	setConnected(boolean connected)
void	setLastConsistencyCheckResults(Map<String,ConsistencyCheckResult> lastConsistencyCheckResults)
void	setLastSyncStats(Map<String,WanSyncStats> lastSyncStats)
void	setOutboundQueueSize(int outboundQueueSize)
void	setSentCacheEventCounter(Map<String,DistributedServiceWanEventCounters.DistributedObjectWanEventCounters> sentCacheEventCounter)
void	setSentMapEventCounter(Map<String,DistributedServiceWanEventCounters.DistributedObjectWanEventCounters> sentMapEventCounter)
void	setState(WanPublisherState state)
JsonObject	toJson() Serializes state represented by this object into a JsonObject.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalWanPublisherStatsImpl

public LocalWanPublisherStatsImpl()

Method Detail

isConnected

public boolean isConnected()

Description copied from interface: LocalWanPublisherStats

Returns if this member is connected to the Wan publisher

Specified by:

isConnected in interface LocalWanPublisherStats

Returns:

if this member is connected to the Wan publisher

setConnected

public void setConnected(boolean connected)

getOutboundQueueSize

public int getOutboundQueueSize()

Description copied from interface: LocalWanPublisherStats

Returns the outbound queue size on this member

Specified by:

getOutboundQueueSize in interface LocalWanPublisherStats

Returns:

outbound queue size on this member

setOutboundQueueSize

public void setOutboundQueueSize(int outboundQueueSize)

getPublisherState

public WanPublisherState getPublisherState()

Description copied from interface: LocalWanPublisherStats

Returns the current WanPublisherState of this publisher.

Specified by:

getPublisherState in interface LocalWanPublisherStats

See Also:

WanReplicationService.pause(String, String), WanReplicationService.stop(String, String)

setState

public void setState(WanPublisherState state)

getTotalPublishLatency

public long getTotalPublishLatency()

Description copied from interface: LocalWanPublisherStats

Returns the total latency of published wan events from this member by millisecond.

Specified by:

getTotalPublishLatency in interface LocalWanPublisherStats

Returns:

latency of outbound records from this member by millisecond.

getTotalPublishedEventCount

public long getTotalPublishedEventCount()

Description copied from interface: LocalWanPublisherStats

Returns the total number of published events from this member

Specified by:

getTotalPublishedEventCount in interface LocalWanPublisherStats

Returns:

number of total published events from this member

getSentMapEventCounter

public Map<String,DistributedServiceWanEventCounters.DistributedObjectWanEventCounters> getSentMapEventCounter()

Description copied from interface: LocalWanPublisherStats

Returns the counter for the successfully transfered map WAN events.

Specified by:

getSentMapEventCounter in interface LocalWanPublisherStats

setSentMapEventCounter

public void setSentMapEventCounter(Map<String,DistributedServiceWanEventCounters.DistributedObjectWanEventCounters> sentMapEventCounter)

getSentCacheEventCounter

public Map<String,DistributedServiceWanEventCounters.DistributedObjectWanEventCounters> getSentCacheEventCounter()

Description copied from interface: LocalWanPublisherStats

Returns the counter for the successfully transfered cache WAN events.

Specified by:

getSentCacheEventCounter in interface LocalWanPublisherStats

setSentCacheEventCounter

public void setSentCacheEventCounter(Map<String,DistributedServiceWanEventCounters.DistributedObjectWanEventCounters> sentCacheEventCounter)

setLastConsistencyCheckResults

public void setLastConsistencyCheckResults(Map<String,ConsistencyCheckResult> lastConsistencyCheckResults)

getLastConsistencyCheckResults

public Map<String,ConsistencyCheckResult> getLastConsistencyCheckResults()

Description copied from interface: LocalWanPublisherStats

Returns the last results of the consistency checks, mapped by map name.

Specified by:

getLastConsistencyCheckResults in interface LocalWanPublisherStats

setLastSyncStats

public void setLastSyncStats(Map<String,WanSyncStats> lastSyncStats)

getLastSyncStats

public Map<String,WanSyncStats> getLastSyncStats()

Description copied from interface: LocalWanPublisherStats

Returns the last synchronization statistics, mapped by map name.

Specified by:

getLastSyncStats in interface LocalWanPublisherStats

incrementPublishedEventCount

public void incrementPublishedEventCount(long latency)

toJson

public JsonObject toJson()

Description copied from interface: JsonSerializable

Serializes state represented by this object into a JsonObject.

Specified by:

toJson in interface JsonSerializable

Returns:

the JSON representation of this object

fromJson

public void fromJson(JsonObject json)

Description copied from interface: JsonSerializable

Extracts the state from the given json object and mutates the state of this object.

Specified by:

fromJson in interface JsonSerializable

Parameters:

json - the JSON object carrying state for this object

toString

public String toString()

Overrides:

toString in class Object