com.j_spaces.core.filters
Class ReplicationStatistics.OutgoingChannel
java.lang.Object
com.j_spaces.core.filters.ReplicationStatistics.OutgoingChannel
- All Implemented Interfaces:
- Externalizable, Serializable
- Enclosing class:
- ReplicationStatistics
public static class ReplicationStatistics.OutgoingChannel
- extends Object
- implements Externalizable
Expose outgoing replication channel statistics
- Author:
- eitany
- See Also:
- Serialized Form
Constructor Summary |
ReplicationStatistics.OutgoingChannel()
|
ReplicationStatistics.OutgoingChannel(com.gigaspaces.cluster.replication.IReplicator replicator,
com.gigaspaces.cluster.replication.IReplicationChannel replChannel)
|
ReplicationStatistics.OutgoingChannel(String targetMemberName,
ReplicationStatistics.ReplicationMode replicationMode,
ReplicationStatistics.ChannelState channelState,
long lastKeyToReplicate,
long lastConfirmedKeyFromTarget,
int throughPut,
String inconsistencyReason,
long generatedTraffic,
long receivedTraffic,
long generatedTrafficTP,
long receivedTrafficTP,
long generatedTrafficPerPacket,
long redologRetainedSize,
ReplicationStatistics.ReplicationOperatingMode operatingMode)
|
ReplicationStatistics.OutgoingChannel
public ReplicationStatistics.OutgoingChannel()
ReplicationStatistics.OutgoingChannel
public ReplicationStatistics.OutgoingChannel(String targetMemberName,
ReplicationStatistics.ReplicationMode replicationMode,
ReplicationStatistics.ChannelState channelState,
long lastKeyToReplicate,
long lastConfirmedKeyFromTarget,
int throughPut,
String inconsistencyReason,
long generatedTraffic,
long receivedTraffic,
long generatedTrafficTP,
long receivedTrafficTP,
long generatedTrafficPerPacket,
long redologRetainedSize,
ReplicationStatistics.ReplicationOperatingMode operatingMode)
ReplicationStatistics.OutgoingChannel
public ReplicationStatistics.OutgoingChannel(com.gigaspaces.cluster.replication.IReplicator replicator,
com.gigaspaces.cluster.replication.IReplicationChannel replChannel)
getLastConfirmedKeyFromTarget
public long getLastConfirmedKeyFromTarget()
getTargetMemberName
public String getTargetMemberName()
getState
@Deprecated
public com.gigaspaces.cluster.replication.IReplicationChannel.State getState()
- Deprecated. use
getChannelState()
getChannelState
public ReplicationStatistics.ChannelState getChannelState()
- Gets the current channel state,
- Since:
- 8.0
getLastKeyToReplicate
public long getLastKeyToReplicate()
getReplicationMode
public ReplicationStatistics.ReplicationMode getReplicationMode()
getNumberOfReplicatedPackets
public long getNumberOfReplicatedPackets()
getSendPacketsPerSecond
public int getSendPacketsPerSecond()
- Returns:
- current rate of packet being sent per second.
- Since:
- 8.0
isInconsistent
public boolean isInconsistent()
- Since:
- 8.0
getInconsistencyReason
public String getInconsistencyReason()
- Returns:
- channel inconsistency reason or null if the channel is
consistent
- Since:
- 8.0
getSentBytes
public long getSentBytes()
- Returns:
- total bytes sent (resets during fail-over).
- Since:
- 8.0
getReceivedBytes
public long getReceivedBytes()
- Returns:
- total bytes received (resets during fail-over).
- Since:
- 8.0
getSendBytesPerSecond
public long getSendBytesPerSecond()
- Returns:
- current rate of bytes being sent per second.
- Since:
- 8.0
getReceiveBytesPerSecond
public long getReceiveBytesPerSecond()
- Returns:
- current rate of bytes being received per second.
- Since:
- 8.0
getSendBytesPerPacket
public long getSendBytesPerPacket()
- Returns:
- current rate of bytes being sent per replication packet.
- Since:
- 8.0
getRedologRetainedSize
public long getRedologRetainedSize()
- Returns:
- gets the number of packets that are kept in the redolog for
this channel
- Since:
- 8.0
getOperatingMode
public ReplicationStatistics.ReplicationOperatingMode getOperatingMode()
- Returns:
- the current mode this channel is operation in, a sync channel
can move to async operating mode upon errors and during
reconnection while the accumulated data in the redolog is
being replicated, a reliable async channel can move to async operating mode if currently there
is no active synchronous backup keeping the replication redolog of this target in case of a primary space instance
failure.
- Since:
- 8.0
toString
public String toString()
- Overrides:
toString
in class Object
readExternal
public void readExternal(ObjectInput in)
throws IOException,
ClassNotFoundException
- Specified by:
readExternal
in interface Externalizable
- Throws:
IOException
ClassNotFoundException
writeExternal
public void writeExternal(ObjectOutput out)
throws IOException
- Specified by:
writeExternal
in interface Externalizable
- Throws:
IOException
Copyright © GigaSpaces.