GigaSpaces XAP 9.7.2 API

com.j_spaces.core.filters
Class ReplicationStatistics.OutgoingChannel

java.lang.Object
  extended by 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(String targetMemberName, ReplicationStatistics.ReplicationMode replicationMode, ReplicationStatistics.ChannelState channelState, long lastKeyToReplicate, long lastConfirmedKeyFromTarget, int throughPut, long totalNumberOfReplicatedPackets, String inconsistencyReason, long generatedTraffic, long receivedTraffic, long generatedTrafficTP, long receivedTrafficTP, long generatedTrafficPerPacket, long redologRetainedSize, ReplicationStatistics.ReplicationOperatingMode operatingMode, com.gigaspaces.internal.cluster.node.impl.router.ReplicationEndpointDetails targetDetails, com.gigaspaces.management.transport.ConnectionEndpointDetails delegatorDetails)
           
 
Method Summary
 ReplicationStatistics.ChannelState getChannelState()
          Gets the current channel state,
 com.gigaspaces.management.transport.ConnectionEndpointDetails getDelegatorDetails()
           
 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()
 com.gigaspaces.management.transport.ConnectionEndpointDetails getTargetDetails()
           
 String getTargetHostname()
          Deprecated. since 9.5 - Use getTargetDetails().getHostName() instead.
 String getTargetMemberName()
           
 long getTargetPid()
          Deprecated. since 9.5 - Use getTargetDetails().getProcessId() instead.
 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,
                                             long totalNumberOfReplicatedPackets,
                                             String inconsistencyReason,
                                             long generatedTraffic,
                                             long receivedTraffic,
                                             long generatedTrafficTP,
                                             long receivedTrafficTP,
                                             long generatedTrafficPerPacket,
                                             long redologRetainedSize,
                                             ReplicationStatistics.ReplicationOperatingMode operatingMode,
                                             com.gigaspaces.internal.cluster.node.impl.router.ReplicationEndpointDetails targetDetails,
                                             com.gigaspaces.management.transport.ConnectionEndpointDetails delegatorDetails)
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()
Returns:
an approximation of the total number of replicated packets through this channel

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

getTargetHostname

@Deprecated
public String getTargetHostname()
Deprecated. since 9.5 - Use getTargetDetails().getHostName() instead.

Returns:
the channel target hostname
Since:
9.0.1

getTargetPid

@Deprecated
public long getTargetPid()
Deprecated. since 9.5 - Use getTargetDetails().getProcessId() instead.

Returns:
the channel target hosting process id, may be -1 if connection was never established.
Since:
9.0.1

getTargetDetails

public com.gigaspaces.management.transport.ConnectionEndpointDetails getTargetDetails()
Returns:
the channel target connection endpoint details, may be null if connection was never established.
Since:
9.5

getDelegatorDetails

public com.gigaspaces.management.transport.ConnectionEndpointDetails getDelegatorDetails()
Returns:
the channel target delegator connection endpoint details, may be null if there is no delegator and the target is connected directly or a connection was never established.
Since:
9.5

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

GigaSpaces XAP 9.7.2 API

Copyright © GigaSpaces.