buffer

package

v4.2.2 Latest Latest Go to latest Published: May 25, 2026 License: AGPL-3.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Block interface {
	io.ReaderAt
	io.WriterAt
	Size() int64
}

func NewBlockAdapter(w WriteAtSeeker, r SizedReadAtSeeker) Block

func NewByteBlock(buf []byte) Block

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

将一个Block包装为ReadAtSeeker。动态大小：Size() 是动态跟随底层 Block。

func NewDynamicReadAtSeeker(block Block) *DynamicReadAtSeeker

func (r *DynamicReadAtSeeker) Read(p []byte) (n int, err error)

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

func (r *DynamicReadAtSeeker) Seek(offset int64, whence int) (int64, error)

func (r *DynamicReadAtSeeker) Size() int64

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

func NewPipeBuffer(ctx context.Context, block Block) *PipeBuffer

NewPipeBuffer is a buffer that can have 1 read & 1 write at the same time. when read is faster write, immediately feed data to read after written

func (br *PipeBuffer) Close() error

func (br *PipeBuffer) Read(p []byte) (int, error)

func (br *PipeBuffer) Reset(limit int) error

func (br *PipeBuffer) Write(p []byte) (int, error)

type ReadAtSeeker = model.File

func ReadAtSeekerOf(b Block) ReadAtSeeker

将一个Block包装为ReadAtSeeker。固定大小：当前Block的Size()。

type ReadAtSeekerProvider interface{ GetReadAtSeeker() ReadAtSeeker }

type SizedReadAtSeeker interface {
	ReadAtSeeker
	Size() int64
}

type WriteAtSeeker = model.FileWriter

func WriteAtSeekerOf(b Block) WriteAtSeeker

type WriteAtSeekerProvider interface{ GetWriteAtSeeker() WriteAtSeeker }