Packages

package node

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package callback
  2. package config
  3. package constant
  4. package db
  5. package models
  6. package networking
  7. package util

Type Members

  1. 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

  2. sealed trait FilterOrFilterHeaderSync extends SyncNodeState

    Either we are syncing NodeState.FilterHeaderSync or NodeState.FilterSync

  3. case class NeutrinoNode(walletCreationTimeOpt: Option[Instant], nodeConfig: NodeAppConfig, chainConfig: ChainAppConfig, actorSystem: ActorSystem, paramPeers: Vector[Peer]) extends Node with SourceQueue[NodeStreamMessage] with Product with Serializable
  4. 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.

  5. trait NodeCallbacks extends ModuleCallbacks[NodeCallbacks] with NodeApiCallbacks with BitcoinSLogger

    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.

  6. sealed trait NodeRunningState extends NodeState

    Means our node has been started and is running

  7. sealed abstract class NodeState extends AnyRef
  8. sealed abstract class NodeStreamMessage extends AnyRef
  9. trait OnBlockHeadersReceived extends Callback[Vector[BlockHeader]]

    Callback for handling a received block header

  10. trait OnCompactFiltersReceived extends Callback[Vector[(DoubleSha256DigestBE, GolombFilter)]]

    Callback for handling a received compact block filter

  11. trait OnMerkleBlockReceived extends Callback2[MerkleBlock, Vector[Transaction]]

    Callback for handling a received Merkle block with its corresponding TXs

  12. trait OnTxReceived extends Callback[Transaction]

    Callback for handling a received transaction

  13. sealed trait PeerData extends AnyRef

    PeerData contains objects specific to a peer associated together

  14. case class PeerFinder(peerManagerApi: PeerManagerApi, paramPeers: Vector[Peer], queue: SourceQueue[NodeStreamMessage])(implicit ec: ExecutionContext, system: ActorSystem, nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig) extends StartStopAsync[PeerFinder] with P2PLogger with Product with Serializable
  15. case class PeerManager(paramPeers: Vector[Peer], walletCreationTimeOpt: Option[Instant], queue: SourceQueue[NodeStreamMessage])(implicit ec: ExecutionContext, nodeAppConfig: NodeAppConfig, chainAppConfig: ChainAppConfig) extends StartStopAsync[PeerManager] with PeerManagerApi with P2PLogger with Product with Serializable
  16. case class PeerOrdering(peer: PeerData, priority: Int, id: Int) extends Product with Serializable
  17. case class PeerStack() extends Product with Serializable
  18. 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

  19. case class ResponseTimeout(payload: NetworkPayload) extends Product with Serializable
  20. sealed abstract class SyncNodeState extends NodeState with NodeRunningState

    State to indicate that we are syncing the blockchain

Ungrouped