Struct Observer 

pub struct Observer<T = f32> { /* private fields */ }

Observer actors monitor the system without directly intervening. They collect data, analyze patterns, and build context but do not initiate transformations.

Implementations

impl<T> Observer<T>

pub fn new() -> Observer<T>

where T: FromPrimitive,

Create a new observer

pub const fn id(&self) -> Id

returns a copy of the observer’s ID

pub const fn is_initialized(&self) -> bool

returns true if the observer is initialized

pub const fn is_uninitialized(&self) -> bool

returns true if the observer is not initialized

pub const fn threshold(&self) -> &T

returns a reference to the observation threshold

pub const fn threshold_mut(&mut self) -> &mut T

returns a mutable reference to the observation threshold

pub const fn observations(&self) -> &VecDeque<(LPR, Triads, Triads)>

returns an immutable reference to the observations

pub const fn observations_mut(&mut self) -> &mut VecDeque<(LPR, Triads, Triads)>

returns a mutable reference to the observations

pub const fn tonal_regions(&self) -> &HashMap<[usize; 3], String>

returns an immutable reference to the tonal regions

pub const fn tonal_regions_mut(&mut self) -> &mut HashMap<[usize; 3], String>

returns a mutable reference to the tonal regions

pub fn set_id(&mut self, id: Id) -> &mut Observer<T>

update the current id and return a mutable reference to the observer

pub fn set_threshold(&mut self, threshold: T) -> &mut Observer<T>

where T: Float,

update the current threshold and return a mutable reference to the observer

pub fn set_observations( &mut self, observations: VecDeque<(LPR, Triads, Triads)>, ) -> &mut Observer<T>

update the current observations and return a mutable reference to the observer

pub fn set_tonal_regions( &mut self, tonal_regions: HashMap<[usize; 3], String>, ) -> &mut Observer<T>

update the current tonal regions and return a mutable reference to the observer

pub fn initialized(self) -> Observer<T>

consumes the current instance to toggle the initialized flag

pub fn with_id(self, id: Id) -> Observer<T>

consumes the current instance to create another with the given ID

pub fn with_observations( self, observations: VecDeque<(LPR, Triads, Triads)>, ) -> Observer<T>

consumes the current instance to create another with the given observations

pub fn with_threshold(self, threshold: T) -> Observer<T>

where T: Float,

consumes the current instance to create another with the given threshold

pub fn with_tonal_regions( self, tonal_regions: HashMap<[usize; 3], String>, ) -> Observer<T>

consumes the current instance to create another with the given tonal regions

pub fn initialize(self) -> Observer<T>

set the initialized flag to true

pub fn observation_count(&self) -> usize

Get the number of transformations observed

pub fn analyze_patterns(&self, memory: &TopoLedger<T>) -> Vec<(Vec<LPR>, T)>

where T: Float + FromPrimitive,

Analyze recent transformations for patterns

pub fn analyze_critical_points<D>(&self, vnode: &VNode<D>) -> Vec<(String, T)>

where D: RawDriver<Triad>, T: Float + FromPrimitive,

Analyze critical points in relation to triad

Trait Implementations

impl<D, T> Actor<D, T> for Observer<T>

where D: RawDriver<Triad>, T: Sum + Float + FromPrimitive + NumAssign,

fn kind(&self) -> &'static str

Returns the name of this actor type

fn initialize(&mut self) -> Result<(), ActorError>

Initialize the actor with required resources

fn process_transform( &mut self, transform: LPR, plant: &mut D, _memory: &mut TopoLedger<T>, ) -> Result<bool, ActorError>

Process a transformation request and determine response

fn process_message( &mut self, _source: IndexBase<usize, EdgeIndex>, _message: &[u8], _memory: &mut TopoLedger<T>, ) -> Result<(), ActorError>

Process incoming message from another node

fn on_activate( &mut self, _plant: &D, _memory: &mut TopoLedger<T>, ) -> Result<(), ActorError>

Called when the node enters this actor mode

fn on_deactivate( &mut self, _plant: &D, memory: &mut TopoLedger<T>, ) -> Result<(), ActorError>

Called when the node leaves this actor mode

fn resource_requirements(&self) -> (usize, usize)

Calculate resource requirements for this actor mode

fn allows_pattern_sharing(&self) -> bool

Whether this actor allows pattern sharing

fn contextualize( &self, plant: &D, memory: &TopoLedger<T>, ) -> Result<ActorContext<T>, ActorError>

Derive contextual meaning from current state

impl<T> Clone for Observer<T>

where T: Clone,

fn clone(&self) -> Observer<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for Observer<T>

where T: Debug,

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

Formats the value using the given formatter.

impl<T> Default for Observer<T>

where T: Default + FromPrimitive,

fn default() -> Observer<T>

Returns the “default value” for a type.

impl<T> Hash for Observer<T>

fn hash<H>(&self, state: &mut H)

where H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<'a, T> PartialEq<&'a Observer<T>> for Observer<T>

fn eq(&self, other: &&'a Observer<T>) -> 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<'a, T> PartialEq<&'a mut Observer<T>> for Observer<T>

fn eq(&self, other: &&'a mut Observer<T>) -> 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<T> PartialEq<Observer<T>> for &Observer<T>

fn eq(&self, other: &Observer<T>) -> 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<T> PartialEq<Observer<T>> for &mut Observer<T>

fn eq(&self, other: &Observer<T>) -> 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<T> PartialEq for Observer<T>

fn eq(&self, other: &Observer<T>) -> 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<T> Eq for Observer<T>