16#ifndef __IceStorm_Metrics_h__
17#define __IceStorm_Metrics_h__
40#ifndef ICE_IGNORE_VERSION
41# if ICE_INT_VERSION / 100 != 307
42# error Ice version mismatch!
44# if ICE_INT_VERSION % 100 >= 50
45# error Beta header file detected
47# if ICE_INT_VERSION % 100 < 11
48# error Ice patch level mismatch!
53# if defined(ICE_STATIC_LIBS)
55# elif defined(ICESTORM_API_EXPORTS)
56# define ICESTORM_API ICE_DECLSPEC_EXPORT
58# define ICESTORM_API ICE_DECLSPEC_IMPORT
62#ifdef ICE_CPP11_MAPPING
68class SubscriberMetrics;
79class ICE_CLASS(ICESTORM_API)
TopicMetrics :
public ::Ice::ValueHelper<TopicMetrics, Metrics>
102 TopicMetrics(const ::std::string&
id,
long long int total,
int current,
long long int totalLifetime,
int failures,
long long int published,
long long int forwarded) :
113 std::tuple<const ::std::string&, const long long int&, const int&, const long long int&, const int&, const long long int&, const long long int&>
ice_tuple()
const
142class ICE_CLASS(ICESTORM_API)
SubscriberMetrics :
public ::Ice::ValueHelper<SubscriberMetrics, Metrics>
178 std::tuple<const ::std::string&, const long long int&, const int&, const long long int&, const int&, const int&, const int&, const long long int&>
ice_tuple()
const
215struct StreamWriter<::IceMX::TopicMetrics, S>
217 static void write(S* ostr, const ::IceMX::TopicMetrics& v)
219 ostr->writeAll(v.published, v.forwarded);
224struct StreamReader<::IceMX::TopicMetrics, S>
226 static void read(S* istr, ::IceMX::TopicMetrics& v)
233struct StreamWriter<::IceMX::SubscriberMetrics, S>
235 static void write(S* ostr, const ::IceMX::SubscriberMetrics& v)
237 ostr->writeAll(v.queued, v.outstanding, v.delivered);
242struct StreamReader<::IceMX::SubscriberMetrics, S>
244 static void read(S* istr, ::IceMX::SubscriberMetrics& v)
257using TopicMetricsPtr = ::std::shared_ptr<TopicMetrics>;
259using SubscriberMetricsPtr = ::std::shared_ptr<SubscriberMetrics>;
274ICESTORM_API void _readProxy(::Ice::InputStream*, ::IceInternal::ProxyHandle< TopicMetrics>&);
275ICESTORM_API ::IceProxy::Ice::Object* upCast(TopicMetrics*);
278class SubscriberMetrics;
280ICESTORM_API void _readProxy(::Ice::InputStream*, ::IceInternal::ProxyHandle< SubscriberMetrics>&);
281ICESTORM_API ::IceProxy::Ice::Object* upCast(SubscriberMetrics*);
293ICESTORM_API ::Ice::Object* upCast(TopicMetrics*);
295typedef ::IceInternal::Handle< TopicMetrics> TopicMetricsPtr;
296typedef ::IceInternal::ProxyHandle< ::IceProxy::IceMX::TopicMetrics> TopicMetricsPrx;
297typedef TopicMetricsPrx TopicMetricsPrxPtr;
299ICESTORM_API void _icePatchObjectPtr(TopicMetricsPtr&, const ::Ice::ObjectPtr&);
302class SubscriberMetrics;
304ICESTORM_API ::Ice::Object* upCast(SubscriberMetrics*);
306typedef ::IceInternal::Handle< SubscriberMetrics> SubscriberMetricsPtr;
307typedef ::IceInternal::ProxyHandle< ::IceProxy::IceMX::SubscriberMetrics> SubscriberMetricsPrx;
308typedef SubscriberMetricsPrx SubscriberMetricsPrxPtr;
310ICESTORM_API void _icePatchObjectPtr(SubscriberMetricsPtr&, const ::Ice::ObjectPtr&);
326class ICE_CLASS(ICESTORM_API) TopicMetrics :
public virtual ::Ice::Proxy<TopicMetrics, ::IceProxy::IceMX::Metrics>
343class ICE_CLASS(ICESTORM_API) SubscriberMetrics :
public virtual ::Ice::Proxy<SubscriberMetrics, ::IceProxy::IceMX::Metrics>
375 typedef TopicMetricsPrx ProxyType;
376 typedef TopicMetricsPtr PointerType;
378 virtual ~TopicMetrics();
398 ::IceMX::Metrics(id, total, current, totalLifetime, failures),
399 published(published),
404#ifdef ICE_CPP11_COMPILER
405 TopicMetrics(
const TopicMetrics&) =
default;
406 TopicMetrics& operator=(
const TopicMetrics&) =
default;
413 virtual ::Ice::ObjectPtr ice_clone()
const;
421 virtual bool ice_isA(const ::std::string&
id, const ::Ice::Current& current =
::Ice::emptyCurrent)
const;
428 virtual ::std::vector< ::std::string> ice_ids(const ::Ice::Current& current =
::Ice::emptyCurrent)
const;
435 virtual const ::std::string& ice_id(const ::Ice::Current& current =
::Ice::emptyCurrent)
const;
441 static const ::std::string& ice_staticId();
447 static ::Ice::ValueFactoryPtr ice_factory();
452 virtual void _iceWriteImpl(::Ice::OutputStream*)
const;
453 virtual void _iceReadImpl(::Ice::InputStream*);
468static ::Ice::ValueFactoryPtr _iceS_TopicMetrics_init = ::IceMX::TopicMetrics::ice_factory();
472inline bool operator==(
const TopicMetrics& lhs,
const TopicMetrics& rhs)
474 return static_cast<const ::Ice::Object&
>(lhs) ==
static_cast<const ::Ice::Object&
>(rhs);
477inline bool operator<(
const TopicMetrics& lhs,
const TopicMetrics& rhs)
479 return static_cast<const ::Ice::Object&
>(lhs) <
static_cast<const ::Ice::Object&
>(rhs);
491 typedef SubscriberMetricsPrx ProxyType;
492 typedef SubscriberMetricsPtr PointerType;
494 virtual ~SubscriberMetrics();
497 SubscriberMetrics() :
516 ::IceMX::Metrics(id, total, current, totalLifetime, failures),
518 outstanding(outstanding),
523#ifdef ICE_CPP11_COMPILER
524 SubscriberMetrics(
const SubscriberMetrics&) =
default;
525 SubscriberMetrics& operator=(
const SubscriberMetrics&) =
default;
532 virtual ::Ice::ObjectPtr ice_clone()
const;
540 virtual bool ice_isA(const ::std::string&
id, const ::Ice::Current& current =
::Ice::emptyCurrent)
const;
547 virtual ::std::vector< ::std::string> ice_ids(const ::Ice::Current& current =
::Ice::emptyCurrent)
const;
554 virtual const ::std::string& ice_id(const ::Ice::Current& current =
::Ice::emptyCurrent)
const;
560 static const ::std::string& ice_staticId();
566 static ::Ice::ValueFactoryPtr ice_factory();
571 virtual void _iceWriteImpl(::Ice::OutputStream*)
const;
572 virtual void _iceReadImpl(::Ice::InputStream*);
591static ::Ice::ValueFactoryPtr _iceS_SubscriberMetrics_init = ::IceMX::SubscriberMetrics::ice_factory();
595inline bool operator==(
const SubscriberMetrics& lhs,
const SubscriberMetrics& rhs)
597 return static_cast<const ::Ice::Object&
>(lhs) ==
static_cast<const ::Ice::Object&
>(rhs);
600inline bool operator<(
const SubscriberMetrics& lhs,
const SubscriberMetrics& rhs)
602 return static_cast<const ::Ice::Object&
>(lhs) <
static_cast<const ::Ice::Object&
>(rhs);
613struct StreamWriter< ::IceMX::TopicMetrics, S>
615 static void write(S* ostr, const ::IceMX::TopicMetrics& v)
617 ostr->write(v.published);
618 ostr->write(v.forwarded);
623struct StreamReader< ::IceMX::TopicMetrics, S>
625 static void read(S* istr, ::IceMX::TopicMetrics& v)
633struct StreamWriter< ::IceMX::SubscriberMetrics, S>
635 static void write(S* ostr, const ::IceMX::SubscriberMetrics& v)
637 ostr->write(v.queued);
638 ostr->write(v.outstanding);
639 ostr->write(v.delivered);
644struct StreamReader< ::IceMX::SubscriberMetrics, S>
646 static void read(S* istr, ::IceMX::SubscriberMetrics& v)
#define ICESTORM_API
Definition Metrics.h:58
#define ICE_INT64(n)
Definition Config.h:343
#define ICE_MEMBER(API)
Definition Config.h:177
The base class for metrics.
Definition Metrics.h:341
SubscriberMetrics & operator=(SubscriberMetrics &&)=default
virtual ~SubscriberMetrics()
SubscriberMetrics(const ::std::string &id, long long int total, int current, long long int totalLifetime, int failures, int queued, int outstanding, long long int delivered)
One-shot constructor to initialize all data members.
Definition Metrics.h:166
std::tuple< const ::std::string &, const long long int &, const int &, const long long int &, const int &, const int &, const int &, const long long int & > ice_tuple() const
Obtains a tuple containing all of the value's data members.
Definition Metrics.h:178
int queued
Number of queued events.
Definition Metrics.h:192
SubscriberMetrics()=default
long long int delivered
Number of forwarded events.
Definition Metrics.h:200
SubscriberMetrics(const SubscriberMetrics &)=default
int outstanding
Number of outstanding events.
Definition Metrics.h:196
SubscriberMetrics & operator=(const SubscriberMetrics &)=default
static const ::std::string & ice_staticId()
Obtains the Slice type ID of this value.
SubscriberMetrics(SubscriberMetrics &&)=default
Provides information on IceStorm topics.
Definition Metrics.h:80
TopicMetrics(TopicMetrics &&)=default
long long int forwarded
Number of events forwarded on the topic by IceStorm topic links.
Definition Metrics.h:131
std::tuple< const ::std::string &, const long long int &, const int &, const long long int &, const int &, const long long int &, const long long int & > ice_tuple() const
Obtains a tuple containing all of the value's data members.
Definition Metrics.h:113
TopicMetrics(const ::std::string &id, long long int total, int current, long long int totalLifetime, int failures, long long int published, long long int forwarded)
One-shot constructor to initialize all data members.
Definition Metrics.h:102
static const ::std::string & ice_staticId()
Obtains the Slice type ID of this value.
TopicMetrics & operator=(TopicMetrics &&)=default
long long int published
Number of events published on the topic by publishers.
Definition Metrics.h:127
TopicMetrics(const TopicMetrics &)=default
TopicMetrics & operator=(const TopicMetrics &)=default
Definition BuiltinSequences.h:56
int Int
The mapping for the Slice int type.
Definition Config.h:54
long long int Long
The mapping for the Slice long type.
Definition Config.h:57
const Current emptyCurrent
A default-initialized Current instance.
bool operator<(const C &lhs, const C &rhs)
Relational operator for generated structs and classes.
Definition Comparable.h:136
bool operator==(const C &lhs, const C &rhs)
Relational operator for generated structs and classes.
Definition Comparable.h:184