pulsar-client-cpp
BrokerConsumerStats.h
1 
19 #ifndef PULSAR_CPP_BROKERCONSUMERSTATS_H
20 #define PULSAR_CPP_BROKERCONSUMERSTATS_H
21 
22 #include <boost/date_time/posix_time/ptime.hpp>
23 #include <string.h>
24 #include <iostream>
25 #include <pulsar/Result.h>
26 #include <boost/function.hpp>
27 #include <pulsar/ConsumerType.h>
28 
29 #pragma GCC visibility push(default)
30 namespace pulsar {
31 class BrokerConsumerStatsImplBase;
32 class PulsarWrapper;
33 
34 /* @note: isValid() or getXXX() methods are not allowed on an invalid BrokerConsumerStats */
36  private:
37  boost::shared_ptr<BrokerConsumerStatsImplBase> impl_;
38  public:
39  explicit BrokerConsumerStats(boost::shared_ptr<BrokerConsumerStatsImplBase> impl);
40 
42 
44  virtual bool isValid() const;
45 
47  virtual double getMsgRateOut() const;
48 
50  virtual double getMsgThroughputOut() const;
51 
53  virtual double getMsgRateRedeliver() const;
54 
56  virtual const std::string getConsumerName() const;
57 
59  virtual uint64_t getAvailablePermits() const;
60 
62  virtual uint64_t getUnackedMessages() const;
63 
65  virtual bool isBlockedConsumerOnUnackedMsgs() const;
66 
68  virtual const std::string getAddress() const;
69 
71  virtual const std::string getConnectedSince() const;
72 
74  virtual const ConsumerType getType() const;
75 
77  virtual double getMsgRateExpired() const;
78 
80  virtual uint64_t getMsgBacklog() const;
81 
83  boost::shared_ptr<BrokerConsumerStatsImplBase> getImpl() const;
84 
85  friend class PulsarWrapper;
86  friend std::ostream& operator<<(std::ostream &os, const BrokerConsumerStats &obj);
87 };
88 typedef boost::function<void(Result result, BrokerConsumerStats brokerConsumerStats)> BrokerConsumerStatsCallback;
89 
90 }
91 
92 #pragma GCC visibility pop
93 
94 #endif //PULSAR_CPP_BROKERCONSUMERSTATS_H
virtual uint64_t getAvailablePermits() const
ConsumerType
Definition: ConsumerType.h:24
virtual double getMsgThroughputOut() const
virtual double getMsgRateOut() const
virtual uint64_t getUnackedMessages() const
virtual bool isValid() const
Definition: Authentication.h:31
virtual const ConsumerType getType() const
virtual uint64_t getMsgBacklog() const
virtual const std::string getConnectedSince() const
virtual bool isBlockedConsumerOnUnackedMsgs() const
virtual const std::string getAddress() const
boost::shared_ptr< BrokerConsumerStatsImplBase > getImpl() const
virtual const std::string getConsumerName() const
virtual double getMsgRateRedeliver() const
virtual double getMsgRateExpired() const
Definition: BrokerConsumerStats.h:35