NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <Identifiers/Identifiers.hpp>
#include <Monitoring/MonitoringForwardRefs.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>
Classes | |
class | NES::Monitoring::NetworkMetrics |
This class represents the metric values read from /proc/net/dev: bytes The total number of bytes of data transmitted or received by the interface. packets The total number of packets of data transmitted or received by the interface. errs The total number of transmit or receive errors detected by the device driver. fifo The number of FIFO buffer errors. frame The number of packet framing errors. colls The number of collisions detected on the interface. compressed The number of compressed packets transmitted or received by the device driver. (This appears to be unused in the 2.2.15 kernel.) carrier The number of carrier losses detected by the device driver. multicast The number of multicast frames transmitted or received by the device driver. More... | |
Namespaces | |
NES | |
This exception represents a network error. | |
NES::Configurations | |
NES::Monitoring | |
Functions | |
class NES::Monitoring::CpuMetrics | NES::Monitoring::__attribute__ ((packed)) |
NetworkMetrics () | |
void | writeToBuffer (Runtime::TupleBuffer &buf, uint64_t tupleIndex) const |
Writes a metrics objects to the given TupleBuffer and index. More... | |
void | readFromBuffer (Runtime::TupleBuffer &buf, uint64_t tupleIndex) |
Parses a metrics objects from a TupleBuffer.. More... | |
nlohmann::json | toJson () const |
Returns the metrics as json. More... | |
bool | operator== (const NetworkMetrics &rhs) const |
bool | operator!= (const NetworkMetrics &rhs) const |
void | NES::Monitoring::writeToBuffer (const NetworkMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex) |
Writes metrics objects to a given Schema and TupleBuffer. More... | |
void | NES::Monitoring::readFromBuffer (NetworkMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex) |
Parses metrics objects from a given Schema and TupleBuffer. More... | |
nlohmann::json | NES::Monitoring::asJson (const NetworkMetrics &metrics) |
Parses the metric to JSON. More... | |
Variables | |
WorkerId | nodeId |
uint64_t | timestamp |
uint64_t | interfaceName |
uint64_t | rBytes |
uint64_t | rPackets |
uint64_t | rErrs |
uint64_t | rDrop |
uint64_t | rFifo |
uint64_t | rFrame |
uint64_t | rCompressed |
uint64_t | rMulticast |
uint64_t | tBytes |
uint64_t | tPackets |
uint64_t | tErrs |
uint64_t | tDrop |
uint64_t | tFifo |
uint64_t | tColls |
uint64_t | tCarrier |
uint64_t | tCompressed |
__attribute__::NetworkMetrics | ( | ) |
Referenced by NES::Monitoring::AbstractSystemResourcesReader::readNetworkStats(), and NES::Monitoring::LinuxSystemResourcesReader::readNetworkStats().
bool __attribute__::operator!= | ( | const NetworkMetrics & | rhs | ) | const |
bool __attribute__::operator== | ( | const NetworkMetrics & | rhs | ) | const |
void __attribute__::readFromBuffer | ( | Runtime::TupleBuffer & | buf, |
uint64_t | tupleIndex | ||
) |
Parses a metrics objects from a TupleBuffer..
buf | the tuple buffer |
the | tuple index indicating the location of the tuple |
nlohmann::json __attribute__::toJson | ( | ) | const |
Returns the metrics as json.
void __attribute__::writeToBuffer | ( | Runtime::TupleBuffer & | buf, |
uint64_t | tupleIndex | ||
) | const |
Writes a metrics objects to the given TupleBuffer and index.
buf | the tuple buffer |
tupleIndex | the index indication its location in the buffer |
uint64_t interfaceName |
WorkerId nodeId |
uint64_t rBytes |
uint64_t rCompressed |
uint64_t rDrop |
uint64_t rErrs |
uint64_t rFifo |
uint64_t rFrame |
uint64_t rMulticast |
uint64_t rPackets |
uint64_t tBytes |
uint64_t tCarrier |
uint64_t tColls |
uint64_t tCompressed |
uint64_t tDrop |
uint64_t tErrs |
uint64_t tFifo |
uint64_t timestamp |
uint64_t tPackets |