19 #ifndef PULSAR_CPP_BROKERCONSUMERSTATS_H 20 #define PULSAR_CPP_BROKERCONSUMERSTATS_H 22 #include <boost/date_time/posix_time/ptime.hpp> 25 #include <pulsar/Result.h> 26 #include <boost/function.hpp> 27 #include <pulsar/ConsumerType.h> 29 #pragma GCC visibility push(default) 31 class BrokerConsumerStatsImplBase;
37 boost::shared_ptr<BrokerConsumerStatsImplBase> impl_;
83 boost::shared_ptr<BrokerConsumerStatsImplBase>
getImpl()
const;
85 friend class PulsarWrapper;
88 typedef boost::function<void(Result result, BrokerConsumerStats brokerConsumerStats)> BrokerConsumerStatsCallback;
92 #pragma GCC visibility pop 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