CatapultServer  v0.5.0.1 (Elephant)
BlockConsumers.h File Reference
Include dependency graph for BlockConsumers.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Namespaces

 catapult
 
 catapult::chain
 
 catapult::io
 
 catapult::model
 
 catapult::utils
 
 catapult::consumers
 

Typedefs

using catapult::consumers::RequiresValidationPredicate = model::MatchingEntityPredicate
 Predicate for checking whether or not an entity requires validation. More...
 
using catapult::consumers::NewBlockSink = consumer< const std::shared_ptr< const model::Block > & >
 Prototype for a function that is called with a new block. More...
 

Functions

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)