iroha::network Namespace Reference

Namespaces
	detail

Classes
class	AsyncGrpcClient
class	BlockLoader
class	BlockLoaderImpl
class	BlockLoaderInit
class	BlockLoaderService
class	ChannelFactory
class	ChannelFactoryTls
class	ChannelPool
class	ChannelProvider
class	ClientFactory
class	ClientFactoryImpl
class	ConsensusGate
class	GenericClientFactory
struct	GrpcChannelParams
class	MstTransport
class	MstTransportGrpc
class	MstTransportNotification
class	MstTransportStub
struct	OrderingEvent
class	OrderingGate
class	OrderingGateNotification
class	OrderingGateTransport
class	OrderingService
class	OrderingServiceNotification
class	OrderingServiceTransport
class	PeerCommunicationService
class	PeerCommunicationServiceImpl
class	PeerTlsCertificatesProvider
class	PeerTlsCertificatesProviderRoot
class	PeerTlsCertificatesProviderWsv
class	ServerRunner
struct	TlsCredentials

Functions
void	sendStateAsync (MstState const &state, shared_model::interface::types::PublicKeyHexStringView sender_key, transport::MstTransportGrpc::StubInterface &client_stub, AsyncGrpcClient< google::protobuf::Empty > &async_call, std::function< void(grpc::Status &, google::protobuf::Empty &)> on_response={})
std::unique_ptr< GrpcChannelParams >	getDefaultChannelParams ()
template<typename Service >
grpc::ChannelArguments	makeInterPeerChannelArguments (const GrpcChannelParams &params)
template<typename Service >
std::shared_ptr< grpc::Channel >	createInsecureChannel (const shared_model::interface::types::AddressType &address, const GrpcChannelParams &params)
std::shared_ptr< grpc::Channel >	createInsecureChannel (const shared_model::interface::types::AddressType &address, const std::string &service_full_name, const GrpcChannelParams &params)
template<typename Service >
std::unique_ptr< typename Service::StubInterface >	createInsecureClient (const std::string &address, const GrpcChannelParams &params)
template<typename Service >
std::unique_ptr< typename Service::StubInterface >	createInsecureClient (const std::string &ip, size_t port, const GrpcChannelParams &params)
std::shared_ptr< const shared_model::interface::Proposal >	getProposalUnsafe (const OrderingEvent &event)

Function Documentation

createInsecureChannel() [1/2]

template<typename Service >

std::shared_ptr<grpc::Channel> iroha::network::createInsecureChannel	(	const shared_model::interface::types::AddressType &	address,
		const GrpcChannelParams &	params
	)

Creates a channel

Template Parameters

Service

type for gRPC stub, e.g. proto::Yac

Parameters

address	ip address and port for connection, ipv4:port
params	grpc channel params

Returns

grpc channel with provided params

createInsecureChannel() [2/2]

std::shared_ptr< grpc::Channel > iroha::network::createInsecureChannel	(	const shared_model::interface::types::AddressType &	address,
		const std::string &	service_full_name,
		const GrpcChannelParams &	params
	)

Creates a channel

Parameters

address	ip address and port to connect to, ipv4:port
service_full_name	gRPC service full name, e.g. iroha.consensus.yac.proto.Yac
params	grpc channel params

Returns

grpc channel with provided params

Here is the call graph for this function:

createInsecureClient() [1/2]

template<typename Service >

std::unique_ptr<typename Service::StubInterface> iroha::network::createInsecureClient	(	const std::string &	address,
		const GrpcChannelParams &	params
	)

Creates client

Template Parameters

Service

type for gRPC stub, e.g. proto::Yac

Parameters

address	ip address and port for connection, ipv4:port
params	grpc channel params

Returns

gRPC stub of parametrized type

createInsecureClient() [2/2]

template<typename Service >

std::unique_ptr<typename Service::StubInterface> iroha::network::createInsecureClient	(	const std::string &	ip,
		size_t	port,
		const GrpcChannelParams &	params
	)

Creates client

Template Parameters

Service

type for gRPC stub, e.g. proto::Yac

Parameters

address	ip address to connect to
port	port to connect to
params	grpc channel params

Returns

gRPC stub of parametrized type

getDefaultChannelParams()

std::unique_ptr< GrpcChannelParams > iroha::network::getDefaultChannelParams

(

)

Creates client params which enable sending and receiving messages of INT_MAX bytes size with retries (see implementation for details).

Here is the caller graph for this function:

getProposalUnsafe()

std::shared_ptr< const shared_model::interface::Proposal > iroha::network::getProposalUnsafe

(

const OrderingEvent &

event

)

makeInterPeerChannelArguments()

template<typename Service >

grpc::ChannelArguments iroha::network::makeInterPeerChannelArguments

(

const GrpcChannelParams &

params

)

Creates channel arguments for inter-peer communication.

Template Parameters

Service

type for gRPC stub, e.g. proto::Yac

Parameters

params

grpc channel params

Returns

gRPC channel arguments

Here is the call graph for this function:

sendStateAsync()

void iroha::network::sendStateAsync	(	MstState const &	state,
		shared_model::interface::types::PublicKeyHexStringView	sender_key,
		transport::MstTransportGrpc::StubInterface &	client_stub,
		AsyncGrpcClient< google::protobuf::Empty > &	async_call,
		std::function< void(grpc::Status &, google::protobuf::Empty &)>	on_response = {}
	)

Here is the caller graph for this function: