Package org.apache.pekko.actor.typed.internal

Interface DeliveryFlightRecorder

All Known Implementing Classes:

NoOpDeliveryFlightRecorder$

public interface DeliveryFlightRecorder

INTERNAL API

Method Summary

Modifier and Type	Method	Description
void	consumerChangedProducer(java.lang.String producerId)
void	consumerCreated(ActorPath path)
void	consumerDuplicate(java.lang.String producerId, long expectedSeqNr, long seqNr)
void	consumerMissing(java.lang.String producerId, long expectedSeqNr, long seqNr)
void	consumerReceived(java.lang.String producerId, long seqNr)
void	consumerReceivedPreviousInProgress(java.lang.String producerId, long seqNr, int stashed)
void	consumerReceivedResend(long seqNr)
void	consumerSentRequest(java.lang.String producerId, long requestedSeqNr)
void	consumerStarted(ActorPath path)
void	consumerStashFull(java.lang.String producerId, long seqNr)
void	producerCreated(java.lang.String producerId, ActorPath path)
void	producerReceived(java.lang.String producerId, long currentSeqNr)
void	producerReceivedRequest(java.lang.String producerId, long requestedSeqNr, long confirmedSeqNr)
void	producerReceivedResend(java.lang.String producerId, long fromSeqNr)
void	producerRequestNext(java.lang.String producerId, long currentSeqNr, long confirmedSeqNr)
void	producerResentFirst(java.lang.String producerId, long firstSeqNr)
void	producerResentFirstUnconfirmed(java.lang.String producerId, long seqNr)
void	producerResentUnconfirmed(java.lang.String producerId, long fromSeqNr, long toSeqNr)
void	producerSent(java.lang.String producerId, long seqNr)
void	producerStarted(java.lang.String producerId, ActorPath path)
void	producerWaitingForRequest(java.lang.String producerId, long currentSeqNr)

Method Detail

consumerChangedProducer

void consumerChangedProducer(java.lang.String producerId)

consumerCreated

void consumerCreated(ActorPath path)

consumerDuplicate

void consumerDuplicate(java.lang.String producerId,
                       long expectedSeqNr,
                       long seqNr)

consumerMissing

void consumerMissing(java.lang.String producerId,
                     long expectedSeqNr,
                     long seqNr)

consumerReceived

void consumerReceived(java.lang.String producerId,
                      long seqNr)

consumerReceivedPreviousInProgress

void consumerReceivedPreviousInProgress(java.lang.String producerId,
                                        long seqNr,
                                        int stashed)

consumerReceivedResend

void consumerReceivedResend(long seqNr)

consumerSentRequest

void consumerSentRequest(java.lang.String producerId,
                         long requestedSeqNr)

consumerStarted

void consumerStarted(ActorPath path)

consumerStashFull

void consumerStashFull(java.lang.String producerId,
                       long seqNr)

producerCreated

void producerCreated(java.lang.String producerId,
                     ActorPath path)

producerReceived

void producerReceived(java.lang.String producerId,
                      long currentSeqNr)

producerReceivedRequest

void producerReceivedRequest(java.lang.String producerId,
                             long requestedSeqNr,
                             long confirmedSeqNr)

producerReceivedResend

void producerReceivedResend(java.lang.String producerId,
                            long fromSeqNr)

producerRequestNext

void producerRequestNext(java.lang.String producerId,
                         long currentSeqNr,
                         long confirmedSeqNr)

producerResentFirst

void producerResentFirst(java.lang.String producerId,
                         long firstSeqNr)

producerResentFirstUnconfirmed

void producerResentFirstUnconfirmed(java.lang.String producerId,
                                    long seqNr)

producerResentUnconfirmed

void producerResentUnconfirmed(java.lang.String producerId,
                               long fromSeqNr,
                               long toSeqNr)

producerSent

void producerSent(java.lang.String producerId,
                  long seqNr)

producerStarted

void producerStarted(java.lang.String producerId,
                     ActorPath path)

producerWaitingForRequest

void producerWaitingForRequest(java.lang.String producerId,
                               long currentSeqNr)