aboutsummaryrefslogtreecommitdiff
path: root/weed/util/log_buffer/log_buffer.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2024-01-08 23:27:02 -0800
committerchrislu <chris.lu@gmail.com>2024-01-08 23:27:02 -0800
commitd51efddf5c18c6743cb0129e6c125617be3ceced (patch)
tree22da007d5b53d998af71740417bf54bd222f8f17 /weed/util/log_buffer/log_buffer.go
parentfbb4917e2fc444e371aa3a9041c44d4b84eb23a4 (diff)
downloadseaweedfs-d51efddf5c18c6743cb0129e6c125617be3ceced.tar.xz
seaweedfs-d51efddf5c18c6743cb0129e6c125617be3ceced.zip
flush to disk
Need to do: read from disk
Diffstat (limited to 'weed/util/log_buffer/log_buffer.go')
-rw-r--r--weed/util/log_buffer/log_buffer.go6
1 files changed, 4 insertions, 2 deletions
diff --git a/weed/util/log_buffer/log_buffer.go b/weed/util/log_buffer/log_buffer.go
index 2cb6f8c41..567d660ef 100644
--- a/weed/util/log_buffer/log_buffer.go
+++ b/weed/util/log_buffer/log_buffer.go
@@ -22,6 +22,8 @@ type dataToFlush struct {
data *bytes.Buffer
}
+type LogFlushFuncType func(startTime, stopTime time.Time, buf []byte)
+
type LogBuffer struct {
name string
prevBuffers *SealedBuffers
@@ -34,7 +36,7 @@ type LogBuffer struct {
lastFlushTime time.Time
sizeBuf []byte
flushInterval time.Duration
- flushFn func(startTime, stopTime time.Time, buf []byte)
+ flushFn LogFlushFuncType
notifyFn func()
isStopping *atomic.Bool
flushChan chan *dataToFlush
@@ -42,7 +44,7 @@ type LogBuffer struct {
sync.RWMutex
}
-func NewLogBuffer(name string, flushInterval time.Duration, flushFn func(startTime, stopTime time.Time, buf []byte), notifyFn func()) *LogBuffer {
+func NewLogBuffer(name string, flushInterval time.Duration, flushFn LogFlushFuncType, notifyFn func()) *LogBuffer {
lb := &LogBuffer{
name: name,
prevBuffers: newSealedBuffers(PreviousBufferCount),