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::MemoryMetrics |
MemoryMetrics class, that is responsible for collecting and managing memory metrics. More... | |
Namespaces | |
NES | |
This exception represents a network error. | |
NES::Configurations | |
NES::Monitoring | |
Typedefs | |
using | NES::Monitoring::MemoryMetricsPtr = std::shared_ptr< MemoryMetrics > |
Functions | |
class NES::Monitoring::CpuMetrics | NES::Monitoring::__attribute__ ((packed)) |
MemoryMetrics () | |
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 MemoryMetrics &rhs) const |
bool | operator!= (const MemoryMetrics &rhs) const |
void | NES::Monitoring::writeToBuffer (const MemoryMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex) |
Writes metrics objects to a given Schema and TupleBuffer. More... | |
void | NES::Monitoring::readFromBuffer (MemoryMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex) |
Parses metrics objects from a given Schema and TupleBuffer. More... | |
nlohmann::json | NES::Monitoring::asJson (const MemoryMetrics &metrics) |
Parses the metric to JSON. More... | |
Variables | |
WorkerId | nodeId |
uint64_t | timestamp |
uint64_t | TOTAL_RAM |
uint64_t | TOTAL_SWAP |
uint64_t | FREE_RAM |
uint64_t | SHARED_RAM |
uint64_t | BUFFER_RAM |
uint64_t | FREE_SWAP |
uint64_t | TOTAL_HIGH |
uint64_t | FREE_HIGH |
uint64_t | PROCS |
uint64_t | MEM_UNIT |
uint64_t | LOADS_1MIN |
uint64_t | LOADS_5MIN |
uint64_t | LOADS_15MIN |
__attribute__::MemoryMetrics | ( | ) |
Referenced by NES::Monitoring::LinuxSystemResourcesReader::readMemoryStats().
bool __attribute__::operator!= | ( | const MemoryMetrics & | rhs | ) | const |
bool __attribute__::operator== | ( | const MemoryMetrics & | 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 BUFFER_RAM |
uint64_t FREE_HIGH |
uint64_t FREE_RAM |
uint64_t FREE_SWAP |
uint64_t LOADS_15MIN |
uint64_t LOADS_1MIN |
uint64_t LOADS_5MIN |
uint64_t MEM_UNIT |
WorkerId nodeId |
uint64_t PROCS |
uint64_t SHARED_RAM |
uint64_t timestamp |
uint64_t TOTAL_HIGH |
uint64_t TOTAL_RAM |
uint64_t TOTAL_SWAP |