pub struct BundleEmbedder { /* private fields */ }Expand description
Production embedder: loads an application-owned bundle and executes it through the natively linked Traverse runtime.
Implementations§
Source§impl BundleEmbedder
impl BundleEmbedder
Sourcepub fn init(config: EmbedderConfig) -> Result<Self, EmbedderError>
pub fn init(config: EmbedderConfig) -> Result<Self, EmbedderError>
runtime.init: load, verify, and register the application bundle.
§Errors
Returns an EmbedderError with a stable code when the bundle path
cannot be resolved, the bundle schema version is unsupported, the
bundle fails validation or registration, or the WASM executor cannot
initialize. Rejections are deterministic and never fall back to a
sidecar (spec 068 NFR-001).
Sourcepub fn inject_data_store(&mut self, store: HostDataStore)
pub fn inject_data_store(&mut self, store: HostDataStore)
Explicitly injects a host-owned DataStore.
This additive host surface is deliberately separate from capability execution. It accepts neither a root path nor a capability identity, so the runtime cannot derive storage locations or grant capability code direct access.
Sourcepub fn data_store_read(
&mut self,
key: &str,
) -> Result<Option<StateRecord>, EmbeddedDataStoreError>
pub fn data_store_read( &mut self, key: &str, ) -> Result<Option<StateRecord>, EmbeddedDataStoreError>
Reads one host-owned state record from the injected DataStore.
Returns None when the injected store has no record for key.
§Errors
Returns a safe typed failure when no store was injected or its read operation fails.
Sourcepub fn data_store_write(
&mut self,
record: StateRecord,
) -> Result<(), EmbeddedDataStoreError>
pub fn data_store_write( &mut self, record: StateRecord, ) -> Result<(), EmbeddedDataStoreError>
Writes one host-owned state record to the injected DataStore.
§Errors
Returns a safe typed failure when no store was injected or its write operation fails.
Sourcepub fn data_store_delete(
&mut self,
key: &str,
) -> Result<(), EmbeddedDataStoreError>
pub fn data_store_delete( &mut self, key: &str, ) -> Result<(), EmbeddedDataStoreError>
Deletes one host-owned state record from the injected DataStore.
§Errors
Returns a safe typed failure when no store was injected or its delete operation fails.
Trait Implementations§
Source§impl EmbeddedTraceApi for BundleEmbedder
impl EmbeddedTraceApi for BundleEmbedder
Source§fn embedded_trace_api_version(&self) -> &'static str
fn embedded_trace_api_version(&self) -> &'static str
Source§fn trace_list(
&self,
requested_version: &str,
page_size: usize,
cursor: Option<&str>,
) -> Result<EmbeddedTracePage, EmbeddedTraceApiError>
fn trace_list( &self, requested_version: &str, page_size: usize, cursor: Option<&str>, ) -> Result<EmbeddedTracePage, EmbeddedTraceApiError>
trace.list: returns a deterministic page of safe local summaries. Read moreSource§fn trace_get(
&self,
requested_version: &str,
trace_id: &str,
) -> Result<EmbeddedTraceDetail, EmbeddedTraceApiError>
fn trace_get( &self, requested_version: &str, trace_id: &str, ) -> Result<EmbeddedTraceDetail, EmbeddedTraceApiError>
trace.get: returns one safe retained local trace detail. Read moreSource§impl TraverseEmbedderApi for BundleEmbedder
impl TraverseEmbedderApi for BundleEmbedder
Source§fn submit(&mut self, target_id: &str, input: &Value) -> SubmitOutcome
fn submit(&mut self, target_id: &str, input: &Value) -> SubmitOutcome
runtime.submit: execute a bundled workflow or WASM capability.Source§fn subscribe(&mut self, callback: EventCallback)
fn subscribe(&mut self, callback: EventCallback)
runtime.subscribe: register an ordered event callback. Previously
emitted events are replayed to the new subscriber first, so late
subscribers observe the identical ordered stream.Source§fn start_compatible(
&mut self,
capability_id: &str,
input: &Value,
) -> CompatibleStartOutcome
fn start_compatible( &mut self, capability_id: &str, input: &Value, ) -> CompatibleStartOutcome
compatible.start: start a compatible-mode capability instance.Source§fn stop_compatible(
&mut self,
capability_id: &str,
instance_id: Option<&str>,
) -> CompatibleLifecycleOutcome
fn stop_compatible( &mut self, capability_id: &str, instance_id: Option<&str>, ) -> CompatibleLifecycleOutcome
compatible.stop: gracefully stop one instance (instance_id) or
every running instance of the capability (None).Source§fn kill_compatible(
&mut self,
capability_id: &str,
instance_id: Option<&str>,
) -> CompatibleLifecycleOutcome
fn kill_compatible( &mut self, capability_id: &str, instance_id: Option<&str>, ) -> CompatibleLifecycleOutcome
compatible.kill: force-terminate one instance (instance_id) or
every running instance of the capability (None).Source§fn shutdown(&mut self) -> ShutdownOutcome
fn shutdown(&mut self) -> ShutdownOutcome
runtime.shutdown: kill running compatible instances and stop
accepting operations. Idempotent.Source§fn release_evidence(&self) -> Value
fn release_evidence(&self) -> Value
Auto Trait Implementations§
impl !RefUnwindSafe for BundleEmbedder
impl !Send for BundleEmbedder
impl !Sync for BundleEmbedder
impl !UnwindSafe for BundleEmbedder
impl Freeze for BundleEmbedder
impl Unpin for BundleEmbedder
impl UnsafeUnpin for BundleEmbedder
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
Source§impl<T> GetSetFdFlags for T
impl<T> GetSetFdFlags for T
Source§fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
self file descriptor.Source§fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
Source§fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: Sized + AsFilelike,
fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: Sized + AsFilelike,
self file descriptor. Read moreSource§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> ⓘ
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> ⓘ
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 more