object PeerManager extends BitcoinSLogger with Serializable
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- PeerManager
- Serializable
- BitcoinSLogger
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def fetchCompactFilterHeaders(state: FilterHeaderSync, chainApi: ChainApi, peerMessageSenderApi: PeerMessageSenderApi, stopBlockHeaderDb: BlockHeaderDb)(implicit ec: ExecutionContext, chainAppConfig: ChainAppConfig): Future[Option[FilterHeaderSync]]
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getCompactFilterStartHeight(chainApi: ChainApi, walletCreationTimeOpt: Option[Instant])(implicit ec: ExecutionContext): Future[Option[Int]]
Return the starting point for first sync of compact filters from the network
Return the starting point for first sync of compact filters from the network
- walletCreationTimeOpt
the time the wallet was created, we will start syncing form this point if given
- returns
the start height for compact filters
- def handleHealthCheck(runningState: NodeRunningState)(implicit nodeAppConfig: NodeAppConfig): Future[NodeRunningState]
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def isFiltersOutOfSync(blockCount: Int, oldFilterHeaderCount: Int, currentFilterHeaderCount: Int, oldFilterCount: Int, currentFilterCount: Int): Boolean
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: Logger
- Definition Classes
- BitcoinSLogger
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def sendFirstGetCompactFilterHeadersCommand(peerMessageSenderApi: PeerMessageSenderApi, chainApi: ChainApi, stopBlockHeaderDb: BlockHeaderDb, state: FilterHeaderSync)(implicit ec: ExecutionContext, chainConfig: ChainAppConfig): Future[Option[FilterHeaderSync]]
Sends first getcfheader message.
Sends first getcfheader message. Returns None if are our filter headers are in sync with our block headers or if the peer we are attempting to send messages to does not support block filters
- def sendNextGetCompactFilterCommand(peerMessageSenderApi: PeerMessageSenderApi, chainApi: ChainApi, filterBatchSize: Int, startHeightOpt: Option[Int], stopBlockHash: DoubleSha256DigestBE, peer: Peer)(implicit ec: ExecutionContext): Future[Boolean]
- returns
a flag indicating if we are syncing or not
- def sendNextGetCompactFilterHeadersCommand(peerMessageSenderApi: PeerMessageSenderApi, chainApi: ChainApi, filterHeaderBatchSize: Int, prevStopHash: DoubleSha256DigestBE, stopHash: DoubleSha256DigestBE)(implicit ec: ExecutionContext): Future[Boolean]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()