Package org.corfudb.infrastructure

Interface Summary

Interface	Description
CorfuServer.BootstrapConfigurer	A functional interface for receiving and configuring a ServerBootstrap.
IDataStore	Key Value data store abstraction that provides persistence for variables that need retain values across node restarts or need to be accessed by multiple modules/threads.
IServerRouter	Created by mwei on 12/13/15.
MonitoringService	MonitoringService implementations run by the management agent.

Class Summary

Class	Description
AbstractServer	Created by mwei on 12/4/15.
BaseServer	Created by mwei on 12/8/15.
BatchProcessor	This class manages access for operations that need ordering while executing against the backing storage.
BatchWriterOperation<T>	This container is used by the logunit to add work to the batch writer.
CorfuMsgHandler	This class implements message handlers for AbstractServer implementations.
CorfuServer	This is the new Corfu server single-process executable.
DataStore	Stores data as JSON.
IDataStore.KvRecord<T>	Key-value meta information class, provides all the information for saving and getting data from a data store
LayoutServer	The layout server serves layouts, which are used by clients to find the Corfu infrastructure.
LogUnitServer	Created by mwei on 12/10/15.
LogUnitServer.LogUnitServerConfig	Log unit server configuration class
ManagementAgent	Instantiates and performs failure detection and handling asynchronously.
ManagementServer	Handles reconfiguration and workflow requests to the Management Server.
NettyServerRouter	The netty server router routes incoming messages to registered roles using the Created by mwei on 12/1/15.
Rank	Tuple to store the rank and clientId for each round in Paxos.
RemoteMonitoringService	Remote Monitoring Service constitutes of failure and healing monitoring and handling.
SequencerServer	This server implements the sequencer functionality of Corfu.
SequencerServer.Config	Sequencer server configuration
SequencerServerCache	Sequencer server cache.
SequencerServerCache.ConflictTxStream	Contains the conflict hash code for a stream ID and conflict param.
ServerContext	Server Context: Contains the common node level DataStore Responsible for Server level EPOCH Should contain common services/utilities that the different Servers in a node require.
ServerHandshakeHandler	The ServerHandshakeHandler waits for the handshake message, validates and sends a response to the client.
ServerThreadFactory
ServerThreadFactory.ExceptionHandler

Enum Summary

Enum	Description
AbstractServer.ServerState	The server state.
BatchWriterOperation.Type
RemoteMonitoringService.DetectorTask

Annotation Types Summary

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