|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <Monitoring/MonitoringForwardRefs.hpp>#include <Runtime/RuntimeForwardRefs.hpp>#include <Util/TopologyLinkInformation.hpp>Classes | |
| class | NES::Monitoring::DiskMetrics |
| DiskMetrics class, that is responsible for collecting and managing disk metrics. More... | |
Namespaces | |
| NES | |
| This exception represents a network error. | |
| NES::Configurations | |
| NES::Monitoring | |
Typedefs | |
| using | NES::Monitoring::DiskMetricsPtr = std::shared_ptr< DiskMetrics > |
Functions | |
| class NES::Monitoring::CpuMetrics | NES::Monitoring::__attribute__ ((packed)) |
| DiskMetrics () | |
| 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 DiskMetrics &rhs) const |
| bool | operator!= (const DiskMetrics &rhs) const |
| void | NES::Monitoring::writeToBuffer (const DiskMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex) |
| The serialize method to write metrics into the given Schema and TupleBuffer. More... | |
| void | NES::Monitoring::readFromBuffer (DiskMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex) |
| Parses metrics objects from a given Schema and TupleBuffer. More... | |
| nlohmann::json | NES::Monitoring::asJson (const DiskMetrics &metrics) |
| Parses the metric to JSON. More... | |
Variables | |
| WorkerId | nodeId |
| uint64_t | timestamp |
| uint64_t | fBsize |
| uint64_t | fFrsize |
| uint64_t | fBlocks |
| uint64_t | fBfree |
| uint64_t | fBavail |
| __attribute__::DiskMetrics | ( | ) |
| bool __attribute__::operator!= | ( | const DiskMetrics & | rhs | ) | const |
| bool __attribute__::operator== | ( | const DiskMetrics & | 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 fBavail |
| uint64_t fBfree |
| uint64_t fBlocks |
| uint64_t fBsize |
| uint64_t fFrsize |
| WorkerId nodeId |
| uint64_t timestamp |