From 504587c724bf089d0efa714e5124671e19a2e8d6 Mon Sep 17 00:00:00 2001 From: Ayoub Mrini Date: Thu, 23 Oct 2025 11:35:16 +0200 Subject: [PATCH] chore(direct_io): fix constructor's name (#17371) Signed-off-by: machine424 --- tsdb/chunks/chunks.go | 2 +- tsdb/fileutil/direct_io_force.go | 2 +- tsdb/fileutil/direct_io_linux.go | 2 +- tsdb/fileutil/direct_io_unsupported.go | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/tsdb/chunks/chunks.go b/tsdb/chunks/chunks.go index 034106238e..4e48836be9 100644 --- a/tsdb/chunks/chunks.go +++ b/tsdb/chunks/chunks.go @@ -408,7 +408,7 @@ func (w *Writer) cut() error { // Uncached IO is implemented using direct I/O for now. wbuf, err = fileutil.NewDirectIOWriter(f, size) } else { - wbuf, err = fileutil.NewBufioWriterWithSeek(f, size) + wbuf, err = fileutil.NewBufioWriterWithSize(f, size) } if err != nil { return err diff --git a/tsdb/fileutil/direct_io_force.go b/tsdb/fileutil/direct_io_force.go index e2f811b9f2..bb65403911 100644 --- a/tsdb/fileutil/direct_io_force.go +++ b/tsdb/fileutil/direct_io_force.go @@ -23,6 +23,6 @@ func NewDirectIOWriter(f *os.File, size int) (BufWriter, error) { return newDirectIOWriter(f, size) } -func NewBufioWriterWithSeek(f *os.File, size int) (BufWriter, error) { +func NewBufioWriterWithSize(f *os.File, size int) (BufWriter, error) { return NewDirectIOWriter(f, size) } diff --git a/tsdb/fileutil/direct_io_linux.go b/tsdb/fileutil/direct_io_linux.go index 7406cc1594..a1d5f9577d 100644 --- a/tsdb/fileutil/direct_io_linux.go +++ b/tsdb/fileutil/direct_io_linux.go @@ -20,7 +20,7 @@ import ( "os" ) -func NewBufioWriterWithSeek(f *os.File, size int) (BufWriter, error) { +func NewBufioWriterWithSize(f *os.File, size int) (BufWriter, error) { return &writer{bufio.NewWriterSize(f, size)}, nil } diff --git a/tsdb/fileutil/direct_io_unsupported.go b/tsdb/fileutil/direct_io_unsupported.go index 3e3555ebf8..a03782fe42 100644 --- a/tsdb/fileutil/direct_io_unsupported.go +++ b/tsdb/fileutil/direct_io_unsupported.go @@ -20,7 +20,7 @@ import ( "os" ) -func NewBufioWriterWithSeek(f *os.File, size int) (BufWriter, error) { +func NewBufioWriterWithSize(f *os.File, size int) (BufWriter, error) { return &writer{bufio.NewWriterSize(f, size)}, nil }