cas-kit 0.2.1

Content-addressed blob store: BLAKE3 addressing, bucketed layout, optional Zstd compression, packfiles, verify-on-read, mark-sweep GC with the cas-gc CLI.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

// SPDX-License-Identifier: MIT OR Apache-2.0
//! Error types for the content-addressed store.

use std::io;

use thiserror::Error;

use crate::pack::PackError;

/// Errors that can occur during CAS operations.
#[derive(Error, Debug)]
pub enum CasError {
    /// The requested blob does not exist in the store (loose or packed).
    #[error("blob not found: {0}")]
    BlobNotFound(String),

    /// The stored bytes did not hash to the requested address.
    #[error("hash mismatch: expected {expected}, got {actual}")]
    HashMismatch {
        /// The hash the blob was addressed by.
        expected: String,
        /// The hash of what was actually read back.
        actual: String,
    },

    /// A mutex protecting interior cache state was poisoned.
    #[error("lock poisoned: {0}")]
    LockPoisoned(String),

    /// An underlying filesystem operation failed.
    #[error("I/O error: {0}")]
    Io(#[from] io::Error),

    /// Zstd compression failed (requires the `zstd` feature).
    #[error("compression error: {0}")]
    CompressionError(String),

    /// Zstd decompression failed (requires the `zstd` feature).
    #[error("decompression error: {0}")]
    DecompressionError(String),

    /// Decompressed data exceeded the configured safety limit
    /// (zip-bomb protection).
    #[error("decompressed data too large: {max} bytes max")]
    DecompressionTooLarge {
        /// The maximum accepted decompressed size in bytes.
        max: usize,
    },

    /// [`crate::store::BlobStore::put_blob_new`] was called for an existing blob.
    #[error("blob already exists: {0}")]
    AlreadyExists(String),

    /// A derived path was not usable (e.g. malformed hex on disk).
    #[error("invalid path: {0}")]
    InvalidPath(String),

    /// A packfile operation failed.
    #[error("pack error: {0}")]
    Pack(#[from] PackError),

    /// A garbage-collection sweep was asked to trash or delete a path
    /// outside the store root (internal invariant violation).
    #[error("gc path outside store root: {0}")]
    GcPathEscape(String),

    /// A `spawn_blocking` task joined by an async GC wrapper panicked or
    /// the tokio runtime was already shut down (requires the `tokio`
    /// feature).
    #[error("background gc task failed: {0}")]
    TaskJoin(String),
}