pub struct OutboundConfig {
pub worker_id: u16,
pub abort_outbound: Arc<AtomicBool>,
pub m_id: u32,
pub p_type: ProtocolType,
pub qname: Option<String>,
pub info_url: Option<String>,
pub probing_rate: u32,
pub src: Address,
pub sport: u16,
pub dport: u16,
pub origin_id: u32,
}Expand description
Configuration for the outbound/sending thread
Fields§
§worker_id: u16The unique ID of this specific worker.
abort_outbound: Arc<AtomicBool>Shared signal to forcefully shut down the worker (e.g., when the CLI disconnects).
m_id: u32The 16-bit measurement ID
p_type: ProtocolTypeProtocol type used
qname: Option<String>Optional domain name to query in DNS measurement probes.
info_url: Option<String>Optional URL to be embedded in the probe’s payload (e.g., an opt-out link).
probing_rate: u32The target rate for sending probes, measured in packets per second (pps).
src: AddressSource address to use
sport: u16Source port to use
dport: u16Destination port to use
origin_id: u32Origin ID associated with this outbound sender
Auto Trait Implementations§
impl Freeze for OutboundConfig
impl RefUnwindSafe for OutboundConfig
impl Send for OutboundConfig
impl Sync for OutboundConfig
impl Unpin for OutboundConfig
impl UnsafeUnpin for OutboundConfig
impl UnwindSafe for OutboundConfig
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].