diff options
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), |