ConsumerInput.h

Go to the documentation of this file.

 
#pragma once
#include "DisruptorTypes.h"
#include "InputSource.h"
#include "catapult/model/AnnotatedEntityRange.h"
#include "catapult/model/RangeTypes.h"
 
namespace catapult { namespace disruptor {
 
    class ConsumerInput {
    public:
        ConsumerInput();
 
        explicit ConsumerInput(model::AnnotatedBlockRange&& range, InputSource source = InputSource::Unknown);
 
        explicit ConsumerInput(model::AnnotatedTransactionRange&& range, InputSource source = InputSource::Unknown);
 
    public:
        bool empty() const;
 
        bool hasBlocks() const;
 
        bool hasTransactions() const;
 
    public:
        BlockElements& blocks();
 
        const BlockElements& blocks() const;
 
        TransactionElements& transactions();
 
        const TransactionElements& transactions() const;
 
        InputSource source() const;
 
        const Key& sourcePublicKey() const;
 
    public:
        model::BlockRange detachBlockRange();
 
        model::TransactionRange detachTransactionRange();
 
    public:
        friend std::ostream& operator<<(std::ostream& out, const ConsumerInput& input);
 
    private:
        // backing memory
        model::BlockRange m_blockRange;
        model::TransactionRange m_transactionRange;
 
        // used by consumers
        BlockElements m_blockElements;
        TransactionElements m_transactionElements;
 
        InputSource m_source;
        Key m_sourcePublicKey;
 
        // used by formatting
        Height m_startHeight;
        Height m_endHeight;
    };
}}