pub struct InMemoryArtifactService { /* private fields */ }Available on crate feature
artifacts only.Expand description
In-memory artifact storage for development and testing.
Artifacts are stored in a HashMap behind an RwLock. Data is lost
when the process exits. For persistent storage, use FileArtifactService.
Implementations§
Source§impl InMemoryArtifactService
impl InMemoryArtifactService
Sourcepub fn new() -> InMemoryArtifactService
pub fn new() -> InMemoryArtifactService
Create a new empty in-memory artifact store.
Trait Implementations§
Source§impl ArtifactService for InMemoryArtifactService
impl ArtifactService for InMemoryArtifactService
Source§fn save<'life0, 'async_trait>(
&'life0 self,
req: SaveRequest,
) -> Pin<Box<dyn Future<Output = Result<SaveResponse, AdkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
InMemoryArtifactService: 'async_trait,
fn save<'life0, 'async_trait>(
&'life0 self,
req: SaveRequest,
) -> Pin<Box<dyn Future<Output = Result<SaveResponse, AdkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
InMemoryArtifactService: 'async_trait,
Store a binary artifact, returning the version that was written.
Source§fn load<'life0, 'async_trait>(
&'life0 self,
req: LoadRequest,
) -> Pin<Box<dyn Future<Output = Result<LoadResponse, AdkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
InMemoryArtifactService: 'async_trait,
fn load<'life0, 'async_trait>(
&'life0 self,
req: LoadRequest,
) -> Pin<Box<dyn Future<Output = Result<LoadResponse, AdkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
InMemoryArtifactService: 'async_trait,
Retrieve a stored artifact by filename and optional version.
Source§fn delete<'life0, 'async_trait>(
&'life0 self,
req: DeleteRequest,
) -> Pin<Box<dyn Future<Output = Result<(), AdkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
InMemoryArtifactService: 'async_trait,
fn delete<'life0, 'async_trait>(
&'life0 self,
req: DeleteRequest,
) -> Pin<Box<dyn Future<Output = Result<(), AdkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
InMemoryArtifactService: 'async_trait,
Delete an artifact (specific version or all versions).
Source§fn list<'life0, 'async_trait>(
&'life0 self,
req: ListRequest,
) -> Pin<Box<dyn Future<Output = Result<ListResponse, AdkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
InMemoryArtifactService: 'async_trait,
fn list<'life0, 'async_trait>(
&'life0 self,
req: ListRequest,
) -> Pin<Box<dyn Future<Output = Result<ListResponse, AdkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
InMemoryArtifactService: 'async_trait,
List all artifact filenames in a session.
Source§fn versions<'life0, 'async_trait>(
&'life0 self,
req: VersionsRequest,
) -> Pin<Box<dyn Future<Output = Result<VersionsResponse, AdkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
InMemoryArtifactService: 'async_trait,
fn versions<'life0, 'async_trait>(
&'life0 self,
req: VersionsRequest,
) -> Pin<Box<dyn Future<Output = Result<VersionsResponse, AdkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
InMemoryArtifactService: 'async_trait,
List all available versions of a specific artifact.
Source§impl Default for InMemoryArtifactService
impl Default for InMemoryArtifactService
Source§fn default() -> InMemoryArtifactService
fn default() -> InMemoryArtifactService
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for InMemoryArtifactService
impl RefUnwindSafe for InMemoryArtifactService
impl Send for InMemoryArtifactService
impl Sync for InMemoryArtifactService
impl Unpin for InMemoryArtifactService
impl UnsafeUnpin for InMemoryArtifactService
impl UnwindSafe for InMemoryArtifactService
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::RequestCreates a shared type from an unshared type.