abstract class Synchronizer : CoroutineScope
(source)
<init> |
Synchronizer(executor: ExecutorService = Executors.newFixedThreadPool(1), coroutineContext: CoroutineContext = executor.asCoroutineDispatcher(), repository: BlockchainRepository, client: EthRequestsManager, peerRepository: EthereumPeerRepository) |
client |
val client: EthRequestsManager |
coroutineContext |
open val coroutineContext: CoroutineContext |
executor |
val executor: ExecutorService |
peerRepository |
val peerRepository: EthereumPeerRepository |
repository |
val repository: BlockchainRepository |
addHeaders |
fun addHeaders(result: List<BlockHeader>): Unit |
start |
abstract fun start(): Unit |
stop |
abstract fun stop(): Unit |
FromBestBlockSynchronizer |
class FromBestBlockSynchronizer : Synchronizer |
FromUnknownParentSynchronizer |
class FromUnknownParentSynchronizer : Synchronizer |
PeerStatusEthSynchronizer |
Synchronizer responsible for pulling blocks until such time the highest known block is met, or close enough. class PeerStatusEthSynchronizer : Synchronizer |