| Package | Description |
|---|---|
| ds.funnel.data.channel | |
| ds.funnel.data.channel.tcp | |
| ds.funnel.data.channel.udp | |
| ds.funnel.data.format | |
| ds.funnel.data.msglink | |
| ds.funnel.data.msglink.protocol3 | |
| ds.funnel.node | |
| ds.funnel.node.compnt | |
| ds.funnel.overlay | |
| ds.funnel.peer | |
| ds.funnel.peer.event | |
| ds.funnel.topic | |
| ds.granules.dataset |
This package contains functionality related to datasets that deployed application instances need to operate on.
|
| ds.granules.exchange |
This package contains classes related to processing exchanges.
|
| ds.granules.interfere.computation | |
| ds.granules.interfere.placement | |
| ds.granules.interfere.prediction | |
| ds.granules.interfere.resource | |
| ds.granules.interfere.streaming | |
| ds.granules.operation |
This package encapsulates functionality related to application instances that will be deployed on the cloud.
|
| ds.granules.results |
Functionality for processing results generated by application instances.
|
| ds.synapse.peer |
| Modifier and Type | Method and Description |
|---|---|
void |
ChannelAddress.marshall(ChannelAddress.ChannelAddressType type,
FormatWriter mFormat)
Write this object to a message output object.
|
ChannelAddress |
ChannelAddress.ChannelAddressType.unmarshall(FormatReader mFormat)
Unmarshall this type from a message input object.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TCPChannelAddr.marshall(FormatWriter mFormat) |
| Constructor and Description |
|---|
TCPChannelAddr(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
UDPChannelAddr.marshall(FormatWriter mFormat) |
| Constructor and Description |
|---|
UDPChannelAddr(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
FormatMarshaller.marshall(FormatWriter mFormat) |
boolean |
FormatReader.readBool() |
byte |
FormatReader.readByte() |
byte[] |
FormatReader.readBytes() |
double |
FormatReader.readDouble() |
<T extends java.lang.Enum<T>> |
FormatReader.readEnum(java.lang.Class<T> type) |
float |
FormatReader.readFloat() |
int |
FormatReader.readInt() |
long |
FormatReader.readLong() |
<T> T |
FormatReader.readObject(FormatUnmarshaller<T> type) |
java.lang.Object |
FormatReader.readObjectMarshalled() |
java.lang.Object |
FormatReader.readObjectSerialized() |
short |
FormatReader.readShort() |
java.lang.String |
FormatReader.readString() |
T |
FormatUnmarshaller.unmarshall(FormatReader mFormat) |
void |
FormatWriter.writeBool(boolean val)
Writes a boolean to the underlying buffer.
|
void |
FormatWriter.writeByte(byte val)
Writes a byte to the underlying buffer.
|
void |
FormatWriter.writeBytes(byte[] val)
Writes a byte array to the underlying buffer.
|
void |
FormatWriter.writeBytesNoCopy(byte[] val)
Write the bytes to the final buffer.
|
void |
FormatWriter.writeDouble(double val)
Writes a double to the underlying buffer.
|
<T extends java.lang.Enum<T>> |
FormatWriter.writeEnum(T val)
Writes an enum to the underlying buffer.
|
void |
FormatWriter.writeFloat(float val)
Writes a float to the underlying buffer.
|
void |
FormatWriter.writeInt(int val)
Writes an integer to the underlying buffer.
|
void |
FormatWriter.writeLong(long val)
Writes a long to the underlying buffer.
|
<T extends FormatMarshaller> |
FormatWriter.writeObject(T val)
Writes an object to the underlying buffer.
|
void |
FormatWriter.writeObjectMarshalled(java.lang.Object val)
Writes an object to the underlying buffer using an object marshaller.
|
void |
FormatWriter.writeObjectSerialized(java.io.Serializable val)
Writes an object to the underlying buffer by serializing it.
|
void |
FormatWriter.writeShort(short val)
Writes a short to the underlying buffer.
|
void |
FormatWriter.writeString(java.lang.String val)
Writes a string to the underlying buffer.
|
| Modifier and Type | Method and Description |
|---|---|
static MessageEvent |
MessageType.getMessage(int inCode,
MessageFormat mInput)
Creates the Message corresponding to a given code.
|
void |
LinkStatisticsImpl.marshall(FormatWriter mFormat) |
void |
LinkStatisticsSnapshotImpl.marshall(FormatWriter mFormat) |
LinkStatistics |
LinkStatisticsSnapshotImpl.unmarshall(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
MessageFormatMarshaller.marshall(FormatWriter mFormat,
java.lang.Object inObj)
Marshall the passed object, writing it to the passed formatter.
|
boolean |
MessageFormat.readBool() |
byte |
MessageFormat.readByte() |
byte[] |
MessageFormat.readBytes() |
double |
MessageFormat.readDouble() |
<T extends java.lang.Enum<T>> |
MessageFormat.readEnum(java.lang.Class<T> type) |
int |
MessageFormat.readInt() |
long |
MessageFormat.readLong() |
<T> T |
MessageFormat.readObject(FormatUnmarshaller<T> type) |
java.lang.Object |
MessageFormat.readObjectMarshalled() |
java.lang.Object |
MessageFormat.readObjectSerialized() |
short |
MessageFormat.readShort() |
java.lang.String |
MessageFormat.readString() |
java.lang.Object |
MessageFormatMarshaller.unmarshall(FormatReader mFormat)
Read a single object using the passed formatter.
|
void |
MessageFormat.writeBool(boolean val) |
void |
MessageFormat.writeByte(byte val) |
void |
MessageFormat.writeBytes(byte[] val) |
void |
MessageFormat.writeBytesNoCopy(byte[] val) |
void |
MessageFormat.writeDouble(double val) |
<T extends java.lang.Enum<T>> |
MessageFormat.writeEnum(T val) |
void |
MessageFormat.writeInt(int val) |
void |
MessageFormat.writeLong(long val) |
<T extends FormatMarshaller> |
MessageFormat.writeObject(T val) |
void |
MessageFormat.writeObjectMarshalled(java.lang.Object val) |
void |
MessageFormat.writeObjectSerialized(java.io.Serializable val) |
void |
MessageFormat.writeShort(short val) |
void |
MessageFormat.writeString(java.lang.String val) |
| Modifier and Type | Method and Description |
|---|---|
NodeDetails |
NodeDetailsType.unmarshall(FormatReader mFormat)
Unmarshall this type from a message input object.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NodeComponentKey.marshall(FormatWriter mFormat) |
NodeComponentKey |
NodeComponentKey.unmarshall(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
OverlayPathImpl.marshall(FormatWriter mFormat) |
OverlayPath |
OverlayPathImpl.unmarshall(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
RouterDetails.marshall(FormatWriter mFormat) |
| Constructor and Description |
|---|
RouterDetails(FormatReader mFormat) |
| Constructor and Description |
|---|
MsgTopicData(MessageFormat inFormat) |
MsgTopicData(java.util.Properties inProps,
byte[] inData) |
MsgTopicData(java.util.Properties inProps,
byte[] inData,
int inSize,
int inOffset,
java.util.List<OverlayPath> inDests) |
| Modifier and Type | Method and Description |
|---|---|
void |
StringTopic.marshall(FormatWriter mFormat) |
Topic |
TopicBase.TopicType.unmarshall(FormatReader mFormat)
Unmarshall this type from a message input object.
|
| Constructor and Description |
|---|
StringTopic(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
StreamDatasetImpl.marshall(FormatWriter mFormat) |
void |
StreamDatasetImplLegacy.marshall(FormatWriter mFormat)
Deprecated.
|
void |
Dataset.DatasetType.marshall(FormatWriter mFormat) |
void |
DatasetCollectionManagement.marshall(FormatWriter mFormat) |
Dataset |
Dataset.DatasetType.unmarshall(FormatReader mFormat) |
| Constructor and Description |
|---|
StreamDatasetImpl(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
Exchange.getBytes()
Retrieve the byte[] representation of the exchange.
|
abstract void |
Exchange.marshallExchangeSpecificElements(FormatWriter mFormat)
This method is utilized by the derived classes to marshall (or serialize)
elements that are specific to the derived class.
|
void |
DeploymentMessage.marshallExchangeSpecificElements(FormatWriter mFormat) |
void |
ResourceDiscovery.marshallExchangeSpecificElements(FormatWriter mFormat) |
void |
ExecutionStatus.marshallExchangeSpecificElements(FormatWriter mFormat) |
void |
Exchange.reconstruct(byte[] marshalledBytes)
Reconstruct the exchange from the byte[] representation.
|
abstract void |
Exchange.unmarshallExchangeSpecificElements(FormatReader mFormat)
This method is utilized by the derived classes to reconstruct elements
that are specific to the derived class.
|
void |
DeploymentMessage.unmarshallExchangeSpecificElements(FormatReader mFormat) |
void |
ResourceDiscovery.unmarshallExchangeSpecificElements(FormatReader mFormat) |
void |
ExecutionStatus.unmarshallExchangeSpecificElements(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
GIComputation.marshall(FormatWriter mFormat) |
void |
CompStreamDescription.marshall(FormatWriter mFormat) |
void |
ComputationDescription.marshall(FormatWriter mFormat) |
ComputationUsage |
ComputationUsage.ComputationUsageType.unmarshall(FormatReader mFormat)
Unmarshall this type from a message input object.
|
void |
GIComputation.unmarshall(FormatReader mFormat) |
CompStreamDescription |
CompStreamDescription.unmarshall(FormatReader mFormat) |
ComputationDescription |
ComputationDescription.unmarshall(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
GIPlacementDetails.marshall(FormatWriter mFormat) |
| Constructor and Description |
|---|
GIPlacementDetails(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
PredictionRing.marshall(FormatWriter mFormat) |
void |
UsageFutureRing.marshall(FormatWriter mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
GIResourceDetails.marshall(FormatWriter mFormat) |
| Constructor and Description |
|---|
GIResourceDetails(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
GIStreamingDetails.marshall(FormatWriter mFormat) |
| Constructor and Description |
|---|
GIStreamingDetails(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
OperationBase.marshall(FormatWriter mFormat) |
void |
MapReduceBase.marshall(FormatWriter mFormat) |
void |
OperationBase.unmarshall(FormatReader mFormat) |
void |
Operation.unmarshall(FormatReader marshalledBytes)
Unmarshall the operation from a set of marshalled bytes.
|
Operation |
Operation.OperationType.unmarshall(FormatReader mFormat) |
void |
MapReduceBase.unmarshall(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
Results |
ResultsFactory.getResults(byte[] marshalledBytes)
Recreate the Results object from a byte[].
|
Results |
ResultsFactory.getResults(FormatReader mFormat)
Recreate the Results object from a byte[].
|
SequencingInfo |
ResultsFactory.getSequencingInfo(FormatReader mFormat)
Creates a sequencing info from a set of bytes.
|
void |
ResultsWidget.marshall(FormatWriter mFormat) |
void |
SequencingWidget.marshall(FormatWriter mFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
SynapseDHTDetails.marshall(FormatWriter mFormat) |
| Constructor and Description |
|---|
SynapseDHTDetails(FormatReader mFormat) |