mirrors/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2026-05-05 04:16:15 +02:00
Code Issues Projects Releases Wiki Activity

chore(direct_io): fix constructor's name (#17371)

Browse Source 
Signed-off-by: machine424 <ayoubmrini424@gmail.com>
This commit is contained in:
Ayoub Mrini 2025-10-23 11:35:16 +02:00 committed by GitHub
parent 2063b953c7
commit 504587c724
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tsdb/chunks/chunks.go
View File

@ -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

2
tsdb/fileutil/direct_io_force.go
View File

@ -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)
}

2
tsdb/fileutil/direct_io_linux.go
View File

@ -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
}

2
tsdb/fileutil/direct_io_unsupported.go
View File

@ -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
}