diff options
| author | chrislu <chris.lu@gmail.com> | 2024-04-02 16:25:43 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-04-02 16:25:43 -0700 |
| commit | ccdd9cd8decf66089ac201b7c2ca1f5889582b93 (patch) | |
| tree | 3297dc54cff9893043fea8675b9ea3ef9d595bf3 /weed/util/log_buffer/log_buffer.go | |
| parent | f37c0d0d7a59d433a48a0102d7d76471ab034f40 (diff) | |
| download | seaweedfs-ccdd9cd8decf66089ac201b7c2ca1f5889582b93.tar.xz seaweedfs-ccdd9cd8decf66089ac201b7c2ca1f5889582b93.zip | |
refactor
Diffstat (limited to 'weed/util/log_buffer/log_buffer.go')
| -rw-r--r-- | weed/util/log_buffer/log_buffer.go | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/weed/util/log_buffer/log_buffer.go b/weed/util/log_buffer/log_buffer.go index 65d20a757..efe42176e 100644 --- a/weed/util/log_buffer/log_buffer.go +++ b/weed/util/log_buffer/log_buffer.go @@ -2,6 +2,7 @@ package log_buffer import ( "bytes" + "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" "sync" "sync/atomic" "time" @@ -68,7 +69,11 @@ func NewLogBuffer(name string, flushInterval time.Duration, flushFn LogFlushFunc return lb } -func (logBuffer *LogBuffer) AddToBuffer(partitionKey, data []byte, processingTsNs int64) { +func (logBuffer *LogBuffer) AddToBuffer(message *mq_pb.DataMessage) { + logBuffer.AddDataToBuffer(message.Key, message.Value, message.TsNs) +} + +func (logBuffer *LogBuffer) AddDataToBuffer(partitionKey, data []byte, processingTsNs int64) { var toFlush *dataToFlush logBuffer.Lock() |