iroha::ordering::transport::OnDemandOsClientGrpc Class Reference

#include "on_demand_os_client_grpc.hpp"

Inheritance diagram for iroha::ordering::transport::OnDemandOsClientGrpc:

Collaboration diagram for iroha::ordering::transport::OnDemandOsClientGrpc:

Public Types
using	TransportFactoryType = shared_model::interface::AbstractTransportFactory< shared_model::interface::Proposal, iroha::protocol::Proposal >
using	TimepointType = std::chrono::system_clock::time_point
using	TimeoutType = std::chrono::milliseconds
Public Types inherited from iroha::ordering::transport::OdOsNotification
using	ProposalType = shared_model::interface::Proposal
using	BatchesSetType = std::unordered_set< std::shared_ptr< shared_model::interface::TransactionBatch >, BatchPointerHasher, shared_model::interface::BatchHashEquality >
using	TransactionBatchType = std::shared_ptr< shared_model::interface::TransactionBatch >
using	CollectionType = std::vector< TransactionBatchType >

Public Member Functions
	OnDemandOsClientGrpc (std::shared_ptr< proto::OnDemandOrdering::StubInterface > stub, std::shared_ptr< network::AsyncGrpcClient< google::protobuf::Empty >> async_call, std::shared_ptr< TransportFactoryType > proposal_factory, std::function< TimepointType()> time_provider, std::chrono::milliseconds proposal_request_timeout, logger::LoggerPtr log)
void	onBatches (CollectionType batches) override
boost::optional< std::shared_ptr< const ProposalType > >	onRequestProposal (consensus::Round round) override
Public Member Functions inherited from iroha::ordering::transport::OdOsNotification
virtual	~OdOsNotification ()=default

Detailed Description

gRPC client for on demand ordering service

Member Typedef Documentation

TimeoutType

using iroha::ordering::transport::OnDemandOsClientGrpc::TimeoutType = std::chrono::milliseconds

TimepointType

using iroha::ordering::transport::OnDemandOsClientGrpc::TimepointType = std::chrono::system_clock::time_point

TransportFactoryType

using iroha::ordering::transport::OnDemandOsClientGrpc::TransportFactoryType = shared_model::interface::AbstractTransportFactory< shared_model::interface::Proposal, iroha::protocol::Proposal>

Constructor & Destructor Documentation

OnDemandOsClientGrpc()

OnDemandOsClientGrpc::OnDemandOsClientGrpc	(	std::shared_ptr< proto::OnDemandOrdering::StubInterface >	stub,
		std::shared_ptr< network::AsyncGrpcClient< google::protobuf::Empty >>	async_call,
		std::shared_ptr< TransportFactoryType >	proposal_factory,
		std::function< TimepointType()>	time_provider,
		std::chrono::milliseconds	proposal_request_timeout,
		logger::LoggerPtr	log
	)

Constructor is left public because testing required passing a mock stub interface

Member Function Documentation

onBatches()

void OnDemandOsClientGrpc::onBatches ( CollectionType  batches )

overridevirtual

Callback on receiving transactions

Parameters

batches

- vector of passed transaction batches

Implements iroha::ordering::transport::OdOsNotification.

onRequestProposal()

boost::optional< std::shared_ptr< const OdOsNotification::ProposalType > > OnDemandOsClientGrpc::onRequestProposal ( consensus::Round  round )

overridevirtual

Callback on request about proposal

Parameters

round

- number of collaboration round. Calculated as block_height + 1

Returns

proposal for requested round

Implements iroha::ordering::transport::OdOsNotification.

---

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

• irohad/ordering/impl/on_demand_os_client_grpc.hpp
• irohad/ordering/impl/on_demand_os_client_grpc.cpp