Struct LocalBlobStore 

pub struct LocalBlobStore { /* private fields */ }

Filesystem-backed BlobStore.

Blobs are written to a temporary file in the destination directory and renamed into place, so a reader never observes a partially written blob.

Examples

use ironflow_artifacts::blob_store::BlobStore;
use ironflow_artifacts::local::LocalBlobStore;
use ironflow_artifacts::stream_from_bytes;

let store = LocalBlobStore::new("/var/lib/ironflow/artifacts").max_bytes(10 * 1024 * 1024);

store
    .put("artifacts/run/step/id", stream_from_bytes(b"report".to_vec()))
    .await?;

Implementations

impl LocalBlobStore

pub fn new(root: impl Into<PathBuf>) -> Self

Create a store rooted at root, with the default size limit.

The directory is created lazily on the first write.

Examples

use ironflow_artifacts::local::{DEFAULT_MAX_ARTIFACT_BYTES, LocalBlobStore};

let store = LocalBlobStore::new("/tmp/ironflow-artifacts");
assert_eq!(store.max_bytes_limit(), DEFAULT_MAX_ARTIFACT_BYTES);

pub fn max_bytes(self, limit: u64) -> Self

Override the per-artifact size limit.

Examples

use ironflow_artifacts::local::LocalBlobStore;

let store = LocalBlobStore::new("/tmp/a").max_bytes(1024);
assert_eq!(store.max_bytes_limit(), 1024);

pub fn max_bytes_limit(&self) -> u64

The configured per-artifact size limit, in bytes.

pub fn root(&self) -> &Path

The filesystem root holding the blobs.

Trait Implementations

impl BlobStore for LocalBlobStore

fn put<'a>( &'a self, key: &'a str, content: ByteStream, ) -> BlobFuture<'a, BlobDigest>

Write a blob under key, replacing any existing content.

fn get<'a>(&'a self, key: &'a str) -> BlobFuture<'a, ByteStream>

Open a blob for reading.

fn delete<'a>(&'a self, key: &'a str) -> BlobFuture<'a, bool>

Delete a blob.

impl Clone for LocalBlobStore

fn clone(&self) -> LocalBlobStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LocalBlobStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.