object BitcoindRpcBackendUtil extends BitcoinSLogger
Useful utilities to use in the wallet project for syncing things against bitcoind
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- BitcoindRpcBackendUtil
- 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 buildBitcoindNodeApi(bitcoindRpcClient: BitcoindRpcClient, walletF: Future[WalletApi], chainCallbacksOpt: Option[ChainCallbacks])(implicit system: ActorSystem): NodeApi
Creates an anonymous NodeApi that downloads blocks using akka streams from bitcoind, and then calls NeutrinoWalletApi.processBlock
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def createDLCWalletWithBitcoindCallbacks(bitcoind: BitcoindRpcClient, wallet: DLCWallet, chainCallbacksOpt: Option[ChainCallbacks])(implicit system: ActorSystem): DLCWallet
- def createWalletWithBitcoindCallbacks(bitcoind: BitcoindRpcClient, wallet: Wallet, chainCallbacksOpt: Option[ChainCallbacks])(implicit system: ActorSystem): Wallet
- 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])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- 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 startBitcoindBlockPolling(wallet: WalletApi, bitcoind: BitcoindRpcClient, chainCallbacksOpt: Option[ChainCallbacks], interval: FiniteDuration = 10.seconds)(implicit system: ActorSystem): Cancellable
Starts the ActorSystem to poll the BitcoindRpcClient for its block count, if it has changed, it will then request those blocks to process them
Starts the ActorSystem to poll the BitcoindRpcClient for its block count, if it has changed, it will then request those blocks to process them
- interval
The amount of time between polls, this should not be too aggressive as the wallet will need to process the new blocks
- def startBitcoindMempoolPolling(wallet: WalletApi, bitcoind: BitcoindRpcClient, interval: FiniteDuration = 10.seconds)(processTx: (Transaction) => Future[Unit])(implicit system: ActorSystem, ec: ExecutionContext): Cancellable
- def startZMQWalletCallbacks(wallet: NeutrinoHDWalletApi, zmqConfig: ZmqConfig)(implicit ec: ExecutionContext): WalletZmqSubscribers
- def syncWalletToBitcoind(bitcoind: BitcoindRpcClient, wallet: NeutrinoHDWalletApi, chainCallbacksOpt: Option[ChainCallbacks])(implicit system: ActorSystem): Future[Unit]
Has the wallet process all the blocks it has not seen up until bitcoind's chain tip
- 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()