Struct ArtifactStore 

pub struct ArtifactStore { /* private fields */ }

Content-addressed artifact store using BLAKE3 hashes.

Thread-safe via DashMap. The store guarantees:

• Deduplication: same content always produces the same hash.
• Integrity: every load verifies the content hash.
• Reference counting: tracks how many consumers reference each artifact.

Implementations

impl ArtifactStore

pub fn new_memory() -> Self

Create a new in-memory artifact store.

pub fn new_file(base_path: PathBuf) -> Self

Create a new file-backed artifact store.

pub fn store( &self, content: &[u8], content_type: ArtifactType, ) -> Result<String, KernelError>

Store content and return the BLAKE3 hash.

If the content is already stored, increments the reference count and returns the existing hash (deduplication).

pub fn load(&self, hash: &str) -> Result<Vec<u8>, KernelError>

Load content by hash, verifying integrity on read.

pub fn contains(&self, hash: &str) -> bool

Check whether an artifact exists by hash.

pub fn release(&self, hash: &str) -> bool

Decrement the reference count for an artifact.

Returns true if the reference count reached zero (eligible for GC).

pub fn remove(&self, hash: &str) -> Result<(), KernelError>

Remove an artifact and its data from storage.

pub fn count(&self) -> usize

Total number of stored artifacts.

pub fn total_bytes(&self) -> u64

Total stored bytes.

pub fn metadata( &self, hash: &str, ) -> Option<(String, u64, ArtifactType, DateTime<Utc>, u32)>

Get metadata for an artifact (hash, size, type, stored_at, refcount).

Trait Implementations

impl SystemService for ArtifactStore

fn name(&self) -> &str

Human-readable service name.

fn service_type(&self) -> ServiceType

Service type category.

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start the service.

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop the service.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = HealthStatus> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Perform a health check.