fallback

package

v0.9.3 Latest Latest Go to latest Published: Nov 9, 2025 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewDirBuffer(dir string) *DirBuffer

A disk-based ping-pong buffer. Reads and writes can be done simultaneously.

func (f *DirBuffer) Close() (err error)

Close implements io.WriteCloser.

func (d *DirBuffer) HasData() (ok bool, err error)

func (d *DirBuffer) Reader(fn func(n int, r io.Reader) error) (err error)

func (f *DirBuffer) Write(p []byte) (n int, err error)

Write implements io.WriteCloser.

type Fallback interface {
	io.WriteCloser
	HasData() (ok bool, err error)
	Reader(fn func(n int, r io.Reader) error) (err error)
}

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

A file-based buffer. Reads and writes are blocking each other - always prefer using the DirBuffer for this reason.

func NewFileBuffer(path string) *FileBuffer

func (f *FileBuffer) Close() (err error)

Close implements io.WriteCloser.

func (f *FileBuffer) HasData() (ok bool, err error)

HasData implements Fallback.

func (f *FileBuffer) Reader(fn func(n int, r io.Reader) error) (err error)

Reader implements Fallback.

func (f *FileBuffer) Write(p []byte) (n int, err error)

Write implements io.WriteCloser.