com.gigaspaces.cluster.replication.async.mirror

Class MirrorStatisticsImpl

java.lang.Object

com.gigaspaces.cluster.replication.async.mirror.AbstractMirrorOperations

com.gigaspaces.cluster.replication.async.mirror.MirrorStatisticsImpl

All Implemented Interfaces:

MirrorOperations, MirrorOperationStatistics, MirrorStatistics, IReplicationInOperation, IReplicationInOperations<MirrorOperationStatistics>, IReplicationInOperationsStatistics<MirrorOperations>, SmartExternalizable, Externalizable, Serializable

public class MirrorStatisticsImpl
extends AbstractMirrorOperations
implements MirrorStatistics, SmartExternalizable, IReplicationInOperationsStatistics<MirrorOperations>

Default implementation of the mirror space statistics. Contains the operation statistics for all the cluster operations and also statistcis per channel.

Since:

7.1.1

Author:

anna

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MirrorStatisticsImpl()

Method Summary

Modifier and Type	Method and Description
Map<String,? extends MirrorOperations>	getAllSourceChannelStatistics() Get mirror statistics for all space instances incoming channels to the mirror
MirrorOperationStatistics	getChangeOperationStatistics() Return statistics on change operations
MirrorOperationStatistics	getRemoveOperationStatistics() Return statistics on remove operations
MirrorOperations	getSourceChannelStatistics(String channelName) Get the mirror statistics per specific space instance replication channel that replicates data to the mirror.
MirrorOperationStatistics	getUpdateOperationStatistics() Return statistics on update operations
MirrorOperationStatistics	getWriteOperationStatistics() Return statistics on write operations
void	readExternal(ObjectInput in)
void	setMetricRegistrator(MetricRegistrator metricRegistrator)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class com.gigaspaces.cluster.replication.async.mirror.AbstractMirrorOperations

getDiscardedOperationCount, getFailedOperationCount, getInProgressOperationCount, getOperationCount, getSuccessfulOperationCount

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.cluster.replication.async.mirror.MirrorOperationStatistics

getDiscardedOperationCount, getFailedOperationCount, getInProgressOperationCount, getOperationCount, getSuccessfulOperationCount

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Detail

MirrorStatisticsImpl

public MirrorStatisticsImpl()

Method Detail

toString

public String toString()

Overrides:

toString in class AbstractMirrorOperations

setMetricRegistrator

public void setMetricRegistrator(MetricRegistrator metricRegistrator)

getAllSourceChannelStatistics

public Map<String,? extends MirrorOperations> getAllSourceChannelStatistics()

Description copied from interface: MirrorStatistics

Get mirror statistics for all space instances incoming channels to the mirror

Specified by:

getAllSourceChannelStatistics in interface MirrorStatistics

Specified by:

getAllSourceChannelStatistics in interface IReplicationInOperationsStatistics<MirrorOperations>

getSourceChannelStatistics

public MirrorOperations getSourceChannelStatistics(String channelName)

Description copied from interface: MirrorStatistics

Get the mirror statistics per specific space instance replication channel that replicates data to the mirror. Each space instance has it's own replication channel to the mirror. For example: SpaceInstanceStatistics statistics = spaceInstance.getStatistics(); MirrorStatistics mirrorStat =statistics.getMirrorStatistics(); MirrorBulkStatistics primaryToMirrorStatistics = mirrorStat.getSourceChannelStatistics("mySpace_container1:mySpace"); long bulkCountFromPrimary = primaryToMirrorStatistics.getOperationCount(); long writeCountFromPrimary = primaryToMirrorStatistics.getWriteOperationStatistics().getOperationCount();

Specified by:

getSourceChannelStatistics in interface MirrorStatistics

Specified by:

getSourceChannelStatistics in interface IReplicationInOperationsStatistics<MirrorOperations>

Parameters:

channelName - the name of the source mirror channel. Format :

getWriteOperationStatistics

public MirrorOperationStatistics getWriteOperationStatistics()

Description copied from interface: MirrorOperations

Return statistics on write operations

Specified by:

getWriteOperationStatistics in interface MirrorOperations

Specified by:

getWriteOperationStatistics in interface IReplicationInOperations<MirrorOperationStatistics>

getUpdateOperationStatistics

public MirrorOperationStatistics getUpdateOperationStatistics()

Description copied from interface: MirrorOperations

Return statistics on update operations

Specified by:

getUpdateOperationStatistics in interface MirrorOperations

Specified by:

getUpdateOperationStatistics in interface IReplicationInOperations<MirrorOperationStatistics>

getRemoveOperationStatistics

public MirrorOperationStatistics getRemoveOperationStatistics()

Description copied from interface: MirrorOperations

Return statistics on remove operations

Specified by:

getRemoveOperationStatistics in interface MirrorOperations

Specified by:

getRemoveOperationStatistics in interface IReplicationInOperations<MirrorOperationStatistics>

getChangeOperationStatistics

public MirrorOperationStatistics getChangeOperationStatistics()

Description copied from interface: MirrorOperations

Return statistics on change operations

Specified by:

getChangeOperationStatistics in interface MirrorOperations

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException