#include "command_service_impl.hpp"


Public Types | |
| using | CacheType = iroha::cache::Cache< shared_model::crypto::Hash, std::shared_ptr< shared_model::interface::TransactionResponse >, shared_model::crypto::Hash::Hasher > |
Public Member Functions | |
| CommandServiceImpl (std::shared_ptr< iroha::torii::TransactionProcessor > tx_processor, std::shared_ptr< iroha::torii::StatusBus > status_bus, std::shared_ptr< shared_model::interface::TxStatusFactory > status_factory, std::shared_ptr< iroha::torii::CommandServiceImpl::CacheType > cache, std::shared_ptr< iroha::ametsuchi::TxPresenceCache > tx_presence_cache, logger::LoggerPtr log) | |
| CommandServiceImpl (const CommandServiceImpl &)=delete | |
| CommandServiceImpl & | operator= (const CommandServiceImpl &)=delete |
| void | handleTransactionBatch (std::shared_ptr< shared_model::interface::TransactionBatch > batch) override |
| std::shared_ptr< shared_model::interface::TransactionResponse > | getStatus (const shared_model::crypto::Hash &request) override |
| void | processTransactionResponse (std::shared_ptr< shared_model::interface::TransactionResponse > response) override |
Public Member Functions inherited from iroha::torii::CommandService | |
| virtual | ~CommandService ()=default |
Actual implementation of sync CommandServiceImpl.
| using iroha::torii::CommandServiceImpl::CacheType = iroha::cache::Cache< shared_model::crypto::Hash, std::shared_ptr<shared_model::interface::TransactionResponse>, shared_model::crypto::Hash::Hasher> |
| CommandServiceImpl::CommandServiceImpl | ( | std::shared_ptr< iroha::torii::TransactionProcessor > | tx_processor, |
| std::shared_ptr< iroha::torii::StatusBus > | status_bus, | ||
| std::shared_ptr< shared_model::interface::TxStatusFactory > | status_factory, | ||
| std::shared_ptr< iroha::torii::CommandServiceImpl::CacheType > | cache, | ||
| std::shared_ptr< iroha::ametsuchi::TxPresenceCache > | tx_presence_cache, | ||
| logger::LoggerPtr | log | ||
| ) |
Creates a new instance of CommandService
| tx_processor | - processor of received transactions |
| status_bus | is a common notifier for tx statuses |
| cache | - non-persistent cache, an instance of type CommandServiceImpl::CacheType |
| tx_presence_cache | a cache over persistent storage |
| log | to print progress |
|
delete |
Disable copying in any way to prevent potential issues with common storage/tx_processor
|
overridevirtual |
Request to retrieve a status of any particular transaction
| request | - TxStatusRequest object which identifies transaction uniquely |
Implements iroha::torii::CommandService.
|
overridevirtual |
Actual implementation of sync Torii in CommandService
| batch | - transactions we've received |
Implements iroha::torii::CommandService.
|
delete |
|
overridevirtual |
Implements iroha::torii::CommandService.