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

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

ExchangeProtocol(std::shared_ptr< PartitionManager > partitionManager, std::shared_ptr< ExchangeProtocolListener > listener)NES::Network::ExchangeProtocolexplicit
ExchangeProtocol(const ExchangeProtocol &other)NES::Network::ExchangeProtocol
getPartitionManager() constNES::Network::ExchangeProtocol
onBuffer(NesPartition nesPartition, Runtime::TupleBuffer &buffer, SequenceData messageSequenceData)NES::Network::ExchangeProtocol
onChannelError(Messages::ErrorMessage error)NES::Network::ExchangeProtocol
onClientAnnouncement(Messages::ClientAnnounceMessage msg)NES::Network::ExchangeProtocol
onEndOfStream(Messages::EndOfStreamMessage endOfStreamMessage, std::optional< ReconfigurationMarkerPtr > marker=std::nullopt)NES::Network::ExchangeProtocol
onEvent(NesPartition nesPartition, Runtime::BaseEvent &event)NES::Network::ExchangeProtocol
onServerError(Messages::ErrorMessage error)NES::Network::ExchangeProtocol