pub struct EmbeddedKernel { /* private fields */ }Expand description
One opened embedded kernel: the composed service plus the store handle for operational tooling (replay, stats, compaction).
Implementations§
Source§impl EmbeddedKernel
impl EmbeddedKernel
Sourcepub fn open(data_dir: &Path) -> Result<Self, PortError>
pub fn open(data_dir: &Path) -> Result<Self, PortError>
Opens the store at data_dir (fail-fast per ADR-012) and composes the
kernel. A second session on the same data dir fails here with an
explicit single-writer error (ADR-011; the engine holds the lock).
pub fn data_dir(&self) -> &Path
pub fn store(&self) -> &EmbeddedKernelStore
pub fn service(&self) -> Arc<EmbeddedMemoryService> ⓘ
pub fn quality_observer(&self) -> Arc<dyn QualityMetricsObserver> ⓘ
pub fn quality_telemetry_dropped_observations(&self) -> u64
pub fn quality_telemetry_write_failures(&self) -> u64
pub fn quality_telemetry_error(&self) -> Option<&str>
pub fn quality_telemetry_active(&self) -> bool
Trait Implementations§
Source§impl MemoryRecallApi for EmbeddedKernel
impl MemoryRecallApi for EmbeddedKernel
Source§fn capabilities(&self) -> ApiCapabilities
fn capabilities(&self) -> ApiCapabilities
What this implementation is and what it can do. Checked by consumers at
startup, before anything is at stake.
Source§async fn wake(
&self,
request: MemoryWakeRequest,
) -> Result<MemoryRecallView, ApiError>
async fn wake( &self, request: MemoryWakeRequest, ) -> Result<MemoryRecallView, ApiError>
Recall the bounded context of one about.
Source§async fn ask(
&self,
request: MemoryAskRequest,
) -> Result<MemoryRecallView, ApiError>
async fn ask( &self, request: MemoryAskRequest, ) -> Result<MemoryRecallView, ApiError>
Ask one question of the memory, under an explicit answer policy.
Source§impl MemoryRecordApi for EmbeddedKernel
impl MemoryRecordApi for EmbeddedKernel
Source§fn capabilities(&self) -> ApiCapabilities
fn capabilities(&self) -> ApiCapabilities
What this implementation is and what it can do. The report is the same
one the recall side gives — one implementation, one account of itself.
Source§async fn record(
&self,
request: MemoryRecordRequest,
) -> Result<RecordedMemoryView, ApiError>
async fn record( &self, request: MemoryRecordRequest, ) -> Result<RecordedMemoryView, ApiError>
Put something into the memory of one about, idempotently. Read more
Auto Trait Implementations§
impl !RefUnwindSafe for EmbeddedKernel
impl !UnwindSafe for EmbeddedKernel
impl Freeze for EmbeddedKernel
impl Send for EmbeddedKernel
impl Sync for EmbeddedKernel
impl Unpin for EmbeddedKernel
impl UnsafeUnpin for EmbeddedKernel
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