Namespaces | |
| details | |
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 |
| class | OnDemandOrderingInit |
| 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 (shared_model::interface::Peer const &to, MstState const &state, shared_model::interface::types::PublicKeyHexStringView sender_key, AsyncGrpcClient< google::protobuf::Empty > &async_call, std::function< void(grpc::Status &, google::protobuf::Empty &)> on_response={}) |
| std::unique_ptr< GrpcChannelParams > | getDefaultChannelParams () |
| grpc::ChannelArguments | makeChannelArguments (const std::set< std::string > &services, const GrpcChannelParams ¶ms) |
| template<typename Service > | |
| grpc::ChannelArguments | makeChannelArguments (const GrpcChannelParams ¶ms) |
| template<typename Service > | |
| std::unique_ptr< typename Service::StubInterface > | createInsecureClient (const std::string &address, const GrpcChannelParams ¶ms) |
| template<typename Service > | |
| std::unique_ptr< typename Service::StubInterface > | createInsecureClient (const std::string &ip, size_t port, const GrpcChannelParams ¶ms) |
| std::shared_ptr< grpc::Channel > | createInsecureChannel (const shared_model::interface::types::AddressType &address, const std::string &service_full_name, const GrpcChannelParams ¶ms) |
| template<typename T > | |
| auto | createClientWithCredentials (const grpc::string &address, std::shared_ptr< grpc::ChannelCredentials > credentials) |
| template<typename T > | |
| auto | createClient (const grpc::string &address) |
| template<typename T > | |
| std::unique_ptr< typename T::Stub > | createSecureClient (const grpc::string &address, const std::string &root_certificate) |
| std::shared_ptr< const shared_model::interface::Proposal > | getProposalUnsafe (const OrderingEvent &event) |
| auto iroha::network::createClient | ( | const grpc::string & | address | ) |
Creates client which is capable of sending and receiving messages of INT_MAX bytes size
| T | type for gRPC stub, e.g. proto::Yac |
| address | ip address for connection, ipv4:port |
| auto iroha::network::createClientWithCredentials | ( | const grpc::string & | address, |
| std::shared_ptr< grpc::ChannelCredentials > | credentials | ||
| ) |
Creates client with specified credentials, which is capable of sending and receiving messages of INT_MAX bytes size with retry policy (see details::getChannelArguments()).
| T | type for gRPC stub, e.g. proto::Yac |
| address | ip address for connection, ipv4:port |
| credentials | credentials for the gRPC channel |
| 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 client
| 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 |


| std::unique_ptr<typename Service::StubInterface> iroha::network::createInsecureClient | ( | const std::string & | address, |
| const GrpcChannelParams & | params | ||
| ) |
Creates client
| Service | type for gRPC stub, e.g. proto::Yac |
| address | ip address and port for connection, ipv4:port |
| params | grpc channel params |

| std::unique_ptr<typename Service::StubInterface> iroha::network::createInsecureClient | ( | const std::string & | ip, |
| size_t | port, | ||
| const GrpcChannelParams & | params | ||
| ) |
Creates client
| Service | type for gRPC stub, e.g. proto::Yac |
| address | ip address to connect to |
| port | port to connect to |
| params | grpc channel params |

| std::unique_ptr<typename T::Stub> iroha::network::createSecureClient | ( | const grpc::string & | address, |
| const std::string & | root_certificate | ||
| ) |
Creates secure client which is capable of sending and receiving messages of INT_MAX bytes size
| T | type for gRPC stub, e.g. proto::Yac |
| address | ip address for connection, ipv4:port |
| root_certificate | root certificate for the server's CA |
| 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).
| std::shared_ptr< const shared_model::interface::Proposal > iroha::network::getProposalUnsafe | ( | const OrderingEvent & | event | ) |
| grpc::ChannelArguments iroha::network::makeChannelArguments | ( | const std::set< std::string > & | services, |
| const GrpcChannelParams & | params | ||
| ) |


| grpc::ChannelArguments iroha::network::makeChannelArguments | ( | const GrpcChannelParams & | params | ) |
Creates channel arguments corresponding to provided params.
| Service | type for gRPC stub, e.g. proto::Yac |
| params | grpc channel params |

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