NodeIDType - FIXME: Incomplete. This class is unusable.public class DynamoReplicaCoordinator<NodeIDType> extends AbstractReplicaCoordinator<NodeIDType>
app, messenger| Constructor and Description |
|---|
DynamoReplicaCoordinator(Replicable app,
NodeIDType myID,
ConsistentNodeConfig<NodeIDType> nodeConfig,
JSONMessenger<NodeIDType> messenger) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
coordinateRequest(Request request,
ExecutedCallback callback)
Start of abstract methods
|
boolean |
createReplicaGroup(java.lang.String serviceName,
int epoch,
java.lang.String state,
java.util.Set<NodeIDType> nodes)
This method should return true if the replica group is successfully
created or one already exists with the same set of nodes.
|
boolean |
deleteReplicaGroup(java.lang.String serviceName,
int epoch)
This method should result in all state corresponding to serviceName being
deleted
|
java.util.Set<NodeIDType> |
getReplicaGroup(java.lang.String serviceName)
This method must return the replica group that was most recently
successfully created for the serviceName using createReplicaGroup.
|
java.util.Set<IntegerPacketType> |
getRequestTypes() |
java.lang.String |
toString() |
callCallback, checkpoint, createReplicaGroup, deleteFinalState, execute, execute, execute, getAppRequestTypes, getARARNodesAsString, getARRCNodesAsString, getCallback, getCoordinatorRequestTypes, getEpoch, getFinalState, getMessenger, getMutualAuthAppRequestTypes, getMyID, getRequest, getRequest, getRequest, getStopRequest, handleIncoming, hasLargeCheckpoints, putInitialState, registerCoordination, restore, sendAllLazy, setCallback, setLargeCheckpoints, setMessenger, setStopCallback, stopclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetMutualAuthRequestTypes, getServerAuthRequestTypespublic DynamoReplicaCoordinator(Replicable app, NodeIDType myID, ConsistentNodeConfig<NodeIDType> nodeConfig, JSONMessenger<NodeIDType> messenger)
app - myID - nodeConfig - messenger - public java.util.Set<IntegerPacketType> getRequestTypes()
public boolean coordinateRequest(Request request, ExecutedCallback callback) throws java.io.IOException, RequestParseException
AbstractReplicaCoordinatorcoordinateRequest in interface ReplicaCoordinator<NodeIDType>coordinateRequest in class AbstractReplicaCoordinator<NodeIDType>java.io.IOExceptionRequestParseExceptionpublic java.util.Set<NodeIDType> getReplicaGroup(java.lang.String serviceName)
ReplicaCoordinatorgetReplicaGroup in interface ReplicaCoordinator<NodeIDType>getReplicaGroup in class AbstractReplicaCoordinator<NodeIDType>serviceName.public java.lang.String toString()
toString in class java.lang.Objectpublic boolean createReplicaGroup(java.lang.String serviceName,
int epoch,
java.lang.String state,
java.util.Set<NodeIDType> nodes)
ReplicaCoordinatorcreateReplicaGroup in interface ReplicaCoordinator<NodeIDType>createReplicaGroup in class AbstractReplicaCoordinator<NodeIDType>public boolean deleteReplicaGroup(java.lang.String serviceName,
int epoch)
ReplicaCoordinatordeleteReplicaGroup in interface ReplicaCoordinator<NodeIDType>deleteReplicaGroup in class AbstractReplicaCoordinator<NodeIDType>