Struct PayloadRaw 

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

A type-erased raw payload containing bytes, its associated neuron, and tracing context.

Examples

let payload = PayloadRaw::new(vec![1, 2, 3], neuron);
assert_eq!(*payload.value, vec![1, 2, 3]);

Fields

value: Arc<Vec<u8>>

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

trace: TraceContext

Implementations

impl<T, C> PayloadRaw<T, C>

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

pub fn with_correlation( value: Vec<u8>, 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 PayloadRaw with default tracing fields (new span_id, no parent_id). Used when initiating a new signal where payload is already raw bytes.

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

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

Examples

let ns = Arc::new(NamespaceImpl { delimiter: ".", parts: vec!["test"] });
let neuron = Arc::new(NeuronImpl::<Dummy, Dummy>::new(ns));
let raw_data = vec![1, 2, 3];

let payload = PayloadRaw::new(raw_data.clone(), neuron);
assert_eq!(*payload.value, raw_data);

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 PayloadRaw<T, C>

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

Formats the value using the given formatter.

impl<T, C> LogTrace for PayloadRaw<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.