binarychunk

type BinaryReference struct {
	Offset int `json:"offset"`
	Length int `json:"len"`
	Buffer int `json:"buffer"`
}

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

type Compressor interface {
	// Compress reads all bytes from given reader and returns a reader for the compressed buffer.
	Compress(ctx context.Context, reader io.Reader) (io.ReadCloser, error)
}

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

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

type LargeBinaryWriter interface {
	// Write the specified text and returns the BinaryReference
	Write(data []byte) (*BinaryReference, error)
	// Read buffer from a BinaryReference
	Read(ref *BinaryReference) ([]byte, error)
	// ChunkReader returns a read closer for the result binary chunk.
	ChunkReader() (io.ReadCloser, error)
	// Seal marks this writer done writing.
	Seal() error
}