Struct ReForwarder 

pub struct ReForwarder { /* private fields */ }

Re-forwarder that relays traces to a downstream acceptor

Implementations

impl ReForwarder

pub fn new( handle: ForwarderHandle, namespace_filters: Option<Vec<Vec<String>>>, ) -> Self

Create an outbound re-forwarder backed by a ForwarderHandle

pub fn new_inbound( tx: Sender<Arc<Vec<TraceObject>>>, namespace_filters: Option<Vec<Vec<String>>>, ) -> Self

Create an inbound re-forwarder backed by a broadcast channel.

Callers must also spawn run_accepting_loop so that downstream connections are accepted and receive from the channel.

pub async fn forward(&self, traces: &[TraceObject])

Forward a batch of traces, applying namespace filters