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

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
 

Function Documentation

◆ DiskMetrics()

__attribute__::DiskMetrics ( )

◆ operator!=()

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

◆ operator==()

bool __attribute__::operator== ( const DiskMetrics 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

◆ fBavail

uint64_t fBavail

◆ fBfree

uint64_t fBfree

◆ fBlocks

uint64_t fBlocks

◆ fBsize

uint64_t fBsize

◆ fFrsize

uint64_t fFrsize

◆ nodeId

WorkerId nodeId

◆ timestamp

uint64_t timestamp