package node
- Alphabetic
- Public
- Protected
Package Members
Type Members
- case class AttemptToConnectPeerData(peer: Peer, peerMessageSender: PeerMessageSender)(implicit system: ActorSystem, nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig) extends PeerData with Product with Serializable
A peer we are just discovering on the p2p network for future connections we do not want to be persistently connected to this peer, just see if we can connect to it and exchange version/verack messages
- case class NeutrinoNode(walletCreationTimeOpt: Option[Instant], nodeConfig: NodeAppConfig, chainConfig: ChainAppConfig, actorSystem: ActorSystem, paramPeers: Vector[Peer]) extends Node with SourceQueue[NodeStreamMessage] with Product with Serializable
- trait Node extends NodeApi with ChainQueryApi with StartStopAsync[Node] 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. - sealed abstract class NodeStreamMessage extends AnyRef
- 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
- sealed trait PeerData extends AnyRef
PeerData contains objects specific to a peer associated together
- case class PeerFinder(paramPeers: Vector[Peer], queue: SourceQueue[NodeStreamMessage], skipPeers: () => Set[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], walletCreationTimeOpt: Option[Instant], queue: SourceQueue[NodeStreamMessage], finder: PeerFinder)(implicit ec: ExecutionContext, system: ActorSystem, nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig) extends StartStopAsync[PeerManager] with PeerManagerApi with P2PLogger with Product with Serializable
- case class PeerStack() extends Product with Serializable
- case class PersistentPeerData(peer: Peer, peerMessageSender: PeerMessageSender)(implicit system: ActorSystem, nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig) extends PeerData with Product with Serializable
A peer we plan on being connected to persistently
- case class ResponseTimeout(payload: NetworkPayload) extends Product with Serializable
Value Members
- object NodeCallbacks extends CallbackFactory[NodeCallbacks]
- object NodeStreamMessage
- object PeerManager extends Logging with Serializable