package node
Ordering
- Alphabetic
Visibility
- Public
- Protected
Package Members
Type Members
- case class NeutrinoNode(walletCreationTimeOpt: Option[Instant], nodeConfig: NodeAppConfig, chainConfig: ChainAppConfig, actorSystem: ActorSystem, paramPeers: Vector[Peer] = Vector.empty) extends Node with Product with Serializable
- trait Node extends NodeApi with ChainQueryApi with P2PLogger
This a base trait for various kinds of nodes.
This a base trait for various kinds of nodes. It contains house keeping methods required for all nodes.
- trait NodeCallbacks extends ModuleCallbacks[NodeCallbacks] with Logging
Callbacks for responding to events in the node.
Callbacks for responding to events in the node. The appropriate callback is executed whenever the node receives a
getdata
message matching it. - trait OnBlockHeadersReceived extends Callback[Vector[BlockHeader]]
Callback for handling a received block header
- trait OnBlockReceived extends Callback[Block]
Callback for handling a received block
- trait OnCompactFiltersReceived extends Callback[Vector[(DoubleSha256Digest, GolombFilter)]]
Callback for handling a received compact block filter
- trait OnMerkleBlockReceived extends Callback2[MerkleBlock, Vector[Transaction]]
Callback for handling a received Merkle block with its corresponding TXs
- trait OnTxReceived extends Callback[Transaction]
Callback for handling a received transaction
- case class PeerData(peer: Peer, controlMessageHandler: ControlMessageHandler, queue: SourceQueueWithComplete[StreamDataMessageWrapper], peerMessageSenderApi: PeerMessageSenderApi)(implicit system: ActorSystem, nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig) extends Product with Serializable
PeerData contains objects specific to a peer associated together
- case class PeerFinder(paramPeers: Vector[Peer], controlMessageHandler: ControlMessageHandler, queue: SourceQueueWithComplete[StreamDataMessageWrapper], peerMessageSenderApi: PeerMessageSenderApi, skipPeers: () => Vector[Peer])(implicit ec: ExecutionContext, system: ActorSystem, nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig) extends StartStopAsync[PeerFinder] with P2PLogger with Product with Serializable
- case class PeerManager(paramPeers: Vector[Peer] = Vector.empty, walletCreationTimeOpt: Option[Instant])(implicit ec: ExecutionContext, system: ActorSystem, nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig) extends StartStopAsync[PeerManager] with PeerMessageSenderApi with SourceQueue[StreamDataMessageWrapper] with P2PLogger with Product with Serializable
- case class PeerStack() extends Product with Serializable
- case class ResponseTimeout(payload: NetworkPayload) extends Product with Serializable
Value Members
- object NodeCallbacks extends CallbackFactory[NodeCallbacks]
- object PeerManager extends Logging with Serializable