NES::Network::detail Namespace Reference

Classes
class	TestSourceWithLatch
struct	TestEvent
class	BaseNetworkChannel
	This is the base class for a network channel with support to connection init and close. More...
class	NetworkDataSender
	Mixin to add sendBuffer semantics to the BaseChannelType. More...
class	NetworkEventSender
	Mixin to add event sending semantics to a base channel. More...
struct	overloaded
class	UlimitNumFdChanger

Functions
template<typename T >
std::unique_ptr< T >	createNetworkChannel (std::shared_ptr< zmq::context_t > const &zmqContext, std::string &&socketAddr, NesPartition nesPartition, ExchangeProtocol &protocol, Runtime::BufferManagerPtr bufferManager, int highWaterMark, std::chrono::milliseconds waitTime, uint8_t retryTimes, DecomposedQueryPlanVersion version=0, std::optional< std::future< bool >> abortConnection=std::nullopt)
template<class... Ts>
	overloaded (Ts...) -> overloaded< Ts... >

Function Documentation

createNetworkChannel()

template<typename T >

std::unique_ptr<T> NES::Network::detail::createNetworkChannel	(	std::shared_ptr< zmq::context_t > const &	zmqContext,
		std::string &&	socketAddr,
		NesPartition	nesPartition,
		ExchangeProtocol &	protocol,
		Runtime::BufferManagerPtr	bufferManager,
		int	highWaterMark,
		std::chrono::milliseconds	waitTime,
		uint8_t	retryTimes,
		DecomposedQueryPlanVersion	version = 0,
		std::optional< std::future< bool >>	abortConnection = std::nullopt
	)

References NES::Network::Messages::DataChannel, NES::Network::Messages::ErrorMessage, NES::Network::Messages::EventOnlyChannel, NES::Runtime::NesThread::getId(), NES::Network::ChannelId::getNesPartition(), backward::details::move(), NES_ASSERT2_FMT, NES_DEBUG, NES_ERROR, NES_INFO, NES_THROW_RUNTIME_ERROR, NES_WARNING, protocol, and NES::Network::Messages::ServerReady.

Here is the call graph for this function:

overloaded()

template<class... Ts>

NES::Network::detail::overloaded

(

Ts...

)

-> overloaded< Ts... >