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)

Method Summary

ReplicationStatistics.ChannelState	getChannelState() Gets the current channel state,
String	getInconsistencyReason()
long	getLastConfirmedKeyFromTarget()
long	getLastKeyToReplicate()
long	getNumberOfReplicatedPackets()
ReplicationStatistics.ReplicationOperatingMode	getOperatingMode()
long	getReceiveBytesPerSecond()
long	getReceivedBytes()
long	getRedologRetainedSize()
ReplicationStatistics.ReplicationMode	getReplicationMode()
long	getSendBytesPerPacket()
long	getSendBytesPerSecond()
int	getSendPacketsPerSecond()
long	getSentBytes()
com.gigaspaces.cluster.replication.IReplicationChannel.State	getState() Deprecated. use getChannelState()
String	getTargetMemberName()
boolean	isInconsistent()
void	readExternal(ObjectInput in)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

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)

Method Detail

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