pub enum KernelEvent {
Show 30 variants
AgentCreated {
id: AgentId,
name: String,
},
AgentStarted {
id: AgentId,
},
AgentStopped {
id: AgentId,
},
AgentFailed {
id: AgentId,
error: String,
},
MessageReceived {
from: AgentId,
content: String,
},
SeedCreated {
seed_id: Uuid,
},
EvaluationComplete {
seed_id: Uuid,
passed: bool,
},
PhaseStarted {
session_id: String,
phase: Phase,
},
PhaseCompleted {
session_id: String,
phase: Phase,
result_summary: String,
},
AgentOutput {
session_id: String,
agent_id: AgentId,
output: String,
},
ApprovalRequested {
id: Uuid,
action: String,
resource: String,
reason: String,
},
ApprovalResolved {
id: Uuid,
approved: bool,
},
MemoryStored {
id: String,
memory_type: String,
source: String,
},
MemoryRecalled {
query: String,
count: usize,
},
AgentGroupCreated {
group_id: Uuid,
agent_count: usize,
},
AgentGroupMemberCompleted {
group_id: Uuid,
agent_id: Uuid,
success: bool,
},
ProjectCreated {
project_id: Uuid,
name: String,
source: String,
},
ProjectActivated {
project_id: Uuid,
name: String,
},
EvolutionStarted {
seed_id: Uuid,
new_seed_id: Uuid,
iteration: u32,
},
EvolutionMaxReached {
seed_id: Uuid,
final_score: f64,
iterations: u32,
},
ToolExecutionStarted {
session_id: String,
tool_name: String,
tool_call_id: String,
tool_args: Value,
},
ToolExecutionFinished {
session_id: String,
tool_call_id: String,
tool_name: String,
duration_ms: u64,
is_error: bool,
output_summary: String,
},
ToolExecutionProgress {
session_id: String,
tool_call_id: String,
tool_name: String,
progress: String,
tab_id: Option<Uuid>,
context: Option<Value>,
},
MemoryRecallUsed {
session_id: String,
query: String,
count: usize,
source: String,
},
TokenUsageUpdate {
session_id: String,
input_tokens: u64,
output_tokens: u64,
},
ReasoningFragment {
session_id: String,
content: String,
source: String,
},
CalendarEventCreated {
uid: String,
title: String,
start: String,
end: String,
},
CalendarEventUpdated {
uid: String,
title: String,
},
CalendarEventDeleted {
uid: String,
title: String,
},
EmailSent {
subject: String,
message_id: String,
template_name: Option<String>,
},
}Expand description
Events that flow through the kernel event bus.
Variants§
AgentCreated
A new agent has been created.
AgentStarted
An agent has started executing.
AgentStopped
An agent has been stopped.
AgentFailed
An agent has encountered a failure.
MessageReceived
A message has been received from an agent.
SeedCreated
A new seed has been created.
EvaluationComplete
An evaluation has completed.
PhaseStarted
An Ouroboros phase has started.
PhaseCompleted
An Ouroboros phase has completed.
Fields
AgentOutput
An agent has produced output.
Fields
ApprovalRequested
A HitL approval request has been submitted.
Fields
ApprovalResolved
A HitL approval has been resolved (approved or rejected).
Fields
MemoryStored
A memory entry was stored.
Fields
MemoryRecalled
Memories were recalled for a new session.
AgentGroupCreated
Multi-agent group created.
AgentGroupMemberCompleted
An agent in a group completed.
Fields
ProjectCreated
A new Project has been created (RFC-011).
Fields
ProjectActivated
A Project has been activated (RFC-011).
EvolutionStarted
Evolution has started (evaluate → evolve → re-execute loop).
Fields
EvolutionMaxReached
Evolution loop reached max iterations.
Fields
ToolExecutionStarted
A tool execution has started (real-time, RFC-015).
Fields
ToolExecutionFinished
A tool execution has finished (real-time, RFC-015).
Fields
ToolExecutionProgress
A tool execution emitted a progress update (real-time, RFC-015).
Fields
MemoryRecallUsed
Memory was recalled during agent execution (RFC-015).
Fields
TokenUsageUpdate
Token usage update (RFC-015).
Fields
ReasoningFragment
Reasoning/compaction fragment (RFC-015).
Fields
CalendarEventCreated
A calendar event was created.
Fields
CalendarEventUpdated
A calendar event was updated.
CalendarEventDeleted
A calendar event was deleted.
EmailSent
An email has been sent.
Trait Implementations§
Source§impl Clone for KernelEvent
impl Clone for KernelEvent
Source§fn clone(&self) -> KernelEvent
fn clone(&self) -> KernelEvent
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for KernelEvent
impl Debug for KernelEvent
Source§impl<'de> Deserialize<'de> for KernelEvent
impl<'de> Deserialize<'de> for KernelEvent
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Auto Trait Implementations§
impl Freeze for KernelEvent
impl RefUnwindSafe for KernelEvent
impl Send for KernelEvent
impl Sync for KernelEvent
impl Unpin for KernelEvent
impl UnsafeUnpin for KernelEvent
impl UnwindSafe for KernelEvent
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
impl<T> ErasedDestructor for Twhere
T: 'static,
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>
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 moreimpl<T> MaybeSendSync for T
Source§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
Source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Source§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self and passes that borrow into the pipe function. Read moreSource§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self and passes that borrow into the pipe function. Read moreSource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
Source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
Source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
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
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
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
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self, then passes self.deref() into the pipe function.Source§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
Source§impl<T> Tap for T
impl<T> Tap for T
Source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B> of a value. Read moreSource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B> of a value. Read moreSource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R> view of a value. Read moreSource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R> view of a value. Read moreSource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target of a value. Read moreSource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target of a value. Read moreSource§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap() only in debug builds, and is erased in release builds.Source§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut() only in debug builds, and is erased in release
builds.Source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.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
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.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
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.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
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.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
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref() only in debug builds, and is erased in release
builds.