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

Classes

class  NES::Monitoring::NetworkMetricsWrapper
 Wrapper class to represent a tuple buffer with multiple NetworkMetrics objects. More...
 

Namespaces

 NES
 This exception represents a network error.
 
 NES::Monitoring
 

Functions

class NES::Monitoring::CpuMetrics NES::Monitoring::__attribute__ ((packed))
 
 NetworkMetricsWrapper ()
 
 NetworkMetricsWrapper (WorkerId nodeId)
 
 NetworkMetricsWrapper (std::vector< NetworkMetrics > &&arr)
 
void writeToBuffer (Runtime::TupleBuffer &buf, uint64_t tupleIndex) const
 Writes a wrapper object to a given TupleBuffer. More...
 
void readFromBuffer (Runtime::TupleBuffer &buf, uint64_t tupleIndex)
 Parses a wrapper object from a given TupleBuffer. More...
 
NetworkMetrics getNetworkValue (uint64_t interfaceNo) const
 Returns the Network metrics for a given core. More...
 
void addNetworkMetrics (NetworkMetrics &&nwValue)
 
uint64_t size () const
 
std::vector< std::string > getInterfaceNames ()
 
WorkerId getNodeId () const
 
void setNodeId (WorkerId nodeId)
 
nlohmann::json toJson () const
 Returns the metrics as json. More...
 
bool operator== (const NetworkMetricsWrapper &rhs) const
 
bool operator!= (const NetworkMetricsWrapper &rhs) const
 
void NES::Monitoring::writeToBuffer (const NetworkMetricsWrapper &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
 The serialize method to write metrics into the given Schema and TupleBuffer. More...
 
void NES::Monitoring::readFromBuffer (NetworkMetricsWrapper &wrapper, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
 The deserialize method to read metrics from the given Schema and TupleBuffer. More...
 
nlohmann::json NES::Monitoring::asJson (const NetworkMetricsWrapper &metrics)
 Parses the metric to JSON. More...
 

Function Documentation

◆ addNetworkMetrics()

void __attribute__::addNetworkMetrics ( NetworkMetrics &&  nwValue)

◆ getInterfaceNames()

std::vector<std::string> __attribute__::getInterfaceNames ( )

◆ getNetworkValue()

NetworkMetrics __attribute__::getNetworkValue ( uint64_t  interfaceNo) const

Returns the Network metrics for a given core.

Parameters
NetworkCorecore number
Returns
the Network metrics

◆ getNodeId()

WorkerId __attribute__::getNodeId ( ) const

◆ NetworkMetricsWrapper() [1/3]

__attribute__::NetworkMetricsWrapper ( )

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

Here is the caller graph for this function:

◆ NetworkMetricsWrapper() [2/3]

__attribute__::NetworkMetricsWrapper ( std::vector< NetworkMetrics > &&  arr)

◆ NetworkMetricsWrapper() [3/3]

__attribute__::NetworkMetricsWrapper ( WorkerId  nodeId)

◆ operator!=()

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

◆ operator==()

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

◆ readFromBuffer()

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

Parses a wrapper object from a given TupleBuffer.

Parameters
buf
tupleIndex

◆ setNodeId()

void __attribute__::setNodeId ( WorkerId  nodeId)

◆ size()

uint64_t __attribute__::size ( ) const

◆ 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 wrapper object to a given TupleBuffer.

Parameters
buf
tupleIndex