Classes
class	MonitoringManager
	The MonitoringManager is responsible for managing all global metrics of all nodes in the topology. More...

class	CpuCollector

class	DiskCollector

class	MemoryCollector

class	MetricCollector

class	NetworkCollector

class	CpuMetrics
	This class represents the metrics read from /proc/stat: usr – % CPU usage at the user level nice – % CPU usage for user processes labeled “nice” sys – % CPU usage at the system (Linux kernel) level iowait – % CPU usage idling waiting on a disk read/write irq – % CPU usage handling hardware interrupts soft – % CPU usage handing software interrupts steal – % CPU usage being forced to wait for a hypervisor handling other virtual processors guest – % CPU usage spent running a virtual processor idle – % CPU usage on idle time (no processes, and not waiting on a disk read/write) More...

class	DiskMetrics
	DiskMetrics class, that is responsible for collecting and managing disk metrics. More...

class	MemoryMetrics
	MemoryMetrics class, that is responsible for collecting and managing memory metrics. More...

class	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...

class	RegistrationMetrics

class	RuntimeMetrics
	Wrapper class to represent the metrics read from the OS about dynamically changing data represented in other metric classes. More...

class	Metric
	The metric class is a conceptual superclass that represents all metrics in NES. Currently existing metrics are Counter, GaugeCollectors, Histogram and Meter. More...

class	CpuMetricsWrapper
	Wrapper class to represent a tuple buffer with multiple CpuMetrics objects. More...

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

class	MonitoringAgent
	The MonitoringAgent which is responsible for collecting metrics on a local level. More...

class	MonitoringCatalog

class	MonitoringPlan
	The MonitoringPlan is a config class to represent what metrics shall be collected and how. More...

class	AbstractSystemResourcesReader
	This is an abstract class so derived classes can collect basic system information Warning: Only Linux distributions are currently supported. More...

class	LinuxSystemResourcesReader
	This is a static utility class to collect basic system information on a Linux operating System Warning: Only Linux distributions are currently supported. More...

class	SystemResourcesReaderFactory

class	AbstractMetricStore
	The LatestEntriesMetricStore that stores all the metrics for monitoring. More...

class	AllEntriesMetricStore
	The AllEntriesMetricStore that stores all the metrics for monitoring. More...

class	LatestEntriesMetricStore
	The LatestEntriesMetricStore that stores all the metrics for monitoring. More...

class	MetricUtils
	Pre-defined metrics used for NES internally. More...

Typedefs
using	MonitoringManagerPtr = std::shared_ptr< MonitoringManager >

using	MonitoringPlanPtr = std::shared_ptr< MonitoringPlan >

using	SourceCatalogPtr = std::shared_ptr< SourceCatalog >

using	NesCoordinatorPtr = std::shared_ptr< NesCoordinator >

using	NesWorkerPtr = std::shared_ptr< NesWorker >

using	CpuCollectorPtr = std::shared_ptr< CpuCollector >

using	DiskCollectorPtr = std::shared_ptr< DiskCollector >

using	MemoryCollectorPtr = std::shared_ptr< MemoryCollector >

using	MetricCollectorPtr = std::shared_ptr< MetricCollector >

using	NetworkCollectorPtr = std::shared_ptr< NetworkCollector >

using	DiskMetricsPtr = std::shared_ptr< DiskMetrics >

using	MemoryMetricsPtr = std::shared_ptr< MemoryMetrics >

using	RegistrationMetricsPtr = std::shared_ptr< RegistrationMetrics >

using	RuntimeNesMetricsPtr = std::shared_ptr< RuntimeMetrics >

using	MetricPtr = std::shared_ptr< Metric >

using	MonitoringAgentPtr = std::shared_ptr< MonitoringAgent >

using	MonitoringCatalogPtr = std::shared_ptr< MonitoringCatalog >

using	AbstractSystemResourcesReaderPtr = std::shared_ptr< AbstractSystemResourcesReader >

using	MetricStorePtr = std::shared_ptr< AbstractMetricStore >

using	TimestampMetricPtr = std::shared_ptr< std::pair< uint64_t, MetricPtr > >

using	StoredNodeMetricsPtr = std::shared_ptr< std::unordered_map< MetricType, std::shared_ptr< std::vector< TimestampMetricPtr > >> >

