|
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 } |