Skip to main content

KernelHandle

Struct KernelHandle 

Source
pub struct KernelHandle {
Show 18 fields pub state: StateApi, pub agents: AgentApi, pub security: SecurityApi, pub persona: PersonaApi, pub extensions: ExtensionApi, pub mcp: McpApi, pub infra: InfraApi, pub projects: Option<ProjectApi>, pub mounts: Option<MountApi>, pub exec: ExecApi, pub a2a: A2aApi, pub engine: EngineApi, pub knowledge: Arc<KnowledgeBase>, pub knowledge_lens: Arc<KnowledgeLens>, pub marketplace_api: MarketplaceApi, pub calendar: Option<CalendarApi>, pub email: Option<EmailApi>, pub readiness: Arc<ReadinessGate>,
}
Expand description

Oxios kernel System Call API — composed of domain Facades.

Each Facade groups related system calls:

  • StateApi — data persistence, sessions
  • AgentApi — agent lifecycle, budgets, memory
  • SecurityApi — auth, audit trail, RBAC, approvals
  • PersonaApi — multi-persona management
  • ExtensionApi — programs, skills, host tools
  • McpApi — MCP server bridge
  • MountApi — Mount (path alias) management (RFC-025)
  • ProjectApi — Project management, memory linking
  • ExecApi — execution config, access management
  • A2aApi — agent-to-agent communication
  • EngineApi — LLM engine providers, models, config
  • [KnowledgeBase] — markdown note management (kernel-free, via oxios-markdown)

Fields§

§state: StateApi

State management: save/load/sessions.

§agents: AgentApi

Agent management: lifecycle/budgets/memory.

§security: SecurityApi

Security: auth/audit/RBAC/approvals.

§persona: PersonaApi

Persona management.

§extensions: ExtensionApi

Extensions: programs/skills/host tools.

§mcp: McpApi

MCP server bridge.

§infra: InfraApi

Infrastructure: Git/scheduler/cron/resources/events/system.

§projects: Option<ProjectApi>

Project management: work context (RFC-011).

§mounts: Option<MountApi>

Mount management: path aliases (RFC-025).

§exec: ExecApi

Execution: config + access management.

§a2a: A2aApi

Agent-to-agent communication.

§engine: EngineApi

Engine: LLM providers, models, config.

§knowledge: Arc<KnowledgeBase>

Knowledge base: markdown notes (direct access, no kernel dependency).

§knowledge_lens: Arc<KnowledgeLens>

Semantic knowledge overlay (HNSW index + agent recall).

§marketplace_api: MarketplaceApi

Marketplace API — ClawHub search, install, update.

§calendar: Option<CalendarApi>

Calendar events — create, update, delete, list, search, freebusy.

§email: Option<EmailApi>

Email — send HTML emails via SMTP, template management.

§readiness: Arc<ReadinessGate>

RFC-024 SP4: subsystem readiness gate.

Implementations§

Source§

impl KernelHandle

Source

pub fn new( state: StateApi, agents: AgentApi, security: SecurityApi, persona: PersonaApi, extensions: ExtensionApi, mcp: McpApi, infra: InfraApi, projects: Option<ProjectApi>, exec: ExecApi, a2a: A2aApi, engine: EngineApi, knowledge: Arc<KnowledgeBase>, knowledge_lens: Arc<KnowledgeLens>, marketplace_api: MarketplaceApi, calendar: Option<CalendarApi>, email: Option<EmailApi>, ) -> Self

Create a new KernelHandle from 13 domain Facades.

Each Facade is assembled independently in kernel.rs and passed here. This enables testing individual Facades without the full kernel.

Source

pub fn with_mounts(self, mounts: MountApi) -> Self

Attach a MountManager-backed API (RFC-025).

Called by the kernel assembler after SQLite initializes the MountManager. Leaves the Self::projects facade untouched so RFC-011 Projects continue to work during the migration.

Source

pub fn set_mounts(&mut self, mounts: MountApi)

Set the Mounts facade in place (post-construction wiring).

Source

pub async fn save_and_commit<T: Serialize>( &self, category: &str, name: &str, data: &T, ) -> Result<()>

Save data and commit to git (State + Infra).

The state save is the source of truth and is fully propagated. The git commit is best-effort observability: if it fails (full disk, lock contention, missing committer identity) we log a warning rather than failing the save — the data is already persisted on disk and failing here would mislead callers into thinking the save itself failed.

