A pure Zig implementation of the XET protocol for efficient file storage and retrieval through content-defined chunking and deduplication.

XET is a protocol for handling large files by breaking them into chunks based on their content (not fixed sizes), compressing them, and storing them in a way that eliminates duplicates.

It's particularly useful for managing large models and datasets, like those hosted on HuggingFace.

This library implements the full XET protocol spec in Zig, including:

• Content-defined chunking using the Gearhash algorithm (chunks are between 8KB-128KB)
• LZ4 compression with byte grouping optimization and experimental bit grouping
• Merkle tree construction for efficient file verification
• Xorb format for serializing chunked data
• MDB shard format for metadata storage
• CAS client for downloading files from HuggingFace
• Parallel chunk fetching, decompression, and hashing using thread pools

The implementation has been cross-verified against the Rust reference implementation to ensure correctness.

It can be compiled to WebAssembly, but runs at about 45% of the non-threaded native speed.

• Zig 0.16 or newer
• A HuggingFace token (for downloading models)

# Build the project
zig build
# Run tests (98 tests covering all components)
zig build test
# Run the demo CLI
zig build run
# Run benchmarks
zig build bench

The most common use case is downloading models efficiently:

# Set your HuggingFace token
export HF_TOKEN="your_token_here"
# Run the download example (sequential)
zig build run-example-download
# Run the parallel download example (faster for large files)
zig build run-example-parallel

The parallel version uses multiple threads to fetch, decompress, and hash chunks simultaneously, providing significant performance improvements for large models.

Add to your build.zig.zon:

.dependencies = .{
 .xet = .{
 .url = "https://github.com/yourusername/zig-xet/archive/main.tar.gz",
 },
},

Then in your code:

const std = @import("std");
const xet = @import("xet");
// Chunk a file using content-defined chunking
var chunks = try xet.chunking.chunkBuffer(allocator, data);
defer chunks.deinit(allocator);
// Hash chunks with BLAKE3
const hash = xet.hashing.computeDataHash(chunk_data);
// Build a Merkle tree for verification
const merkle_root = try xet.hashing.buildMerkleTree(allocator, &nodes);
// Download a model from HuggingFace (sequential)
var io_instance = std.Io.Threaded.init(allocator);
defer io_instance.deinit();
const io = io_instance.io();
const config = xet.model_download.DownloadConfig{
 .repo_id = "org/model",
 .repo_type = "model",
 .revision = "main",
 .file_hash_hex = "...",
};
try xet.model_download.downloadModelToFile(allocator, io, config, "output.gguf");
// Or download with parallel fetching (faster for large files)
try xet.model_download.downloadModelToFileParallel(
 allocator,
 io,
 config,
 "output.gguf",
 false, // Don't compute hashes during download
);

The XET protocol processes files in several stages:

1. Chunking: Files are split using a rolling hash algorithm. Instead of fixed-size chunks, boundaries are determined by content patterns, which means similar files share many identical chunks.

2. Hashing: Each chunk gets a BLAKE3 hash. A Merkle tree combines these hashes to create a single file identifier.

3. Compression: Chunks are compressed with LZ4, optionally with byte grouping preprocessing for better ratios.

4. Deduplication: Identical chunks (same hash) are stored only once, saving space when you have multiple similar files.

5. Storage: Chunks are bundled into "xorbs" and metadata is stored in "MDB shards" for efficient retrieval.

When downloading from HuggingFace, the library queries the CAS (content-addressable storage) API to find which chunks are needed, fetches them (optionally in parallel using a thread pool), decompresses, and reconstructs the original file.

The parallel fetching implementation uses a thread pool to simultaneously:

• Download chunks via HTTP
• Decompress chunks
• Compute BLAKE3 hashes

This provides significant speedup for large models, especially on multi-core systems with good network bandwidth.

This implementation follows the official XET protocol specification exactly.

All constants, algorithms, and formats match the reference Rust implementation byte-for-byte. The test suite includes cross-verification tests to ensure continued compatibility.

1. Go to https://huggingface.co/settings/tokens
2. Create a new token with "Read access to contents of all public gated repos you can access"
3. Copy the token and set it as HF_TOKEN environment variable

• XET Protocol Draft Specification
• XET Protocol Documentation