Struct Kernel 

pub struct Kernel<P: PolicyEngine> { /* private fields */ }

Implementations

impl<P: PolicyEngine> Kernel<P>

pub fn get_namespace(&self, pack_id: &str) -> Option<&Namespace>

pub fn issue_token( &self, pack_id: &str, agent_id: &str, ttl_s: u64, ) -> Result<CapabilityToken, KernelError>

pub fn revoke_token( &self, token_id: &str, actor_agent_id: Option<&str>, ) -> Result<(), KernelError>

pub fn revoke_generation(&self, below: u64)

pub fn record_audit_event( &self, agent_id: Option<&str>, kind: AuditEventKind, ) -> Result<(), KernelError>

pub async fn execute_task( &self, pack_id: &str, token: &CapabilityToken, task: TaskIntent, ) -> Result<KernelDispatch, KernelError>

pub async fn execute_connector_core( &self, pack_id: &str, token: &CapabilityToken, core_name: Option<&str>, command: ConnectorCommand, ) -> Result<ConnectorDispatch, KernelError>

pub async fn execute_connector_extension( &self, pack_id: &str, token: &CapabilityToken, extension_name: &str, core_name: Option<&str>, command: ConnectorCommand, ) -> Result<ConnectorDispatch, KernelError>

pub async fn execute_runtime_core( &self, pack_id: &str, token: &CapabilityToken, required_capabilities: &BTreeSet<Capability>, core_name: Option<&str>, request: RuntimeCoreRequest, ) -> Result<RuntimeCoreOutcome, KernelError>

pub async fn execute_runtime_extension( &self, pack_id: &str, token: &CapabilityToken, required_capabilities: &BTreeSet<Capability>, extension_name: &str, core_name: Option<&str>, request: RuntimeExtensionRequest, ) -> Result<RuntimeExtensionOutcome, KernelError>

pub async fn execute_tool_core( &self, pack_id: &str, token: &CapabilityToken, required_capabilities: &BTreeSet<Capability>, core_name: Option<&str>, request: ToolCoreRequest, ) -> Result<ToolCoreOutcome, KernelError>

pub async fn execute_tool_extension( &self, pack_id: &str, token: &CapabilityToken, required_capabilities: &BTreeSet<Capability>, extension_name: &str, core_name: Option<&str>, request: ToolExtensionRequest, ) -> Result<ToolExtensionOutcome, KernelError>

pub async fn execute_memory_core( &self, pack_id: &str, token: &CapabilityToken, required_capabilities: &BTreeSet<Capability>, core_name: Option<&str>, request: MemoryCoreRequest, ) -> Result<MemoryCoreOutcome, KernelError>

pub async fn execute_memory_extension( &self, pack_id: &str, token: &CapabilityToken, required_capabilities: &BTreeSet<Capability>, extension_name: &str, core_name: Option<&str>, request: MemoryExtensionRequest, ) -> Result<MemoryExtensionOutcome, KernelError>

Methods from Deref<Target = LoongKernel<P>>

pub fn get_namespace(&self, pack_id: &str) -> Option<&Namespace>

pub fn issue_token( &self, pack_id: &str, agent_id: &str, ttl_s: u64, ) -> Result<CapabilityToken, KernelError>

pub fn issue_scoped_token( &self, pack_id: &str, agent_id: &str, allowed_capabilities: &BTreeSet<Capability>, ttl_s: u64, ) -> Result<CapabilityToken, KernelError>

pub fn revoke_token( &self, token_id: &str, actor_agent_id: Option<&str>, ) -> Result<(), KernelError>

pub fn revoke_generation(&self, below: u64)

pub fn record_audit_event( &self, agent_id: Option<&str>, kind: AuditEventKind, ) -> Result<(), KernelError>

pub fn authorize_operation( &self, pack_id: &str, token: &CapabilityToken, plane: ExecutionPlane, tier: PlaneTier, primary_adapter: &str, delegated_core_adapter: Option<&str>, operation: &str, required_capabilities: &BTreeSet<Capability>, ) -> Result<(), KernelError>

pub async fn execute_task( &self, pack_id: &str, token: &CapabilityToken, task: TaskIntent, ) -> Result<KernelDispatch, KernelError>

pub async fn execute_connector_core( &self, pack_id: &str, token: &CapabilityToken, core_name: Option<&str>, command: ConnectorCommand, ) -> Result<ConnectorDispatch, KernelError>

pub async fn execute_connector_extension( &self, pack_id: &str, token: &CapabilityToken, extension_name: &str, core_name: Option<&str>, command: ConnectorCommand, ) -> Result<ConnectorDispatch, KernelError>

pub async fn execute_runtime_core( &self, pack_id: &str, token: &CapabilityToken, required_capabilities: &BTreeSet<Capability>, core_name: Option<&str>, request: RuntimeCoreRequest, ) -> Result<RuntimeCoreOutcome, KernelError>

pub async fn execute_runtime_extension( &self, pack_id: &str, token: &CapabilityToken, required_capabilities: &BTreeSet<Capability>, extension_name: &str, core_name: Option<&str>, request: RuntimeExtensionRequest, ) -> Result<RuntimeExtensionOutcome, KernelError>

pub async fn execute_tool_core( &self, pack_id: &str, token: &CapabilityToken, required_capabilities: &BTreeSet<Capability>, core_name: Option<&str>, request: ToolCoreRequest, ) -> Result<ToolCoreOutcome, KernelError>

pub async fn execute_tool_extension( &self, pack_id: &str, token: &CapabilityToken, required_capabilities: &BTreeSet<Capability>, extension_name: &str, core_name: Option<&str>, request: ToolExtensionRequest, ) -> Result<ToolExtensionOutcome, KernelError>

pub async fn execute_memory_core( &self, pack_id: &str, token: &CapabilityToken, required_capabilities: &BTreeSet<Capability>, core_name: Option<&str>, request: MemoryCoreRequest, ) -> Result<MemoryCoreOutcome, KernelError>

pub async fn execute_memory_extension( &self, pack_id: &str, token: &CapabilityToken, required_capabilities: &BTreeSet<Capability>, extension_name: &str, core_name: Option<&str>, request: MemoryExtensionRequest, ) -> Result<MemoryExtensionOutcome, KernelError>

Trait Implementations

impl<P: PolicyEngine> AsRef<LoongKernel<P>> for Kernel<P>

fn as_ref(&self) -> &LoongKernel<P>

Converts this type into a shared reference of the (usually inferred) input type.

impl<P: PolicyEngine> Deref for Kernel<P>

type Target = LoongKernel<P>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.