Struct DirectArtifactSink 

pub struct DirectArtifactSink { /* private fields */ }

ArtifactSink backed by a blob store and a run store in the same process.

Used by the API server and by any in-process engine. A remote worker uses an HTTP-backed sink instead.

Examples

use std::sync::Arc;

use ironflow_artifacts::local::LocalBlobStore;
use ironflow_engine::artifact::DirectArtifactSink;
use ironflow_store::memory::InMemoryStore;
use ironflow_store::store::Store;

let store: Arc<dyn Store> = Arc::new(InMemoryStore::new());
let blob = Arc::new(LocalBlobStore::new("/var/lib/ironflow/artifacts"));
let sink = DirectArtifactSink::new(blob, store);

Implementations

impl DirectArtifactSink

pub fn new(blob: Arc<dyn BlobStore>, store: Arc<dyn Store>) -> Self

Build a sink over a blob store and the run store holding the metadata.

Trait Implementations

impl ArtifactSink for DirectArtifactSink

fn put<'a>( &'a self, upload: ArtifactUpload, content: ByteStream, ) -> ArtifactFuture<'a, Artifact>

Store the bytes of an artifact and record its metadata.

fn get<'a>(&'a self, artifact: &'a Artifact) -> ArtifactFuture<'a, ByteStream>

Open the bytes of a recorded artifact for reading.

impl Debug for DirectArtifactSink

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

Formats the value using the given formatter.