Source

pub async fn save_markdown_and_commit( &self, category: &str, name: &str, content: &str, ) -> Result<()>

Save markdown and commit to git (State + Infra).

See Self::save_and_commit for the git-failure policy.

Source

pub async fn delete_and_commit( &self, category: &str, name: &str, ) -> Result<bool>

Delete a file and commit the removal to git (State + Infra).

See Self::save_and_commit for the git-failure policy.

Source

pub fn commit_all(&self, message: &str) -> Result<Option<CommitInfo>>

Commit all current changes to git.

Source

pub fn flush_audit(&self) -> Result<()>

Flush audit trail and commit to git (Security + Infra).

Source

pub async fn schedule( &self, cron_expr: &str, task: &str, persona: Option<&str>, ) -> Result<String>

Schedule a cron job by expression (convenience wrapper).

Note: the persona argument is currently NOT wired into the cron executor — CronJob has no persona field yet. Passing a non-default value logs a warning so callers are not silently surprised. The parameter is retained for forward compatibility with multi-persona scheduling (RFC tracking).

Source

pub async fn unschedule(&self, job_id: &str) -> Result<bool>

Unschedule a cron job by string ID (convenience wrapper).

Returns Ok(true) when the job existed and was removed, Ok(false) when no job with that ID was registered, and Err(...) when the scheduler itself fails (DB corruption, lock poisoning). The previous implementation collapsed scheduler errors into Ok(false), hiding real failures from callers.

Source

pub fn list_schedules(&self) -> Vec<CronJob>

Source

pub async fn load_json<T: DeserializeOwned>( &self, category: &str, name: &str, ) -> Result<Option<T>>

Load JSON from state store.

Source

pub fn start_time(&self) -> Instant

Get kernel start time.

Source

pub fn marketplace_api(&self) -> &MarketplaceApi

Marketplace API — ClawHub search, install, update.

Source

pub fn memory(&self) -> MemoryApi

Get a MemoryApi facade for memory operations.

Returns a fresh MemoryApi each call. It shares the same underlying Arc<MemoryManager> and Arc<HnswMemoryIndex> (when attached) as AgentApi, so semantic search and index rebuilds route through the real index rather than the keyword-only fallback.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> Conv for T

Source§

fn conv<T>(self) -> T
where Self: Into<T>,

Converts self into T using Into<T>. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

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 more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

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 more
Source§

impl<T> MaybeSendSync for T

Source§

impl<T> Pipe for T
where T: ?Sized,

Source§

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

Pipes by value. This is generally the method you want to use. Read more
Source§

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

Borrows self and passes that borrow into the pipe function. Read more
Source§

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

Mutably borrows self and passes that borrow into the pipe function. Read more
Source§

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

Borrows self, then passes self.borrow() into the pipe function. Read more
Source§

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.borrow_mut() into the pipe function. Read more
Source§

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

Borrows self, then passes self.as_ref() into the pipe function.
Source§

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.as_mut() into the pipe function.
Source§

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

Borrows self, then passes self.deref() into the pipe function.
Source§

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.deref_mut() into the pipe function.
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> Tap for T

Source§

fn tap(self, func: impl FnOnce(&Self)) -> Self

Immutable access to a value. Read more
Source§

fn tap_mut(self, func: impl FnOnce(&mut Self)) -> Self

Mutable access to a value. Read more
Source§

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Immutable access to the Borrow<B> of a value. Read more
Source§

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Mutable access to the BorrowMut<B> of a value. Read more
Source§

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Immutable access to the AsRef<R> view of a value. Read more
Source§

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Mutable access to the AsMut<R> view of a value. Read more
Source§

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Immutable access to the Deref::Target of a value. Read more
Source§

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Mutable access to the Deref::Target of a value. Read more
Source§

fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self

Calls .tap() only in debug builds, and is erased in release builds.
Source§

fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self

Calls .tap_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Calls .tap_borrow() only in debug builds, and is erased in release builds.
Source§

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Calls .tap_borrow_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Calls .tap_ref() only in debug builds, and is erased in release builds.
Source§

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Calls .tap_ref_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Calls .tap_deref() only in debug builds, and is erased in release builds.
Source§

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Calls .tap_deref_mut() only in debug builds, and is erased in release builds.
Source§

impl<T> TryConv for T

Source§

fn try_conv<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

Attempts to convert self into T using TryInto<T>. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more