Struct AxonImpl 

pub struct AxonImpl<T, C>
where
    T: Send + Sync + 'static,
    C: Codec<T> + CodecName + Send + Sync + 'static,
{ /* private fields */ }

Implementation of Axon that stores a neuron and ganglion with type erasure handling

Implementations

impl<T, C> AxonImpl<T, C>

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

pub fn new( neuron: Arc<dyn Neuron<T, C> + Send + Sync + 'static>, ganglion: Arc<Mutex<dyn GanglionInternal + Send + Sync + 'static>>, ) -> Self

Create a new AxonImpl with the given neuron and ganglion

pub fn builder() -> AxonBuilder<T, C>

Create a builder for constructing an AxonImpl

pub fn neuron(&self) -> &Arc<dyn Neuron<T, C> + Send + Sync + 'static>

Get a reference to the underlying neuron

pub fn ganglion( &self, ) -> &Arc<Mutex<dyn GanglionInternal + Send + Sync + 'static>>

Get a reference to the underlying ganglion

pub fn clone_neuron(&self) -> Arc<dyn Neuron<T, C> + Send + Sync + 'static>

Clone the neuron for sharing

pub fn clone_ganglion( &self, ) -> Arc<Mutex<dyn GanglionInternal + Send + Sync + 'static>>

Clone the ganglion for sharing

pub async fn ganglion_id(&self) -> Uuid

Get the unique ID of the underlying ganglion

pub fn validate(&self) -> Result<(), String>

Check if the axon components are properly configured

Trait Implementations

impl<T, C> Axon<T, C> for AxonImpl<T, C>

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

fn react( &mut self, reactants: Vec<Box<dyn Reactant<T, C> + Send + Sync + 'static>>, ) -> Pin<Box<dyn Future<Output = Result<(), AxonError>> + Send + '_>>

React to incoming reactants using the neuron

fn transmit( &mut self, data: T, ) -> Pin<Box<dyn Future<Output = Result<Vec<()>, AxonError>> + Send + '_>>

Transmit data through the neuron and ganglion

fn transmit_with_trace( &mut self, data: T, trace_context: TraceContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<()>, AxonError>> + Send + '_>>

Transmit data with explicit tracing context.

fn transmit_erased( &mut self, data: T, ) -> Pin<Box<dyn Future<Output = Result<Vec<()>, AxonError>> + Send + '_>>

Transmit data through the neuron and ganglion using type erasure

fn transmit_erased_with_trace( &mut self, data: T, trace_context: TraceContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<()>, AxonError>> + Send + '_>>

Transmit data using type erasure with explicit tracing context.

fn neuron_name(&self) -> String

Get the neuron name

fn transmit_with_timeout( &mut self, data: T, timeout_duration: Duration, ) -> Pin<Box<dyn Future<Output = Result<Vec<()>, AxonError>> + Send + '_>>

Transmit data with a timeout

fn transmit_with_trace_with_timeout( &mut self, data: T, trace_context: TraceContext, timeout_duration: Duration, ) -> Pin<Box<dyn Future<Output = Result<Vec<()>, AxonError>> + Send + '_>>

Transmit data with a trace and timeout

fn transmit_batch( &mut self, data_items: Vec<T>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<()>>, AxonError>> + Send + '_>>

Transmit multiple data items in batch

fn transmit_batch_with_trace( &mut self, data_items: Vec<T>, trace_context: TraceContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<()>>, AxonError>> + Send + '_>>

Transmit multiple data items in batch with trace

fn is_ready(&self) -> bool

Check if the axon is ready for transmission (convenience method)

fn status(&self) -> String

Get a formatted status string for debugging

impl<T, C> Clone for AxonImpl<T, C>

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

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T, C> Debug for AxonImpl<T, C>

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

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

Formats the value using the given formatter.