Struct Plexus 

pub struct Plexus { /* private fields */ }

A Plexus manages a network of Ganglia, arranging automatic transmission of types between different Ganglia. This is the Rust equivalent of the Python Plexus class.

Implementations

impl Plexus

pub async fn neurons( &self, ) -> RwLockReadGuard<'_, HashMap<String, Arc<dyn NeuronErased + Send + Sync + 'static>>>

Returns a read guard to the neurons map

pub async fn new( relevant_neurons: Vec<Arc<dyn NeuronErased + Send + Sync + 'static>>, ignored_neurons: Vec<Arc<dyn NeuronErased + Send + Sync + 'static>>, ) -> Self

Create a new Plexus with the given ganglia and neuron filters

pub async fn new_shared( relevant_neurons: Vec<Arc<dyn NeuronErased + Send + Sync + 'static>>, ignored_neurons: Vec<Arc<dyn NeuronErased + Send + Sync + 'static>>, ) -> Arc<Mutex<Self>>

Helper to create an Arc<Mutex>

pub async fn infuse_ganglion<G>( &mut self, ganglion: Arc<Mutex<G>>, ) -> Result<(), PlexusError>

where G: GanglionInternal + Ganglion + Send + Sync + 'static,

Add a ganglion to the plexus

pub async fn infuse_external_ganglion<G>( &mut self, ganglion: Arc<Mutex<G>>, ) -> Result<(), PlexusError>

where G: GanglionExternal + Send + Sync + 'static,

Add an external ganglion to the plexus

pub async fn excise_ganglion_by_id( &mut self, ganglion_id: Uuid, ) -> Result<Option<Arc<Mutex<dyn GanglionInternal + Send + Sync + 'static>>>, PlexusError>

Remove a ganglion from the plexus by its ID

pub async fn excise_ganglion<G>( &mut self, ganglion: Arc<Mutex<G>>, ) -> Result<Option<Arc<Mutex<dyn GanglionInternal + Send + Sync + 'static>>>, PlexusError>

where G: GanglionInternal + Send + Sync + ?Sized + 'static,

Remove a ganglion from the plexus

pub async fn excise_external_ganglion_by_id( &mut self, ganglion_id: Uuid, ) -> Result<Option<Arc<Mutex<dyn GanglionExternal + Send + Sync + 'static>>>, PlexusError>

Remove an external ganglion from the plexus by its ID

pub async fn excise_external_ganglion<G>( &mut self, ganglion: Arc<Mutex<G>>, ) -> Result<Option<Arc<Mutex<dyn GanglionExternal + Send + Sync + 'static>>>, PlexusError>

where G: GanglionExternal + Send + Sync + ?Sized + 'static,

Remove an external ganglion from the plexus

pub async fn update_neurons( &self, neuron: Arc<dyn NeuronErased + Send + Sync + 'static>, ) -> Result<(), PlexusError>

Update neurons with a new neuron

Trait Implementations

impl Ganglion for Plexus

fn capable<T, C>(&mut self, neuron: Arc<dyn Neuron<T, C> + Send + Sync>) -> bool

where C: Codec<T> + CodecName + Send + Sync + 'static, T: Send + Sync + 'static,

fn adapt<T, C>( &mut self, neuron: Arc<dyn Neuron<T, C> + Send + Sync>, ) -> Pin<Box<dyn Future<Output = Result<(), GanglionError>> + Send + 'static>>

where C: Codec<T> + CodecName + Send + Sync + 'static, T: Send + Sync + 'static,

impl GanglionInternal for Plexus

fn transmit( &mut self, payload: Arc<dyn PayloadErased + Send + Sync + 'static>, ) -> Pin<Box<dyn Future<Output = Result<Vec<()>, GanglionError>> + Send + 'static>>

fn react( &mut self, neuron_name: String, reactants: Vec<Arc<dyn ReactantErased + Send + Sync + 'static>>, error_reactants: Vec<Arc<dyn ErrorReactantErased + Send + Sync>>, ) -> Pin<Box<dyn Future<Output = Result<(), GanglionError>> + Send + 'static>>

fn unique_id(&self) -> Uuid