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

Interface ReplicatorStats

All Known Subinterfaces:
NonPersistentReplicatorStats
public interface ReplicatorStats
Statistics about a replicator.

  • Method Details

    • getMsgRateIn

      @Deprecated double getMsgRateIn()
      Deprecated.
      Total rate of messages received from the remote cluster (msg/s).

    • getMsgInCount

      long getMsgInCount()
      Total number of messages received from the remote cluster.

    • getMsgThroughputIn

      @Deprecated double getMsgThroughputIn()
      Deprecated.
      Total throughput received from the remote cluster (bytes/s).

    • getBytesInCount

      long getBytesInCount()
      Total number of bytes received from the remote cluster.

    • getMsgRateOut

      @Deprecated double getMsgRateOut()
      Deprecated.
      Total rate of messages delivered to the replication-subscriber (msg/s).

    • getMsgOutCount

      long getMsgOutCount()
      Total number of messages sent to the remote cluster.

    • getMsgThroughputOut

      @Deprecated double getMsgThroughputOut()
      Deprecated.
      Total throughput delivered to the replication-subscriber (bytes/s).

    • getBytesOutCount

      long getBytesOutCount()
      Total number of bytes sent to the remote cluster.

    • getMsgRateExpired

      @Deprecated double getMsgRateExpired()
      Deprecated.
      Total rate of messages expired (msg/s).

    • getMsgExpiredCount

      long getMsgExpiredCount()
      Total number of messages expired.

    • getReplicationBacklog

      long getReplicationBacklog()
      Number of messages pending to be replicated to remote cluster.

    • isConnected

      boolean isConnected()
      is the replication-subscriber up and running to replicate to remote cluster.

    • getReplicationDelayInSeconds

      long getReplicationDelayInSeconds()
      Time in seconds from the time a message was produced to the time when it is about to be replicated.

    • getInboundConnection

      String getInboundConnection()
      Address of incoming replication connection.

    • getInboundConnectedSince

      String getInboundConnectedSince()
      Timestamp of incoming connection establishment time.

    • getOutboundConnection

      String getOutboundConnection()
      Address of outbound replication connection.

    • getOutboundConnectedSince

      String getOutboundConnectedSince()
      Timestamp of outbound connection establishment time.