org.corfudb.protocols.wireprotocol

Interface ICorfuPayload<T>

All Known Subinterfaces:

ITypedEnum<T>

All Known Implementing Classes:

ClusterState, DataType, DetectorMsg, ExceptionMsg, FailureDetectorMetrics, FailureDetectorMetrics.ConnectivityGraph, FillHoleRequest, HandshakeMsg, HandshakeResponse, IMetadata.LogUnitMetadataType, LayoutBootstrapRequest, LayoutCommittedRequest, LayoutPrepareRequest, LayoutPrepareResponse, LayoutProposeRequest, LayoutProposeResponse, LogData, MultipleReadRequest, NodeConnectivity, NodeRank, NodeState, NodeState.HeartbeatTimestamp, OrchestratorMsg, OrchestratorResponse, RangeWriteMsg, ReadRequest, ReadResponse, SequencerMetrics, SequencerRecoveryMsg, StreamsAddressRequest, StreamsAddressResponse, TailsRequest, TailsResponse, TokenRequest, TokenResponse, TokenType, TrimRequest, TxResolutionInfo, WriteRequest

public interface ICorfuPayload<T>

Created by mwei on 8/1/16.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ICorfuPayload.PayloadConstructor<T>

Field Summary

Fields

Modifier and Type	Field and Description
static ConcurrentHashMap<Class<?>,ICorfuPayload.PayloadConstructor<?>>	constructorMap
static MethodHandles.Lookup	lookup A lookup representing the context we'll use to do lookups.

Method Summary

Modifier and Type	Method and Description
void	doSerialize(io.netty.buffer.ByteBuf buf)
static <K extends Enum<K> & ITypedEnum<K>,V> EnumMap<K,V>	enumMapFromBuffer(io.netty.buffer.ByteBuf buf, Class<K> keyClass, Class<V> objClass) A really simple flat map implementation.
static <T> T	fromBuffer(io.netty.buffer.ByteBuf buf, Class<T> cls) Build payload from Buffer
static <T> T	fromBuffer(io.netty.buffer.ByteBuf buf, com.google.common.reflect.TypeToken<T> token) Build payload from Buffer.
static <V> List<V>	listFromBuffer(io.netty.buffer.ByteBuf buf, Class<V> valueClass) A really simple flat list implementation.
static <K,V> Map<K,V>	mapFromBuffer(io.netty.buffer.ByteBuf buf, Class<K> keyClass, Class<V> valueClass) A really simple flat map implementation.
static <V extends Comparable<V>> com.google.common.collect.Range<V>	rangeFromBuffer(io.netty.buffer.ByteBuf buf, Class<V> valueClass) A really simple flat set implementation.
static <V extends Comparable<V>> com.google.common.collect.RangeSet<V>	rangeSetFromBuffer(io.netty.buffer.ByteBuf buf, Class<V> valueClass) A really simple flat set implementation.
static <T> void	serialize(io.netty.buffer.ByteBuf buffer, T payload) Serialize a payload into a given byte buffer.
static <V> Set<V>	setFromBuffer(io.netty.buffer.ByteBuf buf, Class<V> valueClass) A really simple flat set implementation.

Field Detail

constructorMap

static final ConcurrentHashMap<Class<?>,ICorfuPayload.PayloadConstructor<?>> constructorMap

lookup

static final MethodHandles.Lookup lookup

A lookup representing the context we'll use to do lookups.

Method Detail

fromBuffer

static <T> T fromBuffer(io.netty.buffer.ByteBuf buf,
                        Class<T> cls)

Build payload from Buffer

Type Parameters:

T - The type of the payload.

Parameters:

buf - The buffer to deserialize.

cls - The class of the payload.

Returns:

payload

fromBuffer

static <T> T fromBuffer(io.netty.buffer.ByteBuf buf,
                        com.google.common.reflect.TypeToken<T> token)

Build payload from Buffer.

mapFromBuffer

static <K,V> Map<K,V> mapFromBuffer(io.netty.buffer.ByteBuf buf,
                                    Class<K> keyClass,
                                    Class<V> valueClass)

A really simple flat map implementation. The first entry is the size of the map as an int, and the next entries are each key followed by its value. Maps of maps are currently not supported.

Type Parameters:

K - The type of the keys.

V - The type of the values.

Parameters:

buf - The buffer to deserialize.

keyClass - The class of the keys.

valueClass - The class of the values.

Returns:

Map

setFromBuffer

static <V> Set<V> setFromBuffer(io.netty.buffer.ByteBuf buf,
                                Class<V> valueClass)

A really simple flat set implementation. The first entry is the size of the set as an int, and the next entries are each value.

Type Parameters:

V - The type of the values.

Parameters:

buf - The buffer to deserialize.

valueClass - The class of the values.

Returns:

Set of value types

listFromBuffer

static <V> List<V> listFromBuffer(io.netty.buffer.ByteBuf buf,
                                  Class<V> valueClass)

A really simple flat list implementation. The first entry is the size of the set as an int, and the next entries are each value.

Type Parameters:

V - The type of the values.

Parameters:

buf - The buffer to deserialize.

valueClass - The class of the values.

Returns:

List of values types

rangeSetFromBuffer

static <V extends Comparable<V>> com.google.common.collect.RangeSet<V> rangeSetFromBuffer(io.netty.buffer.ByteBuf buf,
                                                                                          Class<V> valueClass)

A really simple flat set implementation. The first entry is the size of the set as an int, and the next entries are each value.

Type Parameters:

V - The type of the values.

Parameters:

buf - The buffer to deserialize.

valueClass - The class of the values.

Returns:

Set of values type

rangeFromBuffer

static <V extends Comparable<V>> com.google.common.collect.Range<V> rangeFromBuffer(io.netty.buffer.ByteBuf buf,
                                                                                    Class<V> valueClass)

A really simple flat set implementation. The first entry is the size of the set as an int, and the next entries are each value.

Type Parameters:

V - The type of the values.

Parameters:

buf - The buffer to deserialize.

valueClass - The class of the values.

Returns:

Set of values type

enumMapFromBuffer

static <K extends Enum<K> & ITypedEnum<K>,V> EnumMap<K,V> enumMapFromBuffer(io.netty.buffer.ByteBuf buf,
                                                                            Class<K> keyClass,
                                                                            Class<V> objClass)

A really simple flat map implementation. The first entry is the size of the map as an int, and the next entries are each value.

Type Parameters:

K - The type of the keys

V - The type of the values.

Parameters:

buf - The buffer to deserialize.

keyClass - The class of the keys.

objClass - The class of the values.

Returns:

Map for use with enum type keys

serialize

static <T> void serialize(io.netty.buffer.ByteBuf buffer,
                          T payload)

Serialize a payload into a given byte buffer.

Type Parameters:

T - The type of the payload.

Parameters:

payload - The Payload to serialize.

buffer - The buffer to serialize it into.

doSerialize

void doSerialize(io.netty.buffer.ByteBuf buf)