com.gigaspaces.cluster.replication.async.mirror

Class MirrorOperationsImpl

java.lang.Object

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

com.gigaspaces.cluster.replication.async.mirror.MirrorOperationsImpl

All Implemented Interfaces:

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

public class MirrorOperationsImpl
extends AbstractMirrorOperations
implements MirrorOperations, SmartExternalizable

Since:

7.1.1

Author:

anna

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MirrorOperationsImpl()

Method Summary

Modifier and Type	Method and Description
void	addFailedOperationCount(List<BulkItem> bulkItems)
void	addOperationCount(List<BulkItem> bulkItems)
void	addSuccessfulOperationCount(List<BulkItem> bulkItems)
MirrorOperationStatisticsImpl	getChangeOperationStatistics() Return statistics on change operations
MirrorOperationStatisticsImpl	getRemoveOperationStatistics() Return statistics on remove operations
MirrorOperationStatisticsImpl	getUpdateOperationStatistics() Return statistics on update operations
MirrorOperationStatisticsImpl	getWriteOperationStatistics() Return statistics on write operations
void	readExternal(ObjectInput in)
void	register(MetricRegistrator metricRegistrator)
void	writeExternal(ObjectOutput out)

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

getDiscardedOperationCount, getFailedOperationCount, getInProgressOperationCount, getOperationCount, getSuccessfulOperationCount, toString

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

MirrorOperationsImpl

public MirrorOperationsImpl()

Method Detail

getWriteOperationStatistics

public MirrorOperationStatisticsImpl 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 MirrorOperationStatisticsImpl 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 MirrorOperationStatisticsImpl 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 MirrorOperationStatisticsImpl getChangeOperationStatistics()

Description copied from interface: MirrorOperations

Return statistics on change operations

Specified by:

getChangeOperationStatistics in interface MirrorOperations

addOperationCount

public void addOperationCount(List<BulkItem> bulkItems)

addSuccessfulOperationCount

public void addSuccessfulOperationCount(List<BulkItem> bulkItems)

addFailedOperationCount

public void addFailedOperationCount(List<BulkItem> bulkItems)

register

public void register(MetricRegistrator metricRegistrator)

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