Package org.corfudb.protocols.wireprotocol

Interface Summary

Interface	Description
ICorfuPayload<T>	Created by mwei on 8/1/16.
ICorfuPayload.PayloadConstructor<T>
ILogData	An interface to log data entries.
IMetadata	Created by mwei on 9/18/15.
IToken	Represents a token, which is a reservation on the log.
ITypedEnum<T extends Enum<T>>	Created by mwei on 8/9/16.

Class Summary

Class	Description
ClientHandshakeHandler	The ClientHandshakeHandler initiates the handshake upon socket connection.
ClusterState	Records the cluster state of the system.
CorfuMsg	Created by mwei on 9/15/15.
CorfuPayloadMsg<T>	A message type which represents an encapsulated Corfu payload.
DetectorMsg	Trigger sent to the management server with the failures detected.
ExceptionMsg	This message wraps exceptions that are encountered on the server.
FillHoleRequest	Request sent to fill a hole.
HandshakeMsg	Message sent to initiate handshake between client and server.
HandshakeResponse	Response sent by server in the handshake stage.
HandshakeState	Created by amartinezman on 12/20/17.
ILogData.SerializationHandle	This class provides a serialization handle, which manages the lifetime of the serialized copy of this entry.
IMetadata.DataRank
InboundMsgFilterHandler	Represent a Netty handler in charge of applying filters on the inbound Corfu messages in order to transform them.
JSONPayloadMsg<T>	Created by mwei on 7/27/16.
LayoutBootstrapRequest	Request sent to bootstrap the server with a Layout.
LayoutCommittedRequest	If the first two phases (prepare and propose) of paxos have been accepted, the proposer sends a Committed message to commit the proposed Layout.
LayoutMsg	Created by mwei on 12/14/15.
LayoutPrepareRequest	Request in first phase of paxos.
LayoutPrepareResponse	LayoutServer response in phase1 of paxos can be an accept or reject.
LayoutProposeRequest	Request in second phase of Paxos.
LayoutProposeResponse	LayoutServer response in second phase of paxos.
LogData	Created by mwei on 8/15/16.
MsgHandlingFilter	This class is a representation of a transforming filter, it is composed of a filter and a list of transforming functions.
MultipleReadRequest	A request to read multiple addresses.
NettyCorfuMessageDecoder	Created by mwei on 10/1/15.
NettyCorfuMessageEncoder	Created by mwei on 10/1/15.
NodeState	Contains a Node's state: Sequencer state - ready/not_ready.
NodeState.HeartbeatTimestamp	Heartbeat timestamp is a tuple of the heartbeat counter and the epoch.
RangeWriteMsg	A sequence of log entries to write
ReadRequest	Created by mwei on 8/11/16.
ReadResponse	Created by mwei on 8/15/16.
SequencerMetrics	Sequencer metrics for a node.
SequencerRecoveryMsg	Created by rmichoud on 6/20/17.
StreamAddressRange	This class represents a range of addresses for a stream.
StreamsAddressRequest	Represents the request sent to the sequencer to retrieve one or several streams address map.
StreamsAddressResponse	Represents the response sent by the sequencer when streams address maps are requested
TailsRequest	A tail request can be specific to the following types: - Global log tail.
TailsResponse	A container that contains information about the log's stream tails map and max global address written (i.e.
Token	Token returned by the sequencer is a combination of the sequence number and the epoch at which it was acquired.
TokenRequest	A token request is at the heart of the Corfu log protocol.
TokenResponse	Created by mwei on 8/8/16.
TrimRequest	Created by mwei on 8/8/16.
TxResolutionInfo	Created by dmalkhi on 12/26/16.
VersionInfo	Created by mwei on 7/27/16.
WriteRequest	Created by mwei on 8/9/16.

Enum Summary

Enum	Description
ClientHandshakeHandler.ClientHandshakeEvent	Events that the handshaker sends to downstream handlers.
CorfuMsgType	Created by mwei on 8/8/16.
DataType	Created by mwei on 8/16/16.
IMetadata.LogUnitMetadataType
SequencerMetrics.SequencerStatus
TokenType	An enum for distinguishing different response from the sequencer.

Exception Summary

Exception	Description
ExceptionMsg.DeserializationFailedException	Represents an exception which failed deserialization.
ExceptionMsg.SerializationFailedException	Represents an exception which failed serialization.

Annotation Types Summary

Annotation Type	Description
CorfuPayload	Created by mwei on 8/8/16.