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

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

create(WorkerId nodeEngineId, const std::string &hostname, uint16_t port, Network::ExchangeProtocol &&exchangeProtocol, const Runtime::BufferManagerPtr &bufferManager, int senderHighWatermark=-1, uint16_t numServerThread=DEFAULT_NUM_SERVER_THREADS, bool connectSinksAsync=false, bool connectSourceEventChannelsAsync=false)NES::Network::NetworkManagerstatic
destroy()NES::Network::NetworkManager
getConnectSinksAsync()NES::Network::NetworkManager
getConnectSourceEventChannelsAsync()NES::Network::NetworkManager
getServerDataPort() constNES::Network::NetworkManager
getServerLocation() constNES::Network::NetworkManager
isPartitionConsumerRegistered(const NesPartition &nesPartition) constNES::Network::NetworkManager
isPartitionProducerRegistered(const NesPartition &nesPartition) constNES::Network::NetworkManager
NetworkManager(WorkerId nodeEngineId, const std::string &hostname, uint16_t port, ExchangeProtocol &&exchangeProtocol, const Runtime::BufferManagerPtr &bufferManager, int senderHighWatermark, uint16_t numServerThread=DEFAULT_NUM_SERVER_THREADS, bool connectSinksAsync=false, bool connectSourceEventChannelsAsync=false)NES::Network::NetworkManagerexplicit
registerSubpartitionConsumer(const NesPartition &nesPartition, const NodeLocation &senderLocation, const DataEmitterPtr &emitter) constNES::Network::NetworkManager
registerSubpartitionEventConsumer(const NodeLocation &nodeLocation, const NesPartition &nesPartition, Runtime::RuntimeEventListenerPtr eventListener)NES::Network::NetworkManager
registerSubpartitionEventProducer(const NodeLocation &nodeLocation, const NesPartition &nesPartition, Runtime::BufferManagerPtr bufferManager, std::chrono::milliseconds waitTime, uint8_t retryTimes)NES::Network::NetworkManager
registerSubpartitionEventProducerAsync(const NodeLocation &nodeLocation, const NesPartition &nesPartition, Runtime::BufferManagerPtr bufferManager, std::chrono::milliseconds waitTime, uint8_t retryTimes)NES::Network::NetworkManager
registerSubpartitionProducer(const NodeLocation &nodeLocation, const NesPartition &nesPartition, Runtime::BufferManagerPtr bufferManager, std::chrono::milliseconds waitTime, uint8_t retryTimes, DecomposedQueryPlanVersion version=0)NES::Network::NetworkManager
registerSubpartitionProducerAsync(const NodeLocation &nodeLocation, const NesPartition &nesPartition, Runtime::BufferManagerPtr bufferManager, std::chrono::milliseconds waitTime, uint8_t retryTimes, Runtime::ReconfigurationMessage reconfigurationMessage, Runtime::QueryManagerPtr queryManager, DecomposedQueryPlanVersion version=0)NES::Network::NetworkManager
unregisterSubpartitionConsumer(const NesPartition &nesPartition) constNES::Network::NetworkManager
unregisterSubpartitionProducer(const NesPartition &nesPartition) constNES::Network::NetworkManager
~NetworkManager()NES::Network::NetworkManager