NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::Network::NetworkChannel Member List

This is the complete list of members for NES::Network::NetworkChannel, including all inherited members.

canSendDataNES::Network::NetworkChannelstatic
canSendEventNES::Network::NetworkChannelstatic
close(Runtime::QueryTerminationType, uint16_t numSendingThreads=0, uint64_t currentMessageSequenceNumber=0, bool shouldPropagateMarker=false, const std::optional< ReconfigurationMarkerPtr > &=std::nullopt)NES::Network::NetworkChannel
create(const std::shared_ptr< zmq::context_t > &zmqContext, std::string &&socketAddr, NesPartition nesPartition, ExchangeProtocol &protocol, Runtime::BufferManagerPtr bufferManager, int highWaterMark, std::chrono::milliseconds waitTime, uint8_t retryTimes, DecomposedQueryPlanVersion version, std::optional< std::future< bool >> abortConnection=std::nullopt)NES::Network::NetworkChannelstatic
NetworkChannel(zmq::socket_t &&zmqSocket, ChannelId channelId, std::string &&address, Runtime::BufferManagerPtr bufferManager)NES::Network::NetworkChannelexplicit
NetworkChannel(const NetworkChannel &)=deleteNES::Network::NetworkChannel
NetworkDataSender(Args &&... args)NES::Network::detail::NetworkDataSender< BaseChannelType >inline
NetworkEventSender(Args &&... args)NES::Network::detail::NetworkEventSender< detail::NetworkDataSender< detail::BaseNetworkChannel > >inline
operator=(const NetworkChannel &)=deleteNES::Network::NetworkChannel
sendBuffer(Runtime::TupleBuffer &buffer, uint64_t tupleSize, uint64_t messageSequenceNumber)NES::Network::detail::NetworkDataSender< BaseChannelType >inline
sendEvent(Arguments &&... args)NES::Network::detail::NetworkEventSender< detail::NetworkDataSender< detail::BaseNetworkChannel > >inline
sendEvent(Runtime::TupleBuffer &&inputBuffer, Runtime::EventType eventType)NES::Network::detail::NetworkEventSender< detail::NetworkDataSender< detail::BaseNetworkChannel > >inline
~NetworkChannel()NES::Network::NetworkChannel