compression

type Algorithm string

type CompressedChunk struct {
	ID         int
	Original   []byte
	Compressed []byte
	Error      error
}

type Compressor interface {
	// Compress compresses data
	Compress(data []byte) ([]byte, error)
	// Decompress decompresses data
	Decompress(data []byte) ([]byte, error)
	// CompressStream compresses from reader to writer
	CompressStream(dst io.Writer, src io.Reader) error
	// DecompressStream decompresses from reader to writer
	DecompressStream(dst io.Writer, src io.Reader) error
	// Algorithm returns the compression algorithm
	Algorithm() Algorithm
	// Level returns the compression level
	Level() Level
}

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

type Config struct {
	Algorithm   Algorithm
	Level       Level
	BufferSize  int
	Concurrency int
}

type Level int

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

type ParallelConfig struct {
	Algorithm  Algorithm
	Level      Level
	NumWorkers int // 0 = auto (NumCPU)
	ChunkSize  int // Size of each chunk in bytes
}