public interface SubscriptionMetrics
Modifier and Type | Method and Description |
---|---|
Map<oracle.kv.impl.topo.RepGroupId,com.sleepycat.je.utilint.VLSN> |
getAckStartVLSN()
Returns the acknowledged start vlsn from NoSQL DB for each subscribed
shard
|
long |
getCurrentOpenTxn()
Returns the current total number of open transactions in publisher
that have not yet committed or aborted.
|
Map<oracle.kv.impl.topo.RepGroupId,com.sleepycat.je.utilint.VLSN> |
getLastAbortVLSN()
Returns the last aborted vlsn for each subscribed shard
|
Map<oracle.kv.impl.topo.RepGroupId,com.sleepycat.je.utilint.VLSN> |
getLastCommitVLSN()
Returns the last committed vlsn for each subscribed shard
|
Map<oracle.kv.impl.topo.RepGroupId,Long> |
getLastMsgTimeStamp()
Returns the timestamp of last message from each subscribed shard
|
long |
getNumTokenRefreshed()
Gets the number of times that token has been refreshed with the secure
store.
|
Map<oracle.kv.impl.topo.RepGroupId,com.sleepycat.je.utilint.VLSN> |
getReqStartVLSN()
Returns the requested start vlsn for each subscribed shard
|
long |
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 subscription
|
long |
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 subscription
|
long |
getTotalConsumedOps()
Returns the total number of stream operations that have been consumed
by subscriber
|
long |
getTotalReconnect()
Returns the total number of reconnections to shards in subscription.
|
Map<oracle.kv.impl.topo.RepGroupId,com.sleepycat.je.utilint.VLSN> getReqStartVLSN()
Map<oracle.kv.impl.topo.RepGroupId,com.sleepycat.je.utilint.VLSN> getAckStartVLSN()
Map<oracle.kv.impl.topo.RepGroupId,com.sleepycat.je.utilint.VLSN> getLastCommitVLSN()
Map<oracle.kv.impl.topo.RepGroupId,com.sleepycat.je.utilint.VLSN> getLastAbortVLSN()
Map<oracle.kv.impl.topo.RepGroupId,Long> getLastMsgTimeStamp()
long getTotalConsumedOps()
long getTotalCommitTxns()
long getTotalAbortTxns()
long getTotalCommitOps()
long getTotalAbortOps()
long getCurrentOpenTxn()
long getTotalReconnect()
long getNumTokenRefreshed()
Copyright (c) 2011, 2017 Oracle and/or its affiliates. All rights reserved.