| 25 | ) |
| 26 | |
| 27 | func TestSequencer(t *testing.T) { |
| 28 | sequencer := NewSequencer() |
| 29 | require.NoError(t, sequencer.Reset()) |
| 30 | sequencer.seq = 0 |
| 31 | defer sequencer.Close() |
| 32 | |
| 33 | for i := 0; i < 10; i++ { |
| 34 | sequencer.Increment() |
| 35 | } |
| 36 | assert.Equal(t, uint64(10), sequencer.Get()) |
| 37 | require.NoError(t, sequencer.Store()) |
| 38 | |
| 39 | sequencer = NewSequencer() |
| 40 | defer sequencer.Close() |
| 41 | assert.Equal(t, uint64(10), sequencer.Get()) |
| 42 | |
| 43 | require.NoError(t, sequencer.Reset()) |
| 44 | assert.Equal(t, uint64(0), sequencer.Get()) |
| 45 | } |
| 46 | |
| 47 | func TestSequencerMonotonic(t *testing.T) { |
| 48 | sequencer := NewSequencer() |