Enum KernelEvent 

pub enum KernelEvent {
    GoalCreated(GoalRecord),
    TaskPlanned(TaskRecord),
    TaskClaimed {
        task_id: TaskId,
        claimed_at: SystemTime,
        assignee: Option<String>,
    },
    TaskBlocked {
        task_id: TaskId,
        blocked_at: SystemTime,
        reason: String,
    },
    TaskCompleted {
        task_id: TaskId,
        completed_at: SystemTime,
        artifact_ids: Vec<ArtifactId>,
    },
    TaskFailed {
        task_id: TaskId,
        failed_at: SystemTime,
        reason: String,
    },
    TaskAbandoned {
        task_id: TaskId,
        abandoned_at: SystemTime,
        reason: String,
    },
    HumanInputRequested {
        task_id: Option<TaskId>,
        requested_at: SystemTime,
        prompt: String,
        resume_token: ResumeToken,
    },
    ObservationAppended(ObservationRecord),
    ArtifactProduced(ArtifactRecord),
    WakeRequested(WakeRequestRecord),
    WakeScheduled(WakeRequestRecord),
    WakeCompleted {
        wake_id: WakeId,
        completed_at: SystemTime,
        reason: String,
    },
    DelegationRequested(DelegationRecord),
    DelegationResolved {
        correlation_id: CorrelationId,
        resolved_at: SystemTime,
        payload: Value,
        metadata: Value,
    },
    ResourceRegistered(ResourceRef),
    RelationshipObserved(RelationshipEdge),
    MemorySearched {
        query: String,
        limit: usize,
    },
    MemoryArchived {
        content: String,
    },
}

Variants

GoalCreated(GoalRecord)

TaskPlanned(TaskRecord)

TaskClaimed

Fields

task_id: TaskId

claimed_at: SystemTime

assignee: Option<String>

TaskBlocked

Fields

task_id: TaskId

blocked_at: SystemTime

reason: String

TaskCompleted

Fields

task_id: TaskId

completed_at: SystemTime

artifact_ids: Vec<ArtifactId>

TaskFailed

Fields

task_id: TaskId

failed_at: SystemTime

reason: String

TaskAbandoned

Fields

task_id: TaskId

abandoned_at: SystemTime

reason: String

HumanInputRequested

Fields

task_id: Option<TaskId>

requested_at: SystemTime

prompt: String

resume_token: ResumeToken

ObservationAppended(ObservationRecord)

ArtifactProduced(ArtifactRecord)

WakeRequested(WakeRequestRecord)

WakeScheduled(WakeRequestRecord)

WakeCompleted

Fields

wake_id: WakeId

completed_at: SystemTime

reason: String

DelegationRequested(DelegationRecord)

DelegationResolved

Fields

correlation_id: CorrelationId

resolved_at: SystemTime

payload: Value

metadata: Value

ResourceRegistered(ResourceRef)

RelationshipObserved(RelationshipEdge)

MemorySearched

Fields

query: String

limit: usize

MemoryArchived

Fields

content: String

Trait Implementations

impl Clone for KernelEvent

fn clone(&self) -> KernelEvent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KernelEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for KernelEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for KernelEvent

fn eq(&self, other: &KernelEvent) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for KernelEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for KernelEvent