object NodeTestUtil extends NodeTestUtil
- Alphabetic
- By Inheritance
- NodeTestUtil
- NodeTestUtil
- P2PLogger
- BitcoinSLogger
- AnyRef
- Any
- Hide All
- Show All
- 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 awaitAllSync(node: NeutrinoNode, bitcoind: BitcoindRpcClient, bestBlockHashBE: Option[DoubleSha256DigestBE] = None)(implicit system: ActorSystem): Future[Unit]
Awaits header, filter header and filter sync between the neutrino node and rpc client
Awaits header, filter header and filter sync between the neutrino node and rpc client
- bitcoind
the node we are syncing against
- bestBlockHashBE
the best block hash we are expected to sync to, this is useful for reorg situations. If None given, we use bitcoind's best block header
- Definition Classes
- NodeTestUtil
- def awaitBestHash(node: Node, bitcoind: BitcoindRpcClient, bestHashOpt: Option[DoubleSha256DigestBE] = None)(implicit system: ActorSystem): Future[Unit]
The future doesn't complete until the nodes best hash is the given hash
The future doesn't complete until the nodes best hash is the given hash
- Definition Classes
- NodeTestUtil
- def awaitCompactFilterHeadersSync(node: NeutrinoNode, rpc: BitcoindRpcClient)(implicit sys: ActorSystem): Future[Unit]
Awaits sync between the given node and bitcoind client
Awaits sync between the given node and bitcoind client
- Definition Classes
- NodeTestUtil
- def awaitCompactFiltersSync(node: NeutrinoNode, rpc: BitcoindRpcClient, bestBlockHashBEOpt: Option[DoubleSha256DigestBE] = None)(implicit sys: ActorSystem): Future[Unit]
Awaits sync between the given node and bitcoind client
Awaits sync between the given node and bitcoind client
- Definition Classes
- NodeTestUtil
- def awaitConnectionCount(node: Node, expectedConnectionCount: Int, interval: FiniteDuration = 1.second, maxTries: Int = 30)(implicit ec: ExecutionContext): Future[Unit]
returns a Future that isn't completed until the peer manager has expectedConnectionCount connections
returns a Future that isn't completed until the peer manager has expectedConnectionCount connections
- Definition Classes
- NodeTestUtil
- def awaitSync(node: NeutrinoNode, rpc: BitcoindRpcClient)(implicit sys: ActorSystem): Future[Unit]
Awaits sync between the given node and bitcoind client
Awaits sync between the given node and bitcoind client
- Definition Classes
- NodeTestUtil
- def awaitSyncAndIBD(node: NeutrinoNode, bitcoind: BitcoindRpcClient)(implicit system: ActorSystem): Future[Unit]
- Definition Classes
- NodeTestUtil
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def disconnectNode(bitcoind: BitcoindRpcClient, node: NeutrinoNode)(implicit system: ActorSystem): Future[Unit]
- Definition Classes
- NodeTestUtil
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def getBitcoindPeer(bitcoindRpcClient: BitcoindRpcClient)(implicit executionContext: ExecutionContext): Future[Peer]
Gets the Peer that corresponds to org.bitcoins.rpc.client.common.BitcoindRpcClient
Gets the Peer that corresponds to org.bitcoins.rpc.client.common.BitcoindRpcClient
- Definition Classes
- NodeTestUtil
- def getBitcoindSocketAddress(bitcoindRpcClient: BitcoindRpcClient)(implicit executionContext: ExecutionContext): Future[InetSocketAddress]
Helper method to get the java.net.InetSocketAddress we need to connect to to make a p2p connection with bitcoind
Helper method to get the java.net.InetSocketAddress we need to connect to to make a p2p connection with bitcoind
- Definition Classes
- NodeTestUtil
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getNodeURIFromBitcoind(bitcoind: BitcoindRpcClient, localAddressBitcoinS: InetSocketAddress)(implicit system: ActorSystem): Future[URI]
get our neutrino node's uri from a test bitcoind instance to send rpc commands for our node.
get our neutrino node's uri from a test bitcoind instance to send rpc commands for our node. The peer must be initialized by the node.
- Definition Classes
- NodeTestUtil
- def getSocks5ProxyParams: Option[Socks5ProxyParams]
- Definition Classes
- NodeTestUtil
- def getStartedNodeCustomConfig(initNode: NeutrinoNode, config: Config)(implicit ec: ExecutionContext): Future[NeutrinoNode]
- Definition Classes
- NodeTestUtil
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isSameBestFilterHeaderHeight(node: NeutrinoNode, rpc: BitcoindRpcClient)(implicit ec: ExecutionContext): Future[Boolean]
- Definition Classes
- NodeTestUtil
- def isSameBestFilterHeight(node: NeutrinoNode, rpc: BitcoindRpcClient)(implicit ec: ExecutionContext): Future[Boolean]
- Definition Classes
- NodeTestUtil
- def isSameBestHash(node: Node, rpc: BitcoindRpcClient)(implicit ec: ExecutionContext): Future[Boolean]
Checks if the given node and bitcoind is synced
Checks if the given node and bitcoind is synced
- Definition Classes
- NodeTestUtil
- def isSameBlockCount(node: Node, rpc: BitcoindRpcClient)(implicit ec: ExecutionContext): Future[Boolean]
Checks if the given light client and bitcoind has the same number of blocks in their blockchains
Checks if the given light client and bitcoind has the same number of blocks in their blockchains
- Definition Classes
- NodeTestUtil
- 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()
- 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()