NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#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>
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 | |
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 } |