Export returns a copy of the SequenceState's state - the latestValues and lastSequenceIncremented. lastSequenceIncremented is only defined if latestValues is non-empty.
()
| 93 | // lastSequenceIncremented. |
| 94 | // lastSequenceIncremented is only defined if latestValues is non-empty. |
| 95 | func (ss *SequenceState) Export() (map[uint32]int64, uint32) { |
| 96 | ss.mu.Lock() |
| 97 | defer ss.mu.Unlock() |
| 98 | res := make(map[uint32]int64, len(ss.mu.latestValues)) |
| 99 | for k, v := range ss.mu.latestValues { |
| 100 | res[k] = v |
| 101 | } |
| 102 | return res, ss.mu.lastSequenceIncremented |
| 103 | } |