case class FilterSync(syncPeer: Peer, peerWithServicesDataMap: Map[PeerWithServices, PersistentPeerData], waitingForDisconnection: Set[Peer], filterBatchCache: Set[CompactFilterMessage], peerFinder: PeerFinder, sentQuery: Instant) extends SyncNodeState with FilterOrFilterHeaderSync with Product with Serializable
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- FilterSync
- Serializable
- Product
- Equals
- FilterOrFilterHeaderSync
- SyncNodeState
- NodeRunningState
- NodeState
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new FilterSync(syncPeer: Peer, peerWithServicesDataMap: Map[PeerWithServices, PersistentPeerData], waitingForDisconnection: Set[Peer], filterBatchCache: Set[CompactFilterMessage], peerFinder: PeerFinder, sentQuery: Instant)
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
- def addPeer(peer: Peer): NodeRunningState
- Definition Classes
- NodeRunningState
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def connectedPeerCount: Int
- Definition Classes
- NodeRunningState
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val filterBatchCache: Set[CompactFilterMessage]
- 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 getPeerConnection(peer: Peer): Option[PeerConnection]
- Definition Classes
- NodeRunningState
- def getPeerData(peer: Peer): Option[PersistentPeerData]
- Definition Classes
- NodeRunningState
- def getPeerMsgSender(peer: Peer): Option[PeerMessageSender]
- Definition Classes
- NodeRunningState
- def getPeerServices(peer: Peer): Option[ServiceIdentifier]
- Definition Classes
- NodeRunningState
- def isConnected(peer: Peer): Boolean
- Definition Classes
- NodeRunningState
- def isDisconnected(peer: Peer): Boolean
- Definition Classes
- NodeRunningState
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isQueryTimedOut(duration: FiniteDuration): Boolean
- Definition Classes
- SyncNodeState
- def isSyncing: Boolean
- Definition Classes
- SyncNodeState → NodeRunningState
- 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 peerDataMap: Map[Peer, PersistentPeerData]
- Definition Classes
- NodeRunningState
- val peerFinder: PeerFinder
- Definition Classes
- FilterSync → NodeRunningState
- val peerWithServicesDataMap: Map[PeerWithServices, PersistentPeerData]
- Definition Classes
- FilterSync → NodeRunningState
- def peers: Set[Peer]
All peers the node is currently connected to
All peers the node is currently connected to
- Definition Classes
- NodeRunningState
- def peersWithServices: Set[PeerWithServices]
- Definition Classes
- NodeRunningState
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def randomPeer(excludePeers: Set[Peer], services: ServiceIdentifier): Option[Peer]
- Definition Classes
- NodeRunningState
- def randomPeerMessageSender(excludePeers: Set[Peer], services: ServiceIdentifier): Option[PeerMessageSender]
- Definition Classes
- NodeRunningState
- def removePeer(peer: Peer): NodeRunningState
Removes the peer from our peerDataMap
Removes the peer from our peerDataMap
- Definition Classes
- NodeRunningState
- def replacePeers(peerWithServicesDataMap: Map[PeerWithServices, PersistentPeerData]): NodeRunningState
- Definition Classes
- NodeRunningState
- def replaceSyncPeer: Option[SyncNodeState]
Replaces the current sync peer with a new sync peer, returns None if there is not a new peer available
Replaces the current sync peer with a new sync peer, returns None if there is not a new peer available
- Definition Classes
- SyncNodeState
- def replaceSyncPeer(newSyncPeer: Peer): SyncNodeState
- Definition Classes
- SyncNodeState
- def replaceWaitingForDisconnection(newWaitingForDisconnection: Set[Peer]): NodeRunningState
- Definition Classes
- NodeRunningState
- val sentQuery: Instant
The time when we sent the last query
The time when we sent the last query
- Definition Classes
- FilterSync → SyncNodeState
- def services: ServiceIdentifier
Services of our syncPeer
Services of our syncPeer
- Definition Classes
- SyncNodeState
- val syncPeer: Peer
- Definition Classes
- FilterSync → SyncNodeState
- def syncPeerMessageSender: PeerMessageSender
- Definition Classes
- SyncNodeState
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toDoneSyncing: DoneSyncing
- Definition Classes
- SyncNodeState
- def toFilterHeaderSync: FilterHeaderSync
- Definition Classes
- SyncNodeState
- def toFilterSync: FilterSync
- Definition Classes
- SyncNodeState
- def toString(): String
- Definition Classes
- FilterSync → SyncNodeState → NodeRunningState → 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()
- val waitingForDisconnection: Set[Peer]
- Definition Classes
- FilterSync → NodeRunningState