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

Class ManagedLedgerInternalStats.CursorStats

java.lang.Object

org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats

Enclosing class:

ManagedLedgerInternalStats

public static class ManagedLedgerInternalStats.CursorStats
extends Object

Pulsar cursor statistics.

Field Summary

Fields

Modifier and Type	Field	Description
boolean	active
long	cursorLedger
long	cursorLedgerLastEntry
String	individuallyDeletedMessages
String	lastLedgerSwitchTimestamp
String	markDeletePosition
long	messagesConsumedCounter
long	numberOfEntriesSinceFirstNotAckedMessage
int	pendingReadOps
Map<String,Long>	properties
String	readPosition
String	state
boolean	subscriptionHavePendingRead
boolean	subscriptionHavePendingReplayRead
int	totalNonContiguousDeletedMessagesRange
boolean	waitingReadOp

Constructor Summary

Constructors

Constructor	Description
CursorStats()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

markDeletePosition

public String markDeletePosition

readPosition

public String readPosition

waitingReadOp

public boolean waitingReadOp

pendingReadOps

public int pendingReadOps

messagesConsumedCounter

public long messagesConsumedCounter

cursorLedger

public long cursorLedger

cursorLedgerLastEntry

public long cursorLedgerLastEntry

individuallyDeletedMessages

public String individuallyDeletedMessages

lastLedgerSwitchTimestamp

public String lastLedgerSwitchTimestamp

state

public String state

active

public boolean active

numberOfEntriesSinceFirstNotAckedMessage

public long numberOfEntriesSinceFirstNotAckedMessage

totalNonContiguousDeletedMessagesRange

public int totalNonContiguousDeletedMessagesRange

subscriptionHavePendingRead

public boolean subscriptionHavePendingRead

subscriptionHavePendingReplayRead

public boolean subscriptionHavePendingReplayRead

properties

public Map<String,Long> properties

Constructor Details

CursorStats

public CursorStats()