NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
MemoryMetrics.hpp File Reference
Include dependency graph for MemoryMetrics.hpp:
This graph shows which files directly or indirectly include this file:

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
 

Function Documentation

◆ MemoryMetrics()

__attribute__::MemoryMetrics ( )

Referenced by NES::Monitoring::LinuxSystemResourcesReader::readMemoryStats().

Here is the caller graph for this function:

◆ operator!=()

bool __attribute__::operator!= ( const MemoryMetrics rhs) const

◆ operator==()

bool __attribute__::operator== ( const MemoryMetrics rhs) const

◆ readFromBuffer()

void __attribute__::readFromBuffer ( Runtime::TupleBuffer &  buf,
uint64_t  tupleIndex 
)

Parses a metrics objects from a TupleBuffer..

Parameters
bufthe tuple buffer
thetuple index indicating the location of the tuple

◆ toJson()

nlohmann::json __attribute__::toJson ( ) const

Returns the metrics as json.

Returns
Json containing the metrics

◆ writeToBuffer()

void __attribute__::writeToBuffer ( Runtime::TupleBuffer &  buf,
uint64_t  tupleIndex 
) const

Writes a metrics objects to the given TupleBuffer and index.

Parameters
bufthe tuple buffer
tupleIndexthe index indication its location in the buffer

Variable Documentation

◆ BUFFER_RAM

uint64_t BUFFER_RAM

◆ FREE_HIGH

uint64_t FREE_HIGH

◆ FREE_RAM

uint64_t FREE_RAM

◆ FREE_SWAP

uint64_t FREE_SWAP

◆ LOADS_15MIN

uint64_t LOADS_15MIN

◆ LOADS_1MIN

uint64_t LOADS_1MIN

◆ LOADS_5MIN

uint64_t LOADS_5MIN

◆ MEM_UNIT

uint64_t MEM_UNIT

◆ nodeId

WorkerId nodeId

◆ PROCS

uint64_t PROCS

◆ SHARED_RAM

uint64_t SHARED_RAM

◆ timestamp

uint64_t timestamp

◆ TOTAL_HIGH

uint64_t TOTAL_HIGH

◆ TOTAL_RAM

uint64_t TOTAL_RAM

◆ TOTAL_SWAP

uint64_t TOTAL_SWAP