Package org.apache.cassandra.repair.consistent

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

Modifier and Type	Method	Description
protected CoordinatorSession	buildSession(CoordinatorSession.Builder builder)
CoordinatorSession	getSession(TimeUUID sessionId)
void	handleFailSessionMessage(FailSession msg)
void	handleFinalizePromiseMessage(FinalizePromise msg)
void	handlePrepareResponse(PrepareConsistentResponse msg)
void	onSessionStateUpdate(CoordinatorSession session)
CoordinatorSession	registerSession(TimeUUID sessionId, java.util.Set<InetAddressAndPort> participants, boolean isForced)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CoordinatorSessions

public CoordinatorSessions()

Method Detail

buildSession

protected CoordinatorSession buildSession(CoordinatorSession.Builder builder)

registerSession

public CoordinatorSession registerSession(TimeUUID sessionId,
                                          java.util.Set<InetAddressAndPort> participants,
                                          boolean isForced)
                                   throws NoSuchRepairSessionException

Throws:

NoSuchRepairSessionException

getSession

public CoordinatorSession getSession(TimeUUID sessionId)

onSessionStateUpdate

public void onSessionStateUpdate(CoordinatorSession session)

handlePrepareResponse

public void handlePrepareResponse(PrepareConsistentResponse msg)

handleFinalizePromiseMessage

public void handleFinalizePromiseMessage(FinalizePromise msg)

handleFailSessionMessage

public void handleFailSessionMessage(FailSession msg)