ioutil

package

v1.9.0 Latest Latest Go to latest Published: Aug 4, 2025 License: GPL-3.0 Imports: 5 Imported by: 0

Details

View Source

const DefaultBatchSize = 512

This section is empty.

func Batchify[T any](items []T, batchSize int) [][]T

type LimitWriter struct {
	W io.Writer
	N int // bytes remaining that can be written
	D int // bytes dropped so far
}

LimitWriter is a writer that limits the number of bytes written to it.

func (l *LimitWriter) Write(p []byte) (rnw int, err error)

type LinePrefixer struct {
	W io.Writer

	Prefix []byte
	// contains filtered or unexported fields
}

LinePrefixer is a writer that prefixes each line written to it with a prefix.

func (l *LinePrefixer) Close() error

func (l *LinePrefixer) Write(p []byte) (n int, err error)

type SizeLimitedWriter struct {
	SizeTrackingWriter
	Limit uint64
}

func (w *SizeLimitedWriter) Write(p []byte) (n int, err error)

type SizeTrackingWriter struct {
	io.Writer
	// contains filtered or unexported fields
}

func (w *SizeTrackingWriter) Size() uint64

Size returns the number of bytes written to the writer. The value is fundamentally racy only consistent if synchronized with the writer or closed.

func (w *SizeTrackingWriter) Write(p []byte) (n int, err error)

type SynchronizedWriter struct {
	Mu sync.Mutex
	W  io.Writer
}

func (w *SynchronizedWriter) Write(p []byte) (n int, err error)