aboutsummaryrefslogtreecommitdiff
path: root/go/sequence
diff options
context:
space:
mode:
Diffstat (limited to 'go/sequence')
-rw-r--r--go/sequence/memory_sequencer.go36
-rw-r--r--go/sequence/sequence.go7
2 files changed, 0 insertions, 43 deletions
diff --git a/go/sequence/memory_sequencer.go b/go/sequence/memory_sequencer.go
deleted file mode 100644
index d727dc723..000000000
--- a/go/sequence/memory_sequencer.go
+++ /dev/null
@@ -1,36 +0,0 @@
-package sequence
-
-import (
- "sync"
-)
-
-// just for testing
-type MemorySequencer struct {
- counter uint64
- sequenceLock sync.Mutex
-}
-
-func NewMemorySequencer() (m *MemorySequencer) {
- m = &MemorySequencer{counter: 1}
- return
-}
-
-func (m *MemorySequencer) NextFileId(count uint64) (uint64, uint64) {
- m.sequenceLock.Lock()
- defer m.sequenceLock.Unlock()
- ret := m.counter
- m.counter += uint64(count)
- return ret, count
-}
-
-func (m *MemorySequencer) SetMax(seenValue uint64) {
- m.sequenceLock.Lock()
- defer m.sequenceLock.Unlock()
- if m.counter <= seenValue {
- m.counter = seenValue + 1
- }
-}
-
-func (m *MemorySequencer) Peek() uint64 {
- return m.counter
-}
diff --git a/go/sequence/sequence.go b/go/sequence/sequence.go
deleted file mode 100644
index fbdc3b8ef..000000000
--- a/go/sequence/sequence.go
+++ /dev/null
@@ -1,7 +0,0 @@
-package sequence
-
-type Sequencer interface {
- NextFileId(count uint64) (uint64, uint64)
- SetMax(uint64)
- Peek() uint64
-}