hyperledger/iroha
Iroha - A simple, decentralized ledger http://iroha.tech
pending_transaction_storage_init.hpp
Go to the documentation of this file.
1 
6 #ifndef IROHA_PENDING_TRANSACTION_STORAGE_INIT_HPP
7 #define IROHA_PENDING_TRANSACTION_STORAGE_INIT_HPP
8 
9 #include <memory>
10 
11 #include <rxcpp/rx-lite.hpp>
13 
14 namespace shared_model {
15  namespace interface {
16  class TransactionBatch;
17  }
18 } // namespace shared_model
19 
20 namespace iroha {
21 
22  class MstProcessor;
23  class MstState;
24  class PendingTransactionStorage;
25 
26  namespace network {
27  class PeerCommunicationService;
28  }
29 
31  public:
33 
34  std::shared_ptr<PendingTransactionStorage>
35  createPendingTransactionsStorage();
36 
37  void setSubscriptions(const MstProcessor &mst_processor);
38 
39  void setSubscriptions(
40  const network::PeerCommunicationService &peer_communication_service);
41 
43 
44  protected:
45  rxcpp::composite_subscription pending_storage_lifetime;
46  rxcpp::subjects::subject<std::shared_ptr<iroha::MstState>> updated_batches;
47  rxcpp::subjects::subject<
48  std::shared_ptr<shared_model::interface::TransactionBatch>>
50  rxcpp::subjects::subject<
51  std::shared_ptr<shared_model::interface::TransactionBatch>>
53  rxcpp::subjects::subject<
57  };
58 } // namespace iroha
59 
60 #endif // IROHA_PENDING_TRANSACTION_STORAGE_INIT_HPP
rxcpp::subjects::subject< std::shared_ptr< shared_model::interface::TransactionBatch > > prepared_batch
Definition: pending_transaction_storage_init.hpp:49
Definition: hash.hpp:18
rxcpp::subjects::subject< std::shared_ptr< shared_model::interface::TransactionBatch > > expired_batch
Definition: pending_transaction_storage_init.hpp:52
rxcpp::subjects::subject< std::pair< shared_model::interface::types::AccountIdType, shared_model::interface::types::HashType > > prepared_txs
Definition: pending_transaction_storage_init.hpp:56
Definition: peer_communication_service.hpp:27
Definition: pending_transaction_storage_init.hpp:30
Definition: block_query.hpp:14
std::string AccountIdType
Type of account id.
Definition: types.hpp:39
Definition: mst_processor.hpp:22
rxcpp::composite_subscription pending_storage_lifetime
Definition: pending_transaction_storage_init.hpp:45
Definition: command_executor.hpp:12
rxcpp::subjects::subject< std::shared_ptr< iroha::MstState > > updated_batches
Definition: pending_transaction_storage_init.hpp:46