org.apache.pulsar.common.policies.data

Class PersistentOfflineTopicStats

java.lang.Object

org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats

public class PersistentOfflineTopicStats
extends Object

This object is populated using meta data in zookeeper without actually bringing the topic online

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	PersistentOfflineTopicStats.CursorDetails
class	PersistentOfflineTopicStats.LedgerDetails

Field Summary

Fields

Modifier and Type	Field and Description
String	brokerName Broker host where this stat was generated
Map<String,PersistentOfflineTopicStats.CursorDetails>	cursorDetails cursor ledger ids and backlog
List<PersistentOfflineTopicStats.LedgerDetails>	dataLedgerDetails data ledger ids
long	messageBacklog Total backlog
Date	statGeneratedAt timestamp when stat was generated
long	storageSize Space used to store the messages for the topic.
String	topicName offline topic name
long	totalMessages Total number of messages

Constructor Summary

Constructors

Constructor and Description
PersistentOfflineTopicStats(String topicName, String brokerName)

Method Summary

Modifier and Type	Method and Description
void	addCursorDetails(String cursor, long backlog, long ledgerId)
void	addLedgerDetails(long entries, long timestamp, long size, long ledgerId)
void	reset()

Methods inherited from class java.lang.Object

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

Field Detail

storageSize

public long storageSize

Space used to store the messages for the topic. bytes

totalMessages

public long totalMessages

Total number of messages

messageBacklog

public long messageBacklog

Total backlog

brokerName

public final String brokerName

Broker host where this stat was generated

topicName

public final String topicName

offline topic name

dataLedgerDetails

public List<PersistentOfflineTopicStats.LedgerDetails> dataLedgerDetails

data ledger ids

cursorDetails

public Map<String,PersistentOfflineTopicStats.CursorDetails> cursorDetails

cursor ledger ids and backlog

statGeneratedAt

public Date statGeneratedAt

timestamp when stat was generated

Constructor Detail

PersistentOfflineTopicStats

public PersistentOfflineTopicStats(String topicName,
                                   String brokerName)

Method Detail

reset

public void reset()

addCursorDetails

public void addCursorDetails(String cursor,
                             long backlog,
                             long ledgerId)

addLedgerDetails

public void addLedgerDetails(long entries,
                             long timestamp,
                             long size,
                             long ledgerId)