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 |