Instrumentation.h
Go to the documentation of this file.
1// **********************************************************************
2//
3// Copyright (c) 2003-2017 ZeroC, Inc. All rights reserved.
4//
5// This copy of Ice is licensed to you under the terms described in the
6// ICE_LICENSE file included in this distribution.
7//
8// **********************************************************************
9//
10// Ice version 3.7.0
11//
12// <auto-generated>
13//
14// Generated from file `Instrumentation.ice'
15//
16// Warning: do not edit this file.
17//
18// </auto-generated>
19//
20
21#ifndef __IceStorm_Instrumentation_h__
22#define __IceStorm_Instrumentation_h__
23
24#include <Ice/Comparable.h>
25#include <Ice/Exception.h>
26#include <Ice/ExceptionHelpers.h>
27#include <Ice/FactoryTableInit.h>
28#include <Ice/GCObject.h>
29#include <Ice/Incoming.h>
30#include <Ice/Instrumentation.h>
31#include <Ice/LocalObject.h>
32#include <Ice/Object.h>
33#include <Ice/ObjectF.h>
34#include <Ice/Optional.h>
35#include <Ice/Proxy.h>
36#include <Ice/ProxyF.h>
37#include <Ice/StreamHelpers.h>
38#include <Ice/Value.h>
39#include <Ice/ValueF.h>
40#include <IceStorm/IceStorm.h>
41#include <IceUtil/PushDisableWarnings.h>
42#include <IceUtil/ScopedArray.h>
43#include <IceUtil/UndefSysMacros.h>
44
45#ifndef ICE_IGNORE_VERSION
46#if ICE_INT_VERSION / 100 != 307
47#error Ice version mismatch!
48#endif
49#if ICE_INT_VERSION % 100 > 50
50#error Beta header file detected
51#endif
52#if ICE_INT_VERSION % 100 < 0
53#error Ice patch level mismatch!
54#endif
55#endif
56
57#ifdef ICE_CPP11_MAPPING // C++11 mapping
58
60{
61
62 class TopicObserver;
64 class ObserverUpdater;
66
67} // namespace IceStorm::Instrumentation
68
70{
71
72 enum class SubscriberState : unsigned char
73 {
77 };
78
79} // namespace IceStorm::Instrumentation
80
82{
83
84 class TopicObserver : public virtual ::Ice::Instrumentation::Observer
85 {
86 public:
87 virtual ~TopicObserver();
88
89 virtual void published() = 0;
90
91 virtual void forwarded() = 0;
92 };
93
94 class SubscriberObserver : public virtual ::Ice::Instrumentation::Observer
95 {
96 public:
97 virtual ~SubscriberObserver();
98
99 virtual void queued(int) = 0;
100
101 virtual void outstanding(int) = 0;
102
103 virtual void delivered(int) = 0;
104 };
105
106 class ObserverUpdater
107 {
108 public:
109 virtual ~ObserverUpdater();
110
111 virtual void updateTopicObservers() = 0;
112
113 virtual void updateSubscriberObservers() = 0;
114 };
115
117 {
118 public:
119 virtual ~TopicManagerObserver();
120
121 virtual ::std::shared_ptr<::IceStorm::Instrumentation::TopicObserver>
122 getTopicObserver(const ::std::string&,
123 const ::std::string&,
124 const ::std::shared_ptr<::IceStorm::Instrumentation::TopicObserver>&) = 0;
125
126 virtual ::std::shared_ptr<::IceStorm::Instrumentation::SubscriberObserver>
128 const ::std::string&,
129 const ::std::string&,
130 const ::std::shared_ptr<::Ice::ObjectPrx>&,
131 const ::IceStorm::QoS&,
132 const ::std::shared_ptr<::IceStorm::TopicPrx>&,
134 const ::std::shared_ptr<::IceStorm::Instrumentation::SubscriberObserver>&) = 0;
135
136 virtual void setObserverUpdater(
137 const ::std::shared_ptr<::IceStorm::Instrumentation::ObserverUpdater>&) = 0;
138 };
139
140} // namespace IceStorm::Instrumentation
141
142namespace Ice
143{
144
145 template <>
146 struct StreamableTraits<::IceStorm::Instrumentation::SubscriberState>
147 {
148 static const StreamHelperCategory helper = StreamHelperCategoryEnum;
149 static const int minValue = 0;
150 static const int maxValue = 2;
151 static const int minWireSize = 1;
152 static const bool fixedLength = false;
153 };
154
155} // namespace Ice
156
158{
159
160 using TopicObserverPtr = ::std::shared_ptr<TopicObserver>;
161
162 using SubscriberObserverPtr = ::std::shared_ptr<SubscriberObserver>;
163
164 using ObserverUpdaterPtr = ::std::shared_ptr<ObserverUpdater>;
165
166 using TopicManagerObserverPtr = ::std::shared_ptr<TopicManagerObserver>;
167
168} // namespace IceStorm::Instrumentation
169
170
171#else // C++98 mapping
172
173namespace IceProxy
174{
175
176}
177
179{
180
181 class TopicObserver;
183 typedef ::IceInternal::Handle<::IceStorm::Instrumentation::TopicObserver> TopicObserverPtr;
184
185 class SubscriberObserver;
187 typedef ::IceInternal::Handle<::IceStorm::Instrumentation::SubscriberObserver>
189
190 class ObserverUpdater;
192 typedef ::IceInternal::Handle<::IceStorm::Instrumentation::ObserverUpdater> ObserverUpdaterPtr;
193
196 typedef ::IceInternal::Handle<::IceStorm::Instrumentation::TopicManagerObserver>
198
199} // namespace IceStorm::Instrumentation
200
202{
203
210
211} // namespace IceStorm::Instrumentation
212
213namespace IceProxy
214{
215
216}
217
219{
220
221 class TopicObserver : virtual public ::Ice::Instrumentation::Observer
222 {
223 public:
225
226 virtual ~TopicObserver();
227
228 virtual void published() = 0;
229
230 virtual void forwarded() = 0;
231 };
232
233 inline bool
234 operator==(const TopicObserver& lhs, const TopicObserver& rhs)
235 {
236 return static_cast<const ::Ice::LocalObject&>(lhs) ==
237 static_cast<const ::Ice::LocalObject&>(rhs);
238 }
239
240 inline bool
241 operator<(const TopicObserver& lhs, const TopicObserver& rhs)
242 {
243 return static_cast<const ::Ice::LocalObject&>(lhs) <
244 static_cast<const ::Ice::LocalObject&>(rhs);
245 }
246
247 class SubscriberObserver : virtual public ::Ice::Instrumentation::Observer
248 {
249 public:
251
252 virtual ~SubscriberObserver();
253
254 virtual void queued(::Ice::Int) = 0;
255
256 virtual void outstanding(::Ice::Int) = 0;
257
258 virtual void delivered(::Ice::Int) = 0;
259 };
260
261 inline bool
263 {
264 return static_cast<const ::Ice::LocalObject&>(lhs) ==
265 static_cast<const ::Ice::LocalObject&>(rhs);
266 }
267
268 inline bool
269 operator<(const SubscriberObserver& lhs, const SubscriberObserver& rhs)
270 {
271 return static_cast<const ::Ice::LocalObject&>(lhs) <
272 static_cast<const ::Ice::LocalObject&>(rhs);
273 }
274
275 class ObserverUpdater : public virtual ::Ice::LocalObject
276 {
277 public:
279
280 virtual ~ObserverUpdater();
281
282 virtual void updateTopicObservers() = 0;
283
284 virtual void updateSubscriberObservers() = 0;
285 };
286
287 inline bool
289 {
290 return static_cast<const ::Ice::LocalObject&>(lhs) ==
291 static_cast<const ::Ice::LocalObject&>(rhs);
292 }
293
294 inline bool
295 operator<(const ObserverUpdater& lhs, const ObserverUpdater& rhs)
296 {
297 return static_cast<const ::Ice::LocalObject&>(lhs) <
298 static_cast<const ::Ice::LocalObject&>(rhs);
299 }
300
301 class TopicManagerObserver : public virtual ::Ice::LocalObject
302 {
303 public:
305
306 virtual ~TopicManagerObserver();
307
308 virtual ::IceStorm::Instrumentation::TopicObserverPtr
309 getTopicObserver(const ::std::string&,
310 const ::std::string&,
311 const ::IceStorm::Instrumentation::TopicObserverPtr&) = 0;
312
313 virtual ::IceStorm::Instrumentation::SubscriberObserverPtr
314 getSubscriberObserver(const ::std::string&,
315 const ::std::string&,
316 const ::Ice::ObjectPrx&,
317 const ::IceStorm::QoS&,
318 const ::IceStorm::TopicPrx&,
320 const ::IceStorm::Instrumentation::SubscriberObserverPtr&) = 0;
321
322 virtual void setObserverUpdater(const ::IceStorm::Instrumentation::ObserverUpdaterPtr&) = 0;
323 };
324
325 inline bool
327 {
328 return static_cast<const ::Ice::LocalObject&>(lhs) ==
329 static_cast<const ::Ice::LocalObject&>(rhs);
330 }
331
332 inline bool
334 {
335 return static_cast<const ::Ice::LocalObject&>(lhs) <
336 static_cast<const ::Ice::LocalObject&>(rhs);
337 }
338
339} // namespace IceStorm::Instrumentation
340
341namespace Ice
342{
343
344 template <>
346 {
347 static const StreamHelperCategory helper = StreamHelperCategoryEnum;
348 static const int minValue = 0;
349 static const int maxValue = 2;
350 static const int minWireSize = 1;
351 static const bool fixedLength = false;
352 };
353
354} // namespace Ice
355
356#endif
357
358#include <IceUtil/PopDisableWarnings.h>
359#endif
The ObserverUpdater interface is implemented by IceStorm and an instance of this interface is provide...
The topic manager observer interface used by the Ice run-time to obtain and update observers for its ...
virtual::IceStorm::Instrumentation::SubscriberObserverPtr getSubscriberObserver(const ::std::string &, const ::std::string &, const ::Ice::ObjectPrx &, const ::IceStorm::QoS &, const ::IceStorm::TopicPrx &, ::IceStorm::Instrumentation::SubscriberState, const ::IceStorm::Instrumentation::SubscriberObserverPtr &)=0
virtual void setObserverUpdater(const ::IceStorm::Instrumentation::ObserverUpdaterPtr &)=0
virtual::IceStorm::Instrumentation::TopicObserverPtr getTopicObserver(const ::std::string &, const ::std::string &, const ::IceStorm::Instrumentation::TopicObserverPtr &)=0
::IceInternal::Handle<::IceStorm::Instrumentation::ObserverUpdater > ObserverUpdaterPtr
bool operator==(const TopicObserver &lhs, const TopicObserver &rhs)
bool operator<(const TopicObserver &lhs, const TopicObserver &rhs)
::IceInternal::Handle<::IceStorm::Instrumentation::SubscriberObserver > SubscriberObserverPtr
::Ice::LocalObject * upCast(::IceStorm::Instrumentation::TopicObserver *)
@ SubscriberStateOnline
Online waiting to send events.
@ SubscriberStateOffline
Offline, retrying.
@ SubscriberStateError
Error state, awaiting to be destroyed.
::IceInternal::Handle<::IceStorm::Instrumentation::TopicManagerObserver > TopicManagerObserverPtr
::IceInternal::Handle<::IceStorm::Instrumentation::TopicObserver > TopicObserverPtr