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

Interface SubscriptionStats

All Known Subinterfaces:
NonPersistentSubscriptionStats
public interface SubscriptionStats
Statistics about subscription.

  • Method Details

    • getMsgRateOut

      double getMsgRateOut()
      Total rate of messages delivered on this subscription (msg/s).

    • getMsgThroughputOut

      double getMsgThroughputOut()
      Total throughput delivered on this subscription (bytes/s).

    • getBytesOutCounter

      long getBytesOutCounter()
      Total bytes delivered to consumer (bytes).

    • getMsgOutCounter

      long getMsgOutCounter()
      Total messages delivered to consumer (msg).

    • getMsgRateRedeliver

      double getMsgRateRedeliver()
      Total rate of messages redelivered on this subscription (msg/s).

    • getMessageAckRate

      double getMessageAckRate()
      Total rate of message ack(msg/s).

    • getChunkedMessageRate

      int getChunkedMessageRate()
      Chunked message dispatch rate.

    • getMsgBacklog

      long getMsgBacklog()
      Number of entries in the subscription backlog.

    • getBacklogSize

      long getBacklogSize()
      Size of backlog in byte.

    • getEarliestMsgPublishTimeInBacklog

      long getEarliestMsgPublishTimeInBacklog()
      Get the publish time of the earliest message in the backlog.

    • getMsgBacklogNoDelayed

      long getMsgBacklogNoDelayed()
      Number of entries in the subscription backlog that do not contain the delay messages.

    • isBlockedSubscriptionOnUnackedMsgs

      boolean isBlockedSubscriptionOnUnackedMsgs()
      Flag to verify if subscription is blocked due to reaching threshold of unacked messages.

    • getMsgDelayed

      long getMsgDelayed()
      Number of delayed messages currently being tracked.

    • getUnackedMessages

      long getUnackedMessages()
      Number of unacknowledged messages for the subscription, where an unacknowledged message is one that has been sent to a consumer but not yet acknowledged. Calculated by summing all ConsumerStats.getUnackedMessages() for this subscription. See ConsumerStats.getUnackedMessages() for additional details.

    • getType

      String getType()
      The subscription type as defined by SubscriptionType.

    • getActiveConsumerName

      String getActiveConsumerName()
      The name of the consumer that is active for single active consumer subscriptions i.e. failover or exclusive.

    • getMsgRateExpired

      double getMsgRateExpired()
      Total rate of messages expired on this subscription (msg/s).

    • getTotalMsgExpired

      long getTotalMsgExpired()
      Total messages expired on this subscription.

    • getLastExpireTimestamp

      long getLastExpireTimestamp()
      Last message expire execution timestamp.

    • getLastConsumedFlowTimestamp

      long getLastConsumedFlowTimestamp()
      Last received consume flow command timestamp.

    • getLastConsumedTimestamp

      long getLastConsumedTimestamp()
      Last consume message timestamp.

    • getLastAckedTimestamp

      long getLastAckedTimestamp()
      Last acked message timestamp.

    • getLastMarkDeleteAdvancedTimestamp

      long getLastMarkDeleteAdvancedTimestamp()
      Last MarkDelete position advanced timesetamp.

    • getConsumers

      List<? extends ConsumerStats> getConsumers()
      List of connected consumers on this subscription w/ their stats.

    • isDurable

      boolean isDurable()
      Tells whether this subscription is durable or ephemeral (eg.: from a reader).

    • isReplicated

      boolean isReplicated()
      Mark that the subscription state is kept in sync across different regions.

    • isAllowOutOfOrderDelivery

      boolean isAllowOutOfOrderDelivery()
      Whether out of order delivery is allowed on the Key_Shared subscription.

    • getKeySharedMode

      String getKeySharedMode()
      Whether the Key_Shared subscription mode is AUTO_SPLIT or STICKY.

    • getConsumersAfterMarkDeletePosition

      Map<String,String> getConsumersAfterMarkDeletePosition()
      This is for Key_Shared subscription to get the recentJoinedConsumers in the Key_Shared subscription.

    • getSubscriptionProperties

      Map<String,String> getSubscriptionProperties()
      SubscriptionProperties (key/value strings) associated with this subscribe.

    • getNonContiguousDeletedMessagesRanges

      int getNonContiguousDeletedMessagesRanges()
      The number of non-contiguous deleted messages ranges.

    • getNonContiguousDeletedMessagesRangesSerializedSize

      int getNonContiguousDeletedMessagesRangesSerializedSize()
      The serialized size of non-contiguous deleted messages ranges.

    • getFilterProcessedMsgCount

      long getFilterProcessedMsgCount()

    • getFilterAcceptedMsgCount

      long getFilterAcceptedMsgCount()

    • getFilterRejectedMsgCount

      long getFilterRejectedMsgCount()

    • getFilterRescheduledMsgCount

      long getFilterRescheduledMsgCount()

    • getDelayedMessageIndexSizeInBytes

      long getDelayedMessageIndexSizeInBytes()