chunker

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

type Chunk struct {
	Hash           string // BLAKE3 hash of chunk content
	Offset         int64  // Offset in original stream
	Size           uint32 // Chunk size in bytes
	CompressedSize uint32 // Compressed chunk size in bytes
	Data           []byte // Chunk data
	// contains filtered or unexported fields
}

type Chunker interface {
	// Chunk splits the reader into content-defined chunks.
	// Returns two channels: one for yielding chunks and one for yielding errors.
	Chunk(ctx context.Context, r io.Reader) (<-chan *Chunk, <-chan error)
}