NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
This is the complete list of members for NES::Network::NetworkChannel, including all inherited members.
canSendData | NES::Network::NetworkChannel | static |
canSendEvent | NES::Network::NetworkChannel | static |
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::NetworkChannel | static |
NetworkChannel(zmq::socket_t &&zmqSocket, ChannelId channelId, std::string &&address, Runtime::BufferManagerPtr bufferManager) | NES::Network::NetworkChannel | explicit |
NetworkChannel(const NetworkChannel &)=delete | NES::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 &)=delete | NES::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 |