TransactionConsumers.h

Go to the documentation of this file.

 
#pragma once
#include "HashCheckOptions.h"
#include "InputUtils.h"
#include "catapult/chain/ChainFunctions.h"
#include "catapult/disruptor/DisruptorConsumer.h"
#include "catapult/model/EntityInfo.h"
#include "catapult/validators/ParallelValidationPolicy.h"
 
namespace catapult { namespace model { class NotificationPublisher; } }
 
namespace catapult { namespace consumers {
 
    disruptor::TransactionConsumer CreateTransactionHashCalculatorConsumer(
            const GenerationHash& generationHash,
            const model::TransactionRegistry& transactionRegistry);
 
    disruptor::TransactionConsumer CreateTransactionHashCheckConsumer(
            const chain::TimeSupplier& timeSupplier,
            const HashCheckOptions& options,
            const chain::KnownHashPredicate& knownHashPredicate);
 
    disruptor::TransactionConsumer CreateTransactionStatelessValidationConsumer(
            const std::shared_ptr<const validators::stateless::AggregateEntityValidator>& pValidator,
            const std::shared_ptr<const validators::ParallelValidationPolicy>& pValidationPolicy,
            const chain::FailedTransactionSink& failedTransactionSink);
 
    using NewTransactionsSink = consumer<TransactionInfos&&>;
 
    disruptor::DisruptorConsumer CreateNewTransactionsConsumer(const NewTransactionsSink& newTransactionsSink);
}}