Package org.apache.pulsar.common.policies.data

Interface NonPersistentTopicStats

All Superinterfaces:

TopicStats

public interface NonPersistentTopicStats
extends TopicStats

Statistics for a non-persistent topic.

Method Summary

Modifier and Type	Method	Description
double	getMsgDropRate()	for non-persistent topic: broker drops msg if publisher publishes messages more than configured max inflight messages per connection.
List<? extends NonPersistentPublisherStats>	getPublishers()	List of connected publishers on this topic w/ their stats.
Map<String,? extends NonPersistentReplicatorStats>	getReplication()	Map of replication statistics by remote cluster context.
Map<String,? extends NonPersistentSubscriptionStats>	getSubscriptions()	Map of subscriptions with their individual statistics.

Methods inherited from interface org.apache.pulsar.common.policies.data.TopicStats

getAverageMsgSize, getBacklogSize, getBytesInCounter, getBytesOutCounter, getCompaction, getDeduplicationStatus, getEarliestMsgPublishTimeInBacklogs, getMsgInCounter, getMsgOutCounter, getMsgRateIn, getMsgRateOut, getMsgThroughputIn, getMsgThroughputOut, getNonContiguousDeletedMessagesRanges, getNonContiguousDeletedMessagesRangesSerializedSize, getOffloadedStorageSize, getStorageSize, getTopicEpoch, getWaitingPublishers, isMsgChunkPublished

Method Details

getMsgDropRate

double getMsgDropRate()

for non-persistent topic: broker drops msg if publisher publishes messages more than configured max inflight messages per connection.

getPublishers

List<? extends NonPersistentPublisherStats> getPublishers()

List of connected publishers on this topic w/ their stats.

Specified by:

getPublishers in interface TopicStats

getSubscriptions

Map<String,? extends NonPersistentSubscriptionStats> getSubscriptions()

Map of subscriptions with their individual statistics.

Specified by:

getSubscriptions in interface TopicStats

getReplication

Map<String,? extends NonPersistentReplicatorStats> getReplication()

Map of replication statistics by remote cluster context.

Specified by:

getReplication in interface TopicStats