Package akka.remote.artery

Class RemotingFlightRecorder

  • public class RemotingFlightRecorder
extends java.lang.Object
    INTERNAL API

    • Constructor Detail

      • RemotingFlightRecorder

        public RemotingFlightRecorder()

    • Method Detail

      • transportMediaDriverStarted

        public static void transportMediaDriverStarted​(java.lang.String directoryName)

      • transportStarted

        public static void transportStarted()

      • transportAeronErrorLogStarted

        public static void transportAeronErrorLogStarted()

      • transportTaskRunnerStarted

        public static void transportTaskRunnerStarted()

      • transportUniqueAddressSet

        public static void transportUniqueAddressSet​(UniqueAddress uniqueAddress)

      • transportMaterializerStarted

        public static void transportMaterializerStarted()

      • transportStartupFinished

        public static void transportStartupFinished()

      • transportKillSwitchPulled

        public static void transportKillSwitchPulled()

      • transportStopped

        public static void transportStopped()

      • transportAeronErrorLogTaskStopped

        public static void transportAeronErrorLogTaskStopped()

      • transportMediaFileDeleted

        public static void transportMediaFileDeleted()

      • transportSendQueueOverflow

        public static void transportSendQueueOverflow​(int queueIndex)

      • transportStopIdleOutbound

        public static void transportStopIdleOutbound​(Address remoteAddress,
                                             int queueIndex)

      • transportQuarantined

        public static void transportQuarantined​(Address remoteAddress,
                                        long uid)

      • transportRemoveQuarantined

        public static void transportRemoveQuarantined​(Address remoteAddress)

      • transportRestartOutbound

        public static void transportRestartOutbound​(Address remoteAddress,
                                            java.lang.String streamName)

      • transportRestartInbound

        public static void transportRestartInbound​(UniqueAddress remoteAddress,
                                           java.lang.String streamName)

      • aeronSinkStarted

        public static void aeronSinkStarted​(java.lang.String channel,
                                    int streamId)

      • aeronSinkTaskRunnerRemoved

        public static void aeronSinkTaskRunnerRemoved​(java.lang.String channel,
                                              int streamId)

      • aeronSinkPublicationClosed

        public static void aeronSinkPublicationClosed​(java.lang.String channel,
                                              int streamId)

      • aeronSinkPublicationClosedUnexpectedly

        public static void aeronSinkPublicationClosedUnexpectedly​(java.lang.String channel,
                                                          int streamId)

      • aeronSinkStopped

        public static void aeronSinkStopped​(java.lang.String channel,
                                    int streamId)

      • aeronSinkEnvelopeGrabbed

        public static void aeronSinkEnvelopeGrabbed​(int lastMessageSize)

      • aeronSinkEnvelopeOffered

        public static void aeronSinkEnvelopeOffered​(int lastMessageSize)

      • aeronSinkGaveUpEnvelope

        public static void aeronSinkGaveUpEnvelope​(java.lang.String cause)

      • aeronSinkDelegateToTaskRunner

        public static void aeronSinkDelegateToTaskRunner​(long countBeforeDelegate)

      • aeronSinkReturnFromTaskRunner

        public static void aeronSinkReturnFromTaskRunner​(long nanosSinceTaskStartTime)

      • aeronSourceStarted

        public static void aeronSourceStarted​(java.lang.String channel,
                                      int streamId)

      • aeronSourceStopped

        public static void aeronSourceStopped​(java.lang.String channel,
                                      int streamId)

      • aeronSourceReceived

        public static void aeronSourceReceived​(int size)

      • aeronSourceDelegateToTaskRunner

        public static void aeronSourceDelegateToTaskRunner​(long countBeforeDelegate)

      • aeronSourceReturnFromTaskRunner

        public static void aeronSourceReturnFromTaskRunner​(long nanosSinceTaskStartTime)

      • compressionActorRefAdvertisement

        public static void compressionActorRefAdvertisement​(long uid)

      • compressionClassManifestAdvertisement

        public static void compressionClassManifestAdvertisement​(long uid)

      • tcpOutboundConnected

        public static void tcpOutboundConnected​(Address remoteAddress,
                                        java.lang.String streamName)

      • tcpOutboundSent

        public static void tcpOutboundSent​(int size)

      • tcpInboundBound

        public static void tcpInboundBound​(java.lang.String bindHost,
                                   java.net.InetSocketAddress address)

      • tcpInboundUnbound

        public static void tcpInboundUnbound​(UniqueAddress localAddress)

      • tcpInboundConnected

        public static void tcpInboundConnected​(java.net.InetSocketAddress remoteAddress)

      • tcpInboundReceived

        public static void tcpInboundReceived​(int size)