Uses of Class
org.apache.cassandra.repair.messages.RepairMessage
Packages that use RepairMessage
Package
Description
-
Uses of RepairMessage in org.apache.cassandra.repair
Method parameters in org.apache.cassandra.repair with type arguments of type RepairMessageModifier and TypeMethodDescriptionvoidRepairMessageVerbHandler.doVerb(Message<RepairMessage> message) -
Uses of RepairMessage in org.apache.cassandra.repair.consistent
Method parameters in org.apache.cassandra.repair.consistent with type arguments of type RepairMessageModifier and TypeMethodDescriptionvoidLocalSessions.handleFinalizeCommitMessage(Message<? extends RepairMessage> message) Finalizes the repair session, completing it as successful.voidCoordinatorSessions.handleFinalizePromiseMessage(Message<? extends RepairMessage> message) voidLocalSessions.handleFinalizeProposeMessage(Message<? extends RepairMessage> message) voidLocalSessions.handlePrepareMessage(Message<? extends RepairMessage> message) The PrepareConsistentRequest promotes the parent repair session to a consistent incremental session, and isolates the data to be repaired from the rest of the table's data No response is sent to the repair coordinator until the data preparation / isolation has completed successfully.voidCoordinatorSessions.handlePrepareResponse(Message<? extends RepairMessage> msg) protected voidLocalSessions.sendMessage(InetAddressAndPort destination, Message<? extends RepairMessage> message) -
Uses of RepairMessage in org.apache.cassandra.repair.messages
Subclasses of RepairMessage in org.apache.cassandra.repair.messagesModifier and TypeClassDescriptionclassMessage to cleanup repair resources on replica nodes.classclassclassclassclassclassclassclassclassclassclassBody part of SYNC_REQUEST repair message.classclassValidationRequestclassValidationComplete message is sent when validation compaction completed successfully.Methods in org.apache.cassandra.repair.messages with parameters of type RepairMessageModifier and TypeMethodDescriptionstatic voidRepairMessage.sendMessageWithFailureCB(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RepairMessage.RepairFailureCallback failureCallback) static voidRepairMessage.sendMessageWithRetries(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint) static <T> voidRepairMessage.sendMessageWithRetries(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RequestCallback<T> finalCallback) static voidRepairMessage.sendMessageWithRetries(SharedContext ctx, RepairMessage request, Verb verb, InetAddressAndPort endpoint) static <T> voidRepairMessage.sendMessageWithRetries(SharedContext ctx, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RequestCallback<T> finalCallback) Method parameters in org.apache.cassandra.repair.messages with type arguments of type RepairMessageModifier and TypeMethodDescriptionstatic voidRepairMessage.sendAck(SharedContext ctx, Message<? extends RepairMessage> message) -
Uses of RepairMessage in org.apache.cassandra.service
Method parameters in org.apache.cassandra.service with type arguments of type RepairMessageModifier and TypeMethodDescriptionvoidActiveRepairService.handleMessage(Message<? extends RepairMessage> message)