agentplane 0.47.0

Durable, replayable agent runtime — the journal is the plan of record
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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

//! Execution: the step context, the effect protocol, and the executor.

mod attention;
pub mod batch;
mod build_error;
mod ctx;
#[cfg(feature = "manifest")]
mod declarative;
mod drain;
#[cfg(feature = "manifest")]
pub use declarative::PREVIEW_EVIDENCE_BYTES;
pub mod effects;
mod executor;
pub mod group;
pub mod metrics;
mod pass_journal;
#[cfg(feature = "manifest")]
mod reach;
pub mod replay_only;
mod sweeper;
pub mod telemetry;
mod verdict;

pub use attention::{Attention, Condition, Remedy, SUBJECTS_LISTED};
pub use batch::BatchSpec;
pub use build_error::BuildError;
pub use ctx::{BuildsEffect, Mode, StepCtx};
pub use drain::DrainReport;
#[cfg(feature = "manifest")]
pub use executor::Agent;
pub(crate) use executor::LEASE_FREE_EPOCH;
/// The one `RunStatus` list, shared by every test that owes a per-variant
/// decision — resume, sealing, and the A2A state mapping. Test-only.
#[cfg(test)]
pub(crate) use executor::every_status;
/// The one reader of "what does this run's history say its state is", shared by
/// every surface that answers the question. Crate-internal: the public form is
/// [`Runtime::recorded_outcome`], which is what an embedder holds.
///
/// Ungated, because both in-crate consumers are: the operator API reads it to
/// answer `GET /runs/{run}`, and a restore reads it to name the runs that came
/// back waiting. Two surfaces, one reader — a second copy of the match is the
/// copy that disagrees the day a record kind arrives.
pub(crate) use executor::observed_status;
pub use executor::{
    Admission, ControlLifted, FullBackend, HALT_LIFTED_OUTCOME, HOLD_RELEASED_OUTCOME, LEASE_TTL,
    LiveRun, MAX_ADMISSION_KEY_BYTES, MIN_LEASE_TTL, OBSERVED_OUTCOME, OUTCOMES_OF_RECORD,
    RunFailure, RunOutcome, RunStatus, RunStreamObserver, RunTerms, Runtime, RuntimeBuilder,
    SEALED_OUTCOMES, Spawned, Stores,
};
pub use group::{EffectGroup, Invariant};
pub use verdict::{CannotReplay, Finding, Verdict};

/// The embedder and the index it embeds for, wired as one thing.
///
/// They are one field rather than two because neither is usable without the
/// other and the *pair* is what carries the invariant: a query vector means
/// something only against an index built in the same space, and a plane that
/// held them separately could be wired with two that disagree. `build` refuses
/// that pairing — see [`RuntimeBuilder::semantic_memory`] — so by the time a
/// run can reach this, the check has already happened.
#[derive(Debug)]
pub struct SemanticMemory {
    pub(crate) embedder: std::sync::Arc<dyn crate::memory::Embedder>,
    pub(crate) retriever: std::sync::Arc<dyn crate::memory::SemanticRetriever>,
}
pub use sweeper::{Redelivered, Saturation, SweepReport, WokenRuns};