Package org.apache.pekko.remote.artery

Interface RemotingFlightRecorder

All Superinterfaces:
Extension
All Known Implementing Classes:
NoOpRemotingFlightRecorder$
public interface RemotingFlightRecorder extends Extension
INTERNAL API

  • Method Details

    • transportMediaDriverStarted

      void transportMediaDriverStarted(String directoryName)

    • transportStarted

      void transportStarted()

    • transportAeronErrorLogStarted

      void transportAeronErrorLogStarted()

    • transportTaskRunnerStarted

      void transportTaskRunnerStarted()

    • transportUniqueAddressSet

      void transportUniqueAddressSet(UniqueAddress uniqueAddress)

    • transportMaterializerStarted

      void transportMaterializerStarted()

    • transportStartupFinished

      void transportStartupFinished()

    • transportKillSwitchPulled

      void transportKillSwitchPulled()

    • transportStopped

      void transportStopped()

    • transportAeronErrorLogTaskStopped

      void transportAeronErrorLogTaskStopped()

    • transportMediaFileDeleted

      void transportMediaFileDeleted()

    • transportSendQueueOverflow

      void transportSendQueueOverflow(int queueIndex)

    • transportStopIdleOutbound

      void transportStopIdleOutbound(Address remoteAddress, int queueIndex)

    • transportQuarantined

      void transportQuarantined(Address remoteAddress, long uid)

    • transportRemoveQuarantined

      void transportRemoveQuarantined(Address remoteAddress)

    • transportRestartOutbound

      void transportRestartOutbound(Address remoteAddress, String streamName)

    • transportRestartInbound

      void transportRestartInbound(UniqueAddress remoteAddress, String streamName)

    • aeronSinkStarted

      void aeronSinkStarted(String channel, int streamId)

    • aeronSinkTaskRunnerRemoved

      void aeronSinkTaskRunnerRemoved(String channel, int streamId)

    • aeronSinkPublicationClosed

      void aeronSinkPublicationClosed(String channel, int streamId)

    • aeronSinkPublicationClosedUnexpectedly

      void aeronSinkPublicationClosedUnexpectedly(String channel, int streamId)

    • aeronSinkStopped

      void aeronSinkStopped(String channel, int streamId)

    • aeronSinkEnvelopeGrabbed

      void aeronSinkEnvelopeGrabbed(int lastMessageSize)

    • aeronSinkEnvelopeOffered

      void aeronSinkEnvelopeOffered(int lastMessageSize)

    • aeronSinkGaveUpEnvelope

      void aeronSinkGaveUpEnvelope(String cause)

    • aeronSinkDelegateToTaskRunner

      void aeronSinkDelegateToTaskRunner(long countBeforeDelegate)

    • aeronSinkReturnFromTaskRunner

      void aeronSinkReturnFromTaskRunner(long nanosSinceTaskStartTime)

    • aeronSourceStarted

      void aeronSourceStarted(String channel, int streamId)

    • aeronSourceStopped

      void aeronSourceStopped(String channel, int streamId)

    • aeronSourceReceived

      void aeronSourceReceived(int size)

    • aeronSourceDelegateToTaskRunner

      void aeronSourceDelegateToTaskRunner(long countBeforeDelegate)

    • aeronSourceReturnFromTaskRunner

      void aeronSourceReturnFromTaskRunner(long nanosSinceTaskStartTime)

    • compressionActorRefAdvertisement

      void compressionActorRefAdvertisement(long uid)

    • compressionClassManifestAdvertisement

      void compressionClassManifestAdvertisement(long uid)

    • tcpOutboundConnected

      void tcpOutboundConnected(Address remoteAddress, String streamName)

    • tcpOutboundSent

      void tcpOutboundSent(int size)

    • tcpInboundBound

      void tcpInboundBound(String bindHost, InetSocketAddress address)

    • tcpInboundUnbound

      void tcpInboundUnbound(UniqueAddress localAddress)

    • tcpInboundConnected

      void tcpInboundConnected(InetSocketAddress remoteAddress)

    • tcpInboundReceived

      void tcpInboundReceived(int size)