19#ifndef PULSAR_CPP_BROKERCONSUMERSTATS_H
20#define PULSAR_CPP_BROKERCONSUMERSTATS_H
22#include <pulsar/ConsumerType.h>
23#include <pulsar/Result.h>
24#include <pulsar/defines.h>
31class BrokerConsumerStatsImplBase;
37 std::shared_ptr<BrokerConsumerStatsImplBase> impl_;
85 std::shared_ptr<BrokerConsumerStatsImplBase>
getImpl()
const;
87 friend class PulsarWrapper;
88 friend PULSAR_PUBLIC std::ostream &operator<<(std::ostream &os,
const BrokerConsumerStats &obj);
91 BrokerConsumerStatsCallback;
Definition BrokerConsumerStats.h:35
virtual double getMsgRateOut() const
virtual uint64_t getAvailablePermits() const
virtual const std::string getConsumerName() const
std::shared_ptr< BrokerConsumerStatsImplBase > getImpl() const
virtual const ConsumerType getType() const
virtual uint64_t getMsgBacklog() const
virtual bool isValid() const
virtual const std::string getAddress() const
virtual double getMsgThroughputOut() const
virtual const std::string getConnectedSince() const
virtual double getMsgRateExpired() const
virtual bool isBlockedConsumerOnUnackedMsgs() const
virtual uint64_t getUnackedMessages() const
virtual double getMsgRateRedeliver() const
Definition Authentication.h:31
ConsumerType
Definition ConsumerType.h:24
Result
Definition Result.h:32