Class CoordinatorSessions
- java.lang.Object
-
- org.apache.cassandra.repair.consistent.CoordinatorSessions
-
public class CoordinatorSessions extends java.lang.Object
Container for all consistent repair sessions a node is coordinating
-
-
Constructor Summary
Constructors Constructor Description CoordinatorSessions()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected CoordinatorSession
buildSession(CoordinatorSession.Builder builder)
CoordinatorSession
getSession(java.util.UUID sessionId)
void
handleFailSessionMessage(FailSession msg)
void
handleFinalizePromiseMessage(FinalizePromise msg)
void
handlePrepareResponse(PrepareConsistentResponse msg)
CoordinatorSession
registerSession(java.util.UUID sessionId, java.util.Set<InetAddressAndPort> participants, boolean isForced)
-
-
-
Method Detail
-
buildSession
protected CoordinatorSession buildSession(CoordinatorSession.Builder builder)
-
registerSession
public CoordinatorSession registerSession(java.util.UUID sessionId, java.util.Set<InetAddressAndPort> participants, boolean isForced)
-
getSession
public CoordinatorSession getSession(java.util.UUID sessionId)
-
handlePrepareResponse
public void handlePrepareResponse(PrepareConsistentResponse msg)
-
handleFinalizePromiseMessage
public void handleFinalizePromiseMessage(FinalizePromise msg)
-
handleFailSessionMessage
public void handleFailSessionMessage(FailSession msg)
-
-