Packages

case class PeerManager(paramPeers: Vector[Peer] = Vector.empty, node: NeutrinoNode, walletCreationTimeOpt: Option[Instant])(implicit ec: ExecutionContext, system: ActorSystem, nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig) extends StartStopAsync[PeerManager] with P2PLogger with Product with Serializable

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PeerManager
  2. Serializable
  3. Product
  4. Equals
  5. P2PLogger
  6. Logging
  7. StartStopAsync
  8. StartStop
  9. AnyRef
  10. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new PeerManager(paramPeers: Vector[Peer] = Vector.empty, node: NeutrinoNode, walletCreationTimeOpt: Option[Instant])(implicit ec: ExecutionContext, system: ActorSystem, nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def addPeer(peer: Peer): Future[Unit]
  5. def addPeerToTry(peers: Vector[Peer], priority: Int = 0): Unit
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  8. def connectedPeerCount: Int
  9. val dataMessageStream: SourceQueueWithComplete[StreamDataMessageWrapper]
  10. def debug(mkr: Marker, msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  11. def debug(msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  12. def debug(msg: => Any): Unit
    Attributes
    protected
    Definition Classes
    Logging
  13. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. def error(mkr: Marker, msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  15. def error(msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  16. def error(msg: => Any): Unit
    Attributes
    protected
    Definition Classes
    Logging
  17. def fetchCompactFilterHeaders(currentDmh: DataMessageHandler): Future[DataMessageHandler]
  18. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  19. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  20. def getDataMessageHandler: DataMessageHandler
  21. def getPeerHandler(peer: Peer): Future[Option[PeerHandler]]
  22. def getPeerMsgSender(peer: Peer): Future[Option[PeerMessageSender]]
  23. def info(mkr: Marker, msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  24. def info(msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  25. def info(msg: => Any): Unit
    Attributes
    protected
    Definition Classes
    Logging
  26. def isConnected(peer: Peer): Future[Boolean]
  27. def isDebugEnabled: Boolean
    Attributes
    protected
    Definition Classes
    Logging
  28. def isErrorEnabled: Boolean
    Attributes
    protected
    Definition Classes
    Logging
  29. def isInfoEnabled: Boolean
    Attributes
    protected
    Definition Classes
    Logging
  30. def isInitialized(peer: Peer): Future[Boolean]
  31. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  32. def isReconnection(peer: Peer): Boolean
  33. def isTraceEnabled: Boolean
    Attributes
    protected
    Definition Classes
    Logging
  34. def isWarnEnabled: Boolean
    Attributes
    protected
    Definition Classes
    Logging
  35. def logger: Logger
    Attributes
    protected
    Definition Classes
    Logging
  36. def loggerName: String
    Attributes
    protected
    Definition Classes
    Logging
  37. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  38. val node: NeutrinoNode
  39. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  40. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  41. def onInitialization(peer: Peer): Future[Unit]
  42. def onInitializationTimeout(peer: Peer): Future[Unit]
  43. def onP2PClientStopped(peer: Peer): Future[Unit]
  44. def onQueryTimeout(payload: ExpectsResponse, peer: Peer): Future[Unit]
  45. def onReconnect(peer: Peer): Future[Unit]
  46. def onVersionMessage(peer: Peer, versionMsg: VersionMessage): Unit
  47. val paramPeers: Vector[Peer]
  48. def peerDataMap: Map[Peer, PeerData]
  49. def peerMsgSendersF: Future[Vector[PeerMessageSender]]
  50. def peers: Vector[Peer]
  51. def productElementNames: Iterator[String]
    Definition Classes
    Product
  52. def randomPeerMsgSenderWithService(services: ServiceIdentifier): Future[PeerMessageSender]
  53. def randomPeerWithService(services: ServiceIdentifier): Future[Peer]
  54. def removePeer(peer: Peer): Future[Unit]
  55. def replacePeer(replacePeer: Peer, withPeer: Peer): Future[Unit]
  56. def sendResponseTimeout(peer: Peer, payload: NetworkPayload): Future[Unit]
  57. def start(): Future[PeerManager]
    Definition Classes
    PeerManager → StartStop
  58. def stop(): Future[PeerManager]
    Definition Classes
    PeerManager → StartStop
  59. def syncFromNewPeer(): Future[DataMessageHandler]
  60. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  61. def trace(mkr: Marker, msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  62. def trace(msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  63. def trace(msg: => Any): Unit
    Attributes
    protected
    Definition Classes
    Logging
  64. def updateDataMessageHandler(dataMessageHandler: DataMessageHandler): PeerManager
  65. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  66. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  67. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  68. def waitingForDeletion: Set[Peer]
  69. val walletCreationTimeOpt: Option[Instant]
  70. def warn(mkr: Marker, msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  71. def warn(msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  72. def warn(msg: => Any): Unit
    Attributes
    protected
    Definition Classes
    Logging

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from P2PLogger

Inherited from Logging

Inherited from StartStopAsync[PeerManager]

Inherited from StartStop[Future[PeerManager]]

Inherited from AnyRef

Inherited from Any

Ungrouped