hyperledger/iroha
Iroha - A simple, decentralized ledger http://iroha.tech
iroha::PendingTransactionStorageInit Class Reference

#include "pending_transaction_storage_init.hpp"

Collaboration diagram for iroha::PendingTransactionStorageInit:
Collaboration graph

Public Member Functions

 PendingTransactionStorageInit ()
 
std::shared_ptr< PendingTransactionStoragecreatePendingTransactionsStorage ()
 
void setSubscriptions (const MstProcessor &mst_processor)
 
void setSubscriptions (const network::PeerCommunicationService &peer_communication_service)
 
 ~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
 

Constructor & Destructor Documentation

PendingTransactionStorageInit::PendingTransactionStorageInit ( )
PendingTransactionStorageInit::~PendingTransactionStorageInit ( )

Member Function Documentation

std::shared_ptr< PendingTransactionStorage > PendingTransactionStorageInit::createPendingTransactionsStorage ( )
void PendingTransactionStorageInit::setSubscriptions ( const MstProcessor mst_processor)

Here is the call graph for this function:

void PendingTransactionStorageInit::setSubscriptions ( const network::PeerCommunicationService peer_communication_service)

Here is the call graph for this function:

Member Data Documentation

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

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