RegistrationMetrics.hpp File Reference

#include <Identifiers/Identifiers.hpp>
#include <Monitoring/MonitoringForwardRefs.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>

Include dependency graph for RegistrationMetrics.hpp:

This graph shows which files directly or indirectly include this file:

Classes
class	NES::Monitoring::RegistrationMetrics

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

Typedefs
using	SerializableRegistrationMetricsPtr = std::shared_ptr< SerializableRegistrationMetrics >
using	NES::Monitoring::RegistrationMetricsPtr = std::shared_ptr< RegistrationMetrics >

Functions
class NES::Monitoring::CpuMetrics	NES::Monitoring::__attribute__ ((packed))
	RegistrationMetrics ()
	RegistrationMetrics (bool isMoving, bool hasBattery)
	RegistrationMetrics (const SerializableRegistrationMetrics &metrics)
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...
SerializableRegistrationMetricsPtr	serialize () const
	Converts the object into a grpc protobuf object that can be serialized. More...
bool	operator== (const RegistrationMetrics &rhs) const
bool	operator!= (const RegistrationMetrics &rhs) const
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. More...
void	NES::Monitoring::readFromBuffer (RegistrationMetrics &metrics, Runtime::TupleBuffer &buf, uint64_t tupleIndex)
	Parses a metrics objects from a given Schema and TupleBuffer. More...
nlohmann::json	NES::Monitoring::asJson (const RegistrationMetrics &metrics)
	Parses the metric to JSON. More...

Variables
WorkerId	nodeId
uint64_t	totalMemoryBytes
uint64_t	cpuCoreNum
uint64_t	totalCPUJiffies
int64_t	cpuPeriodUS
int64_t	cpuQuotaUS
bool	isMoving
bool	hasBattery

Typedef Documentation

SerializableRegistrationMetricsPtr

using SerializableRegistrationMetricsPtr = std::shared_ptr<SerializableRegistrationMetrics>

Function Documentation

operator!=()

bool __attribute__::operator!=

(

const RegistrationMetrics &

rhs

)

const

operator==()

bool __attribute__::operator==

(

const RegistrationMetrics &

rhs

)

const

readFromBuffer()

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

Parses a metrics objects from a TupleBuffer..

Parameters

buf	the tuple buffer
the	tuple index indicating the location of the tuple

RegistrationMetrics() [1/3]

__attribute__::RegistrationMetrics

(

)

RegistrationMetrics() [2/3]

__attribute__::RegistrationMetrics	(	bool	isMoving,
		bool	hasBattery
	)

RegistrationMetrics() [3/3]

__attribute__::RegistrationMetrics ( const SerializableRegistrationMetrics &  metrics )

explicit

Ctor to create a RegistrationMetrics object out of a protobuf message.

Parameters

metrics

in protobuf

serialize()

SerializableRegistrationMetricsPtr __attribute__::serialize

(

)

const

Converts the object into a grpc protobuf object that can be serialized.

Returns

the serialized object as protobuf

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

buf	the tuple buffer
tupleIndex	the index indication its location in the buffer

Variable Documentation

cpuCoreNum

uint64_t cpuCoreNum

cpuPeriodUS

int64_t cpuPeriodUS

cpuQuotaUS

int64_t cpuQuotaUS

hasBattery

bool hasBattery

isMoving

bool isMoving

nodeId

WorkerId nodeId

totalCPUJiffies

uint64_t totalCPUJiffies

totalMemoryBytes

uint64_t totalMemoryBytes