|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <Identifiers/Identifiers.hpp>#include <Monitoring/Metrics/Gauge/NetworkMetrics.hpp>#include <Monitoring/MonitoringForwardRefs.hpp>#include <Runtime/RuntimeForwardRefs.hpp>#include <vector>Classes | |
| class | NES::Monitoring::NetworkMetricsWrapper |
| Wrapper class to represent a tuple buffer with multiple NetworkMetrics objects. More... | |
Namespaces | |
| NES | |
| This exception represents a network error. | |
| NES::Monitoring | |
Functions | |
| class NES::Monitoring::CpuMetrics | NES::Monitoring::__attribute__ ((packed)) |
| NetworkMetricsWrapper () | |
| NetworkMetricsWrapper (WorkerId nodeId) | |
| NetworkMetricsWrapper (std::vector< NetworkMetrics > &&arr) | |
| void | writeToBuffer (Runtime::TupleBuffer &buf, uint64_t tupleIndex) const |
| Writes a wrapper object to a given TupleBuffer. More... | |
| void | readFromBuffer (Runtime::TupleBuffer &buf, uint64_t tupleIndex) |
| Parses a wrapper object from a given TupleBuffer. More... | |
| NetworkMetrics | getNetworkValue (uint64_t interfaceNo) const |
| Returns the Network metrics for a given core. More... | |
| void | addNetworkMetrics (NetworkMetrics &&nwValue) |
| uint64_t | size () const |
| std::vector< std::string > | getInterfaceNames () |
| WorkerId | getNodeId () const |
| void | setNodeId (WorkerId nodeId) |
| nlohmann::json | toJson () const |
| Returns the metrics as json. More... | |
| bool | operator== (const NetworkMetricsWrapper &rhs) const |
| bool | operator!= (const NetworkMetricsWrapper &rhs) const |
| void | NES::Monitoring::writeToBuffer (const NetworkMetricsWrapper &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex) |
| The serialize method to write metrics into the given Schema and TupleBuffer. More... | |
| void | NES::Monitoring::readFromBuffer (NetworkMetricsWrapper &wrapper, Runtime::TupleBuffer &buf, uint64_t tupleIndex) |
| The deserialize method to read metrics from the given Schema and TupleBuffer. More... | |
| nlohmann::json | NES::Monitoring::asJson (const NetworkMetricsWrapper &metrics) |
| Parses the metric to JSON. More... | |
| void __attribute__::addNetworkMetrics | ( | NetworkMetrics && | nwValue | ) |
| std::vector<std::string> __attribute__::getInterfaceNames | ( | ) |
| NetworkMetrics __attribute__::getNetworkValue | ( | uint64_t | interfaceNo | ) | const |
Returns the Network metrics for a given core.
| NetworkCore | core number |
| WorkerId __attribute__::getNodeId | ( | ) | const |
| __attribute__::NetworkMetricsWrapper | ( | ) |
Referenced by NES::Monitoring::LinuxSystemResourcesReader::readNetworkStats().
| __attribute__::NetworkMetricsWrapper | ( | std::vector< NetworkMetrics > && | arr | ) |
| __attribute__::NetworkMetricsWrapper | ( | WorkerId | nodeId | ) |
| bool __attribute__::operator!= | ( | const NetworkMetricsWrapper & | rhs | ) | const |
| bool __attribute__::operator== | ( | const NetworkMetricsWrapper & | rhs | ) | const |
| void __attribute__::readFromBuffer | ( | Runtime::TupleBuffer & | buf, |
| uint64_t | tupleIndex | ||
| ) |
Parses a wrapper object from a given TupleBuffer.
| buf | |
| tupleIndex |
| void __attribute__::setNodeId | ( | WorkerId | nodeId | ) |
| uint64_t __attribute__::size | ( | ) | const |
| nlohmann::json __attribute__::toJson | ( | ) | const |
Returns the metrics as json.
| void __attribute__::writeToBuffer | ( | Runtime::TupleBuffer & | buf, |
| uint64_t | tupleIndex | ||
| ) | const |
Writes a wrapper object to a given TupleBuffer.
| buf | |
| tupleIndex |