Skip to content

Commit bc0f9b6

Browse files
committed
Increase line buffering
1 parent 9a22f1f commit bc0f9b6

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

exporter/exporter.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,7 @@ func (p *Exporter) processFileUpdate(path string) error {
124124
slog.Info("File processing complete", "new_offset", p.offset, "duration", time.Since(start))
125125
}()
126126

127-
reader := bufio.NewReaderSize(file, 1<<20) // 1MB buffer
127+
reader := bufio.NewReaderSize(file, 32*1024*1024)
128128
for {
129129
line, err := reader.ReadSlice('\n')
130130
if err != nil {

0 commit comments

Comments
 (0)