Package 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	Description
MirrorStatisticsImpl()

Method Summary

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

MirrorStatisticsImpl

public MirrorStatisticsImpl()

Method Details

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 IReplicationInOperationsStatistics<MirrorOperations>

Specified by:

getAllSourceChannelStatistics in interface MirrorStatistics

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 IReplicationInOperationsStatistics<MirrorOperations>

Specified by:

getSourceChannelStatistics in interface MirrorStatistics

Parameters:

channelName - the name of the source mirror channel. Format : <space-containerName:spaceName>

getWriteOperationStatistics

public MirrorOperationStatistics getWriteOperationStatistics()

Description copied from interface: MirrorOperations

Return statistics on write operations

Specified by:

getWriteOperationStatistics in interface IReplicationInOperations<MirrorOperationStatistics>

Specified by:

getWriteOperationStatistics in interface MirrorOperations

getUpdateOperationStatistics

public MirrorOperationStatistics getUpdateOperationStatistics()

Description copied from interface: MirrorOperations

Return statistics on update operations

Specified by:

getUpdateOperationStatistics in interface IReplicationInOperations<MirrorOperationStatistics>

Specified by:

getUpdateOperationStatistics in interface MirrorOperations

getRemoveOperationStatistics

public MirrorOperationStatistics getRemoveOperationStatistics()

Description copied from interface: MirrorOperations

Return statistics on remove operations

Specified by:

getRemoveOperationStatistics in interface IReplicationInOperations<MirrorOperationStatistics>

Specified by:

getRemoveOperationStatistics in interface MirrorOperations

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