Package oracle.kv.stats
Interface SubscriptionMetrics
-
public interface SubscriptionMetrics
Object represents a set of statistics of a single subscription.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Map<oracle.kv.impl.topo.RepGroupId,Long>
getAckStartVLSN()
Returns the acknowledged start vlsn from NoSQL DB for each subscribed shardlong
getCurrentOpenTxn()
Returns the current total number of open transactions in publisher that have not yet committed or aborted.Map<oracle.kv.impl.topo.RepGroupId,Long>
getLastAbortVLSN()
Returns the last aborted vlsn for each subscribed shardMap<oracle.kv.impl.topo.RepGroupId,Long>
getLastCommitVLSN()
Returns the last committed vlsn for each subscribed shardMap<oracle.kv.impl.topo.RepGroupId,Long>
getLastMsgTimeStamp()
Returns the timestamp of last message from each subscribed shardlong
getNumTokenRefreshed()
Gets the number of times that token has been refreshed with the secure store.Map<oracle.kv.impl.topo.RepGroupId,Long>
getReqStartVLSN()
Returns the requested start vlsn for each subscribed shardlong
getTotalAbortOps()
Returns the total number of operations that were part of aborted transactions in the subscription.long
getTotalAbortTxns()
Returns the total aborted transactions in the subscriptionlong
getTotalCommitOps()
Returns the total number of operations that were part of committed transactions in the subscription.long
getTotalCommitTxns()
Returns the total committed transactions in the subscriptionlong
getTotalConsumedOps()
Returns the total number of stream operations that have been consumed by subscriberlong
getTotalReconnect()
Returns the total number of reconnections to shards in subscription.
-
-
-
Method Detail
-
getReqStartVLSN
Map<oracle.kv.impl.topo.RepGroupId,Long> getReqStartVLSN()
Returns the requested start vlsn for each subscribed shard- Returns:
- the requested start vlsn for each subscribed shard
-
getAckStartVLSN
Map<oracle.kv.impl.topo.RepGroupId,Long> getAckStartVLSN()
Returns the acknowledged start vlsn from NoSQL DB for each subscribed shard- Returns:
- the acknowledged start vlsn from NoSQL DB for each subscribed shard
-
getLastCommitVLSN
Map<oracle.kv.impl.topo.RepGroupId,Long> getLastCommitVLSN()
Returns the last committed vlsn for each subscribed shard- Returns:
- the last committed vlsn for each subscribed shard
-
getLastAbortVLSN
Map<oracle.kv.impl.topo.RepGroupId,Long> getLastAbortVLSN()
Returns the last aborted vlsn for each subscribed shard- Returns:
- the last aborted vlsn for each subscribed shard
-
getLastMsgTimeStamp
Map<oracle.kv.impl.topo.RepGroupId,Long> getLastMsgTimeStamp()
Returns the timestamp of last message from each subscribed shard- Returns:
- the timestamp of last message from each subscribed shard
-
getTotalConsumedOps
long getTotalConsumedOps()
Returns the total number of stream operations that have been consumed by subscriber- Returns:
- the total number of stream operations that have been consumed by subscriber
-
getTotalCommitTxns
long getTotalCommitTxns()
Returns the total committed transactions in the subscription- Returns:
- the total committed transactions in the subscription
-
getTotalAbortTxns
long getTotalAbortTxns()
Returns the total aborted transactions in the subscription- Returns:
- the total aborted transactions in the subscription
-
getTotalCommitOps
long getTotalCommitOps()
Returns the total number of operations that were part of committed transactions in the subscription. It is a sum of operations of all committed transactions.- Returns:
- the total committed operations in the subscription
-
getTotalAbortOps
long getTotalAbortOps()
Returns the total number of operations that were part of aborted transactions in the subscription. It is a sum of operations of all aborted transactions.- Returns:
- the total aborted operations in the subscription
-
getCurrentOpenTxn
long getCurrentOpenTxn()
Returns the current total number of open transactions in publisher that have not yet committed or aborted.- Returns:
- the current total open transactions in the subscription
-
getTotalReconnect
long getTotalReconnect()
Returns the total number of reconnections to shards in subscription. The reconnection happens at level of shard when subscriber is unable to stream from a node in that shard, e.g., the master node is done and a new master is elected, and subscriber will reconnect to the new master of the shard.- Returns:
- the total number of reconnections
-
getNumTokenRefreshed
long getNumTokenRefreshed()
Gets the number of times that token has been refreshed with the secure store. Refreshing a token includes both renewing an existing token and re-authenticating to obtain a new token if existing token cannot be renewed. For non-secure store, it always returns 0.- Returns:
- the number of times that token has been refreshed
-
-