(rs historyRecords)
| 691 | } |
| 692 | |
| 693 | func validateIncrementalTxid(rs historyRecords) error { |
| 694 | lastTxid := rs[0].Txid |
| 695 | |
| 696 | for i := 1; i < len(rs); i++ { |
| 697 | if rs[i].Txid < lastTxid { |
| 698 | return fmt.Errorf("detected non-incremental txid(%d, %d) in %s mode", lastTxid, rs[i].Txid, rs[i].OperationType) |
| 699 | } |
| 700 | lastTxid = rs[i].Txid |
| 701 | } |
| 702 | |
| 703 | return nil |
| 704 | } |
| 705 | |
| 706 | func validateSequential(rs historyRecords) error { |
| 707 | sort.Stable(rs) |