Go to the source code of this file.
|
disruptor::BlockConsumer | catapult::consumers::CreateBlockHashCalculatorConsumer (const GenerationHash &generationHash, const model::TransactionRegistry &transactionRegistry) |
|
disruptor::ConstBlockConsumer | catapult::consumers::CreateBlockHashCheckConsumer (const chain::TimeSupplier &timeSupplier, const HashCheckOptions &options) |
|
disruptor::ConstBlockConsumer | catapult::consumers::CreateBlockChainCheckConsumer (uint32_t maxChainSize, const utils::TimeSpan &maxBlockFutureTime, const chain::TimeSupplier &timeSupplier) |
|
disruptor::ConstBlockConsumer | catapult::consumers::CreateBlockStatelessValidationConsumer (const std::shared_ptr< const validators::stateless::AggregateEntityValidator > &pValidator, const std::shared_ptr< const validators::ParallelValidationPolicy > &pValidationPolicy, const RequiresValidationPredicate &requiresValidationPredicate) |
|
disruptor::DisruptorConsumer | catapult::consumers::CreateBlockChainSyncConsumer (cache::CatapultCache &cache, state::CatapultState &state, io::BlockStorageCache &storage, uint32_t maxRollbackBlocks, const BlockChainSyncHandlers &handlers) |
|
disruptor::ConstDisruptorConsumer | catapult::consumers::CreateBlockChainSyncCleanupConsumer (const std::string &dataDirectory) |
| Creates a consumer that cleans up temporary state produced by the block chain sync consumer given dataDirectory. More...
|
|
disruptor::DisruptorConsumer | catapult::consumers::CreateNewBlockConsumer (const NewBlockSink &newBlockSink, disruptor::InputSource sinkSourceMask) |
|