diff options
| author | chrislu <chris.lu@gmail.com> | 2024-01-08 23:27:02 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-01-08 23:27:02 -0800 |
| commit | d51efddf5c18c6743cb0129e6c125617be3ceced (patch) | |
| tree | 22da007d5b53d998af71740417bf54bd222f8f17 /weed/util/log_buffer/log_buffer.go | |
| parent | fbb4917e2fc444e371aa3a9041c44d4b84eb23a4 (diff) | |
| download | seaweedfs-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.go | 6 |
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), |
