Affected by GO-2025-4237 and 1 other vulnerabilities

GO-2025-4237: Weaviate OSS has a Path Traversal Vulnerability via Backup ZipSlip in github.com/weaviate/weaviate

GO-2025-4238: Weaviate OSS has path traversal vulnerability via the Shard Movement API in github.com/weaviate/weaviate

diskio

package

v1.32.13 Latest Latest Go to latest Published: Oct 20, 2025 License: BSD-3-Clause Imports: 4 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/weaviate/weaviate

Links

Documentation ¶

Index ¶

func FileExists(file string) (bool, error)
func Fsync(path string) error
func GetFileWithSizes(dirPath string) (map[string]int64, error)
func IsDirEmpty(dir string) (bool, error)
type MeteredReader
- func NewMeteredReader(file Reader, cb MeteredReaderCallback) *MeteredReader
- func (m *MeteredReader) Read(p []byte) (n int, err error)
- func (m *MeteredReader) ReadAt(p []byte, off int64) (n int, err error)
type MeteredReaderCallback
type MeteredWriter
- func NewMeteredWriter(w WriterSeekerCloser, cb MeteredWriterCallback) *MeteredWriter
- func (m *MeteredWriter) Seek(offset int64, whence int) (int64, error)
- func (m *MeteredWriter) Write(p []byte) (n int, err error)
type MeteredWriterCallback
type Reader
type WriterSeekerCloser

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func FileExists ¶ added in v1.26.0

func FileExists(file string) (bool, error)

func Fsync ¶ added in v1.28.5

func Fsync(path string) error

func GetFileWithSizes ¶ added in v1.31.5

func GetFileWithSizes(dirPath string) (map[string]int64, error)

GetFileWithSizes gets all files in a directory including their filesize

func IsDirEmpty ¶ added in v1.31.1

func IsDirEmpty(dir string) (bool, error)

Types ¶

type MeteredReader ¶

type MeteredReader struct {
	// contains filtered or unexported fields
}

func NewMeteredReader ¶

func NewMeteredReader(file Reader, cb MeteredReaderCallback) *MeteredReader

func (*MeteredReader) Read ¶

func (m *MeteredReader) Read(p []byte) (n int, err error)

Read passes the read through to the underlying reader. On a successful read, it will trigger the attached callback and provide it with metrics. If no callback is set, it will ignore it.

func (*MeteredReader) ReadAt ¶ added in v1.30.8

func (m *MeteredReader) ReadAt(p []byte, off int64) (n int, err error)

ReadAt passes the read through to the underlying reader. On a successful read, it will trigger the attached callback and provide it with metrics. If no callback is set, it will ignore it.

type MeteredReaderCallback ¶

type MeteredReaderCallback func(read int64, nanoseconds int64)

type MeteredWriter ¶ added in v1.27.23

type MeteredWriter struct {
	// contains filtered or unexported fields
}

func NewMeteredWriter ¶ added in v1.27.23

func NewMeteredWriter(w WriterSeekerCloser, cb MeteredWriterCallback) *MeteredWriter

func (*MeteredWriter) Seek ¶ added in v1.27.23

func (m *MeteredWriter) Seek(offset int64, whence int) (int64, error)

func (*MeteredWriter) Write ¶ added in v1.27.23

func (m *MeteredWriter) Write(p []byte) (n int, err error)

type MeteredWriterCallback ¶ added in v1.27.23

type MeteredWriterCallback func(written int64)

type Reader ¶ added in v1.30.8

type Reader interface {
	Read(p []byte) (n int, err error)
	ReadAt(p []byte, off int64) (n int, err error)
}

type WriterSeekerCloser ¶ added in v1.27.23

type WriterSeekerCloser interface {
	io.Writer
	io.Seeker
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL