Skip to main content

MeasurementState

manycastr::orchestrator

Struct MeasurementState

pub struct MeasurementState {Show 13 fields
    pub m_id: u32,
    pub probing_workers: Vec<u32>,
    pub participants: HashMap<u32, Participant>,
    pub start_instructions: HashMap<u32, Start>,
    pub is_finalizing: bool,
    pub m_type: MeasurementType,
    pub is_gated_broadcast: bool,
    pub is_prefix_hitlist: bool,
    pub nprobes: u32,
    pub worker_stacks: HashMap<u32, VecDeque<Task>>,
    pub trace_config: Option<TracerouteConfig>,
    pub resolved_targets: HashSet<Address>,
    pub live: Option<LiveState>,
}

Expand description

All state associated with a single active measurement.

Fields§

§m_id: u32

16-bit measurement ID (filtering replies) + 16-bit session ID (reply attribution).

§probing_workers: Vec<u32>

Worker IDs of connected Workers that are actively probing

§participants: HashMap<u32, Participant>

Participating workers (removed when a worker finishes; kept on disconnect for rejoin)

§start_instructions: HashMap<u32, Start>

Per-worker Start instructions (re-sent when a worker rejoins mid-measurement)

§is_finalizing: bool

Whether the current measurement is being finalized (no new tasks being sent)

§m_type: MeasurementType

The measurement type (LACeS, catchment, latency, …)

§is_gated_broadcast: bool

Whether --responsive gates a broadcast of measurement probes.

§is_prefix_hitlist: bool

Whether the hitlist holds ranked candidates per prefix (ISI format)

§nprobes: u32

Number of times each measurement probe is sent (always >= 1)

§worker_stacks: HashMap<u32, VecDeque<Task>>

Per-worker stacks of follow-up tasks (discovery → measurement, traceroute hops)

§trace_config: Option<TracerouteConfig>

Traceroute configuration and session tracker (None for non-traceroute measurements)

§resolved_targets: HashSet<Address>

Resolved –responsive targets

§live: Option<LiveState>

Live feed state (None for hitlist-based measurements)

Implementations§

impl MeasurementState

pub fn active_workers(&self) -> usize

Number of connected workers participating in a measurement. The measurement is complete when this reaches zero.

Trait Implementations§

impl Debug for MeasurementState

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

impl Freeze for MeasurementState

impl RefUnwindSafe for MeasurementState

impl Send for MeasurementState

impl Sync for MeasurementState

impl Unpin for MeasurementState

impl UnsafeUnpin for MeasurementState

impl UnwindSafe for MeasurementState

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request

impl<L> LayerExt<L> for L

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].

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,