binarychunk

Nov 17, 2025

Changes in this version

+ const MAXIMUM_CHUNK_SIZE

+ var ErrBufferChunkFilled = errors.New("this buffer is already full")

+ type BinaryReference struct

+ Buffer int

+ Length int

+ Offset int

+ type Builder struct

+ func NewBuilder(compressor Compressor, tmpFolderPath string) *Builder

+ func (b *Builder) Build(ctx context.Context, writer io.Writer, ...) (int, error)

+ func (b *Builder) Read(ref *BinaryReference) ([]byte, error)

+ func (b *Builder) Write(binaryBody []byte) (*BinaryReference, error)

+ type Compressor interface

+ Compress func(ctx context.Context, reader io.Reader) (io.ReadCloser, error)

+ type FileSystemBinaryWriter struct

+ func NewFileSystemBinaryWriter(tmpPath string, bufferIndex int, maxSize int) (*FileSystemBinaryWriter, error)

+ func (w *FileSystemBinaryWriter) ChunkReader() (io.ReadCloser, error)

+ func (w *FileSystemBinaryWriter) Read(ref *BinaryReference) ([]byte, error)

+ func (w *FileSystemBinaryWriter) Seal() error

+ func (w *FileSystemBinaryWriter) Write(data []byte) (*BinaryReference, error)

+ type FileSystemGzipCompressor struct

+ func NewFileSystemGzipCompressor(temporaryFolder string) *FileSystemGzipCompressor

+ func (c *FileSystemGzipCompressor) Compress(ctx context.Context, reader io.Reader) (io.ReadCloser, error)

+ type LargeBinaryWriter interface

+ ChunkReader func() (io.ReadCloser, error)

+ Read func(ref *BinaryReference) ([]byte, error)

+ Seal func() error

+ Write func(data []byte) (*BinaryReference, error)