aboutsummaryrefslogtreecommitdiff
path: root/weed/sequence
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2024-08-10 10:01:57 -0700
committerchrislu <chris.lu@gmail.com>2024-08-10 10:01:57 -0700
commit7438648d1cfacd5ca570dd029d1bdb5fd271bd70 (patch)
treecf12b49473be0373cb03d83470ddc75708454171 /weed/sequence
parent49893267e978cc3fda00dc991e00099742fb5a9d (diff)
parent63c707f9c1b4dc469ec39c446563c324ce4ccb6f (diff)
downloadseaweedfs-7438648d1cfacd5ca570dd029d1bdb5fd271bd70.tar.xz
seaweedfs-7438648d1cfacd5ca570dd029d1bdb5fd271bd70.zip
Merge branch 'master' into mq
Diffstat (limited to 'weed/sequence')
-rw-r--r--weed/sequence/memory_sequencer.go4
-rw-r--r--weed/sequence/sequence.go1
-rw-r--r--weed/sequence/snowflake_sequencer.go5
3 files changed, 0 insertions, 10 deletions
diff --git a/weed/sequence/memory_sequencer.go b/weed/sequence/memory_sequencer.go
index 6e879bd79..92944266c 100644
--- a/weed/sequence/memory_sequencer.go
+++ b/weed/sequence/memory_sequencer.go
@@ -30,7 +30,3 @@ func (m *MemorySequencer) SetMax(seenValue uint64) {
m.counter = seenValue + 1
}
}
-
-func (m *MemorySequencer) Peek() uint64 {
- return m.counter
-}
diff --git a/weed/sequence/sequence.go b/weed/sequence/sequence.go
index 2258d001b..49de63b73 100644
--- a/weed/sequence/sequence.go
+++ b/weed/sequence/sequence.go
@@ -3,5 +3,4 @@ package sequence
type Sequencer interface {
NextFileId(count uint64) uint64
SetMax(uint64)
- Peek() uint64
}
diff --git a/weed/sequence/snowflake_sequencer.go b/weed/sequence/snowflake_sequencer.go
index b63198349..05694f681 100644
--- a/weed/sequence/snowflake_sequencer.go
+++ b/weed/sequence/snowflake_sequencer.go
@@ -42,8 +42,3 @@ func (m *SnowflakeSequencer) NextFileId(count uint64) uint64 {
// ignore setmax as we are snowflake
func (m *SnowflakeSequencer) SetMax(seenValue uint64) {
}
-
-// return a new id as no Peek is stored
-func (m *SnowflakeSequencer) Peek() uint64 {
- return uint64(m.node.Generate().Int64())
-}