o

akka.remote.artery

RemotingFlightRecorder

object RemotingFlightRecorder

INTERNAL API

Annotations
@InternalApi()
Source
RemotingFlightRecorder.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RemotingFlightRecorder
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def aeronSinkDelegateToTaskRunner(countBeforeDelegate: Long): Unit
  2. def aeronSinkEnvelopeGrabbed(lastMessageSize: Int): Unit
  3. def aeronSinkEnvelopeOffered(lastMessageSize: Int): Unit
  4. def aeronSinkGaveUpEnvelope(cause: String): Unit
  5. def aeronSinkPublicationClosed(channel: String, streamId: Int): Unit
  6. def aeronSinkPublicationClosedUnexpectedly(channel: String, streamId: Int): Unit
  7. def aeronSinkReturnFromTaskRunner(nanosSinceTaskStartTime: Long): Unit
  8. def aeronSinkStarted(channel: String, streamId: Int): Unit
  9. def aeronSinkStopped(channel: String, streamId: Int): Unit
  10. def aeronSinkTaskRunnerRemoved(channel: String, streamId: Int): Unit
  11. def aeronSourceDelegateToTaskRunner(countBeforeDelegate: Long): Unit
  12. def aeronSourceReceived(size: Int): Unit
  13. def aeronSourceReturnFromTaskRunner(nanosSinceTaskStartTime: Long): Unit
  14. def aeronSourceStarted(channel: String, streamId: Int): Unit
  15. def aeronSourceStopped(channel: String, streamId: Int): Unit
  16. def compressionActorRefAdvertisement(uid: Long): Unit
  17. def compressionClassManifestAdvertisement(uid: Long): Unit
  18. def tcpInboundBound(bindHost: String, address: InetSocketAddress): Unit
  19. def tcpInboundConnected(remoteAddress: InetSocketAddress): Unit
  20. def tcpInboundReceived(size: Int): Unit
  21. def tcpInboundUnbound(localAddress: UniqueAddress): Unit
  22. def tcpOutboundConnected(remoteAddress: Address, streamName: String): Unit
  23. def tcpOutboundSent(size: Int): Unit
  24. def transportAeronErrorLogStarted(): Unit
  25. def transportAeronErrorLogTaskStopped(): Unit
  26. def transportKillSwitchPulled(): Unit
  27. def transportMaterializerStarted(): Unit
  28. def transportMediaDriverStarted(directoryName: String): Unit
  29. def transportMediaFileDeleted(): Unit
  30. def transportQuarantined(remoteAddress: Address, uid: Long): Unit
  31. def transportRemoveQuarantined(remoteAddress: Address): Unit
  32. def transportRestartInbound(remoteAddress: UniqueAddress, streamName: String): Unit
  33. def transportRestartOutbound(remoteAddress: Address, streamName: String): Unit
  34. def transportSendQueueOverflow(queueIndex: Int): Unit
  35. def transportStarted(): Unit
  36. def transportStartupFinished(): Unit
  37. def transportStopIdleOutbound(remoteAddress: Address, queueIndex: Int): Unit
  38. def transportStopped(): Unit
  39. def transportTaskRunnerStarted(): Unit
  40. def transportUniqueAddressSet(uniqueAddress: UniqueAddress): Unit