org.corfudb.protocols.wireprotocol

Class StreamsAddressRequest

java.lang.Object

org.corfudb.protocols.wireprotocol.StreamsAddressRequest

All Implemented Interfaces:

ICorfuPayload<StreamsAddressRequest>

public class StreamsAddressRequest
extends Object
implements ICorfuPayload<StreamsAddressRequest>

Represents the request sent to the sequencer to retrieve one or several streams address map. Created by annym on 02/06/2019

Nested Class Summary

Nested classes/interfaces inherited from interface org.corfudb.protocols.wireprotocol.ICorfuPayload

ICorfuPayload.PayloadConstructor<T>

Field Summary

Fields

Modifier and Type	Field and Description
static byte	ALL_STREAMS
static byte	STREAMS

Fields inherited from interface org.corfudb.protocols.wireprotocol.ICorfuPayload

constructorMap, lookup

Constructor Summary

Constructors

Constructor and Description
StreamsAddressRequest(Byte reqType)
StreamsAddressRequest(io.netty.buffer.ByteBuf buf) Deserialization Constructor from Bytebuf to StreamsAddressRequest.
StreamsAddressRequest(List<StreamAddressRange> streamsRanges)

Method Summary

Modifier and Type	Method and Description
void	doSerialize(io.netty.buffer.ByteBuf buf)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.corfudb.protocols.wireprotocol.ICorfuPayload

enumMapFromBuffer, fromBuffer, fromBuffer, listFromBuffer, mapFromBuffer, rangeFromBuffer, rangeSetFromBuffer, serialize, setFromBuffer

Field Detail

STREAMS

public static final byte STREAMS

See Also:

Constant Field Values

ALL_STREAMS

public static final byte ALL_STREAMS

See Also:

Constant Field Values

Constructor Detail

StreamsAddressRequest

public StreamsAddressRequest(@NonNull
                             List<StreamAddressRange> streamsRanges)

StreamsAddressRequest

public StreamsAddressRequest(Byte reqType)

StreamsAddressRequest

public StreamsAddressRequest(io.netty.buffer.ByteBuf buf)

Deserialization Constructor from Bytebuf to StreamsAddressRequest.

Parameters:

buf - The buffer to deserialize

Method Detail

doSerialize

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

Specified by:

doSerialize in interface ICorfuPayload<StreamsAddressRequest>