iroha::PendingTransactionStorageInit Class Reference

#include "pending_transaction_storage_init.hpp"

Collaboration diagram for iroha::PendingTransactionStorageInit:

Public Member Functions
	PendingTransactionStorageInit ()
std::shared_ptr< PendingTransactionStorage >	createPendingTransactionsStorage ()
void	setMstSubscriptions (const MstProcessor &mst_processor)
void	setFinalizedTxsSubscription (rxcpp::observable< shared_model::interface::types::HashType > finalized_txs)
	~PendingTransactionStorageInit ()

Protected Attributes
rxcpp::composite_subscription	pending_storage_lifetime
rxcpp::subjects::subject< std::shared_ptr< iroha::MstState > >	updated_batches
rxcpp::subjects::subject< std::shared_ptr< shared_model::interface::TransactionBatch > >	prepared_batch
rxcpp::subjects::subject< std::shared_ptr< shared_model::interface::TransactionBatch > >	expired_batch
rxcpp::subjects::subject< std::pair< shared_model::interface::types::AccountIdType, shared_model::interface::types::HashType > >	prepared_txs
rxcpp::subjects::subject< shared_model::interface::types::HashType >	finalized_txs

Constructor & Destructor Documentation

PendingTransactionStorageInit()

PendingTransactionStorageInit::PendingTransactionStorageInit

(

)

~PendingTransactionStorageInit()

PendingTransactionStorageInit::~PendingTransactionStorageInit

(

)

Member Function Documentation

createPendingTransactionsStorage()

std::shared_ptr< PendingTransactionStorage > PendingTransactionStorageInit::createPendingTransactionsStorage

(

)

Here is the call graph for this function:

setFinalizedTxsSubscription()

void PendingTransactionStorageInit::setFinalizedTxsSubscription

(

rxcpp::observable< shared_model::interface::types::HashType >

finalized_txs

)

setMstSubscriptions()

void PendingTransactionStorageInit::setMstSubscriptions

(

const MstProcessor &

mst_processor

)

Here is the call graph for this function:

Member Data Documentation

expired_batch

rxcpp::subjects::subject< std::shared_ptr<shared_model::interface::TransactionBatch> > iroha::PendingTransactionStorageInit::expired_batch

protected

finalized_txs

rxcpp::subjects::subject<shared_model::interface::types::HashType> iroha::PendingTransactionStorageInit::finalized_txs

protected

pending_storage_lifetime

rxcpp::composite_subscription iroha::PendingTransactionStorageInit::pending_storage_lifetime

protected

prepared_batch

rxcpp::subjects::subject< std::shared_ptr<shared_model::interface::TransactionBatch> > iroha::PendingTransactionStorageInit::prepared_batch

protected

prepared_txs

rxcpp::subjects::subject< std::pair<shared_model::interface::types::AccountIdType, shared_model::interface::types::HashType> > iroha::PendingTransactionStorageInit::prepared_txs

protected

updated_batches

rxcpp::subjects::subject<std::shared_ptr<iroha::MstState> > iroha::PendingTransactionStorageInit::updated_batches

protected

---

The documentation for this class was generated from the following files:

• irohad/main/impl/pending_transaction_storage_init.hpp
• irohad/main/impl/pending_transaction_storage_init.cpp