sombrax_agentic_core 0.1.1

SombraX Agentic Core (SAC) — a provider-agnostic Rust library for building LLM agents: content-modifying hooks, tool/MCP integration, and context optimization.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

//! Lifecycle events emitted by [`super::Store::subscribe`].

use std::pin::Pin;

use futures_util::Stream;

use crate::runs::model::{BundleId, BundleStatus, JobId, JobStatus, RunId, RunStatus};

/// One lifecycle event. Implementations should emit at least the four variants
/// below; new variants may be added in the future, so consumers must use
/// `#[non_exhaustive]` matching.
#[derive(Clone, Debug)]
#[non_exhaustive]
pub enum StoreEvent {
    /// A job reached a terminal state.
    JobTerminal {
        /// The terminal job.
        job_id: JobId,
        /// The run.
        run_id: RunId,
        /// Final status (Completed / Failed / Timeout / Cancelled / Skipped).
        status: JobStatus,
    },
    /// A bundle changed status.
    BundleStatus {
        /// The bundle.
        bundle_id: BundleId,
        /// The run.
        run_id: RunId,
        /// New bundle status.
        status: BundleStatus,
    },
    /// The whole run reached a terminal state.
    RunTerminal {
        /// The run.
        run_id: RunId,
        /// Final run status.
        status: RunStatus,
    },
    /// `cancel_run` fired (emitted exactly once per cancellation).
    RunCancelled {
        /// The run.
        run_id: RunId,
    },
}

/// Boxed `Stream` of [`StoreEvent`]s. Rebroadcast: each subscriber sees events
/// emitted after `subscribe()` returned (no replay).
pub type StoreEventStream = Pin<Box<dyn Stream<Item = StoreEvent> + Send>>;