org.shoal.ha.cache.impl.command
Class ReplicationFrame<K,V>

java.lang.Object
  org.shoal.ha.cache.impl.command.ReplicationFrame<K,V>

public class ReplicationFrame<K,V>
extends java.lang.Object

Constructor Summary

ReplicationFrame(byte frameCommand, int seqNo, java.lang.String sourceInstanceName)

ReplicationFrame(byte frameCommand, java.lang.String sourceInstanceName)

Method Summary

void	addCommand(Command<K,V> cmd)
java.util.List<Command<K,V>>	getCommands()
byte	getFrameCommand()
int	getMaxOutstandingPacketNumber()
int	getMinOutstandingPacketNumber()
int	getSeqNo()
byte[]	getSerializedData()
java.lang.String	getSourceInstanceName()
java.lang.String	getTargetInstanceName()
int	getWindowLen()
void	setMaxOutstandingPacketNumber(int maxOutstandingPacketNumber)
void	setMinOutstandingPacketNumber(int minOutstandingPacketNumber)
void	setSeqNo(int seqNo)
void	setTargetInstanceName(java.lang.String targetInstanceName)
void	setWindowLen(int windowLen)
static <K,V> ReplicationFrame<K,V>	toReplicationFrame(DataStoreContext<K,V> dsc, ReplicationInputStream ris)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationFrame

public ReplicationFrame(byte frameCommand,
                        int seqNo,
                        java.lang.String sourceInstanceName)

ReplicationFrame

public ReplicationFrame(byte frameCommand,
                        java.lang.String sourceInstanceName)

Method Detail

getFrameCommand

public byte getFrameCommand()

getSourceInstanceName

public java.lang.String getSourceInstanceName()

getTargetInstanceName

public java.lang.String getTargetInstanceName()

setTargetInstanceName

public void setTargetInstanceName(java.lang.String targetInstanceName)

getSeqNo

public int getSeqNo()

setSeqNo

public void setSeqNo(int seqNo)

getWindowLen

public int getWindowLen()

setWindowLen

public void setWindowLen(int windowLen)

getMinOutstandingPacketNumber

public int getMinOutstandingPacketNumber()

setMinOutstandingPacketNumber

public void setMinOutstandingPacketNumber(int minOutstandingPacketNumber)

getMaxOutstandingPacketNumber

public int getMaxOutstandingPacketNumber()

setMaxOutstandingPacketNumber

public void setMaxOutstandingPacketNumber(int maxOutstandingPacketNumber)

addCommand

public void addCommand(Command<K,V> cmd)

getCommands

public java.util.List<Command<K,V>> getCommands()

getSerializedData

public byte[] getSerializedData()

toReplicationFrame

public static <K,V> ReplicationFrame<K,V> toReplicationFrame(DataStoreContext<K,V> dsc,
                                                             ReplicationInputStream ris)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object