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

Classes

class  NES::Monitoring::NetworkMetrics
 This class represents the metric values read from /proc/net/dev: bytes The total number of bytes of data transmitted or received by the interface. packets The total number of packets of data transmitted or received by the interface. errs The total number of transmit or receive errors detected by the device driver. fifo The number of FIFO buffer errors. frame The number of packet framing errors. colls The number of collisions detected on the interface. compressed The number of compressed packets transmitted or received by the device driver. (This appears to be unused in the 2.2.15 kernel.) carrier The number of carrier losses detected by the device driver. multicast The number of multicast frames transmitted or received by the device driver. More...
 

Namespaces

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

Functions

class NES::Monitoring::CpuMetrics NES::Monitoring::__attribute__ ((packed))
 
 NetworkMetrics ()
 
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 NetworkMetrics &rhs) const
 
bool operator!= (const NetworkMetrics &rhs) const
 
void NES::Monitoring::writeToBuffer (const NetworkMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
 Writes metrics objects to a given Schema and TupleBuffer. More...
 
void NES::Monitoring::readFromBuffer (NetworkMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
 Parses metrics objects from a given Schema and TupleBuffer. More...
 
nlohmann::json NES::Monitoring::asJson (const NetworkMetrics &metrics)
 Parses the metric to JSON. More...
 

Variables

WorkerId nodeId
 
uint64_t timestamp
 
uint64_t interfaceName
 
uint64_t rBytes
 
uint64_t rPackets
 
uint64_t rErrs
 
uint64_t rDrop
 
uint64_t rFifo
 
uint64_t rFrame
 
uint64_t rCompressed
 
uint64_t rMulticast
 
uint64_t tBytes
 
uint64_t tPackets
 
uint64_t tErrs
 
uint64_t tDrop
 
uint64_t tFifo
 
uint64_t tColls
 
uint64_t tCarrier
 
uint64_t tCompressed
 

Function Documentation

◆ NetworkMetrics()

__attribute__::NetworkMetrics ( )

Referenced by NES::Monitoring::AbstractSystemResourcesReader::readNetworkStats(), and NES::Monitoring::LinuxSystemResourcesReader::readNetworkStats().

Here is the caller graph for this function:

◆ operator!=()

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

◆ operator==()

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

◆ interfaceName

uint64_t interfaceName

◆ nodeId

WorkerId nodeId

◆ rBytes

◆ rCompressed

◆ rDrop

◆ rErrs

◆ rFifo

◆ rFrame

◆ rMulticast

◆ rPackets

◆ tBytes

◆ tCarrier

◆ tColls

◆ tCompressed

◆ tDrop

◆ tErrs

◆ tFifo

◆ timestamp

uint64_t timestamp

◆ tPackets