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, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getMutualAuthRequestTypes, getServerAuthRequestTypes
public 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
AbstractReplicaCoordinator
coordinateRequest
in interface ReplicaCoordinator<NodeIDType>
coordinateRequest
in class AbstractReplicaCoordinator<NodeIDType>
java.io.IOException
RequestParseException
public java.util.Set<NodeIDType> getReplicaGroup(java.lang.String serviceName)
ReplicaCoordinator
getReplicaGroup
in interface ReplicaCoordinator<NodeIDType>
getReplicaGroup
in class AbstractReplicaCoordinator<NodeIDType>
serviceName
.public java.lang.String toString()
toString
in class java.lang.Object
public boolean createReplicaGroup(java.lang.String serviceName, int epoch, java.lang.String state, java.util.Set<NodeIDType> nodes)
ReplicaCoordinator
createReplicaGroup
in interface ReplicaCoordinator<NodeIDType>
createReplicaGroup
in class AbstractReplicaCoordinator<NodeIDType>
public boolean deleteReplicaGroup(java.lang.String serviceName, int epoch)
ReplicaCoordinator
deleteReplicaGroup
in interface ReplicaCoordinator<NodeIDType>
deleteReplicaGroup
in class AbstractReplicaCoordinator<NodeIDType>