Struct PayloadRaw 

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

Fields

value: Arc<Vec<u8>>

neuron: Option<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: Option<Arc<dyn Neuron<T, C> + Send + Sync>>, trace: TraceContext, ) -> Self

pub fn with_correlation( value: Vec<u8>, neuron: Option<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: Option<Arc<dyn Neuron<T, C> + Send + Sync>>, ) -> Arc<Self>

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

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.