Packages

case class PeerManager(paramPeers: Vector[Peer], walletCreationTimeOpt: Option[Instant], queue: SourceQueue[NodeStreamMessage])(implicit ec: ExecutionContext, nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig) extends StartStopAsync[PeerManager] with PeerManagerApi with P2PLogger with Product with Serializable

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

Instance Constructors

  1. new PeerManager(paramPeers: Vector[Peer], walletCreationTimeOpt: Option[Instant], queue: SourceQueue[NodeStreamMessage])(implicit ec: ExecutionContext, 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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def buildP2PMessageHandlerSink(initState: NodeState): Sink[NodeStreamMessage, Future[NodeState]]
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  7. def connectPeer(peer: Peer): Future[Unit]
    Definition Classes
    PeerManagerPeerManagerApi
  8. def connectedPeerCount: Int
  9. def disconnectPeer(peer: Peer): Future[Unit]
    Definition Classes
    PeerManagerPeerManagerApi
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. def getPeerData(peer: Peer): Option[PersistentPeerData]
  14. def gossipGetHeadersMessage(hashes: Vector[DoubleSha256DigestBE]): Future[Unit]

    Gossips the org.bitcoins.core.p2p.GetHeadersMessage to all of our peers to attempt ot get the best block headers

    Gossips the org.bitcoins.core.p2p.GetHeadersMessage to all of our peers to attempt ot get the best block headers

    Definition Classes
    PeerManagerPeerManagerApi
  15. def gossipMessage(msg: NetworkPayload, excludedPeerOpt: Option[Peer]): Future[Unit]

    Gossips the given message to all peers except the excluded peer.

    Gossips the given message to all peers except the excluded peer. If None given as excluded peer, gossip message to all peers

    Definition Classes
    PeerManagerPeerManagerApi
  16. def isConnected(peer: Peer): Future[Boolean]
    Definition Classes
    PeerManagerPeerManagerApi
  17. def isDisconnected(peer: Peer): Future[Boolean]
    Definition Classes
    PeerManagerPeerManagerApi
  18. def isInitialized(peer: Peer): Future[Boolean]
    Definition Classes
    PeerManagerPeerManagerApi
  19. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  20. def logger: Logger
    Definition Classes
    BitcoinSLogger
  21. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  22. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  23. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  24. val paramPeers: Vector[Peer]
  25. def peerWithServicesDataMap: Map[PeerWithServices, PersistentPeerData]
  26. def peers: Set[Peer]

    Peers we are currently connected too and have completed the version/verack handshake with

    Peers we are currently connected too and have completed the version/verack handshake with

    Definition Classes
    PeerManagerPeerManagerApi
  27. def peersWithServices: Set[PeerWithServices]
  28. def productElementNames: Iterator[String]
    Definition Classes
    Product
  29. val queue: SourceQueue[NodeStreamMessage]
  30. def sendToRandomPeer(payload: NetworkPayload): Future[Unit]
    Definition Classes
    PeerManagerPeerManagerApi
  31. def start(): Future[PeerManager]
    Definition Classes
    PeerManagerStartStop
  32. def startFilterSync(chainApi: ChainApi, fofhs: FilterOrFilterHeaderSync): Future[Option[FilterOrFilterHeaderSync]]

    Starts a filter header or filter sync is necesssary.

    Starts a filter header or filter sync is necesssary. Returns None if no sync is started

  33. def stop(): Future[PeerManager]
    Definition Classes
    PeerManagerStartStop
  34. def sync(syncPeerOpt: Option[Peer]): Future[Unit]
  35. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  36. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  37. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  38. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  39. val walletCreationTimeOpt: Option[Instant]

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from P2PLogger

Inherited from BitcoinSLogger

Inherited from PeerManagerApi

Inherited from StartStopAsync[PeerManager]

Inherited from StartStop[Future[PeerManager]]

Inherited from AnyRef

Inherited from Any

Ungrouped