aboutsummaryrefslogtreecommitdiff
path: root/weed/util/log_buffer/log_buffer.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2024-03-10 14:34:28 -0700
committerchrislu <chris.lu@gmail.com>2024-03-10 14:34:28 -0700
commit6f75a0af55811fcfd584f4bf136cdc42db9cff5a (patch)
treeeff13da0237d6acf8a669a0262875ec2fc1d869f /weed/util/log_buffer/log_buffer.go
parentc1a5952009e58fb6524fa18b33ad1ab9e8794fd5 (diff)
downloadseaweedfs-6f75a0af55811fcfd584f4bf136cdc42db9cff5a.tar.xz
seaweedfs-6f75a0af55811fcfd584f4bf136cdc42db9cff5a.zip
ask follower to follow
Diffstat (limited to 'weed/util/log_buffer/log_buffer.go')
-rw-r--r--weed/util/log_buffer/log_buffer.go1
1 files changed, 1 insertions, 0 deletions
diff --git a/weed/util/log_buffer/log_buffer.go b/weed/util/log_buffer/log_buffer.go
index bf787eb79..7709a43e9 100644
--- a/weed/util/log_buffer/log_buffer.go
+++ b/weed/util/log_buffer/log_buffer.go
@@ -27,6 +27,7 @@ type LogFlushFuncType func(logBuffer *LogBuffer, startTime, stopTime time.Time,
type LogReadFromDiskFuncType func(startPosition MessagePosition, stopTsNs int64, eachLogEntryFn EachLogEntryFuncType) (lastReadPosition MessagePosition, isDone bool, err error)
type LogBuffer struct {
+ LastFlushTsNs int64
name string
prevBuffers *SealedBuffers
buf []byte