org.apache.pulsar.common.policies.data

Class TopicStats

java.lang.Object

org.apache.pulsar.common.policies.data.TopicStats

Direct Known Subclasses:

NonPersistentTopicStats, PartitionedTopicStats, PersistentTopicStats

public class TopicStats
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
double	averageMsgSize Average size of published messages.
String	deduplicationStatus
double	msgRateIn Total rate of messages published on the topic.
double	msgRateOut Total rate of messages dispatched for the topic.
double	msgThroughputIn Total throughput of messages published on the topic.
double	msgThroughputOut Total throughput of messages dispatched for the topic.
List<PublisherStats>	publishers List of connected publishers on this topic w/ their stats
Map<String,ReplicatorStats>	replication Map of replication statistics by remote cluster context
long	storageSize Space used to store the messages for the topic.
Map<String,SubscriptionStats>	subscriptions Map of subscriptions with their individual statistics

Constructor Summary

Constructors

Constructor and Description
TopicStats()

Method Summary

Modifier and Type	Method and Description
TopicStats	add(TopicStats stats)
void	reset()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

msgRateIn

public double msgRateIn

Total rate of messages published on the topic. msg/s

msgThroughputIn

public double msgThroughputIn

Total throughput of messages published on the topic. byte/s

msgRateOut

public double msgRateOut

Total rate of messages dispatched for the topic. msg/s

msgThroughputOut

public double msgThroughputOut

Total throughput of messages dispatched for the topic. byte/s

averageMsgSize

public double averageMsgSize

Average size of published messages. bytes

storageSize

public long storageSize

Space used to store the messages for the topic. bytes

publishers

public List<PublisherStats> publishers

List of connected publishers on this topic w/ their stats

subscriptions

public Map<String,SubscriptionStats> subscriptions

Map of subscriptions with their individual statistics

replication

public Map<String,ReplicatorStats> replication

Map of replication statistics by remote cluster context

deduplicationStatus

public String deduplicationStatus

Constructor Detail

TopicStats

public TopicStats()

Method Detail

reset

public void reset()

add

public TopicStats add(TopicStats stats)