(ts uint64)
| 231 | } |
| 232 | |
| 233 | func (o *oracle) CacheAt(ts uint64) *LocalCache { |
| 234 | o.RLock() |
| 235 | defer o.RUnlock() |
| 236 | txn, ok := o.pendingTxns[ts] |
| 237 | if !ok { |
| 238 | return nil |
| 239 | } |
| 240 | return txn.cache |
| 241 | } |
| 242 | |
| 243 | // MinPendingStartTs returns the min start ts which is currently pending a commit or abort decision. |
| 244 | func (o *oracle) MinPendingStartTs() uint64 { |
no test coverage detected