Uses of Interface
org.apache.cassandra.net.RequestCallback
Packages that use RequestCallback
Package
Description
-
Uses of RequestCallback in org.apache.cassandra.net
Subinterfaces of RequestCallback in org.apache.cassandra.netClasses in org.apache.cassandra.net that implement RequestCallbackModifier and TypeClassDescriptionclassA callback specialized for returning a value from a single target; that is, this is for messages that we only send to one recipient.Fields in org.apache.cassandra.net declared as RequestCallbackMethods in org.apache.cassandra.net with parameters of type RequestCallbackModifier and TypeMethodDescriptionvoidRequestCallbacks.addWithExpiration(RequestCallback<?> cb, Message<?> message, InetAddressAndPort to) Register the providedRequestCallback, inferring expiry and id from the providedMessage.voidLatencySubscribers.maybeAdd(RequestCallback cb, InetAddressAndPort address, long latency, TimeUnit unit) Track latency information for the dynamic snitch<REQ,RSP> void MessageDelivery.sendWithCallback(Message<REQ> message, InetAddressAndPort to, RequestCallback<RSP> cb) <REQ,RSP> void MessageDelivery.sendWithCallback(Message<REQ> message, InetAddressAndPort to, RequestCallback<RSP> cb, ConnectionType specifyConnection) voidMessagingService.sendWithCallback(Message message, InetAddressAndPort to, RequestCallback cb) Send a non-mutation message to a given endpoint.voidMessagingService.sendWithCallback(Message message, InetAddressAndPort to, RequestCallback cb, ConnectionType specifyConnection) -
Uses of RequestCallback in org.apache.cassandra.repair.messages
Fields in org.apache.cassandra.repair.messages declared as RequestCallbackModifier and TypeFieldDescriptionstatic final RequestCallback<Object>RepairMessage.NOOP_CALLBACKMethods in org.apache.cassandra.repair.messages with parameters of type RequestCallbackModifier and TypeMethodDescriptionstatic <T> voidRepairMessage.sendMessageWithRetries(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RequestCallback<T> finalCallback) static <T> voidRepairMessage.sendMessageWithRetries(SharedContext ctx, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RequestCallback<T> finalCallback) -
Uses of RequestCallback in org.apache.cassandra.service
Classes in org.apache.cassandra.service that implement RequestCallbackModifier and TypeClassDescriptionclassclassclassThis class blocks for a quorum of responses _in all datacenters_ (CL.EACH_QUORUM).classThis class blocks for a quorum of responses _in the local datacenter only_ (CL.LOCAL_QUORUM).classclassclassHandles blocking writes for ONE, ANY, TWO, THREE, QUORUM, and ALL consistency levels. -
Uses of RequestCallback in org.apache.cassandra.service.paxos
Classes in org.apache.cassandra.service.paxos that implement RequestCallbackModifier and TypeClassDescriptionclassPaxosCommit<OnDone extends Consumer<? super org.apache.cassandra.service.paxos.PaxosCommit.Status>>classPerform one paxos "prepare" attempt, with various optimisations.classNodes that have promised in response to our prepare, may be missing the latestCommit, meaning we cannot be sure the prior round has been committed to the necessary quorum of participants, so that it will be visible to future quorums.classPaxosPropose<OnDone extends Consumer<? super org.apache.cassandra.service.paxos.PaxosPropose.Status>>In waitForNoSideEffect mode, we will not return failure to the caller until we have received a complete set of refusal responses, or at least one accept, indicating (respectively) that we have had no side effect, or that we cannot know if we our proposal produced a side effect.class -
Uses of RequestCallback in org.apache.cassandra.service.paxos.cleanup
Classes in org.apache.cassandra.service.paxos.cleanup that implement RequestCallbackModifier and TypeClassDescriptionclassclassclassclassDetermines the highest ballot we should attempt to repair -
Uses of RequestCallback in org.apache.cassandra.service.paxos.v1
Classes in org.apache.cassandra.service.paxos.v1 that implement RequestCallbackModifier and TypeClassDescriptionclassclassclassProposeCallback has two modes of operation, controlled by the failFast parameter. -
Uses of RequestCallback in org.apache.cassandra.service.reads
Classes in org.apache.cassandra.service.reads that implement RequestCallbackModifier and TypeClassDescriptionclassReadCallback<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E, P>> -
Uses of RequestCallback in org.apache.cassandra.service.reads.repair
Classes in org.apache.cassandra.service.reads.repair that implement RequestCallback