pub struct StreamState {Show 18 fields
pub hebbian: HebbianState,
pub attention: AttentionState,
pub emotional_ring: EmotionalStateRing,
pub resonance: ResonanceState,
pub thought_graph: ThoughtGraphState,
pub predictive_cache: PredictiveCache,
pub archetypes: ArchetypeState,
pub mirror: MirrorState,
pub predicted_query_hash: u64,
pub predicted_confidence: f32,
pub surprise_level: f32,
pub curiosity_level: f32,
pub cycle: u64,
pub last_query_hash: u64,
pub last_query_ms: u64,
pub hebbian_total_energy: f32,
pub snapshot: Arc<SharedSnapshot>,
pub spine: Option<Arc<Spine>>,
}Expand description
A consciousness stream aktuális állapota — minden réteg in-memory.
Fields§
§hebbian: HebbianState§attention: AttentionState§emotional_ring: EmotionalStateRing§resonance: ResonanceState§thought_graph: ThoughtGraphState§predictive_cache: PredictiveCache§archetypes: ArchetypeState§mirror: MirrorState§predicted_query_hash: u64Current prediction: “what will the next query be?”
predicted_confidence: f32§surprise_level: f32Surprise level (0.0 = boring, 1.0 = mind-blowing)
curiosity_level: f32Current curiosity level
cycle: u64Cycle counter
last_query_hash: u64Last query hash that was actually received
last_query_ms: u64Timestamp of last query
hebbian_total_energy: f32Pre-computed sum of hebbian.activations[*].energy. Maintained
incrementally by the background cycle so format() doesn’t have
to iterate 28k+ f32s on every read. Updated in O(1) per decay.
snapshot: Arc<SharedSnapshot>Lock-free, mmap-able view of the stream. The background cycle
publishes a new snapshot once per tick via a seqlock; readers
(this process or another) can read it without taking the Mutex.
Lives as Arc<SharedSnapshot> so the seqlock address is stable
even if the StreamState Mutex is held by a writer.
spine: Option<Arc<Spine>>Spine: the whole layer state of the stream in a single mmap file
(spine.bin in the output directory). The background thread writes
the scalars every tick, the rarer layer headers on a quasi-timer.
None when the file cannot be opened (read-only disk, etc.) — the
stream keeps running without it, just without the cross-process view.
Auto Trait Implementations§
impl !RefUnwindSafe for StreamState
impl !UnwindSafe for StreamState
impl Freeze for StreamState
impl Send for StreamState
impl Sync for StreamState
impl Unpin for StreamState
impl UnsafeUnpin for StreamState
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<A, B, T> HttpServerConnExec<A, B> for Twhere
B: Body,
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 more