case class NeutrinoNode(walletCreationTimeOpt: Option[Instant], paramPeers: Vector[Peer])(implicit nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig, system: ActorSystem) extends Node with SourceQueue[NodeStreamMessage] with Product with Serializable
- Alphabetic
- By Inheritance
- NeutrinoNode
- Serializable
- Product
- Equals
- SourceQueue
- Node
- P2PLogger
- BitcoinSLogger
- StartStopAsync
- StartStop
- ChainQueryApi
- NodeApi
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new NeutrinoNode(walletCreationTimeOpt: Option[Instant], paramPeers: Vector[Peer])(implicit nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig, system: ActorSystem)
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 broadcastTransaction(transaction: Transaction): Future[Unit]
Broadcasts the given transaction over the P2P network
Broadcasts the given transaction over the P2P network
- Definition Classes
- NodeApi
- def broadcastTransactions(transactions: Vector[Transaction]): Future[Unit]
Broadcasts the given transaction over the P2P network
- def chainApiFromDb()(implicit executionContext: ExecutionContext): Future[ChainApi]
This is constructing a chain api from disk every time we call this method This involves database calls which can be slow and expensive to construct our Blockchain
This is constructing a chain api from disk every time we call this method This involves database calls which can be slow and expensive to construct our Blockchain
- Definition Classes
- Node
- implicit val chainAppConfig: ChainAppConfig
- Definition Classes
- NeutrinoNode → Node
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def downloadBlocks(blockHashes: Vector[DoubleSha256DigestBE]): Future[Unit]
Fetches the given blocks from the peers and calls the appropriate Backpressures if the queue is full
Fetches the given blocks from the peers and calls the appropriate Backpressures if the queue is full
- Definition Classes
- NeutrinoNode → NodeApi
- def epochSecondToBlockHeight(time: Long): Future[Int]
Gets the block height of the closest block to the given time
Gets the block height of the closest block to the given time
- Definition Classes
- Node → ChainQueryApi
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- implicit def executionContext: ExecutionContext
- Definition Classes
- Node
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def getBestBlockHash(): Future[DoubleSha256DigestBE]
Gets the hash of the block that is what we consider "best"
Gets the hash of the block that is what we consider "best"
- Definition Classes
- Node → ChainQueryApi
- def getBestHashBlockHeight()(implicit ec: ExecutionContext): Future[Int]
- Definition Classes
- ChainQueryApi
- def getBlockHeight(blockHash: DoubleSha256DigestBE): Future[Option[Int]]
Gets the height of the given block
Gets the height of the given block
- Definition Classes
- Node → ChainQueryApi
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getConnectionCount: Future[Int]
- def getFilterCount(): Future[Int]
Gets the number of compact filters in the database
Gets the number of compact filters in the database
- Definition Classes
- NeutrinoNode → ChainQueryApi
- def getFiltersBetweenHeights(startHeight: Int, endHeight: Int): Future[Vector[FilterResponse]]
- Definition Classes
- NeutrinoNode → ChainQueryApi
- def getHeightByBlockStamp(blockStamp: BlockStamp): Future[Int]
Returns the block height of the given block stamp
Returns the block height of the given block stamp
- Definition Classes
- NeutrinoNode → ChainQueryApi
- def getMedianTimePast(): Future[Long]
calculates the median time passed
calculates the median time passed
- Definition Classes
- Node → ChainQueryApi
- def getNumberOfConfirmations(blockHashOpt: DoubleSha256DigestBE): Future[Option[Int]]
Gets number of confirmations for the given block hash
Gets number of confirmations for the given block hash
- Definition Classes
- Node → ChainQueryApi
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: Logger
- Definition Classes
- BitcoinSLogger
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- implicit val nodeAppConfig: NodeAppConfig
- Definition Classes
- NeutrinoNode → Node
- def nodeCallbacks: NodeCallbacks
- Definition Classes
- Node
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def offer(elem: NodeStreamMessage): Future[QueueOfferResult]
- Definition Classes
- NeutrinoNode → SourceQueue
- val paramPeers: Vector[Peer]
- lazy val peerManager: PeerManager
- Definition Classes
- NeutrinoNode → Node
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def start(): Future[NeutrinoNode]
Starts our node
Starts our node
- Definition Classes
- NeutrinoNode → Node → StartStop
- def stop(): Future[NeutrinoNode]
- Definition Classes
- NeutrinoNode → StartStop
- def sync(): Future[Unit]
Starts to sync our node with our peer If our local best block hash is the same as our peers we will not sync, otherwise we will keep syncing until our best block hashes match up
Starts to sync our node with our peer If our local best block hash is the same as our peers we will not sync, otherwise we will keep syncing until our best block hashes match up
- Definition Classes
- NeutrinoNode → Node
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- implicit val system: ActorSystem
- Definition Classes
- NeutrinoNode → Node
- lazy val txDAO: BroadcastAbleTransactionDAO
- Definition Classes
- Node
- 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()
- val walletCreationTimeOpt: Option[Instant]
- def watchCompletion(): Future[Done]
- Definition Classes
- NeutrinoNode → SourceQueue