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

Interface DeliveryFlightRecorder

All Known Implementing Classes:
NoOpDeliveryFlightRecorder$
public interface DeliveryFlightRecorder
INTERNAL API

  • Method Details

    • consumerChangedProducer

      void consumerChangedProducer(String producerId)

    • consumerCreated

      void consumerCreated(ActorPath path)

    • consumerDuplicate

      void consumerDuplicate(String producerId, long expectedSeqNr, long seqNr)

    • consumerMissing

      void consumerMissing(String producerId, long expectedSeqNr, long seqNr)

    • consumerReceived

      void consumerReceived(String producerId, long seqNr)

    • consumerReceivedPreviousInProgress

      void consumerReceivedPreviousInProgress(String producerId, long seqNr, int stashed)

    • consumerReceivedResend

      void consumerReceivedResend(long seqNr)

    • consumerSentRequest

      void consumerSentRequest(String producerId, long requestedSeqNr)

    • consumerStarted

      void consumerStarted(ActorPath path)

    • consumerStashFull

      void consumerStashFull(String producerId, long seqNr)

    • producerCreated

      void producerCreated(String producerId, ActorPath path)

    • producerReceived

      void producerReceived(String producerId, long currentSeqNr)

    • producerReceivedRequest

      void producerReceivedRequest(String producerId, long requestedSeqNr, long confirmedSeqNr)

    • producerReceivedResend

      void producerReceivedResend(String producerId, long fromSeqNr)

    • producerRequestNext

      void producerRequestNext(String producerId, long currentSeqNr, long confirmedSeqNr)

    • producerResentFirst

      void producerResentFirst(String producerId, long firstSeqNr)

    • producerResentFirstUnconfirmed

      void producerResentFirstUnconfirmed(String producerId, long seqNr)

    • producerResentUnconfirmed

      void producerResentUnconfirmed(String producerId, long fromSeqNr, long toSeqNr)

    • producerSent

      void producerSent(String producerId, long seqNr)

    • producerStarted

      void producerStarted(String producerId, ActorPath path)

    • producerWaitingForRequest

      void producerWaitingForRequest(String producerId, long currentSeqNr)