MaxPending returns the maximum assigned timestamp.
()
| 296 | |
| 297 | // MaxPending returns the maximum assigned timestamp. |
| 298 | func (o *Oracle) MaxPending() uint64 { |
| 299 | o.RLock() |
| 300 | defer o.RUnlock() |
| 301 | return o.maxAssigned |
| 302 | } |
| 303 | |
| 304 | // proposeTxn proposes a txn update, and then updates src to reflect the state |
| 305 | // of the commit after proposal is run. |