Package com.eventstore.dbclient
Class PersistentSubscriptionStats
- java.lang.Object
-
- com.eventstore.dbclient.PersistentSubscriptionStats
-
- Direct Known Subclasses:
PersistentSubscriptionToAllStats
,PersistentSubscriptionToStreamStats
public abstract class PersistentSubscriptionStats extends java.lang.Object
Processing-related persistent subscription statistics.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getAveragePerSecond()
Average number of events per seconds.int
getCountSinceLastMeasurement()
Number of events seen since last measurement on this connection.long
getLiveBufferCount()
Number of events in the live buffer.int
getOutstandingMessagesCount()
Current number of outstanding messages.long
getParkedMessageCount()
The current number of parked messages.int
getReadBufferCount()
Number of events in the read buffer.int
getRetryBufferCount()
Number of events in the retry buffer.int
getTotalInFlightMessages()
Current in flight messages across the persistent subscription group.long
getTotalItems()
Total number of events processed by subscription.
-
-
-
Method Detail
-
getAveragePerSecond
public int getAveragePerSecond()
Average number of events per seconds.
-
getTotalItems
public long getTotalItems()
Total number of events processed by subscription.
-
getCountSinceLastMeasurement
public int getCountSinceLastMeasurement()
Number of events seen since last measurement on this connection. Used as the basis for averagePerSecond
-
getReadBufferCount
public int getReadBufferCount()
Number of events in the read buffer.
-
getLiveBufferCount
public long getLiveBufferCount()
Number of events in the live buffer.
-
getRetryBufferCount
public int getRetryBufferCount()
Number of events in the retry buffer.
-
getTotalInFlightMessages
public int getTotalInFlightMessages()
Current in flight messages across the persistent subscription group.
-
getOutstandingMessagesCount
public int getOutstandingMessagesCount()
Current number of outstanding messages.
-
getParkedMessageCount
public long getParkedMessageCount()
The current number of parked messages.
-
-