Enumerations
enum class	MetricType : uint8_t { CpuMetric , DiskMetric , MemoryMetric , NetworkMetric , RuntimeMetric , RegistrationMetric , WrappedCpuMetrics , WrappedNetworkMetrics , UnknownMetric }
	The metric types of NES represented in the subdirectories of Metrics/.. More...

enum class	MetricStoreType : uint8_t { AllEntries , NewestEntry }
	The metric types of NES represented in the subdirectories of Metrics/.. More...

enum class	MetricCollectorType : uint8_t { CPU_COLLECTOR , DISK_COLLECTOR , MEMORY_COLLECTOR , NETWORK_COLLECTOR , INVALID }

Functions
class NES::Monitoring::CpuMetrics	__attribute__ ((packed))

void	writeToBuffer (const CpuMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	The serialize method to write metrics into the given Schema and TupleBuffer. More...

void	readFromBuffer (CpuMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	Parses a metrics objects from a given Schema and TupleBuffer. More...

nlohmann::json	asJson (const CpuMetrics &metrics)
	Parses the metric to JSON. More...

void	writeToBuffer (const DiskMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	The serialize method to write metrics into the given Schema and TupleBuffer. More...

void	readFromBuffer (DiskMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	Parses metrics objects from a given Schema and TupleBuffer. More...

nlohmann::json	asJson (const DiskMetrics &metrics)
	Parses the metric to JSON. More...

void	writeToBuffer (const MemoryMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	Writes metrics objects to a given Schema and TupleBuffer. More...

void	readFromBuffer (MemoryMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	Parses metrics objects from a given Schema and TupleBuffer. More...

nlohmann::json	asJson (const MemoryMetrics &metrics)
	Parses the metric to JSON. More...

void	writeToBuffer (const NetworkMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	Writes metrics objects to a given Schema and TupleBuffer. More...

void	readFromBuffer (NetworkMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	Parses metrics objects from a given Schema and TupleBuffer. More...

nlohmann::json	asJson (const NetworkMetrics &metrics)
	Parses the metric to JSON. More...

void	writeToBuffer (const RegistrationMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	The serialize method to write metrics into the given Schema and TupleBuffer. More...

void	readFromBuffer (RegistrationMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	Parses a metrics objects from a given Schema and TupleBuffer. More...

nlohmann::json	asJson (const RegistrationMetrics &metrics)
	Parses the metric to JSON. More...

void	writeToBuffer (const RuntimeMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	Writes metrics objects to a given Schema and TupleBuffer. More...

void	readFromBuffer (RuntimeMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	Parses metrics objects from a given Schema and TupleBuffer. More...

nlohmann::json	asJson (const RuntimeMetrics &metrics)
	Parses the metric to JSON. More...

void	writeToBuffer (const uint64_t &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	Class specific serialize methods for basic types. The serialize method to write CpuMetricsWrapper into the given Schema and TupleBuffer. The prefix specifies a string that should be added before each field description in the Schema. More...

void	writeToBuffer (const std::string &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)

void	writeToBuffer (const std::shared_ptr< Metric > metric, Runtime::TupleBuffer &buf, uint64_t tupleIndex)

void	readFromBuffer (uint64_t &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	class specific readFromBuffer() More...

void	readFromBuffer (std::string &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)

void	readFromBuffer (std::shared_ptr< Metric > metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)

nlohmann::json	asJson (uint64_t intMetric)
	class specific asJson() More...

nlohmann::json	asJson (std::string stringMetric)

nlohmann::json	asJson (std::shared_ptr< Metric > ptrMetric)

std::string	toString (MetricType metricType)

void	writeToBuffer (const CpuMetricsWrapper &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	The serialize method to write metrics into the given Schema and TupleBuffer. More...

void	readFromBuffer (CpuMetricsWrapper &wrapper, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	The deserialize method to read metrics from the given Schema and TupleBuffer. More...

nlohmann::json	asJson (const CpuMetricsWrapper &metrics)
	Parses the metric to JSON. More...

void	writeToBuffer (const NetworkMetricsWrapper &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	The serialize method to write metrics into the given Schema and TupleBuffer. More...

void	readFromBuffer (NetworkMetricsWrapper &wrapper, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	The deserialize method to read metrics from the given Schema and TupleBuffer. More...

nlohmann::json	asJson (const NetworkMetricsWrapper &metrics)
	Parses the metric to JSON. More...

std::ostream &	operator<< (std::ostream &os, const CpuMetrics &values)

SchemaPtr	getSchema (const MemoryMetrics &, const std::string &prefix)

std::ostream &	operator<< (std::ostream &strm, const MonitoringPlan &plan)

Typedef Documentation

◆ AbstractSystemResourcesReaderPtr

typedef std::shared_ptr< AbstractSystemResourcesReader > NES::Monitoring::AbstractSystemResourcesReaderPtr

◆ CpuCollectorPtr

using NES::Monitoring::CpuCollectorPtr = typedef std::shared_ptr<CpuCollector>

◆ DiskCollectorPtr

using NES::Monitoring::DiskCollectorPtr = typedef std::shared_ptr<DiskCollector>

◆ DiskMetricsPtr

using NES::Monitoring::DiskMetricsPtr = typedef std::shared_ptr<DiskMetrics>

◆ MemoryCollectorPtr

using NES::Monitoring::MemoryCollectorPtr = typedef std::shared_ptr<MemoryCollector>

◆ MemoryMetricsPtr

using NES::Monitoring::MemoryMetricsPtr = typedef std::shared_ptr<MemoryMetrics>

◆ MetricCollectorPtr

typedef std::shared_ptr< MetricCollector > NES::Monitoring::MetricCollectorPtr

◆ MetricPtr

typedef std::shared_ptr< Metric > NES::Monitoring::MetricPtr

◆ MetricStorePtr

typedef std::shared_ptr< AbstractMetricStore > NES::Monitoring::MetricStorePtr

◆ MonitoringAgentPtr

using NES::Monitoring::MonitoringAgentPtr = typedef std::shared_ptr<MonitoringAgent>

◆ MonitoringCatalogPtr

typedef std::shared_ptr< MonitoringCatalog > NES::Monitoring::MonitoringCatalogPtr

◆ MonitoringManagerPtr

typedef std::shared_ptr< MonitoringManager > NES::Monitoring::MonitoringManagerPtr

◆ MonitoringPlanPtr

typedef std::shared_ptr< MonitoringPlan > NES::Monitoring::MonitoringPlanPtr

◆ NesCoordinatorPtr

using NES::Monitoring::NesCoordinatorPtr = typedef std::shared_ptr<NesCoordinator>

◆ NesWorkerPtr

typedef std::shared_ptr< NesWorker > NES::Monitoring::NesWorkerPtr

◆ NetworkCollectorPtr

using NES::Monitoring::NetworkCollectorPtr = typedef std::shared_ptr<NetworkCollector>

◆ RegistrationMetricsPtr

using NES::Monitoring::RegistrationMetricsPtr = typedef std::shared_ptr<RegistrationMetrics>

◆ RuntimeNesMetricsPtr

using NES::Monitoring::RuntimeNesMetricsPtr = typedef std::shared_ptr<RuntimeMetrics>

◆ SourceCatalogPtr

using NES::Monitoring::SourceCatalogPtr = typedef std::shared_ptr<SourceCatalog>

◆ StoredNodeMetricsPtr

using NES::Monitoring::StoredNodeMetricsPtr = typedef std::shared_ptr<std::unordered_map<MetricType, std::shared_ptr<std::vector<TimestampMetricPtr> >> >

◆ TimestampMetricPtr

using NES::Monitoring::TimestampMetricPtr = typedef std::shared_ptr<std::pair<uint64_t, MetricPtr> >

Enumeration Type Documentation

◆ MetricCollectorType

enum NES::Monitoring::MetricCollectorType : uint8_t

strong

Enumerator
CPU_COLLECTOR
DISK_COLLECTOR
MEMORY_COLLECTOR
NETWORK_COLLECTOR
INVALID

◆ MetricStoreType

enum NES::Monitoring::MetricStoreType : uint8_t

strong

The metric types of NES represented in the subdirectories of Metrics/..

Enumerator
AllEntries
NewestEntry

◆ MetricType

enum NES::Monitoring::MetricType : uint8_t

strong

The metric types of NES represented in the subdirectories of Metrics/..

Enumerator
CpuMetric
DiskMetric
MemoryMetric
NetworkMetric
RuntimeMetric
RegistrationMetric
WrappedCpuMetrics
WrappedNetworkMetrics
UnknownMetric

Function Documentation

◆ attribute()

class NES::Monitoring::NetworkMetricsWrapper NES::Monitoring::__attribute__ ( (packed) )

◆ asJson() [1/11]

nlohmann::json NES::Monitoring::asJson ( const CpuMetrics & metrics )

Parses the metric to JSON.

Parameters

metrics

Returns: the metrics as JSON

References NES::Monitoring::CpuMetrics::toJson().

Referenced by NES::Monitoring::AllEntriesMetricStore::addMetrics(), NES::Monitoring::LatestEntriesMetricStore::addMetrics(), asJson(), NES::Monitoring::CpuCollector::fillBuffer(), NES::Monitoring::NetworkCollector::fillBuffer(), NES::Monitoring::MonitoringAgent::getMetricsAsJson(), NES::TEST_F(), NES::Monitoring::MetricUtils::toJson(), and NES::MonitoringSink::writeData().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ asJson() [2/11]

nlohmann::json NES::Monitoring::asJson ( const CpuMetricsWrapper & metrics )

Parses the metric to JSON.

Parameters

metrics

Returns: the metrics as JSON

References NES::Monitoring::CpuMetricsWrapper::toJson().

Here is the call graph for this function:

◆ asJson() [3/11]

nlohmann::json NES::Monitoring::asJson ( const DiskMetrics & metrics )

Parses the metric to JSON.

Parameters

metrics

Returns: the metrics as JSON

References NES::Monitoring::DiskMetrics::toJson().

Here is the call graph for this function:

◆ asJson() [4/11]

nlohmann::json NES::Monitoring::asJson ( const MemoryMetrics & metrics )

Parses the metric to JSON.

Parameters

metrics

Returns: the metrics as JSON

References NES::Monitoring::MemoryMetrics::toJson().

Here is the call graph for this function:

◆ asJson() [5/11]

nlohmann::json NES::Monitoring::asJson ( const NetworkMetrics & metrics )

Parses the metric to JSON.

Parameters

metrics

Returns: the metrics as JSON

References NES::Monitoring::NetworkMetrics::toJson().

Here is the call graph for this function:

◆ asJson() [6/11]

nlohmann::json NES::Monitoring::asJson ( const NetworkMetricsWrapper & metrics )

Parses the metric to JSON.

Parameters

metrics

Returns: the metrics as JSON

References NES::Monitoring::NetworkMetricsWrapper::toJson().

Here is the call graph for this function:

◆ asJson() [7/11]

nlohmann::json NES::Monitoring::asJson ( const RegistrationMetrics & metrics )

Parses the metric to JSON.

Parameters

metrics

Returns: the metrics as JSON

References NES::Monitoring::RegistrationMetrics::toJson().

Here is the call graph for this function:

◆ asJson() [8/11]

nlohmann::json NES::Monitoring::asJson ( const RuntimeMetrics & metrics )

Parses the metric to JSON.

Parameters

metrics

Returns: the metrics as JSON

References NES::Monitoring::RuntimeMetrics::toJson().

Here is the call graph for this function:

◆ asJson() [9/11]

nlohmann::json NES::Monitoring::asJson ( std::shared_ptr< Metric > ptrMetric )

References asJson().

Here is the call graph for this function:

◆ asJson() [10/11]

nlohmann::json NES::Monitoring::asJson ( std::string stringMetric )

◆ asJson() [11/11]

nlohmann::json NES::Monitoring::asJson ( uint64_t intMetric )

class specific asJson()

Returns: the value

◆ getSchema()

SchemaPtr NES::Monitoring::getSchema	(	const MemoryMetrics &	,
		const std::string &	prefix
	)

References NES::Monitoring::MemoryMetrics::getSchema().

Here is the call graph for this function:

◆ operator<<() [1/2]

std::ostream& NES::Monitoring::operator<<	(	std::ostream &	os,
		const CpuMetrics &	values
	)

Parameters

os
values

Returns: the source

◆ operator<<() [2/2]

std::ostream& NES::Monitoring::operator<<	(	std::ostream &	strm,
		const MonitoringPlan &	plan
	)

◆ readFromBuffer() [1/11]

void NES::Monitoring::readFromBuffer	(	CpuMetrics &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

Parses a metrics objects from a given Schema and TupleBuffer.

Parameters

the	CpuMetrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

Returns: The object

References NES::Monitoring::CpuMetrics::readFromBuffer().

Referenced by NES::Monitoring::CpuMetricsWrapper::readFromBuffer(), NES::Monitoring::NetworkMetricsWrapper::readFromBuffer(), readFromBuffer(), and NES::MonitoringSink::writeData().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ readFromBuffer() [2/11]

void NES::Monitoring::readFromBuffer	(	CpuMetricsWrapper &	wrapper,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

The deserialize method to read metrics from the given Schema and TupleBuffer.

Parameters

the	metrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::CpuMetricsWrapper::readFromBuffer().

Here is the call graph for this function:

◆ readFromBuffer() [3/11]

void NES::Monitoring::readFromBuffer	(	DiskMetrics &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

Parses metrics objects from a given Schema and TupleBuffer.

Parameters

the	metrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::DiskMetrics::readFromBuffer().

Here is the call graph for this function:

◆ readFromBuffer() [4/11]

void NES::Monitoring::readFromBuffer	(	MemoryMetrics &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

Parses metrics objects from a given Schema and TupleBuffer.

Parameters

the	metrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::MemoryMetrics::readFromBuffer().

Here is the call graph for this function:

◆ readFromBuffer() [5/11]

void NES::Monitoring::readFromBuffer	(	NetworkMetrics &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

Parses metrics objects from a given Schema and TupleBuffer.

Parameters

the	metrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::NetworkMetrics::readFromBuffer().

Here is the call graph for this function:

◆ readFromBuffer() [6/11]

void NES::Monitoring::readFromBuffer	(	NetworkMetricsWrapper &	wrapper,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

The deserialize method to read metrics from the given Schema and TupleBuffer.

Parameters

the	metrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::NetworkMetricsWrapper::readFromBuffer().

Here is the call graph for this function:

◆ readFromBuffer() [7/11]

void NES::Monitoring::readFromBuffer	(	RegistrationMetrics &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

Parses a metrics objects from a given Schema and TupleBuffer.

Parameters

schema
buf
prefix

Returns: The object

References NES::Monitoring::RegistrationMetrics::readFromBuffer().

Here is the call graph for this function:

◆ readFromBuffer() [8/11]

void NES::Monitoring::readFromBuffer	(	RuntimeMetrics &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

Parses metrics objects from a given Schema and TupleBuffer.

Parameters

the	metrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::RuntimeMetrics::readFromBuffer().

Here is the call graph for this function:

◆ readFromBuffer() [9/11]

void NES::Monitoring::readFromBuffer	(	std::shared_ptr< Metric >	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

References readFromBuffer().

Here is the call graph for this function:

◆ readFromBuffer() [10/11]

void NES::Monitoring::readFromBuffer	(	std::string &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

References NES_THROW_RUNTIME_ERROR.

◆ readFromBuffer() [11/11]

void NES::Monitoring::readFromBuffer	(	uint64_t &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

class specific readFromBuffer()

Returns: the value

References NES_THROW_RUNTIME_ERROR.

◆ toString()

std::string NES::Monitoring::toString ( MetricType metricType )

References magic_enum::enum_name().

Referenced by NES::MetricValidator::isValid(), NES::MonitoringService::requestMonitoringDataFromAllNodesAsJson(), NES::TEST_F(), NES::TEST_P(), and NES::MetricValidator::waitForMonitoringStreamsOrTimeout().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ writeToBuffer() [1/11]

void NES::Monitoring::writeToBuffer	(	const CpuMetrics &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

The serialize method to write metrics into the given Schema and TupleBuffer.

Parameters

the	CpuMetrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::CpuMetrics::writeToBuffer().

Referenced by NES::Monitoring::CpuCollector::fillBuffer(), NES::Monitoring::DiskCollector::fillBuffer(), NES::Monitoring::MemoryCollector::fillBuffer(), NES::Monitoring::NetworkCollector::fillBuffer(), and writeToBuffer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ writeToBuffer() [2/11]

void NES::Monitoring::writeToBuffer	(	const CpuMetricsWrapper &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

The serialize method to write metrics into the given Schema and TupleBuffer.

Parameters

the	metrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::CpuMetricsWrapper::writeToBuffer().

Here is the call graph for this function:

◆ writeToBuffer() [3/11]

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.

Parameters

the	metrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::DiskMetrics::writeToBuffer().

Here is the call graph for this function:

◆ writeToBuffer() [4/11]

void NES::Monitoring::writeToBuffer	(	const MemoryMetrics &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

Writes metrics objects to a given Schema and TupleBuffer.

Parameters

the	metrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::MemoryMetrics::writeToBuffer().

Here is the call graph for this function:

◆ writeToBuffer() [5/11]

void NES::Monitoring::writeToBuffer	(	const NetworkMetrics &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

Writes metrics objects to a given Schema and TupleBuffer.

Parameters

the	metrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::NetworkMetrics::writeToBuffer().

Here is the call graph for this function:

◆ writeToBuffer() [6/11]

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.

Parameters

the	metrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::NetworkMetricsWrapper::writeToBuffer().

Here is the call graph for this function:

◆ writeToBuffer() [7/11]

void NES::Monitoring::writeToBuffer	(	const RegistrationMetrics &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

The serialize method to write metrics into the given Schema and TupleBuffer.

Parameters

the	CpuMetrics
the	schema
the	TupleBuffer
the	prefix as std::string

References NES::Monitoring::RegistrationMetrics::writeToBuffer().

Here is the call graph for this function:

◆ writeToBuffer() [8/11]

void NES::Monitoring::writeToBuffer	(	const RuntimeMetrics &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

Writes metrics objects to a given Schema and TupleBuffer.

Parameters

the	metrics
the	TupleBuffer
the	tuple index indicating the location of the tuple

References NES::Monitoring::RuntimeMetrics::writeToBuffer().

Here is the call graph for this function:

◆ writeToBuffer() [9/11]

void NES::Monitoring::writeToBuffer	(	const std::shared_ptr< Metric >	metric,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

References writeToBuffer().

Here is the call graph for this function:

◆ writeToBuffer() [10/11]

void NES::Monitoring::writeToBuffer	(	const std::string &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

References NES_THROW_RUNTIME_ERROR.

◆ writeToBuffer() [11/11]

void NES::Monitoring::writeToBuffer	(	const uint64_t &	metrics,
		Runtime::TupleBuffer &	buf,
		uint64_t	tupleIndex
	)

Class specific serialize methods for basic types. The serialize method to write CpuMetricsWrapper into the given Schema and TupleBuffer. The prefix specifies a string that should be added before each field description in the Schema.

Parameters

the	metric
the	schema
the	TupleBuffer
the	prefix as std::string

References NES_THROW_RUNTIME_ERROR.

Classes

Typedefs

Enumerations

Functions

Typedef Documentation

◆ AbstractSystemResourcesReaderPtr

◆ CpuCollectorPtr

◆ DiskCollectorPtr

◆ DiskMetricsPtr

◆ MemoryCollectorPtr

◆ MemoryMetricsPtr

◆ MetricCollectorPtr

◆ MetricPtr

◆ MetricStorePtr

◆ MonitoringAgentPtr

◆ MonitoringCatalogPtr

◆ MonitoringManagerPtr

◆ MonitoringPlanPtr

◆ NesCoordinatorPtr

◆ NesWorkerPtr

◆ NetworkCollectorPtr

◆ RegistrationMetricsPtr

◆ RuntimeNesMetricsPtr

◆ SourceCatalogPtr

◆ StoredNodeMetricsPtr

◆ TimestampMetricPtr

Enumeration Type Documentation

◆ MetricCollectorType

◆ MetricStoreType

◆ MetricType

Function Documentation

◆ __attribute__()

◆ asJson() [1/11]

◆ asJson() [2/11]

◆ asJson() [3/11]

◆ asJson() [4/11]

◆ asJson() [5/11]

◆ asJson() [6/11]

◆ asJson() [7/11]

◆ asJson() [8/11]

◆ asJson() [9/11]

◆ asJson() [10/11]

◆ asJson() [11/11]

◆ getSchema()

◆ operator<<() [1/2]

◆ operator<<() [2/2]

◆ readFromBuffer() [1/11]

◆ readFromBuffer() [2/11]

◆ readFromBuffer() [3/11]

◆ readFromBuffer() [4/11]

◆ readFromBuffer() [5/11]

◆ readFromBuffer() [6/11]

◆ readFromBuffer() [7/11]

◆ readFromBuffer() [8/11]

◆ readFromBuffer() [9/11]

◆ readFromBuffer() [10/11]

◆ readFromBuffer() [11/11]

◆ toString()

◆ writeToBuffer() [1/11]

◆ writeToBuffer() [2/11]

◆ writeToBuffer() [3/11]

◆ writeToBuffer() [4/11]

◆ writeToBuffer() [5/11]

◆ writeToBuffer() [6/11]

◆ writeToBuffer() [7/11]

◆ writeToBuffer() [8/11]

◆ writeToBuffer() [9/11]

◆ writeToBuffer() [10/11]

◆ writeToBuffer() [11/11]

◆ attribute()