Skip to main content

StateSocketProbe

ados_protocol::armed

Struct StateSocketProbe

pub struct StateSocketProbe { /* private fields */ }

Expand description

An ArmedProbe fed by a background reader of the router state socket.

Implementations§

impl StateSocketProbe

pub fn spawn(state_socket: PathBuf, vehicle_profile: bool) -> Arc<Self> ⓘ

Start the reader task on the current tokio runtime and return the probe. A node whose profile carries no vehicle never counts as armed; the task is not started for it. The task reconnects every 2 s, with no cap, after a connect or read failure, and ends when the last probe handle drops.

Trait Implementations§

impl ArmedProbe for StateSocketProbe

fn treated_as_armed(&self) -> bool

Whether a link-dropping action must be refused right now.

Auto Trait Implementations§

impl !Freeze for StateSocketProbe

impl RefUnwindSafe for StateSocketProbe

impl Send for StateSocketProbe

impl Sync for StateSocketProbe

impl Unpin for StateSocketProbe

impl UnsafeUnpin for StateSocketProbe

impl UnwindSafe for StateSocketProbe

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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> Same for T

type Output = T

Should always be Self

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

type Error = !

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, !>

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