NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NetworkMessage.hpp File Reference
#include <Network/ChannelId.hpp>
#include <Reconfiguration/ReconfigurationMarker.hpp>
#include <Runtime/Events.hpp>
#include <Runtime/QueryTerminationType.hpp>
#include <Util/Common.hpp>
#include <cstdint>
#include <stdexcept>
#include <utility>
Include dependency graph for NetworkMessage.hpp:
This graph shows which files directly or indirectly include this file:

Classes

class  NES::Network::Messages::MessageHeader
 this is the pramble of each message that is sent via the network More...
 
class  NES::Network::Messages::ExchangeMessage
 This is the base class for all messages that can be sent in NES. More...
 
class  NES::Network::Messages::ClientAnnounceMessage
 This message is sent when a client announces itself to a server. It's the first message that is sent. More...
 
class  NES::Network::Messages::ServerReadyMessage
 This message is sent back to a client when a server is ready to receive data. More...
 
class  NES::Network::Messages::EndOfStreamMessage
 This message is sent to notify end-of-stream. More...
 
class  NES::Network::Messages::ReconfigurationEventMessage
 This message contains a reconfiguration event which is propagated along the data stream. More...
 
class  NES::Network::Messages::ErrorMessage
 This message represent an error that is sent from the client to the server or vice versa. More...
 
class  NES::Network::Messages::DataBufferMessage
 This is the payload with tuples. More...
 

Namespaces

 NES
 This exception represents a network error.
 
 NES::Network
 
 NES::Network::Messages
 

Typedefs

using NES::Network::Messages::nes_magic_number_t = uint64_t
 This magic number is written as first 64bits of every NES network message. We use this as a checksum to validate that we are not transferring garbage data. More...
 

Enumerations

enum class  NES::Network::Messages::MessageType : uint8_t {
  NES::Network::Messages::ClientAnnouncement , NES::Network::Messages::ServerReady , NES::Network::Messages::DataBuffer , NES::Network::Messages::ErrorMessage ,
  NES::Network::Messages::EndOfStream , NES::Network::Messages::EventBuffer
}
 
enum class  NES::Network::Messages::ErrorType : uint8_t {
  NES::Network::Messages::PartitionNotRegisteredError , NES::Network::Messages::UnknownPartitionError , NES::Network::Messages::DeletedPartitionError , NES::Network::Messages::VersionMismatchError ,
  NES::Network::Messages::UnknownError
}
 this enum defines the errors that can occur in the network stack logic More...
 
enum class  NES::Network::Messages::ChannelType : uint8_t { NES::Network::Messages::DataChannel , NES::Network::Messages::EventOnlyChannel }