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 |