pub struct OutboundConfig {
pub worker_id: u16,
pub tx_origins: Vec<Origin>,
pub abort_s: Arc<AtomicBool>,
pub is_ipv6: bool,
pub is_symmetric: bool,
pub m_id: u32,
pub m_type: u8,
pub qname: String,
pub info_url: String,
pub if_name: String,
pub probing_rate: u32,
}
Expand description
Configuration for an outbound packet sending worker.
This struct holds all the parameters needed to initialize and run a worker that generates and sends measurement probes (e.g., ICMP, DNS, TCP) at a specified rate.
Fields§
§worker_id: u16
The unique ID of this specific worker.
tx_origins: Vec<Origin>
A list of source addresses and port values (Origin
) to send probes from.
abort_s: Arc<AtomicBool>
A shared signal that can be used to forcefully shut down the worker.
E.g., when the CLI has abruptly disconnected.
is_ipv6: bool
Specifies whether to send IPv6 packets (true
) or IPv4 packets (false
).
is_symmetric: bool
Indicates if this is a latency measurement.
m_id: u32
The unique ID of the measurement.
m_type: u8
The type of probe to send (e.g., 1 for ICMP, 2 for DNS/A, 3 for TCP).
qname: String
The domain name to query in DNS measurement probes.
info_url: String
An informational URL to be embedded in the probe’s payload (e.g., an opt-out link).
if_name: String
The name of the network interface to send packets from (e.g., “eth0”).
probing_rate: u32
The target rate for sending probes, measured in packets per second (pps).
Auto Trait Implementations§
impl Freeze for OutboundConfig
impl RefUnwindSafe for OutboundConfig
impl Send for OutboundConfig
impl Sync for OutboundConfig
impl Unpin for OutboundConfig
impl UnwindSafe for OutboundConfig
Blanket Implementations§
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
§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>
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>,
Layered
].