Struct Payload 

pub struct Payload<T, C> {
    pub value: Arc<T>,
    pub neuron: Arc<dyn Neuron<T, C> + Send + Sync>,
    pub trace: TraceContext,
}

Fields

value: Arc<T>

neuron: Arc<dyn Neuron<T, C> + Send + Sync>

trace: TraceContext

Implementations

impl<T, C> Payload<T, C>

pub fn from_parts( value: Arc<T>, neuron: Arc<dyn Neuron<T, C> + Send + Sync>, trace: TraceContext, ) -> Self

pub fn with_correlation( value: T, neuron: Arc<dyn Neuron<T, C> + Send + Sync>, correlation_id: Option<Uuid>, ) -> Arc<Self>

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

Helper to create a new Payload with default tracing fields (new span_id, no parent_id). Used when initiating a new signal.

pub fn new(value: T, neuron: Arc<dyn Neuron<T, C> + Send + Sync>) -> Arc<Self>

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

Simplified creation method for new signals. automatically generates correlation_id and other tracing fields.

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

pub fn correlation_id(&self) -> Uuid

pub fn span_id(&self) -> u64

pub fn parent_id(&self) -> Option<u64>

Trait Implementations

impl<T: Debug, C: Debug> Debug for Payload<T, C>

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

Formats the value using the given formatter.

impl<T, C> LogTrace for Payload<T, C>

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

fn correlation_id(&self) -> Uuid

fn span_id(&self) -> u64

fn parent_id(&self) -> Option<u64>

fn neuron_name(&self) -> String

fn trace_context(&self) -> TraceContext

Returns the full trace context.

fn span_info(&self, name: &'static str) -> Span

Returns a tracing span with the tracing fields attached at INFO level.

fn span_debug(&self, name: &'static str) -> Span

Returns a tracing span with the tracing fields attached at DEBUG level.