Package akka.remote.artery

Interface RemotingFlightRecorder

    • Method Detail

      • transportMediaDriverStarted

        void transportMediaDriverStarted​(java.lang.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,
                              java.lang.String streamName)

      • transportRestartInbound

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

      • aeronSinkStarted

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

      • aeronSinkTaskRunnerRemoved

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

      • aeronSinkPublicationClosed

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

      • aeronSinkPublicationClosedUnexpectedly

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

      • aeronSinkStopped

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

      • aeronSinkEnvelopeGrabbed

        void aeronSinkEnvelopeGrabbed​(int lastMessageSize)

      • aeronSinkEnvelopeOffered

        void aeronSinkEnvelopeOffered​(int lastMessageSize)

      • aeronSinkGaveUpEnvelope

        void aeronSinkGaveUpEnvelope​(java.lang.String cause)

      • aeronSinkDelegateToTaskRunner

        void aeronSinkDelegateToTaskRunner​(long countBeforeDelegate)

      • aeronSinkReturnFromTaskRunner

        void aeronSinkReturnFromTaskRunner​(long nanosSinceTaskStartTime)

      • aeronSourceStarted

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

      • aeronSourceStopped

        void aeronSourceStopped​(java.lang.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,
                          java.lang.String streamName)

      • tcpOutboundSent

        void tcpOutboundSent​(int size)

      • tcpInboundBound

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

      • tcpInboundUnbound

        void tcpInboundUnbound​(UniqueAddress localAddress)

      • tcpInboundConnected

        void tcpInboundConnected​(java.net.InetSocketAddress remoteAddress)

      • tcpInboundReceived

        void tcpInboundReceived​(int size)