Struct AnalyzeCtx 

pub struct AnalyzeCtx<'a> { /* private fields */ }

The context handed to analyze. Read-only by construction.

Implementations

impl<'a> AnalyzeCtx<'a>

pub fn new( reader: &'a dyn SubstrateRead, params: &'a Params, namespaces: &'a [String], watermark_ms: Option<i64>, now_ms: i64, outcome_inputs: &'a [OutcomeInput], ) -> Self

pub fn params(&self) -> &Params

pub fn now_ms(&self) -> i64

pub fn watermark_ms(&self) -> Option<i64>

pub fn capabilities(&self) -> Capabilities

pub fn outcome_inputs(&self) -> &[OutcomeInput]

pub fn grains_of_type( &self, grain_type: &str, opts: ReadOpts, ) -> Result<Vec<GrainRecord>>

All grains of a type across the configured namespaces (or all namespaces when none are configured).

pub fn facts(&self) -> Result<Vec<GrainRecord>>

Live facts across configured namespaces.

pub fn observations(&self) -> Result<Vec<GrainRecord>>

Live observations across configured namespaces.

pub fn grains_in( &self, grain_type: &str, namespace: &str, ) -> Result<Vec<GrainRecord>>

Live grains of one type in ONE explicit namespace — for analyzers whose datasource lives in a well-known system namespace (the run journals in agent:harness) regardless of the sweep’s configured scope.

pub fn skills(&self) -> Result<Vec<GrainRecord>>

Live Skill grains across configured namespaces.

pub fn goals(&self) -> Result<Vec<GrainRecord>>

Live Goal grains across configured namespaces.

pub fn tools_since(&self, since_ms: Option<i64>) -> Result<Vec<GrainRecord>>

Tool grains (captured tool calls), optionally windowed by a since watermark, live only. The flagship analyzer’s input.

pub fn heads(&self) -> Result<Vec<HeadGroup>>

Entities with more than one live head (requires the forks capability).

pub fn telemetry(&self) -> Result<Option<TelemetryView>>

A snapshot of the recall-telemetry rollups (requires the telemetry capability). None when the substrate has no sidecar — a telemetry-fed analyzer then degrades to an activation-ladder entry.