iroha::torii::CommandServiceImpl Class Reference

#include "command_service_impl.hpp"

Inheritance diagram for iroha::torii::CommandServiceImpl:

Collaboration diagram for iroha::torii::CommandServiceImpl:

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::ametsuchi::Storage > storage, 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 () override
	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
rxcpp::observable< std::shared_ptr< shared_model::interface::TransactionResponse > >	getStatusStream (const shared_model::crypto::Hash &hash) override
Public Member Functions inherited from iroha::torii::CommandService
virtual	~CommandService ()=default

Detailed Description

Actual implementation of sync CommandServiceImpl.

Member Typedef Documentation

CacheType

using iroha::torii::CommandServiceImpl::CacheType = iroha::cache::Cache< shared_model::crypto::Hash, std::shared_ptr<shared_model::interface::TransactionResponse>, shared_model::crypto::Hash::Hasher>

Constructor & Destructor Documentation

CommandServiceImpl() [1/2]

iroha::torii::CommandServiceImpl::CommandServiceImpl	(	std::shared_ptr< iroha::torii::TransactionProcessor >	tx_processor,
		std::shared_ptr< iroha::ametsuchi::Storage >	storage,
		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

Parameters

tx_processor	- processor of received transactions
storage	- to query transactions outside the cache
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

~CommandServiceImpl()

iroha::torii::CommandServiceImpl::~CommandServiceImpl ( )

override

CommandServiceImpl() [2/2]

iroha::torii::CommandServiceImpl::CommandServiceImpl ( const CommandServiceImpl &  )

delete

Disable copying in any way to prevent potential issues with common storage/tx_processor

Member Function Documentation

getStatus()

std::shared_ptr< shared_model::interface::TransactionResponse > iroha::torii::CommandServiceImpl::getStatus ( const shared_model::crypto::Hash &  request )

overridevirtual

Request to retrieve a status of any particular transaction

Parameters

request

- TxStatusRequest object which identifies transaction uniquely

Returns

response which contains a current state of requested transaction

Implements iroha::torii::CommandService.

Here is the call graph for this function:

getStatusStream()

rxcpp::observable< std::shared_ptr< shared_model::interface::TransactionResponse > > iroha::torii::CommandServiceImpl::getStatusStream ( const shared_model::crypto::Hash &  hash )

overridevirtual

Streaming call which will repeatedly send all statuses of requested transaction from its status at the moment of receiving this request to the some final transaction status (which cannot change anymore)

Parameters

request-

TxStatusRequest object which identifies transaction uniquely

Returns

observable with transaction statuses

Implements iroha::torii::CommandService.

Here is the call graph for this function:

handleTransactionBatch()

void iroha::torii::CommandServiceImpl::handleTransactionBatch ( std::shared_ptr< shared_model::interface::TransactionBatch >  batch )

overridevirtual

Actual implementation of sync Torii in CommandService

Parameters

batch

- transactions we've received

Implements iroha::torii::CommandService.

operator=()

CommandServiceImpl& iroha::torii::CommandServiceImpl::operator= ( const CommandServiceImpl &  )

delete

---

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

• irohad/torii/impl/command_service_impl.hpp
• irohad/torii/impl/command_service_impl.cpp